1

ZeroMQ 提供了一种零复制技术，尽可能避免网络复制数据。但是它似乎不起作用（用 ZeroMQ v4.1.5 测试过）。

这是服务器代码：

void CustomCleanup(void *data, void *hint)
{
  cout << "free1" << endl;
  delete static_cast<std::string*>(hint);
}

void my_free (void *data, void *hint)
{
    cout << "free2" << endl;
    free (data);
}

int main()
{
    //Allocate a string and zero copy it to client
    std::string* messageString = new string("ABCDEFG");
    cout << messageString->c_str() << endl;

    zmq::context_t context (1);
    zmq::socket_t socket (context, ZMQ_PUSH);
    socket.bind ("tcp://*:5555");

    zmq_msg_t msg;
    zmq_msg_init_data (&msg, messageString, messageString->length(), CustomCleanup, messageString);
    zmq_send (socket, &msg, 7, 0);

    cout << messageString->c_str() << endl;

    //Malloc a data buffer and zero copy it to client
    void *data = malloc (6);
    assert (data);
    memcpy (data, "ABCDEF", 6);
    zmq_msg_t msg2;
    int rc = zmq_msg_init_data (&msg2, data, 6, my_free, NULL); assert (rc == 0);

    zmq_send (socket, &msg2, 6, 0);
}

这是客户端代码：

int main()
{
    zmq::context_t context (1);
    zmq::socket_t socket (context, ZMQ_PULL);
    socket.connect ("tcp://127.0.0.1:5555");

    zmq::message_t message;
    socket.recv(&message);
}

在调用每个zmq_msg_init_data之后，应该调用释放器 CustomCleanup和my_free来释放分配的内存，但在我的情况下，这不会发生。为什么？

注意：在服务器示例中，我同时使用了 new/malloc 以及字符串和 void 指针来帮助查明潜在故障，但在这两种情况下都不起作用。

4

0 回答 0