Java paho mqtt 接收消息慢，如何解决？

雨点打透心脏的1/2处 2024-04-27 16:00 62阅读 0赞

### ![b578fa7f161d9d94e77e494fa6b98995.gif][] ###

> ?本文收录于[「Bug调优」][Bug]专栏，主要记录项目实战过程中的Bug之前因后果及提供真实有效的解决方案，希望能够助你一臂之力，帮你早日登顶实现财富自由?；同时，欢迎大家**关注&&收藏&&订阅**！持续更新中，up！up！up！！

### 问题描述 ###

Java 接收mqtt的消息，消息是每一秒发四条，当数据内容更改后，需要大约一分钟之后才能收到更改后的数据，用emqx观察 满订阅 显示队列满了，队列设置的1000，飞行窗口设置的32，消息流出几百万条 大部分都丢失了，怎么解决这个问题

> 如上问题有来自我自身项目开发，有的收集网站，有的来自读者，如有侵权，立马删除。

### 解决方案 ###

如下是上述问题的解决方案，仅供参考：

--------------------

在使用Java Paho MQTT客户端接收消息时，如果遇到消息接收延迟或大量消息丢失的问题，可能是由于以下几个原因造成的：

1.  **网络延迟**：网络连接问题可能导致消息传输变慢。
2.  **客户端性能**：如果客户端处理消息的速度不够快，可能会导致消息积压。
3.  **QoS设置**：MQTT消息的服务质量（QoS）设置可能影响消息的传输和确认机制。
4.  **队列溢出**：您提到的队列满了可能意味着客户端处理消息的速度跟不上消息到达的速度。
5.  **飞行窗口**：飞行窗口（flight window）设置太小可能导致消息重传效率低下。
6.  **资源限制**：客户端或服务器的资源限制可能导致性能下降。

为了解决这个问题，您可以尝试以下几个方法：

#### 优化客户端性能 ####

*  确保消息处理逻辑尽可能高效，避免耗时的操作。
 *  使用多线程或异步处理来提高消息处理速度。

#### 调整MQTT客户端设置 ####

*  增加飞行窗口大小，以提高消息传输的效率。
 *  如果消息的顺序不重要，可以考虑使用QoS 0（最多一次传输），以减少消息确认的开销。

#### 调整MQTT服务器设置 ####

*  增加队列大小，以减少消息丢失。
 *  检查服务器的配置，确保没有其他限制导致消息处理变慢。

#### 网络优化 ####

*  检查网络连接质量，确保网络稳定。
 *  如果可能，使用有更高带宽的网络连接。

#### 客户端代码示例 ####

以下是一个简单的Java Paho MQTT客户端示例，展示了如何异步处理消息：

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
    import org.eclipse.paho.client.mqttv3.MqttCallback;
    import org.eclipse.paho.client.mqttv3.MqttClient;
    import org.eclipse.paho.client.mqttv3.MqttMessage;
    import org.eclipse.paho.client.mqttv3.MqttTopic;
    
    public class MqttSubscriber implements MqttCallback {
        
        private MqttClient client;
    
        public MqttSubscriber(String serverUri, String clientId, String topic) throws Exception {
        
            // 创建MQTT客户端
            client = new MqttClient(serverUri, clientId);
            // 设置消息回调
            client.setCallback(this);
            // 订阅主题
            client.subscribe(topic);
        }
    
        @Override
        public void connectionLost(Throwable cause) {
        
            // 连接丢失时的处理逻辑
        }
    
        @Override
        public void messageArrived(String topic, MqttMessage message) throws Exception {
        
            // 异步处理接收到的消息
            new Thread(() -> {
        
                try {
        
                    // 处理消息的逻辑
                    System.out.println("Received message: " + new String(message.getPayload()));
                } catch (Exception e) {
        
                    e.printStackTrace();
                }
            }).start();
        }
    
        @Override
        public void deliveryComplete(IMqttDeliveryToken token) {
        
            // 消息确认送达的处理逻辑
        }
    
        public static void main(String[] args) throws Exception {
        
            // 创建并启动MQTT客户端
            new MqttSubscriber("tcp://your-broker:1883", "your-client-id", "your/topic");
        }
    }

请注意，这个示例使用了线程来异步处理每个消息，这可以提高消息处理的速度，但也需要您确保线程安全和资源管理。

最后，如果问题依然存在，您可能需要与MQTT服务器的管理员合作，以确定是否有服务器端的问题导致消息处理变慢。

希望能够帮到有需要的你。

>   PS：如若遇到采纳如下方案还是未解决的同学，希望不要抱怨&&急躁，毕竟影响因素众多，我写出来也是希望能够尽最大努力帮助到同类似问题的小伙伴，即把你未解决或者产生新Bug黏贴在评论区，我们大家一起来努力，一起帮你看看，可以不咯。
> 
>   若有对当前Bug有与如下提供的方法不一致，有个不情之请，希望你能把你的新思路或新方法分享到评论区，一起学习，目的就是帮助更多所需要的同学，正所谓「赠人玫瑰，手留余香」。

## ☀️写在最后 ##

ok，以上就是我这期的Bug修复内容啦，如果还想查找更多解决方案，你可以看看我专门收集Bug及提供解决方案的专栏[「Bug调优」][Bug]，都是实战中碰到的Bug，希望对你有所帮助。到此，咱们下期拜拜。

> 码字不易，如果这篇文章对你有所帮助，帮忙给bugj菌来个**一键三连(关注、点赞、收藏)** ，您的支持就是我坚持写作分享知识点传播技术的最大动力。

> 同时也推荐大家关注我的硬核公众号:[**「猿圈奇妙屋」**][Link 1] ；以第一手学习bug菌的首发干货，不仅能学习更多技术硬货，还可白嫖最新BAT大厂面试真题、4000G Pdf技术书籍、万份简历/PPT模板、技术文章Markdown文档等海量资料，你想要的我都有！

## ?关于我 ##

--------------------

![c2b7fcf358c900780204ab56182153de.gif][]

[b578fa7f161d9d94e77e494fa6b98995.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/5ffa59e0e536489e8bb04874081d0da7.gif
[Bug]: https://blog.csdn.net/weixin_43970743/category_9600553.html
[Link 1]: https://bbs.csdn.net/topics/612438251
[CSDN]: https://blog.csdn.net/weixin_43970743
[Link 2]: https://juejin.cn/user/695333581765240
[InfoQ]: https://www.infoq.cn/profile/4F581734D60B28/publish
[51CTO]: https://blog.51cto.com/u_15700751
[Link 3]: https://bbs.huaweicloud.com/community/usersnew/id_1582617489455371
[Link 4]: https://developer.aliyun.com/profile/uolxikq5k3gke
[Link 5]: https://cloud.tencent.com/developer/user/10216480/articles
[c2b7fcf358c900780204ab56182153de.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/27/4391478bea444e21b06bad5916ad94db.gif