作者: | 来源:互联网 | 2023-10-12 14:16
一:RocketMQ架构模型
二:引入消息队列RocketMQ需要解决的问题
(1)顺序性:我们需要处理的仅仅是将同一语义下的消息放入同一个队列(比如这里是同一个订单),那我们就可以使用 Hash 取模法来保证同一个订单在同一个队列中就行了。
- 重复性:
1.redis的key-value天然支持幂等性
2.数据库主键唯一
- 事务性:事务消息加上事务反查机制
(4)可靠性:
对于消费者而言:重试
对于队列而言:采用持久化机制,同步刷盘或者异步刷盘。
对于生产者而言:发送消息采用同步或者异步的方式获取返回来的处理结果