13518219792
这篇“Docker MQTT怎么安装使用”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Docker MQTT怎么安装使用”文章吧。
成都创新互联，为您提供重庆网站建设、网站制作、网站营销推广、网站开发设计，对服务加固等多个行业拥有丰富的网站建设及推广经验。成都创新互联网站建设公司成立于2013年,提供专业网站制作报价服务,我们深知市场的竞争激烈，认真对待每位客户，为客户提供赏心悦目的作品。 与客户共同发展进步，是我们永远的责任！
mqtt简介
mqtt（message queuing telemetry transport，消息队列遥测传输）是ibm开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和制动器（比如通过twitter让房屋联网）的通信协议。
docker安装rabbitmq配置mqtt
使用rabbitmq作为mqtt服务端，eclipse paho作为客户端。宿主机系统为ubuntu16.04
docker下载镜像
docker pull daocloud.io/library/rabbitmq:3.7.4
启动rabbitmq
docker run -d --hostname my-rabbit --name some-rabbit -p 15672:15672 -p 5672:5672 -p 1883:1883 -p 15675:15675 daocloud.io/library/rabbitmq:3.7.4
注意映射容器端口
15672 是rabbitmq management管理界面默认访问端口
5672 是amqp默认端口
1883 是mqtt tcp协议默认端口
15675 是web_mqtt websocket协议默认端口
启用插件
默认安装后我们需要手动开启rabbitmq_management插件，rabbitmq_mqtt插件和rabbitmq_web_mqtt插件。
执行如下三条命令
docker exec <容器id> rabbitmq-plugins enable rabbitmq_management docker exec <容器id> rabbitmq-plugins enable rabbitmq_mqtt docker exec <容器id> rabbitmq-plugins enable rabbitmq_web_mqtt
当然你也可以写个脚本start.sh，复制到容器中
/usr/sbin/rabbitmq-plugins enable rabbitmq_management /usr/sbin/rabbitmq-plugins enable rabbitmq_mqtt /usr/sbin/rabbitmq-plugins enable rabbitmq_web_mqtt
进入容器执行这个脚本。
sh start.sh
开放宿主机端口
firewall-cmd --zone=public --add-port=15672/tcp --permanent firewall-cmd --zone=public --add-port=5672/tcp --permanent firewall-cmd --zone=public --add-port=1883/tcp --permanent firewall-cmd --zone=public --add-port=15675/tcp --permanent firewall-cmd --reload
python mqtt客户端实现
安装python包
pip install paho-mqtt
发送数据demo（消费者）
# 使用前需要启动hbase和thrift服务器 # 启动hbase在cd /usr/local/hbase下bin/start-hbase.sh 默认端口为 60000 # 启动thrift服务器cd /usr/local/hbase/bin执行./hbase-daemon.sh start thrift 默认端口为9090 import sys import os dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../' sys.path.append(dir_common) # 将根目录添加到系统目录,才能正常引用common文件夹 import argparse # import logging import time,datetime from common.py_log import init_logger,init_console_logger from common.config import * from common.py_hbase import pyhbase import time,json from common.py_rabbit import rabbit_consumer import paho.mqtt.client as mqtt import time host = "192.168.2.46" port = 1883 def client_loop(): client_id = time.strftime('%y%m%d%h%m%s',time.localtime(time.time())) client = mqtt.client(client_id) # clientid不能重复，所以使用当前时间 client.username_pw_set("guest", "guest") # 必须设置，否则会返回「connected with result code 4」 client.on_connect = on_connect client.on_message = on_message client.connect(host, port, 60) client.loop_forever() def on_connect(client, userdata, flags, rc): print("connected with result code "+str(rc)) client.subscribe("test") def on_message(client, userdata, msg): print(msg.topic+" "+msg.payload.decode("utf-8")) if __name__ == '__main__': client_loop()
接收数据demo（生产者）
import sys
import os
dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../'
sys.path.append(dir_common) # 将根目录添加到系统目录,才能正常引用common文件夹
import paho.mqtt.client as mqtt
import time
host = "192.168.2.46"
port = 1883
def client_loop():
client_id = time.strftime('%y%m%d%h%m%s',time.localtime(time.time()))
client = mqtt.client(client_id) # clientid不能重复，所以使用当前时间
client.username_pw_set("guest", "guest") # 必须设置，否则会返回「connected with result code 4」
client.on_connect = on_connect
client.on_message = on_message
client.connect(host, port, 60)
client.loop_forever()
def on_connect(client, userdata, flags, rc):
print("connected with result code "+str(rc))
client.subscribe("test")
def on_message(client, userdata, msg):
print(msg.topic+" "+msg.payload.decode("utf-8"))
if __name__ == '__main__':
client_loop()生产者demo
# import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
import time
host = "192.168.2.46"
port = 1883
def on_connect(client, userdata, flags, rc):
print("connected with result code "+str(rc))
client.subscribe("test")
def on_message(client, userdata, msg):
print(msg.topic+" "+msg.payload.decode("utf-8"))
if __name__ == '__main__':
client_id = time.strftime('%y%m%d%h%m%s',time.localtime(time.time()))
# client = mqtt.client(client_id) # clientid不能重复，所以使用当前时间
# client.username_pw_set("guest", "guest") # 必须设置，否则会返回「connected with result code 4」
# client.on_connect = on_connect
# client.on_message = on_message
# client.connect(host, port, 60)
# client.publish("test", "你好 mqtt", qos=0, retain=false) # 发布消息
publish.single("test", "你好 mqtt", qos = 1,hostname=host,port=port, client_id=client以上就是关于“Docker MQTT怎么安装使用”这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注创新互联行业资讯频道。
