2

公開用と購読用の2 つの.jsファイルがあります。これらのファイルは、実際にはnode-nanomsg GitHub サイトに示されている例の「分割」バージョンです。書き込みと読み取りは同じです。最初に開始し、続いて. はすぐに完了しますが、 はメッセージを受信しません。pub.jssub.jspub.jstcp://127.0.0.1:7789sub.jssub.jspub.jspub.jssub.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ですか?

4

1 に答える 1