zoukankan      html  css  js  c++  java
  • mqtt精简应用python物联网

    直接上代码

    pub.py;向已建立好的mqtt服务,发送消息

    import paho.mqtt.client as mqtt
    
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code: " + str(rc))
    
    def on_message(client, userdata, msg):
        print(msg.topic + " " + str(msg.payload))
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect('mqtt.eclipseprojects.io', 1883, 600) 
    i=20
    while i>0:
        i-=1
        client.publish('fifa', payload='next_sub,%s'%i, qos=0) 

    print('send,%s'%i)
    client.loop_forever()

    sub.py;当mqtt服务已建立,可以接收消息。

    import paho.mqtt.client as mqtt
    
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code: " + str(rc))
    
    def on_message(client, userdata, msg):
        print(msg.topic + " " + str(msg.payload))
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect('mqtt.eclipseprojects.io', 1883, 600) 
    client.subscribe('fifa', qos=0)
    client.loop_forever() 
    mqtt.eclipseprojects.io,是别人已搭建的mqtt服务器地址,如果想用自己的,可以自行搭建mqtt服务器。


    pub_sub.py 收!发!
    import paho.mqtt.client as mqtt
    
    def on_connect(client, userdata, flags, rc):
        print("Connected with result code: " + str(rc))
    
    def on_message(client, userdata, msg):
        print(msg.topic + " " + str(msg.payload))
    
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect('mqtt.eclipseprojects.io', 1883, 600) 
    client.subscribe('fifa', qos=0)
    i=20
    while i>0:
        i-=1
        client.publish('fifa', payload='next_sub,%s'%i, qos=0)
        print('send_pub,%s'%i)
    client.loop_forever() 
  • 相关阅读:
    【Node.js】Jade视图模板的使用
    【Node.js】新建一个NodeJS 4.X项目
    【Node.Js】npm国内被墙的解决方法
    【AngularJS学习笔记】Java Script "use strict" 严格模式
    【Linux学习笔记】Linux-CentOS下安装Redis
    【Linux学习笔记】常用命令速记
    【AngularJS学习笔记】封装一些简单的控件(封装成Html标签)
    数组和切片1
    Go错误处理机制及自定义错误
    内置函数
  • 原文地址:https://www.cnblogs.com/banxiancode/p/15648917.html
Copyright © 2011-2022 走看看