我试图在C#和C ++之间进行交流,并获得不同程度的成功。

我可以使用回复/请求在两者之间发送消息,但是我收到的双打不正确。

为了调试和理解,我目前正在运行以下命令:

Clrzmq 3.0 rc1,Google ProtocolBuffer 2.5,Protobuf-csharp-port-2.4,ZeroMQ-3.2.3

.Proto

package InternalComm;

message Point
{
    optional double x = 1;
    optional double y = 2;
    optional string label = 3;
}


server.cpp(相关部分)

while (true) {
    zmq::message_t request;

    // Wait for next request from client
    socket.recv (&request);
    zmq::message_t reply (request.size());
    memcpy ((void*)reply.data(), request.data(), request.size());
    socket.send(reply);
}


client.cs(相关部分)

public static Point ProtobufPoint(Point point)
    {
        Point rtn = new Point(0,0);
        using (var context = ZmqContext.Create())
        {
            using (ZmqSocket requester = context.CreateSocket(SocketType.REQ))
            {
                requester.Connect("tcp://localhost:5555");
                var p = InternalComm.Point.CreateBuilder().SetX(point.X).SetY(point.Y).Build().ToByteArray();

                requester.Send(p);

                string reply = requester.Receive(Encoding.ASCII);
                Console.WriteLine("Input: {0}", point);

                byte[] bytes = System.Text.Encoding.ASCII.GetBytes(reply);
                var message = InternalComm.Point.ParseFrom(bytes);
                rtn.X = message.X;
                rtn.Y = message.Y;

                Console.WriteLine("Output: {0}", rtn);
            }
        }
        return rtn;
    }


在C#方面,Point是一个非常简单的结构。只是x和y属性。

这是运行上述代码后从单元测试中得到的结果。


  输入(1.31616874365468,4.55516872325469)
  
  输出(0.000473917985115791,4.55516872323627)
  
  
  输入(274.120398471829,274.128936418736)
  
  输出(274.077917334613,274.128936049925)
  
  输入(150.123798461987,2.345E-12)
  
  输出(145.976459594794,1.11014954927532E-13)
  
  输入(150,0)
  
  输出(145.96875,0)


我以为问题是我的protobuf代码不正确(可疑的是,这是Skeet的错误)。我还假设server.cpp对消息不执行任何操作,而是按原样返回。

有什么想法吗?

最佳答案

requestor.Receive(Encoding.ASCII)调用旨在接收字符串,而不是字节块。您正在要求ZmqSocket实例以ASCII字符串形式返回消息,这很可能导致对内容的修改。如果要发送字节数组,请接收字节数组。

尝试这个:

int readSize;
byte[] reply = requester.Receive(null, out readSize);
var message = InternalComm.Point.ParseFrom(reply);


readSize变量将包含接收到的块中有效字节的实际数量,该数量可能与reply数组的大小有所不同,因此您可能需要切分该数组以使其适合于ProtoBuf。

09-25 20:19