如何在rabbitmq队列上使用同步消息？

Question

我有一个 node.js 函数需要为我的应用程序上的每个订单执行。在此函数中，我的应用程序从 oracle 数据库中获取订单号，处理订单，然后将 + 1 添加到数据库上的该数字（需要是函数的最后一件事，因为订单可能会失败，因此不会使用该数字)。

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

所以我使用 rabbit 来尝试解决这种情况，因为它是一个队列。似乎流程按应有的顺序完成，但是第二个流程不会等待第一个流程完成（ack）开始，所以最后我遇到了多次使用相同订单号的相同问题.

我是否可以将队列配置为一次处理一条消息？只有在进程 n 被确认后才启动进程 n+1？

这对我来说是救命稻草！

Answer 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。