在 ZeroMQ 中绑定订阅者套接字并连接发布者套接字会在代码运行时给出错误.为什么

Question

在此代码中，订阅者(在subscriber.cpp代码中(套接字绑定到端口5556。

它从发布者(subscriber.cpp(接收更新/消息，发布者套接字连接到 5556 的订阅者并向其发送更新/消息。

我知道惯例是.bind()出版商，而不是要求.connect()。但从理论上讲，每种插座类型都可以 .bind()或.connect() .

但是，这两个代码在运行时都会给出 zmq 错误。为什么？

这是CPP代码。

publisher.cpp

#include <iostream>
#include <zmq.hpp>
#include <zhelpers.hpp>
using namespace std;
int main () {
zmq::context_t context (1);
zmq::socket_t publisher(context, ZMQ_PUB);
publisher.connect("tcp://*:5556");
while (1) {
    zmq::message_t request (12);
    memcpy (request.data (), "Pub-1 Data", 12);
    sleep(1);
    publisher.send (request);
}
return 0;
}

---

subcriber.cpp

#include <iostream>
#include <zmq.hpp>
int main (int argc, char *argv[])
{
zmq::context_t context (1);
zmq::socket_t subscriber (context, ZMQ_SUB);
subscriber.bind("tcp://localhost:5556");
subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0); // subscribe to all messages
//  Process 10 updates
int update_nbr;
for (update_nbr = 0; update_nbr < 10 ; update_nbr++) {
    zmq::message_t update;
    subscriber.recv (&update);
    std::string updt = std::string(static_cast<char*>(update.data()), update.size());
    std::cout << "Received Update/Messages/TaskList " << update_nbr <<" : "<< updt << std::endl;
}
return 0;
}

Answer 1

不，反转.bind()/.connect()没有问题

这基本上工作正常。

然而，PUB/SUB正式原型受到所谓的晚加入综合症的影响。

如果没有如上所述的彻底调试细节，人们可能只是重复一般的经验法则：

在较新的 API 版本中，可以
添加rc = <aSocket>.setsockopt( ZMQ_CONFLATE, 1 ); assert( rc & "CONFLATE" );
添加rc = <aSocket>.setsockopt( ZMQ_IMMEDIATE, 1 ); assert( rc & "IMMEDIATE" );
等等，
所有这些都是为了更好地调整上下文实例 + 套接字实例属性，从而最大限度地减少后期加入综合征的影响。

Answer 2

反向 bind((/connect(( 没有问题。当我更改行时，代码正在工作 - 订阅者.bind("tcp://localhost:5556"(;自subscriber.bind(">tcp://：5556"(;和publisher.connect("tcp://：5556"(;自publisher.connect("tcp://localhost:5556"(;