1

我正在 C++ 中的核心模块之间传递一些消息,该模块必须与 Python 模块和图形接口进行通信

我正在以下列方式使用 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 工作。

非常感谢

4

1 回答 1

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不能使用send(); 它会抛出Operation Not Supported

于 2013-08-13T20:46:04.943 回答