目录

一线大的MQ组件实现思路和架构设计方案

基础组件封装设计-迅速消息发送

基础组件封装设计-确认消息发送

基础组件封装设计-批量消息发送

基础组件封装设计-延迟消息发送

基础组件封装设计-顺序消息发送

基础组件封装设计-事务消息发送

消息幂等性保障-消息路由规则架构设计


一线大的MQ组件实现思路和架构设计方案

RabbitMQ基础组件

 

基础组件封装设计-迅速消息发送

不进行落库存储,不做可靠性保障

RabbitMQ基础组件

基础组件封装设计-确认消息发送

RabbitMQ基础组件

基础组件封装设计-批量消息发送

把消息放到一个集合里统一提交

RabbitMQ基础组件

基础组件封装设计-延迟消息发送

延迟插件

基础组件封装设计-顺序消息发送

1.消息投递到同一个队列,消费者只有一个(独占模式)

2.然后统一提交,所有消息的会话ID一致

3.添加消息属性:落库

4.并行进行发送给自身的延迟消息(+会话ID、SIZE)

5.数据库处理

6.定时轮询补偿机制

基础组件封装设计-事务消息发送

消息幂等性保障-消息路由规则架构设计

出现消息幂等性的原因

RabbitMQ基础组件

RabbitMQ基础组件

 

相关文章:

  • 2021-12-23
  • 2021-07-07
  • 2021-04-02
  • 2021-08-31
猜你喜欢
  • 2021-09-29
  • 2021-06-24
  • 2022-02-09
  • 2021-07-13
  • 2022-12-23
  • 2021-12-18
  • 2021-08-26
相关资源
相似解决方案