mb_client能够同时读取写入吗

mb_client能够同时读取写入吗,第1张

是的,mb_client可以同时读取和写入。mb_client是一个轻量级的客户端库,可用于与MQTT服务器进行交互。它支持客户端端口的双向通信,并提供了简单的API来连接到基于MQTT的服务器。可以使用mb_client来实现双向读取和写入,以便可以从服务器读取数据并将数据写入服务器。此外,mb_client还可以支持发布/订阅模式,以便可以从服务器收到消息,也可以向服务器发布消息。mb_client还支持断开连接和断开重连,以确保可以在任何时候与服务器保持连接。它还支持认证,以便可以与服务器进行安全的通信。

1、 下载mosquitto安装文件()
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);
}
即可验证!

MQTT不存在上传和下发的定义,只有以topic为单位的推送和订阅。你的情况描述是服务器能看到推送的消息,说明网络、broker配置没有问题,要保证“服务器下发给客户端”能顺利实现的话请确认以下几点:

服务器端推送到的topic和客户端订阅的topic是一致的

本地设备开启了1883端口(或者你自定义的端口号),防火墙没有拦截

如果是自己写代码的话,客户端的on message回调函数里解析报文的逻辑是正确

通过Cocoa Pods添加MQTTKit

MQTTKit在github上链接>      用户在使用CAT1模组MQTT协议对接自己的服务器,有时会遇到设备无法连接服务器问题(比如提示+ECMTCON:0,0,5连接服务器被拒绝,认证失败)。此时可以通过 标准的MQTT服务器 进行对比,因为用户自己的服务器一般加入校验信息,导致模组&MQTT服务器无法连接。

       Eclipse Mosquitto是一个开源消息代理,实现了MQTT协议版本31和311,这里使用该服务器进行测试。针对该服务器更详细的介绍也可以参考 >

欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zz/13435751.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-08-05
下一篇 2023-08-05

发表评论

登录后才能评论

评论列表(0条)

保存