节点 js 示例代码中的发布者订阅者模式不适用于 setinterval

Question

我正在尝试实现 pub/sub，如下所示

publisher.js

var zmq = require('zmq');
var pub = zmq.socket('pub');

pub.bindSync('tcp://127.0.0.1:5555');

pub.send('pub msg');
/*
setInterval(function(){
    console.log("sending message")

},500);*/

subscriber.js

var zmq = require('zmq');
var sub = zmq.socket('sub');
sub.connect('tcp://127.0.0.1:5555');

sub.subscribe('');  //herein lies the question

sub.on('message',function(msg){
    console.log('Received msg:',msg);
})

上面的订阅者只有在setInterval里面pub.send('pub msg');才会收到消息不清楚我的理解

我不想使用 setInterval，而是我必须在消息到达后立即发送

请说出我如何使用 pub/sub 来做到这一点，只是我想我缺少一些基本的理解，请帮助

在 nodejs 代码中，我正在尝试使用一条路线

 router.post('/putMsgIn0MQ', function (req, res, next) {
     pushData(JSON.stringify(req.body))
 })

var pushData = function(dataToPush) {
    var zmqSocket = zmq.socket('pub')
        var zmqPortPart = 'tcp://127.0.0.1:5555'
        zmqSocket.bind(zmqPortPart);
        zmqSocket.send(dataToPush);

}

订户

var sub = zmq.socket('sub');
                sub.connect('tcp://127.0.0.1:5555');
                sub.subscribe('');  //herein lies the question
                console.log('Received msg:');
                sub.on('message',function(msg){
                        console.log('Received msg:');
                        console.log(msg.toString())
                        var jsonPayload = msg.toString();
                        processData(jsonPayload, zmqPortObj.name);
                })

Answer 1

基于此代码，来自他们的文档：

// pubber.js 
var zmq = require('zmq')
   , sock = zmq.socket('pub');

  sock.bindSync('tcp://127.0.0.1:3000');
 console.log('Publisher bound to port 3000');

setInterval(function(){
  console.log('sending a multipart message envelope');
  sock.send(['kitty cats', 'meow!']);
}, 500);

看来setInterval只是一个效用函数:)

是什么阻止了您手动启动它？

所以比如假想控制器：

exports.animals= {
   getCat: function (request, response) {

   var animal = request.payload.catStuff;

   //process the animal object
  //and manually fire the message like:


sock.send(['kitty cats', 'meow!']);

...

节点 js 示例代码中的发布者订阅者模式不适用于 setinterval

publisher subscribber pattern in nodejs sampel code is not woring with out setinterval

node.js

setinterval

zeromq

publish-subscribe