同步发送是指消息发送方发出数据后，同步等待，直到收到接收方发回响应之后才发下一个请求。

然后关于3这个环节，通常MQ存盘时都会先写入操作系统的缓存page cache中，然后再由操作系统异步的将消息写入硬盘。这个中间有个时间差，就可能会造成消息丢失。如果服务挂了，缓存中还没有来得及写入硬盘的消息就会丢失。...

RocketMQ是阿里巴巴开源的一个消息中间件，在阿里内部历经了双十一等很多高并发场景的考验，能够处理亿万级别的消息。2016年开源后捐赠给Apache，现在是Apache的一个顶级项目。在阿里内部，RocketMQ 很好地服务了集团大大小...

在消费者端，需要确保在消息拉取并消费成功之后再给Broker返回ACK，就可以保证消息不丢失了，如果这个过程中Broker一直没收到ACK，那么就可以重试。所以，在消费者的代码中，一定要在业务逻辑的最后一步return ConsumeConcurrent...

发现公司这边的消息中间件采用了aliyun的RocketMQ服务，熟悉开源的同学都知道，RocketMQ是国内最早一批捐献Apache并成功毕业的项目。架构设计参考了kafka的模式，所以如果你了解kafka的架构，对于RocketMQ就可以轻车熟路了，虽...

NameServer 是一个 Broker 与 Topic 路由的注册中心，支持 Broker 的动态注册与发现，主要功能如下：

今天我们通过一篇文章来认识一下常见消息队列RabbitMQ、RocketMQ、Kafka。

并且，索性咱就直接把这个坑填得满满的，直接盘点RocketMQ支持的11种消息类型以及背后的实现原理

RocketMQ 是阿里巴巴旗下一款开源的 MQ 框架，经历过双十一考验，由 Java 编程语言实现，有非常完整的生态系统。RocketMQ 作为一款纯 Java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息...

下图展示了生产者DefaultMQProducer 类的构造函数，包装类 DefaultMQProducerImpl 是我们这一小节的核心。