roda_pygame_sim

# -*- coding: utf-8 -*-
import paho.mqtt.client as mqtt
import time
import json

def on_log(client, userdata, level, buf):
    print("log: "+buf)
def on_connect(client, userdata, flags, rc):
    if rc==0:
        print("Conexão OK")
    else:
        print("Não conectado, erro: ",rc)
def on_message(client, userdata, message):
    mensagem = str(message.payload.decode("utf-8"))
    print("Mensagem recebida: " ,mensagem)
    print("Tópico da mensagem=",message.topic)
    print("Mensagem qos=",message.qos)
    print("Mensagem retain flag=",message.retain)

broker_address="192.168.11.6"

client = mqtt.Client("P1") #criar nova instância
client.on_connect=on_connect #anexar função ao retorno de chamada
client.on_log=on_log
client.on_message = on_message

print("Conectando ao broker")
client.connect(broker_address) #conectar ao broker

client.loop_start()

#client.subscribe("carros/posicao1")
client.subscribe("carros/posicao")
client.subscribe("carros/entidade")

run = True
i = 0
while run:
    i += 1
    troca_c = json.dumps({'carro1':i,'carro2':i+1,'carro3':i+2,'carro4':i+3})
    client.publish("carros/posicao",troca_c)
    if i == 15:
        troca_e = json.dumps({'carro':2,'entidade':'descarte'})
        client.publish("carros/entidade",troca_e)
    if i == 25:
        troca_e = json.dumps({'carro':4,'entidade':'caixa_pronta'})
        client.publish("carros/entidade",troca_e)
    if i == 30:
        i = 1
    time.sleep(3)
client.loop_stop()