如何在nodejs中为common-mq编写发送者和接收者？

Question

我对 nodejs 很陌生。我需要使用 common-mq 模块向 rabbitMQ 发送消息。我已经使用以下命令安装了这个包

npm install common-mq

我无法使用它来编写发送者和接收者。任何人都可以帮助我使用nodejs编写发送者和接收者吗？ var commonmq = require('common-mq'); var connect = commonmq.connect('amqp://localhost:5672/queue');

在此之后我该如何进行？ sender.js 如下所示

 var commonmq = require("common-mq");

 var queue = commonmq.connect('amqp://localhost:5672/queue', {    implOptions: { defaultExchangeName: '' }});

 var msg =JSON.stringify("Hello world");
 console.log("going for ready");
 queue.on('ready',function () {
 console.log("inside event");
 setTimeout(function() { queue.publish({ task: 'take out trash' }); }, 1000);
 });


 //queue.publish({ task: 'sweep floor' });


 queue.on('error',function(err){
   console.log("error is:"+err);
 });

接收器代码是这样的

 var commonmq = require("common-mq");
 var queue = commonmq.connect('amqp://localhost:5672/queue', {   implOptions: { defaultExchangeName: '' }
 });
 queue.on('message', function(message) {
   console.log('Got a new message', message);
 });
 queue.on('error',function(e){
    console.log("errrorrr ",e);
 });

没有收到任何消息。请告诉我我在哪里搞砸了？

Answer 1

设置服务后，您可以收听新消息或发送新消息。

接收者： 接收方侦听队列并根据消息执行操作：

//setup the service
var queue = commonmq.connect('amqp://localhost:5672/queue');

queue.on('message', function(message) {
  console.log('Got a new message', message);
  //do something
});
//listen eventually on other events (error, ready)

发件人： 发件人发布新消息。即使是接收器也可以做到...

//setup the service
var queue = commonmq.connect('amqp://localhost:5672/queue');
queue.publish(yourMessageAsObject);

您还可以收听一些其他事件（例如在出现错误的情况下）。只需查看npm 网站上的手册即可。