0

我需要与两个应用程序通信，一个 C++ 中的服务器和一个 C# 客户端。

我正在尝试在服务器上使用 0MQ 和 binder C# NetMq 。我可以从客户端进行连接并将消息从客户端发送到服务器，但不能从另一个发送。客户端等待，并没有收到服务器的发送。

一些例子？

服务器：

try
{
zmq::context_t context (1);
zmq::socket_t socket(context, ZMQ_PAIR);
socket.bind ("tcp://*:5556");
zmq::message_t request;
// just once
for(;;)
{
    zmq::message_t request;
    socket.recv (&request);
    std::cout << "Received" << std::endl;   
    std::string msg_str(static_cast<char*>(request.data()), request.size());    
    std::cout << msg_str << std::endl;

    zmq::message_t reply (5);
    memcpy (reply.data (), "Hello", 5);
    boost::this_thread::sleep_for(boost::chrono::milliseconds(2000));
    socket.send(reply);
}

客户：

 using (var requestSocket = new RequestSocket(">tcp://192.168.70.150:5556"))
 {
     Console.WriteLine("requestSocket : Sending 'Hello'");
     requestSocket.SendFrame("Hello");

     var message = requestSocket.ReceiveFrameString();

    Console.WriteLine(message);

  }

这是我尝试实现然后扩展的发送和响应的简单示例。

4

1 回答 1

1

代码问题：

  • ZeroMQ 中的 PAIR 套接字用于与 inproc 传输进行线程间通信，您不应将它们与 tcp 一起使用
  • 在.Net 端，您使用的是与 PAIR 不兼容的 REQ 套接字

切换到 C++ 上的 ZMQ_REP 套接字应该可以解决您的问题。这是关于套接字类型的详细文档，ZMQ 指南对基于这些套接字的通信模式有很好的描述。

于 2016-09-07T08:57:43.170 回答