首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >提高ZeroMQ请求/代表性能

提高ZeroMQ请求/代表性能
EN

Stack Overflow用户
提问于 2013-06-12 05:57:54
回答 2查看 2.5K关注 0票数 3

我使用的是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可以处理更多。我是不是做错了什么,或者错过了什么?

以下是示例代码:

代码语言:javascript
运行
复制
//  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;
}

谢谢!

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2013-06-12 06:03:17

你遇到的瓶颈是因为你没有异步流线化你的沟通。

尝试用异步REQ <-> REP模式替换同步ROUTER <-> DEALER模式。

这可以快得多的原因是,如果客户端可以发送连续的请求,而不必在两者之间等待每个响应。处理单个请求/回复的开销分为两部分:

  1. 通过网络发送消息的成本
  2. 在客户端和服务器上处理请求和/或回复的成本

当您运行大量连续请求时,异步模式有助于大大降低(2)的成本。

票数 5
EN

Stack Overflow用户

发布于 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/

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/17054562

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档