最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

如何在Rabbit队列上使用同步消息?

网站源码admin13浏览0评论

如何在Rabbit队列上使用同步消息?

如何在Rabbit队列上使用同步消息?

我有一个node.js函数,需要针对我的应用程序上的每个订单执行该函数。在此函数中,我的应用程序从oracle数据库获取订单号,处理订单,然后在数据库中对该订单号加+1(由于该订单可能失败,因此需要在函数中进行最后处理,因此将不使用该编号)。

如果在时间T(异步)同时处理所有在时间T收到的订单,那么相同的订单号将用于多个订单,我不希望这样。

所以我用兔子试图纠正这种情况,因为这是一个队列。似乎进程按应有的顺序完成,但是第二个进程不等待第一个完成(确认),所以最后我遇到了相同的问题,即多次使用相同的订单号。

无论如何,我是否可以将队列配置为一次处理一封邮件?仅在已确认进程n时才启动进程n + 1?

这对我来说将是救生员!

回答如下:

如果问题是避免重复的订单号,则在插入表中以生成订单号时,请使用Oracle序列或使用标识列:

CREATE TABLE mytab (
       id NUMBER GENERATED BY DEFAULT ON NULL AS IDENTITY(START WITH 1),
       data VARCHAR2(20));
INSERT INTO mytab (data) VALUES ('abc');
INSERT INTO mytab (data) VALUES ('def');
SELECT * FROM mytab;

这将给:

        ID DATA
---------- --------------------
         1 abc
         2 def

如果问题是您希望顺序处理订单,那么在上一个订单完成之前,请勿从队列中提取订单。这将限制您的吞吐量,因此您需要了解您的要求并做出一些体系结构决策。

总的来说,Oracle Advanced Queuing会很合适。参见node-oracledb documentation on AQ。

发布评论

评论列表(0)

  1. 暂无评论