我使用的是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;
}谢谢!
发布于 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
复制相似问题