RocketMQ订单支付场景

文章目录

时序图实战实现的部分逻辑 生产消息使用多线程优化 消费消息订单服务的消费逻辑消费的幂等性处理

时序图

实战实现的部分逻辑

生产消息

创建临时表，以订单id为key存储消息，接收到成功的回调，删除对应记录

sendMessage

使用多线程优化

注入线程池对象 开启线程

消费消息

订单服务的消费逻辑

消费的幂等性处理

回退库存 借助于消费日志记录表 如果操作失败，在catch块记录异常日志。