当前位置: 萬仟网 > 网络运营>服务器>虚拟主机 > Docker MQTT安装使用教程

Docker MQTT安装使用教程

2019年05月24日  | 萬仟网网络运营  | 我要评论
mqtt简介 mqtt(message queuing telemetry transport,消息队列遥测传输)是ibm开发的一个即时通讯协议,有可能成为物联网的重要组

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

官方文档:
mqtt

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对萬仟网的支持。如果你想了解更多相关内容请查看下面相关链接

如您对本文有疑问或者有任何想说的,请点击进行留言回复,万千网友为您解惑!

相关文章:

验证码:
Copyright © 2017-2021  萬仟网 保留所有权利. 粤ICP备17035492号-1
站长QQ:2386932994 | 联系邮箱:2386932994@qq.com