# 云消息队列 MQ #
1
关注
13491内容
RocketMQ原理—2.源码设计简单分析上
本文介绍了NameServer的启动脚本、启动时会解析哪些配置、如何初始化Netty网络服务器、如何启动Netty网络服务器，介绍了Broker启动时是如何初始化配置的、BrokerController的创建以及包含的组件、BrokerController的初始化、启动、Broker如何把自己注册到NameServer上、BrokerOuterAPI是如何发送注册请求的，介绍了NameServer如何处理Broker的注册请求、Broker如何发送定时心跳
RocketMQ原理—1.RocketMQ整体运行原理
本文详细解析了RocketMQ的整体运行原理，涵盖从生产者到消费者的全流程。首先介绍生产者发送消息的机制，包括Topic与MessageQueue的关系及写入策略；接着分析Broker如何通过CommitLog和ConsumeQueue实现消息持久化，并探讨同步与异步刷盘的优缺点。同时，讲解基于DLedger技术的主从同步原理，确保高可用性。消费者部分则重点讨论消费模式（集群 vs 广播）、拉取消息策略及负载均衡机制。网络通信层面，基于Netty的高性能架构通过多线程池分工协作提升并发能力。最后，揭示mmap与PageCache技术优化文件读写的细节，总结了RocketMQ的核心运行机制。
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持久化(交
免费试用