goDCE icon indicating copy to clipboard operation
goDCE copied to clipboard

Published 20 hours ago • verified publisher icon oldfritter

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

Open uestctang opened this issue 4 years ago • 5 comments

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

uestctang avatar Mar 05 '20 03:03 uestctang

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

oldfritter avatar Apr 09 '20 02:04 oldfritter

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

oldfritter avatar Apr 09 '20 03:04 oldfritter

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

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

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

liyoujun123456 avatar May 18 '20 10:05 liyoujun123456

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

dongfengyuli avatar Jun 30 '20 03:06 dongfengyuli

@dongfengyuli 代码可用，有问题可以发我邮件 [email protected]

oldfritter avatar Jun 30 '20 08:06 oldfritter