婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av

主頁 > 知識庫 > Docker MQTT安裝使用教程

Docker MQTT安裝使用教程

熱門標(biāo)簽:西柏坡地圖標(biāo)注 i智能電話機器人yeta 燃?xì)夤芫€地圖標(biāo)注顏色 寧波400電話辦理對企業(yè)的意義 廣東如何申請400電話 北京人工外呼系統(tǒng)廠家 400電話申請要什么條件 哈爾濱400電話去哪辦理 話術(shù)外呼系統(tǒng)

MQTT簡介

MQTT(Message Queuing Telemetry Transport,消息隊列遙測傳輸)是IBM開發(fā)的一個即時通訊協(xié)議,有可能成為物聯(lián)網(wǎng)的重要組成部分。該協(xié)議支持所有平臺,幾乎可以把所有聯(lián)網(wǎng)物品和外部連接起來,被用來當(dāng)做傳感器和制動器(比如通過Twitter讓房屋聯(lián)網(wǎng))的通信協(xié)議。

Docker安裝RabbitMQ配置MQTT

使用RabbitMQ作為MQTT服務(wù)端,Eclipse Paho作為客戶端。宿主機系統(tǒng)為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管理界面默認(rèn)訪問端口
  • 5672 是amqp默認(rèn)端口
  • 1883 是mqtt tcp協(xié)議默認(rèn)端口
  • 15675 是web_mqtt websocket協(xié)議默認(rèn)端口

啟用插件

默認(rèn)安裝后我們需要手動開啟rabbitmq_management插件,rabbitmq_mqtt插件和rabbitmq_web_mqtt插件。

執(zhí)行如下三條命令

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

當(dāng)然你也可以寫個腳本start.sh,復(fù)制到容器中

/usr/sbin/rabbitmq-plugins enable rabbitmq_management
/usr/sbin/rabbitmq-plugins enable rabbitmq_mqtt
/usr/sbin/rabbitmq-plugins enable rabbitmq_web_mqtt

進(jìn)入容器執(zhí)行這個腳本。

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客戶端實現(xiàn)

安裝python包

pip install paho-mqtt

發(fā)送數(shù)據(jù)demo(消費者)

# 使用前需要啟動hbase和thrift服務(wù)器
# 啟動hbase在cd /usr/local/hbase下bin/start-hbase.sh  默認(rèn)端口為 60000
# 啟動thrift服務(wù)器cd /usr/local/hbase/bin執(zhí)行./hbase-daemon.sh start thrift  默認(rèn)端口為9090
import sys
import os
dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../'
sys.path.append(dir_common)  # 將根目錄添加到系統(tǒng)目錄,才能正常引用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不能重復(fù),所以使用當(dāng)前時間
  client.username_pw_set("guest", "guest") # 必須設(shè)置,否則會返回「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()

接收數(shù)據(jù)demo(生產(chǎn)者)

import sys
import os
dir_common = os.path.split(os.path.realpath(__file__))[0] + '/../'
sys.path.append(dir_common)  # 將根目錄添加到系統(tǒng)目錄,才能正常引用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不能重復(fù),所以使用當(dāng)前時間
  client.username_pw_set("guest", "guest") # 必須設(shè)置,否則會返回「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()

生產(chǎn)者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不能重復(fù),所以使用當(dāng)前時間
  # client.username_pw_set("guest", "guest") # 必須設(shè)置,否則會返回「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) # 發(fā)布消息
  publish.single("test", "你好 MQTT", qos = 1,hostname=HOST,port=PORT, client_id=client

官方文檔:
mqtt http://www.rabbitmq.com/mqtt.html

總結(jié)

以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,謝謝大家對腳本之家的支持。如果你想了解更多相關(guān)內(nèi)容請查看下面相關(guān)鏈接

標(biāo)簽:巴中 開封 阜陽 張家口 湘潭 西藏 襄陽 珠海

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《Docker MQTT安裝使用教程》,本文關(guān)鍵詞  Docker,MQTT,安裝,使用,教程,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《Docker MQTT安裝使用教程》相關(guān)的同類信息!
  • 本頁收集關(guān)于Docker MQTT安裝使用教程的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章
    主站蜘蛛池模板: 鄂尔多斯市| 平原县| 乌什县| 彩票| 上杭县| 贵南县| 临潭县| 陆川县| 出国| 囊谦县| 怀化市| 司法| 肇东市| 威宁| 杨浦区| 武功县| 手游| 陵川县| 济阳县| 邛崃市| 嵩明县| 塘沽区| 关岭| 潼关县| 西峡县| 黎川县| 和龙市| 宁国市| 贺州市| 连城县| 浪卡子县| 桃江县| 西平县| 花莲市| 六安市| 札达县| 共和县| 隆尧县| 裕民县| 静乐县| 安徽省|