Hi,
Here is my environment: RHEL/CENTOS 7, CZMQ version 4.2.1, ZMQ version 5.2.3,
GCC version 4.8.5.
I have a classic (as in examples) setting of a client-server:
client:
for (i= 0; i< 1000; i++_ {
zstr_send(client, json_string);
zsys_debug("Sent: %d %s", strlen(json_string), json_string);
}
server:
while(!zsys_interrupted) {
zsock_t *which = (zsock_t *) zpoller_wait (poller, 500);
if (which != NULL) {
char *message = zstr_recv (which);
zsys_debug("Message: %s", message);
handle_json(message);
zstr_free (&message);
}
}
If the client sends 1000 messages, the server handles them with aplomb and all
is well. However, if the client sends 10000 messages, about 1000 are lost. The
client pauses from time to time while sending, but the server loses messages.
I undrstand that while handling json messages, there is a delay. But regardless
of that, even if this would be a simple send and receive, how can I guarantee
delivery? Is there another mechanism or pattern that I should employ? Adding
more server reading threads would help with this? Is there a way of buffering?
Thank you,
Johnny
_______________________________________________
zeromq-dev mailing list
[email protected]
https://lists.zeromq.org/mailman/listinfo/zeromq-dev
