4

我正在使用 node.js 示例。我已经在我的 ubuntu 12.10 机器上安装了 openpgm 和 zeromq 3.2。这是代码：

var zmq = require('zmq')
  , port = 'epgm://eth0;239.192.1.1:5555';

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

  socket.identity = 'publisher' + process.pid;

  var stocks = ['AAPL', 'GOOG', 'YHOO', 'MSFT', 'INTC'];

  socket.bind(port, function(err) {
    if (err) throw err;
    console.log('bound!');

    setInterval(function() {
      var symbol = stocks[Math.floor(Math.random()*stocks.length)]
        , value = Math.random()*1000;

      console.log(socket.identity + ': sent ' + symbol + ' ' + value);
      socket.send(symbol + ' ' + value);
    }, 1000);
  });

和另一个应用程序：

var zmq = require('zmq') ，端口 = 'epgm://eth0;239.192.1.1:5555';

var socket = zmq.socket('sub');

socket.identity = '订阅者' + process.pid;

socket.connect(端口);

socket.subscribe('AAPL'); socket.subscribe('GOOG');

console.log('已连接！');

socket.on('message', function(data) { console.log(socket.identity + ': 接收到的数据' + data.toString()); });

我不确定我是否使用了正确的多播寻址。我已经在同一台机器上尝试了这些应用程序，也在网络中的另一台机器上尝试过。我很确定我没有考虑过那部分，但我似乎在任何地方都找不到任何好的解释。但我希望这无论如何都能在同一台机器上工作。有任何想法吗？

PS：忘记解释到底发生了什么：基本上push程序只是推送所有消息而没有任何错误，而pull程序启动但没有收到任何消息。

4

2 回答 2

2

epgm 和 pgm 仅适用于 PUB/SUB。

于 2013-03-23T09:26:49.183 回答
2

不确定这是否有帮助，但我也一直在节点中试验 zmq 并进行了一些观察：

我正在使用四台机器运行：1：OS X 10.8.3 2：虚拟机中的 Ubuntu 12.10（桥接）3：Ubuntu 12.04 独立机器
4：Ubuntu 12.04 独立机器

当我在所有机器上启动相同的测试服务器时（与上面的代码没有太大区别） 机器 1：看到来自机器 3 和 4 的更新 机器 2：看到来自 1、2、3 和 4 的更新 机器 3：看到来自 1 的更新, 3, 4 机器 4：查看来自 1、3、4 的更新

所以看起来 OS X 阻止了对自己的广播。虚拟机中的 Ubuntu 12.10 得到了所有人的支持，但发送问题（可能与在虚拟机中运行有关？）而其他机器正在得到他们自己的。

我的服务器/客户端：

os = require 'os'
zmq = require 'zmq'

client = zmq.socket "sub"
server = zmq.socket "pub"

client.connect "epgm://224.0.0.1:5555", (error) ->
    if error?
        console.log "client error:", error

client.subscribe ""
client.on "message", (buffer) ->
    console.log "received ping:", buffer.toString!

server.bind "epgm://224.0.0.1:5555", (error) ->
    if error?
        console.log "server error:", error
    setInterval ( -> 
        server.send "#{os.hostname!}" 
    ), 1000

process.on "SIGINIT", ->
    client.close!
    server.close!
    process.exit!
于 2013-03-25T23:20:18.927 回答