Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import paho.mqtt.client as mqtt
- # El callback para cuando el cliente reciva un Connack de respuesta del servidor.
- def on_connect(client, userdata, flags, rc):
- print("Conectado con el siguiente codigo "+str(rc))
- #Suscribirse dentro de On_connect signidica que si perdemos la conexion
- #y nos reconectamos la suscripcion se renovara.
- client.subscribe(MQTT_topicSub)
- # The callback for when a PUBLISH message is received from the server.
- def on_message(client, userdata, msg):
- print(msg.topic+" "+str(msg.payload))
- MQTT_broker = "127.0.0.1"
- MQTT_username = ""
- MQTT_password = ""
- MQTT_topicSub = "/a" #<---topico al que te vas a suscribir
- MQTT_topicAlive = "/a"#topico al que le vas a decir que ya estas conectad
- MQTT_port = 1883
- MQTT_clientID = "conectado "#
- client = mqtt.Client(MQTT_clientID, clean_session=True, userdata=None, protocol="MQTTv311", transport="tcp")
- client.on_connect = on_connect
- client.on_message = on_message
- client.username_pw_set(MQTT_username,MQTT_password )
- client.connect(MQTT_broker, MQTT_port, 60)
- client.publish(MQTT_topicAlive,MQTT_clientID, qos=0, retain=False)
- #
- while 1:
- mensaje= raw_input('mensaje: ')
- client.publish("candidatas", mensaje, qos=0, retain=False)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement