消息队列体系结构(客户端到Web服务器到工作者和后面)

当HTTP请求进入时,Web服务器通过RabbitMQ发送消息.后端在未来的某个时刻选择了它.同时,Web服务器通过HTTP请求发回响应,说明正在发生的事情,稍后将通知用户.

如果你使用快递,它看起来像这样：

var router = express.Router();
router.post("/",postJob);

function postJob(req,res,next){
  req.session.inProgress = true;

  var msg = {
    job: "do some work"
  };

  jobSender.sendJobRequest(msg,function(err){
    if (err) { return next(err); }
    res.render("some-response");
  });
}

这段代码做了很多假设,比如jobSender是某种封装对象,带有一个通过RabbitMQ发送消息的方法.我相信你可以根据你已经说过的内容填写发送邮件的详细信息.

重要的是,HTTP请求处理程序通过RabbitMQ发送消息,然后将HTTP响应发送回Web浏览器.

此时,浏览器可以做任何需要做的事情.

在后端,当其他服务完成它的工作时,它需要做以下两件事之一：

1)在某处更新共享数据库,以便您的Web服务器知道已完成的工作(并且可以读取状态)

要么

2)通过rabbitmq将消息发送回Web服务器

由于各种原因,选项#1可能并不总是一个好的选择.从你的问题来看,无论如何你都想要选项#2.

你需要第二个队列 – 一个是Web服务器正在监听的队列.当Web服务器从此队列接收消息时,它将使用接收的状态更新其自己的数据库.

此状态可能是“完成”或“正在进行”或“错误”或您认为合适的其他内容.

例如,如果您有“作业状态”消息,则可能有一个名为“JobStatusReceiver”的抽象来接收状态消息.

像这样的简单模块可以从作业状态队列接收消息,并使用状态更新本地数据库

var JobStatusReceiver = require("./jobStatusReceiver");
var someDataObject = require("someDataObject");

var jobStatus = {

  listen: function(){
    var receiver = new JobStatusReceiver();
    receiver.receive(function(statusMessage){

      someDataObject.status = statusMessage.status;
      someDataObject.data = statusMessage.data;


      someDataObject.save();
    });
  }

};

module.exports = jobStatus;

请注意,这可能发生在Web服务器中,但它不是HTTP请求的一部分.消息通过RabbitMQ与JobStatusReceiver一起传入,而不是HTTP请求的一部分.

someDataObject对象很可能是来自yoru数据库的对象,因此可以将其保存回数据库.

最后,您需要使用数据通知用户已完成操作的部分可以通过多种方式进行.

一般来说,每隔几秒就可以很容易地在Web服务器上对HTTP API进行AJAX调用,以查找有效的响应.

在浏览器方面,这可能很简单：

var timer = setInterval(function(){

  $.ajax({
    url: "/api/check-status",success: function(data){
      if (data.complete){
        clearInterval(timer);
        doSomeOtherWork(data);
      }
    })
  });

});

再次在Express应用程序中,处理“/ api / check-status”,您将使用相同的“someDataObject”模型来检查状态：

var someDataObject = require("someDataObject");

var router = new express.Router();
router.get("/",checkStatus);

function checkStatus(req,next){

  someDataObject.load(function(err,someData){
    if (err) { return next(err); }

    res.json({
      complete: (someData.status === "complete"),data: someData.data
    });

  });

}

这应该有希望让你走上正确的道路.当然,我遗漏了很多细节,但希望你能够填补缺失的部分.

…

P.S.：在我的RabbitMQ 4 Devs培训课程中,除了浏览器检查计时器的状态更新外,我将覆盖所有这些内容.这是一个完整的包,可以使用RabbitMQ和Node.js启动和运行