mqt.py 文件源码

def pass_message(meg):
    import paho.mqtt.client as mqtt    

    #?????????????    
    def on_connect(client, userdata, flags, rc):    
        #print("Connected with result code "+str(rc))    

    #??on_connect??????    
    #??????????????    
        client.subscribe("topic/sub")    

    #???????????????    
    def on_message(client, userdata, msg):    
        print("??:"+msg.topic+" ??:"+str(msg.payload))    

    client = mqtt.Client()    
    #???
    #client(clean_session=True,userdata=='1',protocol=mqtt.MQTTv31)    
    client.on_connect = on_connect #????????????    
    client.on_message = on_message  #??????????????    
    client.connect("10.66.15.222", 1883, 60)  #?????,???1883,?????60?    

    client.loop_start()
    client.publish("movement",meg)