消息队列 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完成下单和支付操作

支付业务

创建支付订单

下单业务

下单基本流程

环境搭建

数据库、项目初始化、Mybatis逆向工程使用。

技术分析

技术选型：- SpringBoot- Dubbo- Zookeeper- RocketMQ- Mysql

案例介绍

模拟电商网站购物场景中的【下单】和【支付】业务

消息发送样例

导入MQ客户端依赖

集群监控平台搭建

`RocketMQ`有一个对其扩展的开源项目[incubator-rocketmq-externals]，这个项目中有一个子模块叫`rocketmq-console`，这个便是...

mqadmin管理工具

进入RocketMQ安装位置，在bin目录下执行./mqadmin {command} {args}

双主双从集群搭建

消息高可用采用2m-2s（同步双写）方式

RocketMQ集群搭建

* Producer：消息的发送者；举例：发信者 * Consumer：消息接收者；举例：收信者