MQTT未接收到消息问题

根据接口文档订阅MQTT消息，没有接收到消息；

使用>

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

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

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

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

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);
}
即可验证！

第一，pom配置，我们需要引入相关jar：

第二，配置MQTT服务器基本信息，在springBoot配置文件applicationproperties中配置，添加如下：

第三，配置MQTT消息推送配置类，

第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeadersTOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。

第五，接口类测试下功能，用Postman调用sendMqttdo接口，往hello主题发送消息，用MQTTLens订阅hello主题，从下面截图，可以看出可以正常往MQTT服务发送消息了，而且可以订阅到。

在使用 MQTT 协议连接 MQTT 服务器时，可能会遇到连接失败的情况。这通常是由于以下几个原因之一：
服务器配置错误：确保您的 MQTT 服务器已经正确配置，并且已经启动。您可以检查 MQTT 服务器的配置文件，确保 MQTT 服务器的端口号、认证方式、消息格式等参数都正确。
客户端配置错误：确保您的客户端已经正确配置，并且已经启动。您可以检查 MQTT 客户端的配置文件，确保 MQTT 客户端的 URL、端口号、认证方式、消息格式等参数都正确。
网络问题：确保您的网络连接正常，并且可以访问 MQTT 服务器。如果您的网络连接不稳定或者无法访问 MQTT 服务器，可能会导致连接失败。
配置文件错误：确保您的配置文件没有错误。如果您的配置文件中有错误或者不正确的参数，可能会导致连接失败。
如果您已经确保了以上几个方面都没有问题，但是仍然无法连接到 MQTT 服务器，您可以尝试以下几个步骤：
检查 MQTT 服务器的配置文件：确保您的 MQTT 服务器的配置文件没有错误。如果您的配置文件中有错误或者不正确的参数，可能会导致连接失败。
检查 MQTT 客户端的配置文件：确保您的 MQTT 客户端的配置文件没有错误。如果您的配置文件中有错误或者不正确的参数，可能会导致连接失败。
检查网络连接：确保您的网络连接正常，并且可以访问 MQTT 服务器。如果您的网络连接不稳定或者无法访问 MQTT 服务器，可能会导致连接失败。
检查 MQTT 服务器的状态：确保您的 MQTT 服务器已经正确启动，并且可以正常工作。如果您的 MQTT 服务器出现了故障，可能会导致连接失败。
如果以上步骤都没有解决问题，您可以尝试查看 MQTT 服务器的日志，以了解更多有关连接失败的信息。同时，您也可以尝试使用其他的 MQTT 客户端或者其他的 MQTT 服务器来连接，以确保您的连接是正常的。

---