树莓派MQTT客户端搭建

概述树莓派安装和实现MQTT协议下载Mosquitto更新软件源：sudo apt-get  update下载g++编译器：sudo apt-get install g++安装：sudo apt-get install libssl-dev安装：sudo apt-get install uuid-dev下载客户端文件：http://mosquitto.org/files/source/mosquitto-1.5.tar.gz也可以直接网页下载：解压：sudo tar zxfv mosquitto-1.5.tar.gz进入解压目录：cd mosquitto-1.5注意：此处不需要一般源码包安装步骤：./configure..........编译：make安装：sudo make install测试：mosquitto -v 下载python第三方库：方法1： pip3 install paho-mqtt 方法2：下载：https://github.com/eclipse/paho.mqtt.python打开：cd paho.mqtt.python安装：python setup.py install 编写实现代码：#************************************************************************************import paho.mqtt.client as mqttimport timeHOST = "服务器IP地址-----" #如 192.168.11.23PORT = 61613#端口号----def client_loop():client_id = time.strftime('%Y%m%d%H%M%S',time.localtime(time.time()))# ClientId不能重复，所以使用当前时间client = mqtt.Client(client_id) client.username_pw_set("用户名---", "密码---")client.on_connect = on_connectclient.on_message = on_messageclient.connect(HOST, PORT, 60)client.publish("消息号-----", "MQTT start", qos=0, retain=False) # 发布消息client.loop_forever()def on_connect(client, userdata, flags, rc):print("Connected with result code "+str(rc))client.subscribe("消息号------")def on_message(client, userdata, msg):#打印订阅消息print(msg.topic+" "+msg.payload.decode("utf-8"))if __name__ == '__main__':client_loop()#********************************************************************************运行效果：云端java自编客户端捕获和推送消息： 成功，接下来是手机编程连接，然后树莓派接入GPIO口，实现初级控制。  参考:https://blog.csdn.net/itas109/article/details/78873257https://blog.csdn.net/xukai871105/article/details/39255089 

树莓派安装和实现MQTT协议

下载Mosquitto

也可以直接网页下载：

解压：sudo tar zxfv mosquitto-1.5.tar.gz

进入解压目录：cd mosquitto-1.5

注意：此处不需要一般源码包安装步骤：./configure..........

编译：make

安装：sudo make install

测试：mosquitto -v

下载python第三方库：

方法1：

 pip3 install paho-mqtt

方法2：

下载：https://github.com/eclipse/paho.mqtt.python

打开：cd paho.mqtt.python安装：python setup.py install

编写实现代码：

#************************************************************************************

import paho.mqtt.clIEnt as mqttimport time

HOST = "服务器IP地址-----" #如 192.168.11.23PORT = 61613#端口号----

def clIEnt_loop(): clIEnt_ID = time.strftime('%Y%m%d%H%M%s',time.localtime(time.time()))# ClIEntID不能重复，所以使用当前时间 clIEnt = mqtt.ClIEnt(clIEnt_ID)  clIEnt.username_pw_set("用户名---","密码---") clIEnt.on_connect = on_connect clIEnt.on_message = on_message clIEnt.connect(HOST,PORT,60) clIEnt.publish("消息号-----","MQTT start",qos=0,retain=False) # 发布消息 clIEnt.loop_forever()

def on_connect(clIEnt,userdata,flags,rc): print("Connected with result code "+str(rc)) clIEnt.subscribe("消息号------")

def on_message(clIEnt,msg):#打印订阅消息 print(msg.topic+" "+msg.payload.decode("utf-8"))

if __name__ == '__main__': clIEnt_loop()

#********************************************************************************

运行效果：

云端java自编客户端捕获和推送消息：

 成功，接下来是手机编程连接，然后树莓派接入GPIO口，实现初级控制。

参考:

https://blog.csdn.net/itas109/article/details/78873257

https://blog.csdn.net/xukai871105/article/details/39255089

总结

以上是内存溢出为你收集整理的树莓派MQTT客户端搭建全部内容，希望文章能够帮你解决树莓派MQTT客户端搭建所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/yw/1050615.html