消息队列 MQ 性能大揭秘

以下是rabbitmq官方针对RabbitMQ 3.12的性能测试报告，从报告中可以看到他测试的吞吐量是保持在万级的，延迟时间平均在25毫秒左...

Consumer

消息消费以组的模式开展，一个消费组内可以包含多个消费者，每一个消费者组可订阅多个主题，消费组之间有ff式和广播模式两种消...

NameServer

消息生产者的代码都在client模块中，相对于RocketMQ来讲，消息生产者就是客户端，也是消息的提供者。

源码分析

依赖工具 - JDK ：1.8+ - Maven - IntelliJ IDEA

消费幂等

消息队列 RocketMQ 消费者在接收到消息以后，有必要根据业务上的唯一 Key 对消息做幂等处理的必要性。

死信队列

当一条消息初次消费失败，消息队列 RocketMQ 会自动进行消息重试；达到最大重试次数后，若消费依然失败，则表明消费者在正常情...

消息重试

顺序消息的重试

负载均衡

Producer负载均衡

高可用性机制

RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的。

整体联调

通过Rest客户端请求shop-order-web和shop-pay-web完成下单和支付操作