MQTTX 接收不到订阅数据的排查

Posted

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了MQTTX 接收不到订阅数据的排查相关的知识，希望对你有一定的参考价值。


场景

JAVA数据发送端有日志显示数据已经发布出去了。MQTTX订阅该主题，没有收到数据，刚开始能够收到数据，过段时间就无法订阅接收到数据，断开重连，重新订阅也无法接收到数据.

怀疑

MQTTX没有重连，实际上设置了重连也不行


排查过程

1工具收发排查

启动订阅主题

mosquitto_sub.exe -h 10.172.5.3 -p 1883 -u admin -P 123456 -t   PSMXYZ

启动发送

mosquitto_pub.exe-h 10.172.5.3 -p 1883 -u admin -P 123456 -t   PSMXY -m "aaaaaaaaa"

命令行工具能够正常接收到主题信息，而且MQTTX也是能正常接收到消息

说明MQTT服务器是正常的

2服务器抓包查看是否有收到主题消息

由于MQTT消息没有加密，wireshark并且可以完整解析出整一个报文协议，因此监听是否有收到发布的消息

定位到原因：JAVA发送端采用MQTT3的版本（1.2.0）长时间发布消息会出现发送消息失败的问题，目前采用1.4.1版本重新做测试






基于RabbitMQ的MQTT插件搭建MQTT服务，使用MQTTX进行收发测试

本文 基于Rabbit MQ的mqtt插件，针对MQTT进行简单的测试。 包括MQTT协议的介绍，rabbitmq的安装、配置、开启mqtt插件及基于MQTTX进行的测试。

MQTT协议

随着5G时代的到来，连接一切正在成为现实。大量设备的接入和设备管理给网络宽带、通信协议和平台服务体系结构带来了巨大的挑战。

MQTT协议是基于发布-订阅模型的物联网消息传递协议。由于其实现简单、易于实现、支持QoS和小分组，已占据物联网协议的一半
特点如下：

  • 轻量级的和可靠的：紧凑的MQTT包，能够在严格受限的设备硬件和高延迟/低带宽网络上稳定传输
  • 更好的生态：其客户端和SDK覆盖所有语言平台，是AWS IoT Core Azure IoT Hub等顶级云厂商的物联网平台标准通信协议，是物联网的实际标准
  • 发布-订阅模型：基于发布-订阅模型。发布-订阅模型的优点是发布者和订阅者之间的解耦:不需要在订阅者和订阅者之间建立直接连接，也不需要同时在线
  • 为物联网而生：提供全面的物联网应用功能，如心跳机制、Will消息、QoS质量级别+离线消息、异步机制、主题和安全管理
  • 对负载内容屏蔽的消息传输机制。
  • QoS: 对传输消息有三种服务质量 (QoS)：
    • 最多一次，这一级别会发生消息丢失或重复，消息发布依赖于底层 TCP/IP 网络。即：<=1
    • 至多一次，这一级别会确保消息到达，但消息可能会重复。即：>=1
    • 只有一次，确保消息只有一次到达。即：=1。在一些要求比较严格的计费系统中，可以使用此级别
  • 数据传输和协议交换的最小化 (协议头部只有 2 字节)，以减少网络流量
  • 通知机制: 异常中断时通知传输双方

适用范围：在低带宽、不可靠的网络下提供基于云平台的远程设备的数据传输和监控。

rabbitmq的安装

rabbitmq的安装

基于PackageCloud yum源安装

以在centos 7.2中安装为例

配置rabbitmq yum源

在Red Hat 7 或 CentOS 7 上面 基于PackageCloud yum源安装rabbitmq

创建rabbitmq.repo 文件
vi /etc/yum.repos.d/rabbitmq.repo

##
## Zero dependency Erlang
##

[rabbitmq_erlang]
name=rabbitmq_erlang
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

[rabbitmq_erlang-source]
name=rabbitmq_erlang-source
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/SRPMS
repo_gpgcheck=1
gpgcheck=0
enabled=1
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

##
## RabbitMQ server
##

[rabbitmq_server]
name=rabbitmq_server
baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

[rabbitmq_server-source]
name=rabbitmq_server-source
baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/SRPMS
repo_gpgcheck=1
gpgcheck=0
enabled=1
gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

安装依赖

install these dependencies from standard OS repositories

yum install socat logrotate -y

yum install erlang  -y

安装rabbitmq

yum install  rabbitmq-server  -y

启动rabbitmq

#配置开机启动
chkconfig rabbitmq-server on

/sbin/service rabbitmq-server start
/sbin/service rabbitmq-server status
/sbin/service rabbitmq-server stop

开启必要的插件

# 开启管理插件
rabbitmq-plugins enable rabbitmq_management

#开启mqtt插件,也可同时开启 rabbitmq-plugins enable rabbitmq_web_mqtt
rabbitmq-plugins enable rabbitmq_mqtt

# 查看已经安装的插件,输出结果见下图
rabbitmq-plugins list

# 禁止xxx插件,如rabbitmq_mqtt
rabbitmq-plugins disable rabbitmq_mqtt

# 查看开启的插件，返回[rabbitmq_management,rabbitmq_mqtt].
more /etc/rabbitmq/enabled_plugins

配置用户

用户权限配置请参考access-control

当服务器第一次开始运行，并检测到它的数据库未初始化或已被删除，它将使用以下资源初始化一个新的数据库

默认的Virtual Host and User如下：

  • 一个名为/(斜杠)的虚拟主机，
  • 一个名为guest的用户，默认密码为guest，被授予对/虚拟主机的完全访问权。注意："guest"用户只能从本地主机连接

为了安全和能远程登录管理页面，需要删除guest用户并创建新用户，用户的标签有5种:administrator ，monitoring，policymaker，management和none ，详见rabbitmq management

#查看用户列表:
rabbitmqctl list_users --formatter=json
# 删除guest用户
rabbitmqctl delete_user guest
#增加用户
rabbitmqctl add_user "admin"  根据提示输入密码,如输入20212021
#增加vhost, 根据需要执行，默认的vhost为/
rabbitmqctl add_vhost vnode22
# 给用户赋予权限
#https://www.rabbitmq.com/access-control.html
# First ".*" for configure permission on every entity
# Second ".*" for write permission on every entity
# Third ".*" for read permission on every entity
rabbitmqctl set_permissions -p "/" "admin" ".*" ".*" ".*"
# 给用户增加管理员标签
rabbitmqctl set_user_tags admin administrator

安装验证

登录管理页面

http://172.25.11.22:15672/#/
输入用户 admin / 20212021 进行登录，首页展示如下：

测试MQTT

安装mqttx

下载mqttx, 然后直接安装，安装后打开如下：
mqttx下载地址

配置exchanges

新增加一个exchange，类型是: topic

在mqttx中配置收发客户端

可以看到，发送到mq中的消息，订阅者可以立即收到

以上是关于MQTTX 接收不到订阅数据的排查的主要内容，如果未能解决你的问题，请参考以下文章

基于RabbitMQ的MQTT插件搭建MQTT服务，使用MQTTX进行收发测试

thinkphp接收不到ajax传递的post数据

SQL Server同步复制问题排查方法

桌面客户端性能提升，优化使用资源消耗

MQTT未接收到消息问题

手机邮箱收不到邮件