全棧工程師開發手冊 （作者：欒鵬）

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
 

/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 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_id,auth = {'username':"guest", 'password':"guest"})

k8s部署rabbit，啟動manager，mqtt，websocket