我需要构建一个实时的低延迟消息传递系统。
我读了ZeroMQ指南，因为我的需求ROUTER-DEALER模式完全匹配。我围绕它构建了系统，它工作得很好。但当我做性能测试时，我发现ZeroMQ延迟高得惊人。
libzmq版本：4.2.5

./local_lat  tcp://127.0.0.1:5555 1 1000
./remote_lat tcp://127.0.0.1:5555 1 1000

message size:       1 [B]
roundtrip count: 1000
average latency:   26.123 [us]

当消息数很高时，ZeroMQ性能非常好，但是当消息数为1时，延迟相当高。

./local_lat  tcp://127.0.0.1:5555 1 1
./remote_lat tcp://127.0.0.1:5555 1 1

message size:      1 [B]
roundtrip count:   1
average latency: 506.500 [us]

我仍然不满意，我从ZeroMQ指南中选择了PUB-SUB示例，修改为ROUTER-DEALER，添加了时间戳并再次测试。延迟也非常高。这使得ZeroMQ无法使用。我同意当消息量很高时，没有什么能击败ZeroMQ，但对于延迟非常关键的系统，即使是单个消息ZeroMQ也会失败。
注意：我还运行了PUB-SUB示例，它显示了相同的延迟数字
sender.cpp

#include <zmq.hpp>
#include <stdlib.h>
#include <unistd.h>
#include <iostream>
#include <sys/time.h>

int main () {

    //  Prepare our context and publisher
    zmq::context_t context (1);
    zmq::socket_t publisher (context, ZMQ_ROUTER);
    publisher.bind("tcp://*:5556");

    //wait for peer to connect
    //once connected store the identity to send message later
    zmq::message_t identity,m;
    publisher.recv(&identity);//identity
    publisher.recv(&m);//message
    sleep(1);//sleep to set up connections
    struct timeval timeofday;
    int i=1;//no of messages to send
    while (i) {
      zmq::message_t id,message("10101",5);
      id.copy(&identity);
        gettimeofday(&timeofday,NULL);
    publisher.send(id,ZMQ_SNDMORE);
        publisher.send(message);

    std::cout << timeofday.tv_sec << ", " << timeofday.tv_usec << std::endl;
        usleep(1);
    --i;
    }
    return 0;
}

型
reciever.cpp

#include <zmq.hpp>
#include <iostream>
#include <sys/time.h>

int main (int argc, char *argv[])
{
    zmq::context_t context (1);

      zmq::socket_t subscriber (context, ZMQ_DEALER);
       subscriber.setsockopt(ZMQ_IDENTITY,"1",1);
       subscriber.connect("tcp://localhost:5556");

    struct timeval timeofday;
    subscriber.send(" ",1);
    int update_nbr;
    int i=1;
    for (update_nbr = 0; update_nbr < i; update_nbr++) {

        zmq::message_t update;

        subscriber.recv(&update);

    gettimeofday(&timeofday,NULL);
        std::cout << timeofday.tv_sec << ", " << timeofday.tv_usec << std::endl;
    }
    return 0;
}

发送器输出

1562908600, 842072

接收机输出

1562908600, 842533

如您所见，这大约需要400 ms。
有什么办法可以减少延迟吗？