0
我有一个类连接是一种Zmq Request/Reply上的包装。使用这个我会接受来自客户端的请求并将回复发送回去。用于实现这两个功能是: -需要一种方法来同步两个操作
void Connection::receiveMessage()
{
//recv messages over zmq and send it to back-end.
}
void Connection::sendMessage()
{
//This method would be called by back-end and it will send the message over Zmq.
}
问题面临: - 作为ZMQ请求/应答是同步操作,我必须发送应答(我会得到来自后端在响应于recvd消息)在收到新消息之前。在某些情况下,Connection类在后端对象上执行一个方法并返回。当后端准备好数据时,它会调用sendMessage。但在这里我再次尝试接收消息而不发送先前的响应。
任何人都可以请帮助我确保连接不会进入recv,直到它发送回应以前的消息。 在此先感谢。