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，连接数等很多信息。
经过上面的简单步骤，服务器基本上就已经完成。