延迟消息是实际开发中一个非常有用的功能，本文第一部分从整体上介绍秒级精度延迟消息的实现思路，在第二部分结合RocketMQ的延迟消息实现，进行细致的讲解，点出关键部分的源码。第三步介绍延迟消息与消息重试的关系。Broker判断这是一个延迟消息后，将其通过临

头条的业务背景为什么选择 RocketMQRocketMQ 在头条的落地实践头条的容灾系统建设业务背景。我们也用到了 Kafka ，它的主要问题是在业务线和 Topic 繁多，其写入性能会出现明显的下降，拆分集群又会增加额外的运维负担。并且在高负载下，其故

分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题：。消息有序指的是可以按照消息的发送顺序来消费。假如生产者产生了2条消息：M1、M2，要保证这两条消息的顺序，应该怎样做？将

4.比较友好的分布式特性；

rocketmq这么复杂的东西，没有运维工具可搞不定啊。哈哈，别急，官方提供了一个WEB项目，可以查看rocketmq数据和执行一些操作。connection查询生产则和消费者的连接信息。注意consumer这一项，可以查询消息积压，这是我们最关心的。首先

项目组使用阿里RocketMQ，对同一个消费组设置不同的tag订阅关系，出现消息丢失的问题，本文从rocketmq源码研究消息发布与订阅原理，并分析导致该问题的原因。只能从源码找答案。key为topic不同的消费者启动后，依次注册订阅关系，因为tag不一样

7 月 6 日，Apache Flink Meetup 再度回归魔都，来自阿里巴巴、网易的 Flink 技术专家联合 Apache RocketMQ 社区大咖来一场 Flink 与 RocketMQ 的邂逅，看看 Apache RocketMQ × Apa

本文主要分析RocketMQ中如何保证消息有序的。RocketMQ的版本为：4.2.0 release。1 DefaultMQProducer#send：发送消息，入参中有自定义的消息队列选择器。throw new MQClientException(&q

在消息队列中，当消费者去消费消息的时候，无论是通过 pull 的方式还是 push 的方式，都可能会出现大批量的消息突刺。如果此时要处理所有消息，很可能会导致系统负载过高，影响稳定性。但其实可能后面几秒之内都没有消息投递，若直接把多余的消息丢掉则没有充分利

我是在解决分布式事务的一致性问题时了解到的RabbitMQ，当时主要是要基于RabbitMQ来实现我们分布式系统之间对有事务可靠性要求的系统间通信。提到RabbitMQ，不难想到的几个关键字：消息中间件、消息队列。当时在大学学习操作系统这门课，消息队列不难