本文共 6602 字，大约阅读时间需要 22 分钟。

一、介绍

ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层，像框架一样的一个socket library，他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。ZMQ的明确目标是“成为标准网络协议栈的一部分，之后进入Linux内核”。现在还未看到它们的成功。但是，它无疑是极具前景的、并且是人们更加需要的“传统”BSD套接字之上的一层封装。

官网：

二、安装

1 安装必需库：

$ sudo apt-get install libtool pkg-config build-essential autoconf automake

2 编译安装加密库，ZMQ核心库，ZMQ的C和C++封装,默认安装目录：

头文件都在：usr/local/include

2-1 编译安装ZMQ使用的加密库：

$ git clone git://github.com/jedisct1/libsodium.gitcd libsodium./autogen.sh./configure && make checksudo make install sudo ldconfig cd ..

2-2 编译安装ZMQ核心库：

git clone https://github.com/zeromq/libzmq./autogen.sh./configure && make checksudo make installsudo ldconfigcd ..

由于ZMQ把核心和实现分开了。因此只装核心库是不够的。我们开发一般用C/C++。下面安装这两个语言的绑定库。其他语言参考：

2-3 编译安装ZMQ的C绑定：

git clone git://github.com/zeromq/czmq.gitcd czmq./autogen.sh./configure && make checksudo make installsudo ldconfigcd ..

之后就可以编译C绑定的ZMQ程序了：gcc-lczmq -lzmq myapp.c -o myapp

2-4 添加ZMQC++绑定

git clone https://github.com/zeromq/cppzmq.gitcd cppzmqsudo cp zmq.hpp /usr/local/include/cd ..

3 学习ZMQ。

git clone https://github.com/imatix/zguide.git

3-1 C的示例：

cd zguide/examples/C./build all

这样就编译了所有这个目录下的例子。下面运行一个客户服务端例子：

打开两个终端，都进入到zguide/examples/C

T1输入：

./hwserver

T2输入：

./hwclient

三、测试Demo

（1）server端代码：server.cpp

#include 
   
                                                                                                                                                              #include 
    
                                                                                         #include 
     
                                                                                          #include 
      
                                                                                           #include 
       
                                                                                                                                                                                                    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");                                                                           sleep (1);          //  Do some 'work'                                                                 zmq_send (responder, "World", 5, 0);                                                               }                                                                                                      return 0;                                                                                          }
       
      
     
    
   

（2）client端代码：client.cpp

#include 
   
                                                                                           #include 
    
                                                                                         #include 
     
                                                                                           #include 
      
                                                                                                                                                                                                  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 != 10; 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;                                                                                          }
      
     
    
   

(3) 编译

g++ server.cpp -o server -lzmq g++ client.cpp -o client -lzmq

四、效果：

参考资料：

转载地址：https://blog.csdn.net/huoxingrenhdh/article/details/86688142 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！