全栈工程师开发手册（作者：栾鹏）
架构系列文章

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

import sys
import osimport paho.mqtt.client as mqtt
import timeHOST="192.168.2.177"
PORT = 59085def client_loop():client_id = time.strftime('%Y%m%d%H%M%S',time.localtime(time.time()))client = mqtt.Client(client_id, userdata=None, protocol=4)    # ClientId不能重复，所以使用当前时间   4就是MQTT3.1.1client.username_pw_set("guest", "guest")  # 必须设置，否则会返回「Connected with result code 4」client.on_connect = on_connectclient.on_message = on_messageclient.on_subscribe = on_subscribeclient.connect(HOST, PORT, keepalive=60)print('mqtt connect success')client.loop_forever(timeout=1.0)# 开始时订阅 callback
def on_subscribe(self, client, userdata, mid, granted_qos):print("Begin subscribe topic with ", mid)# 链接成功的函数
def on_connect(client, userdata, flags, rc):print("Connected with result code "+str(rc))client.subscribe("test_topic")      # 设置topic    0/#import json
# 接收到消息的函数
def on_message(client, userdata, msg):# print(msg)# print(client,userdata,msg)print(msg.topic+" "+msg.payload.decode("utf-8"))content = json.loads(msg.payload.decode("utf-8"))# print(content)if __name__ == '__main__':client_loop()

生产者demo

import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish
import timeHOST = "192.168.2.177"
PORT = 59085# rc 是操作结果的状态码，0 代表成功
#     断开连接时的 callback
def on_disconnect(self, client, userdata, rc):print(self.get_time(), " end a loop with code " + str(rc))# 链接成功
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__':for i in range(11):client_id = time.strftime('%Y%m%d%H%M%S',time.localtime(time.time()))client = mqtt.Client(client_id, userdata=None, protocol=4)    # ClientId不能重复，所以使用当前时间，# 4就是MQTT3.1.1client.username_pw_set("guest", "guest")  # 必须设置，否则会返回「Connected with result code 4」client.on_connect = on_connectclient.on_disconnect = on_disconnectclient.on_message = on_messageclient.connect(HOST, PORT, keepalive=60)pub_result=client.publish("test_topic", payload="你好 MQTT", qos=0, retain=False)  # 发布消息if pub_result.is_published:print(" success pub message with id: ", pub_result.mid)else:print("failed to  pub message")time.sleep(1)# for i in range(10):#     publish.single("test", "你好 MQTT", qos = 1,hostname=HOST,port=PORT, client_id=client_id,auth = {'username':"guest", 'password':"guest"})

k8s部署rabbit，启动manager，mqtt，websocket

我已经上传到github上了，大家可以下载安装https://github.com/626626cdllp/k8s

# 集群中的每个rabbitmq都要是相同的cookie
echo $(openssl rand -base64 32) > erlang.cookie
kubectl -n cloudai-2 create secret generic erlang.cookie --from-file=erlang.cookie
kubectl create -f mqtt-serviceAccount.yaml
kubectl create -f mqtt-service.yaml
kubectl create -f mqtt-deployment.yaml

mqtt安装使用教程。（基于rabbitmq插件，docker部署，k8s部署，python教程）相关推荐

android设备安装kali,在Android设备上安装Kali Linux基于Android设备的Kali Linux渗透测试教程大学霸...
在Android设备上安装Kali Linux基于Android设备的Kali Linux渗透测试教程大学霸基于Android设备的Kali Linux渗透测试教程2 Android是一种基于Lin ...
哪里可以找到python的免费教程-哪里可以找到比较靠谱的Python教程？
网上有15页教程学会Python的教程,你没看错,是15页.学完15页的教程后立即上手,然后赶紧开始做些简单小练习,后期具体用到哪个库再详查. 而且有国人将它翻译成中文原版地址Microsoft A ...
廖雪峰python教程在哪看_：廖雪峰python教程在哪
标签,你可以自己查看网页源代码. 廖雪峰的python教程有一点地方没看明白,求指导题主贴了函数,似乎是一样的,就分析这一个版本:def add_end(L=None): if L is None: ...
python教程鱼c_我见过最全的python教程鱼C工作室，资源教程下载
课程名称我见过最全的python教程鱼C工作室,资源教程下载课程目录 [1]开发基础带安装包 0000安装包 000愉快的开始 001我和Python的第一次亲密接触 002用Python设计第一 ...
php 聊天室教程,基于PHP的聊天室编程思想-PHP教程,PHP基础
1 页面登陆的基本要素你可以在我的竹叶看到登陆的表单,这里提供了最基本的登陆表单项 (1)登陆表单 (a)聊天表单的名字为chatform,我使用action=enter作为进入聊天室的入口,如果 ...
FAQ：Docker和K8s部署常见问题汇总（持续更新）
目录 FAQ1:centos 7 Docker容器启动报WARNING: IPv4 forwarding is disabled. Networking will not work 解决办法: FAQ ...
python教程视频在线-微软再推免费在线Python教程包含20个视频
去年九月,微软曾面向 Python 初学者,推出了一套免费的教程视频.从基本介绍和 VS Code 的配置讲起,循序渐进语法概念等基础内容讲解.目前为止,该系列视频播放量已达到将近 180 万次. 近 ...
廖雪峰python教程整理笔记_python小白01廖雪峰python教程笔记
高级特性切片:前10个数,每两个取一个: L[:10:2]:[0, 2, 4, 6, 8] 可迭代对象的判断: isinstance('abc', Iterable) list变成索引-元素对:fo ...
实战生产环境：kubeadmin安装1.13.3最新版k8s集群教程
2019年3月6日:出版安装kubeadmin部署k8s集群教程本次安装采用kubeadmin ! 安装的k8s版本为1.13.3版,是当前最新版本! 本篇文章,所使用的任何镜像和yaml我都会发一 ...

mqtt安装使用教程。（基于rabbitmq插件，docker部署，k8s部署，python教程）

Docker安装RabbitMQ配置MQTT

Python MQTT客户端实现

k8s部署rabbit，启动manager，mqtt，websocket

mqtt安装使用教程。（基于rabbitmq插件，docker部署，k8s部署，python教程）相关推荐

最新文章

热门文章