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') , port = '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: 正確に何が起こるかを説明するのを忘れました: 基本的に、プッシュ プログラムはエラーなしですべてのメッセージをプッシュし、プル プログラムは開始しますが、メッセージを受け取りません。

4

2 に答える 2

2

これが役立つかどうかはわかりませんが、ノードでも zmq を試してみて、いくつかの観察を行いました。

4 台のマシンを使用して実行しています: 1: OS X 10.8.3 2: VM 内の 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 が自分自身へのブロードキャストをブロックしているようです。VM 内の Ubuntu 12.10 は全員のものを取得していますが、送信に問題があり (おそらく VM での実行に関連していますか?)、他のマシンは独自のものを取得しています。

私のサーバー/クライアント:

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 に答える
2

epgm と pgm は、PUB/SUB に対してのみ機能します。

于 2013-03-23T09:26:49.183 に答える