我正在尝试使用zeromq框架实现pub sub设计模式。这个想法是启动一个订阅者，然后启动发布者。订阅者将侦听100条消息，发布者将发布100条消息。到目前为止一切顺利......然而实际情况是，即使订阅者在发布者启动时已经启动并运行，不是所有的消息都被订阅者接收到（如果发布者将发送至少500条消息，则订阅者将拾取100条消息）。
有什么想法吗
先谢谢你了，奥默。

订阅者代码（在发布者之前启动）

int i=0;
zmq::context_t context (1);
zmq::socket_t subscriber (context, ZMQ_SUB);
subscriber.connect("tcp://localhost:5556");
subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);

for (int update_nbr = 0; update_nbr < 100; update_nbr++) 
{        
    zmq::message_t update;
    subscriber.recv(&update);
    i++;
    std::cout<<"receiving  :"<<i<<std::endl;
}

发布者代码（在订阅者之后启动）

zmq::context_t context (1);
zmq::socket_t publisher (context, ZMQ_PUB);
publisher.bind("tcp://*:5556");

int i = 0;
for (int update_nbr = 0; update_nbr < 100; update_nbr++) 
{        
    //  Send message to all subscribers
    zmq::message_t request (20);

    time_t seconds;
    seconds = time (NULL);

    char update [20]="";
    sprintf (update, "%ld", seconds);

    memcpy ((void *) request.data (), update,strlen(update));
    publisher.send(request);
    i++;
    std::cout << "sending :" << i << std::endl;

}