MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议。它是一种发布/订阅,极其简单和轻量级的消息传递协议,专为受限设备和低带宽,高延迟或不可靠的网络而设计。它的设计思想是轻巧、开放、简单、规范,易于实现。这些特点使得它对很多场景来说都是很好的选择,特别是对于受限的环境如机器与机器的通信(M2M)以及物联网环境。相对于XMPP,MQTT更加轻量级,并且占用的宽带低。
MQTT协议有以下特点:
那么问题来了?重连连接成功后重复接收到最后一条消息
MQTT推送消息订阅端重复接收问题。
(背景)订阅端断开的时候,发布端多次推送消息。
(现象)订阅端启动时,接收到最后一条推送消息有两次;即使Qos设置为2;依然是两次。
经排查是因为
MqttMessage的Retained设置为了true;
该值很多文章上只说了是 消息保留机制,若设置为true,mqtt服务器会保留每次发布的消息;较少提到 若订阅某主题的客户端重启,则会把此主题之前发布的消息重新推送到客户端。该值默认为false;去掉修改该值即可
那么问题来了?重连连接后手动那么多遗漏的消息,怎么选择只接收最新的一条消息呢?
MQTT推送消息订阅端重复接收问题。
(背景)订阅端断开的时候,发布端多次推送消息。
(现象)订阅端启动时,接收到msg1,msg2,msg3 (这三个消息都是同一个类型消息,只需要处理最新的msg3就好,不然界面会刷新三次)这个谁有什么好办法没呢?
GitHub地址: >mqtt与socket的区别有:
1、mqtt协议是为工作在低带宽、不可靠网络的远程传感器和控制设备通讯而设计的协议,而WebSocket则是为了浏览器与服务器全双工通信的一种协议。
2、mqtt是IBM开发的一个即时通讯协议,有可能成为物联网的重要组成部分。Socket是HTML5一种新的协议。
MQTT是一个基于客户端-服务器的消息发布、订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的环境中,如:机器与机器、通信和物联网。其在智能家居、及一些小型化设备中已广泛使用。
2、 找到相应系统的安装文件安装,如果不想做任何设置直接在服务里启动就行。
3、配置文件
如果需要配置一些用户名、密码、用户权限的参数,则需要修改安装目录下的mosquittoconf文件
下面来说说我用到的一些参数吧:
①用户密码: #password_file pwfileexample 后面跟着是用户密码配置文件,需写上绝对路径并且路径不带空格
②创建用户密码:打开doc窗口,进入mosquitto安装目录,运行mosquitto_passwd -c pwfileexample userName 回车,然后输入密码(密码输入两遍后,在该文件里会自动加密密码)
生成的文件内容格式例如:
userName:$6$Ls7JYQTdn9xagJJ2$zngeT758n1Wn1hnVLjFdK2cHb6lcmI5CMrMTNZe2SqkUj0fBgKts62gvlyWYwdY3/WArx/SAtFRKlvKKnHRCUg==
userName2:$6$bymgVcrtj+7wj8mR$nq1atPD3nreRgA6gDbDjfbUGZIlrmenOcWrXMoneBp+zmAxnOybqJvrBZboxX1XXPnz/TKZwz9aKQJ72zJym5A=
③如果想再增加用户,则执行mosquitto_passwd -u pwfileexample userName2即可
④用户权限:#acl_file aclfileexample 后面跟着是用户权限配置文件,需写上绝对路径并且路径
文件内容格式为:
user userName
/etc/ldsoconfd
mosquittoconf
/usr/local/lib/python26/site-packages ( mosquittopy )
/usr/local/bin
vi /etc/sysconfig/iptables
/usr/local/src/mosquitto-113/lib/python
make install
ldconfig
不改configmk里面的东西
需要安装
yum -y install patch make gcc gcc-c++ gcc-g77 flex bison
centos56下 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://127001:1883","java_client0000000000");
// 回调处理类
Myback callback = new Myback();
clientsetCallback(callback);
// 创建连接可选项信息
MqttConnectOptions conOptions = new MqttConnectOptions();
conOptionssetCleanSession(false);
conOptionssetUserName("userName");
conOptionssetPassword("pwd"toCharArray());
// 连接broker
clientconnect(conOptions);
clientsubscribe("主题");
}
发布:
MqttClient client = new MqttClient("tcp://127001:1883","mqttserver-pub");
MqttTopic topic = clientgetTopic("主题");
MqttMessage message = new MqttMessage(topicgetName()getBytes());
messagesetQos(1);
MqttConnectOptions options = new MqttConnectOptions();
optionssetUserName("userName");
optionssetPassword("pwd"toCharArray());
clientconnect(options);
topicpublish(message);
}
即可验证!通过Cocoa Pods添加MQTTKit
MQTTKit在github上链接>
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)