我使用的是ZeroMQ 3.2.3和CZmq 1.4.1。我尝试了一下"Hello world“示例。当使用10个并发客户端时,该示例(https://github.com/imatix/zguide/tree/master/examples/C)允许我在本地主机(Ubuntu13.04)上的英特尔i7 (8 GB内存,总共8个内核)上每秒最多交换12500条消息。
我读到ZeroMQ可以处理更多。我是不是做错了什么,或者错过了什么?
以下是示例代码:
// Hello World server
#include <zmq.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
int main (void)
{
// Socket to talk to clients
void *context = zmq_ctx_new ();
void *responder = zmq_socket (context, ZMQ_REP);
int rc = zmq_bind (responder, "tcp://*:5555");
assert (rc == 0);
while (1) {
char buffer [10];
zmq_recv (responder, buffer, 10, 0);
//printf ("Received Hello\n");
zmq_send (responder, "World", 5, 0);
//usleep (1); // Do some 'work'
}
return 0;
}
// Hello World client
#include <zmq.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
int main (void)
{
printf ("Connecting to hello world server...\n");
void *context = zmq_ctx_new ();
void *requester = zmq_socket (context, ZMQ_REQ);
zmq_connect (requester, "tcp://localhost:5555");
int request_nbr;
for (request_nbr = 0; request_nbr != 100000; request_nbr++) {
char buffer [10];
// printf ("Sending Hello %d...\n", request_nbr);
zmq_send (requester, "Hello", 5, 0);
zmq_recv (requester, buffer, 10, 0);
// printf ("Received World %d\n", request_nbr);
}
zmq_close (requester);
zmq_ctx_destroy (context);
return 0;
}谢谢!
发布于 2013-06-12 06:03:17
你遇到的瓶颈是因为你没有异步流线化你的沟通。
尝试用异步REQ <-> REP模式替换同步ROUTER <-> DEALER模式。
这可以快得多的原因是,如果客户端可以发送连续的请求,而不必在两者之间等待每个响应。处理单个请求/回复的开销分为两部分:
当您运行大量连续请求时,异步模式有助于大大降低(2)的成本。
发布于 2014-04-27 09:55:41
对于那些对寻找nanoMsg风格的REP-REQ感兴趣的人,这里有一个关于如何结合zeroMQ路由器套接字和NanoMSG REP-REQ的很好的片段:
结合ZeroMQ和NanoMsg服务Web请求:http://my-classes.com/2014/04/26/combining-zeromq-and-nanomsg-for-serving-web-requests/
https://stackoverflow.com/questions/17054562
复制相似问题