一:RocketMQ架构模型

RocketMQ知识总结

二:引入消息队列RocketMQ需要解决的问题

(1)顺序性:我们需要处理的仅仅是将同一语义下的消息放入同一个队列(比如这里是同一个订单),那我们就可以使用 Hash 取模法来保证同一个订单在同一个队列中就行了。

  1. 重复性:

1.redis的key-value天然支持幂等性

2.数据库主键唯一

 

  1. 事务性:事务消息加上事务反查机制

RocketMQ知识总结

(4)可靠性:

对于消费者而言:重试

对于队列而言:采用持久化机制,同步刷盘或者异步刷盘。

对于生产者而言:发送消息采用同步或者异步的方式获取返回来的处理结果

RocketMQ知识总结

相关文章:

  • 2021-12-28
  • 2021-12-02
  • 2022-02-17
猜你喜欢
  • 2022-01-19
  • 2021-12-04
  • 2021-09-04
  • 2022-01-18
  • 2021-08-04
相关资源
相似解决方案