mqttpython
㈠ paho.mqtt.python模塊怎麼安裝
【1】MQTT協議中可指定用戶名和密碼，在yeelink協議中，用戶名變為U-ApiKey，密碼為U-ApiKey的具體值。
【2】訂閱主題為設備URI，需要把API版本號修改為v1.1
【3】主機名稱為mqtt.yeelink.net，而不是api.yeelink.net
在mqtt.js的示例代碼中：client = mqtt.connect('mqtt://user:pass@localhost');
在yeelink的示例代碼中：client = mqtt.connect("mqtt://U-ApiKey:<your_key>@mqtt.yeelink.net");
以上的兩個示例代碼更可以說明各參數的對應關系。
㈡ MQTT和Websocket的區別是什麼
MQTT跟WebSocket關系不大。他們不是在一個層級的。
WebSocket很多網站使用輪詢實現推送技術。輪詢是在特定的的時間間隔（比如1秒），由瀏覽器對伺服器發出HTTP request，然後由伺服器返回最新的數據給瀏覽器。輪詢的缺點很明顯，瀏覽器需要不斷的向伺服器發出請求，然而HTTP請求的header是非常長的，而實際傳輸的數據可能很小，這就造成了帶寬和伺服器資源的浪費。
Comet使用了AJAX改進了輪詢，可以實現雙向通信。但是Comet依然需要發出請求，而且在Comet中，普遍採用了長鏈接，這也會大量消耗伺服器帶寬和資源。
於是，WebSocket協議應運而生。 瀏覽器通過 javaScript 向伺服器發出建立 WebSocket 連接的請求，連接建立以後，客戶端和伺服器通過 TCP 連接直接交換數據。WebSocket 連接本質上是一個 TCP 連接。
WebSocket在數據傳輸的穩定性和數據傳輸量的大小方面，具有很大的性能優勢。Websocket.org 比較了輪詢和WebSocket的性能優勢：
HTTP 輪訓每次需要返回871個位元組，websocket每次只需要2個位元組
Use Case A： 1,000個客戶端每秒接受一個message，網路吞吐量 （2*1,000）=2,000 bytes = 16,000 每秒bits
Use Case B： 10,000個客戶端每秒接受一個message，網路吞吐量 （2*10,000）=20,000 bytes = 160,000 每秒bits
Use Case C： 100,000個客戶端每秒接受一個message，網路吞吐量 （2*100,000）=200,000 bytes = 1,600,000 每秒bits
MQTT 協議是為大量計算能力有限，且工作在低帶寬、不可靠的網路的遠程感測器和控制設備通訊而設計的協議，它具有以下主要的幾項特性：
非常小的通信開銷（最小的消息大小為 2 位元組），小型傳輸，開銷很小（固定長度的頭部是 2 位元組），協議交換最小化，以降低網路流量。
支持各種流行編程語言（包括 C，Java，Ruby，Python 等等）且易於使用的客戶端；
使用發布 / 訂閱消息模式，提供一對多的消息發布，解除應用程序耦合。
對負載內容屏蔽的消息傳輸。
使用 TCP/IP 提供網路連接。
有三種消息發布服務質量，讓消息能按需到達目的地，適應在不穩定工作的網路傳輸需求 ：
"至多一次"，消息發布完全依賴底層 TCP/IP 網路。會發生消息丟失或重復。這一級別可用於如下情況，環境感測器數據，丟失一次讀記錄無所謂，因為不久後還會有第二次發送。
"至少一次"，確保消息到達，但消息重復可能會發生。
"只有一次"，確保消息到達一次。這一級別可用於如下情況，在計費系統中，消息重復或丟失會導致不正確的結果。
㈢ mqtt斷開之後需要重新訂閱嗎
1.目標：測試Mosquitto使用MQTT協議發消息的相關性能指標，包含發送速度，並發負載能力，資源佔用，消息到達率。 2.MQTT協議簡介： 1).建立長連接。客戶端發起請求和服務端建立長連接，建立成功後，服務端會返回ACK(CONNACK) 2).客戶端訂閱：客戶端發起訂閱，訂閱成功後，服務端會返回ACK(SUBACK) 3).發消息：發布者會給服務端發消息，服務端在把消息給合適的客戶端。 Qos=0(服務質量)：客戶端消息收到後，不會發出ACK給服務端(PUBACK)。 Qos =1:服務端會發ACK給發布者，客戶端收到消息後會發ACK給服務端。 4).取消訂閱：客戶端發起取消訂閱，服務端返回ACK(UNSUBACK) 5)Pingreq&Pingresp:客戶端和服務端會保持心跳。 3.存在問題： 1. 如何模擬出40W的用戶 2. 如何長連接，訂閱，發消息，取消訂閱，Pingreq行為如何實現。 4. python開源庫 Mosquitto.py，解決所有問題 1. 模擬40W用戶 a)可以使用虛擬機和Mosquitto.py實現，具體為：一般一台虛擬機最多是6W+的模擬數據（需要修改句柄數，我使用5W），方法是Client_id可以簡單的做出5W個來，然後調用Mosquitto裡面的connect方法，建立長連接。准備8台虛擬機就可以實現40W客戶端的模擬 2.行為的模擬 a)訂閱：Mosquitto.subscribe / 發消息：Mosquitto.publish / 取消訂閱：Mosquitto.unsubscribe。 簡單一句話 Mosquitto庫實現所有的行為. 5. 指標：發送速度，到達率，並發負載，資源佔用。 a. 發送速度：服務端日誌記錄，分析解決 b. 到達率： 1.客戶端記錄下收到消息，分析計算。2.計算服務端收到的PUBACK（客戶端收到消息返回的ACK），進行計算 c. 並發負載：5W 用戶不斷增加，注意觀察服務端的負載情況。 e.資源佔用：其實主要是cpu/mem/帶寬：cpu多核的話需要觀察top命令下的_id欄位, mem可以觀察free -h命令的剩餘mem, 帶寬可以使用mpstat進行觀察 6. 可以遇見問題： a. 模擬客戶端的虛擬機需要修改句柄數才能支持5W的客戶端模擬數量 b. 要先吃透MQTT協議的流程，吃透了進行測試會非常的方便 c. Clear session，設置為true則不為客戶端保留休息，設置為false保留消息。其實就是客戶端離線後在連接上可以收到之前推出的消息。
㈣ mqtt 伺服器 哪個好 activemq rabbitmq mosquitto
1、 下載mosquitto安裝文件（）
2、 找到相應系統的安裝文件安裝，如果不想做任何設置直接在服務里啟動就行。
3、配置文件
如果需要配置一些用戶名、密碼、用戶許可權的參數，則需要修改安裝目錄下的mosquitto.conf文件
下面來說說我用到的一些參數吧：
①用戶密碼： #password_file pwfile.example 後面跟著是用戶密碼配置文件，需寫上絕對路徑並且路徑不帶空格
②創建用戶密碼：打開doc窗口，進入mosquitto安裝目錄，運行mosquitto_passwd -c pwfile.example userName 回車，然後輸入密碼(密碼輸入兩遍後，在該文件里會自動加密密碼)
生成的文件內容格式例如：
userName:$6$Ls7JYQTdn9xagJJ2$/WArx/SAtFRKlvKKnHRCUg==
userName2:$6$bymgVcrtj+7wj8mR$+zmAxnOybqJvrBZboxX1XXPnz/TKZwz9aKQJ72zJym5A=
③如果想再增加用戶，則執行mosquitto_passwd -u pwfile.example userName2即可
④用戶許可權：#acl_file aclfile.example 後面跟著是用戶許可權配置文件，需寫上絕對路徑並且路徑
文件內容格式為：
user userName
/etc/ld.so.conf.d
mosquitto.conf
/usr/local/lib/python2.6/site-packages ( mosquitto.py )
/usr/local/bin
vi /etc/sysconfig/iptables
/usr/local/src/mosquitto-1.1.3/lib/python
make install
ldconfig
不改config.mk裡面的東西
需要安裝
yum -y install patch make gcc gcc-c++ gcc-g77 flex bison
centos5.6下 yum -y install gcc automake autoconf libtool make
yum -y install openssl openssl-devel vim-minimal
這里為只讀
topic read 主題
user userName2
這里為可讀可寫
topic 主題
topic #(或+)表示可以讀寫任何主題
到這里用戶密碼及許可權已配置完成，訂閱和發布的時候加上用戶名及密碼即可驗證：
例如：訂閱
client = new MqttClient("tcp://127.0.0.1:1883","java_client0000000000");
// 回調處理類
Myback callback = new Myback();
client.setCallback(callback);
// 創建連接可選項信息
MqttConnectOptions conOptions = new MqttConnectOptions();
conOptions.setCleanSession(false);
conOptions.setUserName("userName");
conOptions.setPassword("pwd".toCharArray());
// 連接broker
client.connect(conOptions);
client.subscribe("主題");
}
發布：
MqttClient client = new MqttClient("tcp://127.0.0.1:1883","mqttserver-pub");
MqttTopic topic = client.getTopic("主題");
MqttMessage message = new MqttMessage(topic.getName().getBytes());
message.setQos(1);
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName("userName");
options.setPassword("pwd".toCharArray());
client.connect(options);
topic.publish(message);
}
即可驗證！
㈤ 如何用python啟動mosquitto mqtt伺服器
配置文件路徑 /etc/mosquitto/mosquitto.conf
啟動服務進程mosquitto，除了可能用命令行參數，還要以通過配置文件，配置文件更為詳細。
可以指定ip地址和埠，還可以使用用戶名和密碼！
㈥ python 如何監測進程是否關閉
如果被監測程序是你自己編寫的，那你可以在程序進程結束的時候主動去通知監測進程。
如果不是，而你要監測它的運行情況，那麼這和操作系統有關。Windows和Linux下的處理方式是不一樣的。
㈦ python mqtt 怎樣查詢設備是否在線
設置套接字操作的超時期，timeout是一個浮點數，單位是秒。值為None表示沒有超時期。一般，超時期應該在剛創建套接字時設置， 因為它們可能用於連接的操作（如 client 連接最多等待5s ）！
㈧ 用python開發一個物流web代碼
詳細如下。
一個名叫「Remi」的Python庫，就是用來開發WebApp的。1.Remi庫簡介
Remi是一個用於Python應用程序的GUI庫，它將應用程序的界面轉換為HTML，以便在Web瀏覽器中呈現。嚴格地說，我們不能用Remi庫來編寫傳統的網站，而只能將它當成Web形式的Tkinter庫（Python最經典的圖形界面庫）來使用。如果要做網站，還是要老老實實學點前端知識，然後結合Python的Flask框架來開發。
2.Remi庫的安裝
Remi可以採用pip命令安裝
3.Remi庫的代碼
運行這段代碼後，瀏覽器會自動打開一個本地的網址，出現如下圖所示的界面。將「127.0.0.1」換成IP地址，就能通過其他電腦、手機的瀏覽器來訪問了。
點擊「請點擊這里」按鈕，界面會發生變化，如下圖所示。不用寫復雜的JS代碼，在Remi的支持下，網頁交互就變得這么簡單。如果需要了解更多關於Remi庫的資源，可以訪問github或者官方文檔。
github地址：https://github.com/dddomodossola/remi
文檔地址：https://remi.readthedocs.io/en/latest/
基於Remi編寫基於Web的物聯網應用程序，既然是編寫物聯網應用程序，那麼肯定還需要安裝siot庫。這也是「虛穀物聯」團隊開發的Python庫，因為MQTT的官方Python庫（paho-mqtt）編寫出來的代碼冗長，不好理解，於是委託上海蘑菇雲團隊在paho-mqtt的基礎上進行了新的封裝。siot庫可以通過pip命令來安裝，命令如下：
pipinstallsiot
㈨ 有支持tcp udp mqtt rs232協議的python框架嗎
從GitHub中整理出的15個最受歡迎的Python開源框架。這些框架包括事件I/O，OLAP，Web開發，高性能網路通信，測試，爬蟲等。 Django: Python Web應用開發框架 Django 應該是最出名的Python框架
㈩ paho.mqtt.python-master怎麼安裝
1、下載Apollo伺服器，下載後解壓，然後運行apache-apollo-1.6\bin\apollo.cmd，輸入create mybroker（名字任意取，這里是根據 官網 介紹的來取的）創建伺服器實例，伺服器實例包含了所有的配置，運行時數據等，並且和一個伺服器進程關聯。
2、create mybroker之後會在bin目錄下生成mybroker文件夾，裡麵包含有很多信息，其中etc\apollo.xml文件下是配置伺服器信息的文件，etc\users.properties文件包含連接MQTT伺服器時用到的用戶名和密碼，後面會介紹，可以修改原始的admin=password，可以接著換行添加新的用戶名密碼。
3、打開cmd，運行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 開啟伺服器，可以在瀏覽器中輸入 查看是否安裝成功，該界面展示了topic，連接數等很多信息。
經過上面的簡單步驟，伺服器基本上就已經完成。