javascript - Nodejs中如何处理异步事务

Question

我的应用程序是基于Nodejs + Mongodb + amqp构建的。核心模块接收来自amqp的消息，然后将其包装到相应的消息事务中。在消息事务中，将消息信息保存到mongodb以及一些其他逻辑中。

function messageReceiverCallback(msg) {
  try {
    messageHandler(decode(msg));
  } catch (ex) {
  } 
}

function messageHandler(msg) {
  function defaultTransaction() {
  }
  var dispatch = {
    'default': defaultTransaction
  }

  dispatch[MSG.TYPE1] = Msg1Transaction;
  // other message transaction here

  return (dispatch[msg.type] || dispatch['default'])(msg);
}

function Msg1Transaction(msg) {
   // some mongodb operation here...
}

但是，当amqp队列中存在多个具有不同消息字段值的相同类型消息时，则会调用messageReceiverCallback，并执行Msg1Transaction 也可以被多次调用。结果，保存在 mongodb 中的数据将不正确，因为我忽略了 mongodb 上的异步操作。 这种情况我该如何处理？

我有一个想法，也许添加一个用 Promise 包装的新事务队列。因此事务可以异步处理。但我不知道怎么执行呢？有人可以帮助我或其他更好的解决方案来解决它吗？

Answer 1

我不熟悉amqp，但如果我理解你的问题，你希望messageHandler在mongo操作完成时返回。在这种情况下，正确的逻辑是:

function messageReceiverCallback(msg) {
   try {
     messageHandler(decode(msg));
    } catch (ex) { ... } 
}

function messageHandler(msg) {
   Msg1Transaction(msg, callbackAfterTransaction);
}

function callbackAfterTransaction(data){
   // update transaction info
}

function Msg1Transaction(msg, callback) {
 // some mongodb operation here...
 Collection.find ({}, 
    function(err, data)
    {
       ...
       callback(data);
    }
}