# 云消息队列 MQ #
1
关注
13454内容
聊聊 RocketMQ中 Topic，Queue，Consumer，Consumer Group的关系
本文详细解析了RocketMQ中Topic、Queue、Consumer及Consumer Group之间的关系。文中通过图表展示了Topic可包含多个Queue，Queue分布在不同Broker上；Consumer组内多个消费者共享消息；并深入探讨了集群消费与广播消费模式下Queue与Consumer的关系，以及Rebalancing机制在实例增减时如何确保负载均衡。理解这些关系有助于更好地掌握RocketMQ的工作原理，提升系统运维效率。
代码很少，却很优秀！RocketMQ的NameServer做到了！
本文深入剖析了RocketMQ的注册中心NameServer，基于RocketMQ release-5.2.0版本。NameServer作为Broker、Producer与Consumer之间的纽带，仅由少数几个类构成，却实现了高性能与轻量化。文章详细介绍了NameServer的AP设计思想、简洁的数据结构及心跳机制。AP设计避免了复杂的分布式协议，简化了网络开销；数据结构主要包括路由表、Broker信息等；心跳机制则通过定时扫描确保Broker的活跃状态。通过这些核心设计，NameServer实现了高效稳定的注册与发现功能。
一览纵山小，原来RocketMQ是这样工作的!
本文介绍了阿里巴巴开源的高性能分布式消息队列系统RocketMQ的核心组件及其作用。RocketMQ拥有四个关键组件：NameServer、Broker、Producer和Consumer。NameServer作为注册中心维护路由信息；Broker负责消息的接收、存储和转发；Producer生成消息并通过Topic与Broker关联；Consumer则订阅并处理消息。文章详细解析了各组件的功能及交互逻辑，并展示了RocketMQ在异步通信、日志收集、流处理及事件驱动架构中的典型应用场景。通过整体框架的梳理，有助于读者更好地理解和掌握RocketMQ的工作机制。
微软一面：订单超时未支付，如何自动关闭？
本文探讨了微软面试中关于订单超时自动关闭的设计题，提供了四种解决方案：定时器轮询、被动关闭、MQ延时消息及分布式超时中心。每种方案均详细阐述了实现思路、优缺点及适用场景。强调架构应基于业务需求，而非盲目追求高大上。适合不同规模的企业参考选用。
Kafka ACK机制详解！
本文深入剖析了Kafka的ACK机制，涵盖其原理、源码分析及应用场景，并探讨了acks=0、acks=1和acks=all三种级别的优缺点。文中还介绍了ISR（同步副本）的工作原理及其维护机制，帮助读者理解如何在性能与可靠性之间找到最佳平衡。适合希望深入了解Kafka消息传递机制的开发者阅读。
rabbitmq基础教程（ui，java，springamqp）
本文提供了RabbitMQ的基础教程，包括如何使用UI创建队列和交换机、Java代码操作RabbitMQ、Spring AMQP进行消息发送和接收，以及如何使用不同的交换机类型（fanout、direct、topic）进行消息路由。
Docker安装rabbitmq
如何使用Docker安装和配置RabbitMQ服务，包括拉取RabbitMQ镜像、创建容器、配置持久化和访问管理界面的步骤。
一键掌控未来！用 Uno Platform 打造跨平台 IoT 应用，轻松连接你的智能设备，让生活更智能！
本文通过具体案例介绍了如何使用微软的开源框架 Uno Platform 实现与 IoT 设备的集成。Uno Platform 支持一次编写、多平台部署，适用于 Windows、macOS、Linux、WebAssembly 及 iOS/Android。本例创建了一个控制网络 LED 灯的应用，详细说明了环境搭建、MQTT 客户端配置、主题订阅及控制指令发送等步骤。该案例展示了 Uno Platform 在 IoT 领域的潜力及其跨平台优势，未来可扩展至更多设备类型，构建智能家居系统。
评测
本项目通过Java与Spring Boot搭建Maven工程，实现基于RabbitMQ的消息收发功能，验证了其消息流传输机制。在RabbitMQ控制台进行消息轨迹跟踪，确认消息传递流程，并利用ARMS服务监控功能评估队列状态及性能。此外，通过多线程并发测试，进一步检验了RabbitMQ在高并发场景下的处理能力。
免费试用