xyj
/
lot_manager
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
xyj 2023-12-05 17:04:37 +08:00
parent 42a53c63fa
commit a5e3ec951c
3 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
MQTT.py
View File

@ -46,7 +46,8 @@ class MQTT:
self.client.on_connect = self.on_connect self.client.on_connect = self.on_connect
self.client.on_message = self.on_message self.client.on_message = self.on_message
# Establish a connection # Establish a connection
self.client.connect('ceshi-mqtt.lihaink.cn', 1883) # ceshi-mqtt.lihaink.cn
self.client.connect('127.0.0.1', 1883)
# Publish a message # Publish a message
self.client.loop_forever(retry_first_connection=True) self.client.loop_forever(retry_first_connection=True)

2
ceshi.py
View File

@ -35,7 +35,7 @@ if __name__ == '__main__':
client.on_connect = on_connect client.on_connect = on_connect
client.on_connect_fail = on_connect_fail client.on_connect_fail = on_connect_fail
# Establish a connection # Establish a connection
client.connect('ceshi-mqtt.lihaink.cn', 1883) client.connect('127.0.0.1', 1883)
# Publish a message # Publish a message
client.loop_forever() client.loop_forever()
except Exception as e: except Exception as e:

5
sensor_to_server.py
View File

@ -40,11 +40,12 @@ def on_connect(client, userdata, flags, rc):
if __name__ == '__main__': if __name__ == '__main__':
client = mqtt.Client(transport="websockets") client = mqtt.Client()
client.username_pw_set("demo", "123456") client.username_pw_set("demo", "123456")
# Specify callback function # Specify callback function
client.on_connect = on_connect client.on_connect = on_connect
# Establish a connection # Establish a connection
client.connect('ceshi-mqtt.lihaink.cn', 8083) # ceshi-mqtt.lihaink.cn
client.connect('192.168.1.27', 1883)
# Publish a message # Publish a message
client.loop_forever() client.loop_forever()