c++ - 如何在 C++ 和 ZMQ 中正确使用多线程

Question

我正在用 C++ 在核心模块之间传递一些消息，它必须与 Python 模块和图形接口(interface)进行通信

我正在按照以下方式使用 ZMQ 进行消息传递:

int main()
{
    context_t context(1);
    socket_t publisher(context, ZMQ_PUB);
    publisher.bind("tcp://127.0.0.1:50000");
//This sockets takes charge of the python publishing
    socket_t send_py(context, ZMQ_SUB);
    send_py.bind("tcp://127.0.0.1:5557");
    socket_t receive_py(context, ZMQ_SUB);
    receive_py.connect("tcp://127.0.0.1:5558");
    receive_py.setsockopt(ZMQ_SUBSCRIBE, NULL, 0);
    zmq::message_t control_signal(sizeof(float));
    zmq::message_t control_signal_second(sizeof(float));
    cout<<"flag"<<endl;
    publisher.send(control_signal);
    cout<<"flag_1"<<endl;
    send_py.send(control_signal_second);
    cout<<"flag_2"<<endl

}

我已经对这些地址进行了研究，而且我确定这些端口是打开的。

代码编译，但我得到以下输出:

flag
flag_1
terminate called after throwing an instance of 'zmq::error_t'
  what():  Operation not supported
Aborted (core dumped)

正在正确发布其中之一，但没有让 send_pyu.send 工作。

非常感谢

Answer 1

看来您已将 send_py 定义为订阅者:

socket_t send_py(context, ZMQ_SUB);
send_py.bind("tcp://127.0.0.1:5557");

..但您正试图在其上发送数据，这是无效且不受支持的；订阅者接收，他们不发送数据。

send_py.send(control_signal_second);

如果您需要发送数据，请使用 PUB、PUSH 或其他一些套接字类型，但 SUB 不能与 发送();它将抛出 Operation Not Supported。