请问代码中是怎么解决消息队列冥等的问题的啊

[uestctang]

下单后通过消息队列发送到撮合，撮合是怎么判断这个订单有没有处理过

[oldfritter]

@uestctang 目前的撮合逻辑是
1.将订单写入数据库。
2.向消息队列发送消息。
3.撮合引擎收到消息后，从数据库中取出对应订单做撮合成交处理，没有成功产生成交的，压入待撮合数据的栈。
4.当撮合引擎重启时，预先加载数据库中未成交的订单入待撮合的栈，之后开始接收队列中的消息。
这应该能解释你的疑问

[oldfritter]

消息队列的幂等应该由rabbitmq解决，
不应该在业务代码中解决，不是吗

[liyoujun123456]

3.撮合引擎收到消息后，从数据库中取出对应订单做撮合成交处理

撮合引擎收到消息后，应该是从RabbitMQ中取出对应订单做撮合成交处理吧？

另外请问有整个项目的架构图吗？可以分享一下吗？

[dongfengyuli]

你好，这个项目你跑起来了吗？？能加个微信咨询一下吗？？

[oldfritter]

@dongfengyuli 代码可用，有问题可以发我邮件 leon.zcf@gmail.com