0

我对带有 node 和 zmq 的基本 pubsub 应用程序有一个奇怪的问题：

客户端正在向代理发布字符串，问题是代理只接收第一行。在网络级别，我注意到只有第一条消息被发送，然后对 .send() 函数的下一次调用无效（没有发送数据包）所以我认为问题出在客户端/发布者中。我使用了官方指南中提供的示例代码，效果很好，我的代码中唯一的区别是我使用原型来具有可重用的结构。（我没有粘贴订阅者的代码，因为不相关，并删除了一些其他不相关的东西）

客户/出版商的相关部分：

Publisher = function(zmq, pport) {
    this.logread = spawn('tail', ['-n0', '-f', '/var/log/auth.log']);
    this.publisher = zmq.socket('req');
    this.pport = pport;
};

Publisher.prototype.start = function() {
    var self = this;
    this.publisher.connect('tcp://127.0.0.1:' + this.pport);
    this.logread.stdout.on('data', function(data){
        self.publisher.send(data.toString());
        console.log(data.toString());
    });
};

经纪人的相关部分：

Broker = function(zmq, bpport, bsport) {
    this.server = zmq.socket('rep');
    this.bpport = bpport;
    this.bsport = bsport;
};

Broker.prototype.start = function() {
    this.server.on('message', function(request) {
        console.log(request.toString());
    });

    this.server.bind('tcp://127.0.0.1:' + this.bsport, function(err) {
        if (err)
            console.log(err);
    });

};
4

2 回答 2

1

您正在谈论发布订阅模式，但在您的代码中，您创建了一个req套接字，并在代理中创建了一个套接字，该rep套接字用于请求-回复模式。请求-回复模式严格需要先发送，而不是接收，请参阅api docs文档，或从指南中阅读更多信息

我想你应该pub在客户端使用套接字，sub在另一端使用套接字，但不知道你想要实现什么，也许不同的模式会更好地满足你的需求。

于 2013-06-12T08:52:09.647 回答
0

所以我会回答我的问题：服务器必须向客户端发送回复，在此之前客户端不会发送更多消息

server.send('OK');

我还认为有一种不同的方法可以实现这一目标

于 2013-06-11T22:06:50.810 回答