我正在尝试实现进程间通信。
模型: Part A -> 向 Part B发送消息。
我已经使用ZMQ
教程中的客户端-服务器示例(代码附在下面)实现了这一点,但面临进程被“锁定”的问题。
实施这种模型的最佳实践是什么?
它不是经典的“客户端-服务器”。实际上只有一部分将数据发送到第二部分,第二部分使用它。
是否有发送超时消息的选项,它不会锁定进程?
任何输入/示例将不胜感激!
Server:
zmq::context_t context(1);
zmq::socket_t socket(context, ZMQ_REP);
socket.bind("tcp://*:5555");
..
socket.recv(&request); // SERVER.receives first
socket.send(reply); // SERVER.sends next to Client
.. // .analyze .recv'd data
Client:
requester = context.socket(ZMQ.REQ);
requester.connect("tcp://localhost:5555");
requester.send(str.getBytes(), 0); // CLIENT.sends
byte[] reply = requester.recv(0); // CLIENT.receives