iframe-proxy | Sunbelt Computer Software

History

44 lines (36 loc) · 1.4 KB

Raw

#!/usr/bin/env python

# -*- encoding: utf-8 -*-

"""

Topic: 模拟家电

Desc :

"""

import paho.mqtt.client as mqtt

import paho.mqtt.publish as publish

# The callback for when the client receives a CONNACK response from the server.

def on_connect(cli, userdata, rc):

# Subscribing in on_connect() means that if we lose the connection and

print("Connected with result code " + str(rc))

# reconnect then subscriptions will be renewed.

cli.subscribe("clients/command/+")

def on_connect2(cli, userdata, rc):

print("Connected with result code " + str(rc))

cli.publish("clients/result/{}".format('001'), "Success")

cli.disconnect()

# The callback for when a PUBLISH message is received from the server.

def on_message(cli, userdata, msg):

print(msg.topic + " " + str(msg.payload))

# publish.single("clients/result/{}".format('001'),

# "Success", hostname="192.168.203.107")

cli.publish("clients/result/{}".format('001'), "Success")

client2 = mqtt.Client()

client2.on_connect = on_connect2

client2.connect("192.168.203.107", 1883, 60)

# client2.connect("mqtt2.samples.net", 80, 60)

client2.loop_start()

if __name__ == '__main__':

client = mqtt.Client()

client.on_connect = on_connect

client.on_message = on_message

client.connect("192.168.203.107", 1883, 60)

# client.connect("mqtt2.samples.net", 80, 60)

client.loop_forever()

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

machine.py

Latest commit

History

machine.py

File metadata and controls