为什么会选择使用RabbitMQ ? 有什么好处 ?
选择使用RabbitMQ是因为RabbitMQ的功能比较丰富 , 支持各种消息收发模式(简单队列模式, 工作队列模式 , 路由模式 , 直接模式 , 主题模式等) , 支持延迟队列 , 惰性队列而且天然支持集群, 保证服务的高可用, 同时性能非常不错 , 社区也比较活跃, 文档资料非常丰富
使用MQ有很多好处：
● 吞吐量提升：无需等待订阅者处理完成，响应更快速
● 故障隔离：服务没有直接调用，不存在级联失败问题
● 调用间没有阻塞，不会造成无效的资源占用
● 耦合度极低，每个服务都可以灵活插拔，可替换
● 流量削峰：不管发布事件的流量波动多大，都由Broker接收，订阅者可以按照自己的速度去
使用RabbitMQ如何保证消息不丢失 ?
消息从发送，到消费者接收，会经理多个过程 , 其中的每一步都可能导致消息丢失
针对这些问题，RabbitMQ分别给出了解决方案：
● 消息发送到交换机丢失 : 发布者确认机制publisher-confirm消息发送到交换机失败会向生产者返回ACK , 生产者通过回调接收发送结果 , 如果发送失败, 重新发送, 或者记录日志人工介入
● 消息从交换机路由到队列丢失 : 发布者回执机制publisher-return消息从交换机路由到队列失败会向生产者返回失败原因 , 生产者通过回调接收回调结果 , 如果发送失败, 重新发送, 或者记录日志人工介入
● 消息保存到队列中丢失 : MQ持久化(交
4步实现状态机驱动的MQTT客户端，快速接入OneNet (1)
本文介绍了基于状态机驱动的MQTT客户端快速接入OneNet平台的实现方法，通过4步完成模块设计。文章以开源项目`Sparrow`为基础，引入`OneNetMqtt`业务模块，采用事件驱动模型和双层状态机设计，实现设备状态管理、消息处理及定时任务等功能。模块分为三层：`OneNetManager`负责核心逻辑，`OneNetDevice`管理设备信息，`OneNetDriver`处理Socket与MQTT通信。验证结果显示设备连接、数据上报及下线功能正常，稳定性良好。该设计简化了复杂条件判断，增强了系统灵活性与可扩展性，适用于实际项目参考。文末提供源码获取方式，助力读者实践与学习。
【杂谈】-MQTT与HTTP在物联网中的比较：为什么MQTT是更好的选择
通过上述分析，可以看出MQTT在物联网应用中的确是更好的选择。其高效的通信模型、低带宽消耗、稳定的连接保持机制以及可靠的消息质量保证，使其在各种物联网场景中都能表现出色。开发者在设计和实现物联网系统时，应优先考虑采用MQTT协议，以充分发挥其在资源受限环境下的优势，提升系统的整体性能和可靠性。
