公開用と購読用の2 つの.js
ファイルがあります。これらのファイルは、実際にはnode-nanomsg GitHub サイトに示されている例の「分割」バージョンです。書き込みと読み取りは同じです。最初に開始し、続いて. はすぐに完了しますが、 はメッセージを受信しません。pub.js
sub.js
pub.js
tcp://127.0.0.1:7789
sub.js
sub.js
pub.js
pub.js
sub.js
pub.js
var nano = require('nanomsg')
var pub = nano.socket('pub')
pub.bind('tcp://127.0.0.1:7789')
//
pub.send('Hello')
pub.close()
sub.js
var nano = require('nanomsg')
var sub = nano.socket('sub')
sub.connect('tcp://127.0.0.1:7789')
//
sub.on('data', function(buf) {
console.log(String(buf))
sub.close()
})
アップデート
pub.js
以下のように書いて最初に起動するとsub.js
通信が通ります。
var nano = require('nanomsg')
var pub = nano.socket('pub')
pub.bind('tcp://127.0.0.1:7789')
//
setTimeout(() => {
pub.send('Hello')
},2000)
//pub.close()
ただし、pub-sub パラダイムでは、パブリッシャーとサブスクライバーがお互いを認識している必要はありません。で pub-sub システムを有効にするにはどうすればよいnanomsg
ですか?