FreeMQTT Plus: 一个新型 MQTT Broker 集群的实现
FreeMQTT Plus 是一款基于 MQTT 协议的高性能消息中间件，采用分布式架构解决单点瓶颈问题。其核心由 Nginx 负载均衡器、黑（A）节点（MQTT Broker）、白（B）节点（消息路由）和日志（L）节点组成。通过无主从设计，支持高可用性、负载均衡与灵活扩展。针对会话同步、消息路由等挑战，FreeMQTT Plus 利用 MQTT5 特性定义元命令，实现节点间高效通信，无需依赖第三方组件。适用于物联网海量设备接入与高并发场景，为未来边缘计算和多级集群部署提供坚实基础。
为什么会选择使用RabbitMQ ? 有什么好处 ?
选择使用RabbitMQ是因为RabbitMQ的功能比较丰富 , 支持各种消息收发模式(简单队列模式, 工作队列模式 , 路由模式 , 直接模式 , 主题模式等) , 支持延迟队列 , 惰性队列而且天然支持集群, 保证服务的高可用, 同时性能非常不错 , 社区也比较活跃, 文档资料非常丰富
使用MQ有很多好处：
● 吞吐量提升：无需等待订阅者处理完成，响应更快速
● 故障隔离：服务没有直接调用，不存在级联失败问题
● 调用间没有阻塞，不会造成无效的资源占用
● 耦合度极低，每个服务都可以灵活插拔，可替换
● 流量削峰：不管发布事件的流量波动多大，都由Broker接收，订阅者可以按照自己的速度去
使用RabbitMQ如何保证消息不丢失 ?
消息从发送，到消费者接收，会经理多个过程 , 其中的每一步都可能导致消息丢失
针对这些问题，RabbitMQ分别给出了解决方案：
● 消息发送到交换机丢失 : 发布者确认机制publisher-confirm消息发送到交换机失败会向生产者返回ACK , 生产者通过回调接收发送结果 , 如果发送失败, 重新发送, 或者记录日志人工介入
● 消息从交换机路由到队列丢失 : 发布者回执机制publisher-return消息从交换机路由到队列失败会向生产者返回失败原因 , 生产者通过回调接收回调结果 , 如果发送失败, 重新发送, 或者记录日志人工介入
● 消息保存到队列中丢失 : MQ持久化(交
