我有两个 .js 文件- pub.js 供出版和 sub.js 订阅。这些文件实际上是示例的“拆分”版本,如 node-nanomsg GitHub site . 这个 通用汽车公司 写入 tcp://127.0.0.1:7789 和 亚JS 读取相同的内容。我启动了 亚JS 先是后是 通用汽车公司 . 而 通用汽车公司 很快就完成了, 亚JS 从不接收消息。

通用汽车公司

var nano = require('nanomsg')
var pub = nano.socket('pub')
pub.bind('tcp://127.0.0.1:7789')
//
pub.send('Hello')
pub.close()

亚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()
})

更新

如果 通用汽车公司 写如下: 亚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子范式并不要求发布者和订阅者相互了解。如何启用pub子系统 nanomsg ?