1、Mosquitto簡介
Mosquitto簡介是一個開源(BSD許可證)的消息代理,實現MQTT(消息隊列遙測傳輸)協議版本3.1.1。
MQTT(MQ Telemetry Transport),消息隊列遙測傳輸協議,輕量級的發布/訂閱協議,適用於一些條件比較苛刻的環境,進行低帶寬、不可靠或間歇性的通信。目前已經是物聯網消息通信事實上的標准協議了。
值得一提的是mqtt提供三種不同質量的消息服務:
“至多一次”:消息發布完全依賴底層 TCP/IP 網絡。會發生消息丟失或重復。這一級別可用於如下情況,環境傳感器數據,丟失一次讀記錄無所謂,因為不久后還會有第二次發送。
“至少一次”:確保消息到達,但消息重復可能會發生。
“只有一次”:確保消息到達一次。這一級別可用於如下情況,在計費系統中,消息重復或丟失會導致不正確的結果。
2、安裝步驟
a、配置yum
在/etc/yum.repos.d/ 目錄中新建一個mosquitto.repo文件,文件內容如下:
[home_oojah_mqtt] name=mqtt (CentOS_CentOS-6) type=rpm-md baseurl=http://download.opensuse.org/repositories/home:/oojah:/mqtt/CentOS_CentOS-6/ gpgcheck=1 gpgkey=http://download.opensuse.org/repositories/home:/oojah:/mqtt/CentOS_CentOS-6/repodata/repomd.xml.key enabled=1
b、使用yum在線安裝
# yum search all mosquitto # yum install mosquitto mosquitto-clients libmosquitto-devel libmosquittopp-devel python-mosquitto
c、配置文件
# ================================================================= # General configuration # ================================================================= # 客戶端心跳的間隔時間 #retry_interval 20 # 系統狀態的刷新時間 #sys_interval 10 # 系統資源的回收時間,0表示盡快處理 #store_clean_interval 10 # 服務進程的PID #pid_file /var/run/mosquitto.pid # 服務進程的系統用戶 #user mosquitto # 客戶端心跳消息的最大並發數 #max_inflight_messages 10 # 客戶端心跳消息緩存隊列 #max_queued_messages 100 # 用於設置客戶端長連接的過期時間,默認永不過期 #persistent_client_expiration # ================================================================= # Default listener # ================================================================= # 服務綁定的IP地址 #bind_address # 服務綁定的端口號 #port 1883 # 允許的最大連接數,-1表示沒有限制 #max_connections -1 # cafile:CA證書文件 # capath:CA證書目錄 # certfile:PEM證書文件 # keyfile:PEM密鑰文件 #cafile #capath #certfile #keyfile # 必須提供證書以保證數據安全性 #require_certificate false # 若require_certificate值為true,use_identity_as_username也必須為true #use_identity_as_username false # 啟用PSK(Pre-shared-key)支持 #psk_hint # SSL/TSL加密算法,可以使用“openssl ciphers”命令獲取 # as the output of that command. #ciphers # ================================================================= # Persistence # ================================================================= # 消息自動保存的間隔時間 #autosave_interval 1800 # 消息自動保存功能的開關 #autosave_on_changes false # 持久化功能的開關 persistence true # 持久化DB文件 #persistence_file mosquitto.db # 持久化DB文件目錄 #persistence_location /var/lib/mosquitto/ # ================================================================= # Logging # ================================================================= # 4種日志模式:stdout、stderr、syslog、topic # none 則表示不記日志,此配置可以提升些許性能 log_dest none # 選擇日志的級別(可設置多項) #log_type error #log_type warning #log_type notice #log_type information # 是否記錄客戶端連接信息 #connection_messages true # 是否記錄日志時間 #log_timestamp true # ================================================================= # Security # ================================================================= # 客戶端ID的前綴限制,可用於保證安全性 #clientid_prefixes # 允許匿名用戶 #allow_anonymous true # 用戶/密碼文件,默認格式:username:password #password_file # PSK格式密碼文件,默認格式:identity:key #psk_file # pattern write sensor/%u/data # ACL權限配置,常用語法如下: # 用戶限制:user <username> # 話題限制:topic [read|write] <topic> # 正則限制:pattern write sensor/%u/data #acl_file # ================================================================= # Bridges # ================================================================= # 允許服務之間使用“橋接”模式(可用於分布式部署) #connection <name> #address <host>[:<port>] #topic <topic> [[[out | in | both] qos-level] local-prefix remote-prefix] # 設置橋接的客戶端ID #clientid # 橋接斷開時,是否清除遠程服務器中的消息 #cleansession false # 是否發布橋接的狀態信息 #notifications true # 設置橋接模式下,消息將會發布到的話題地址 # $SYS/broker/connection/<clientid>/state #notification_topic # 設置橋接的keepalive數值 #keepalive_interval 60 # 橋接模式,目前有三種:automatic、lazy、once #start_type automatic # 橋接模式automatic的超時時間 #restart_timeout 30 # 橋接模式lazy的超時時間 #idle_timeout 60 # 橋接客戶端的用戶名 #username # 橋接客戶端的密碼 #password # bridge_cafile:橋接客戶端的CA證書文件 # bridge_capath:橋接客戶端的CA證書目錄 # bridge_certfile:橋接客戶端的PEM證書文件 # bridge_keyfile:橋接客戶端的PEM密鑰文件 #bridge_cafile #bridge_capath #bridge_certfile #bridge_keyfile # 自己的配置可以放到以下目錄中 include_dir /etc/mosquitto/conf.d
3、啟動服務
# mosquitto -c /etc/mosquitto/mosquitto.conf -d # sudo /etc/init.d/mosquitto start
4、測試服務
一、開啟另一個終端窗口,運行訂閱程序mosquitto_sub:
*注意:消息推送的發布和訂閱要有主題,選項[-t] 主題,即:
mosquitto -t 主題
如需指定用戶名稱則加選項[-i] 用戶名,即:
mosquitto_sub -t 主題 -i 訂閱端
# mosquitto_sub -t mqtt
二、開啟另一個終端窗口,運行發布程序mosquitto_pub:
指定消息推送的主題,發布端用戶名和消息:
mosquitto_pub -t 主題 -i 發布端 -h 主機 -m 你好
*注意:如果消息中間有空格則消息要用引號括起來。
mosquitto_pub -t 主題 -i 發布端 -h host -m ‘我是發布端,你好。
# mosquitto_pub -h localhost -t mqtt -m "hello world."
這時候前面那個訂閱窗口就可以收到”hello world”的消息了。