ZeroMQ初步学习

川长思鸟来 2022-08-07 11:40 213阅读 0赞

今天先来编译一下ZeroMQ的示例程序。

首先要先安装zeromq，使用默认的选项./configure, make, make install。

然后是zeromq的server的示例代码

1.  \#include <zmq.hpp>  
    
2.  \#include <string>  
    
3.  \#include <iostream>  
    
4.  \#include <unistd.h>  
    
5.    
    
6.  int main () \{   
    
7.      // Prepare our context and socket  
    
8.      zmq::context\_t context (1);  
    
9.      zmq::socket\_t socket (context, ZMQ\_REP);  
    
10.     socket.bind ("tcp://\*:5555");  
    
11.   
    
12.     while (true) \{   
    
13.         zmq::message\_t request;  
    
14.   
    
15.         // Wait for next request from client  
    
16.         socket.recv (&request);  
    
17.         std::cout << "Received Hello" << std::endl;  
    
18.   
    
19.         // Do some 'work'  
    
20.         sleep (1);  
    
21.   
    
22.         // Send reply back to client  
    
23.         zmq::message\_t reply (5);  
    
24.         memcpy ((void \*) reply.data (), "World", 5);  
    
25.         socket.send (reply);  
    
26.     \}  
    
27.     return 0;  
    
28. \}

编译：

1.  g\+\+ \-g \-Wall \-fPIC \-I../../include \-I../../utils \-shared \-c server.cpp \-o server.o  
    
2.  cc \-L../../lib \-g \-lstdc\+\+ \-lzmq \-o server server.o

在编译的时候，如果找不到zmq库，别忘了把安装路径加入到/etc/ld.so.conf中，并执行ldconfig。

下面是client的示例程序

1.  //  
    
2.  // Hello World client  
    
3.  // Connects REQ socket to tcp://localhost:5555  
    
4.  // Sends "Hello" to server, expects "World" back  
    
5.  //  
    
6.  \#include <zmq.h>  
    
7.  \#include <string.h>  
    
8.  \#include <stdio.h>  
    
9.  \#include <unistd.h>  
    
10.   
    
11. int main (void)  
    
12. \{   
    
13.     void \*context = zmq\_init (1);  
    
14.   
    
15.     // Socket to talk to server  
    
16.     printf ("Connecting to hello world server…\\n");  
    
17.     void \*requester = zmq\_socket (context, ZMQ\_REQ);  
    
18.     zmq\_connect (requester, "tcp://localhost:5555");  
    
19.   
    
20.     int request\_nbr;  
    
21.     for (request\_nbr = 0; request\_nbr != 10; request\_nbr\+\+) \{   
    
22.         zmq\_msg\_t request;  
    
23.         zmq\_msg\_init\_size (&request, 5);  
    
24.         memcpy (zmq\_msg\_data (&request), "Hello", 5);  
    
25.         printf ("Sending Hello %d…\\n", request\_nbr);  
    
26.         zmq\_send (requester, &request, 0);  
    
27.         zmq\_msg\_close (&request);  
    
28.   
    
29.         zmq\_msg\_t reply;  
    
30.         zmq\_msg\_init (&reply);  
    
31.         zmq\_recv (requester, &reply, 0);  
    
32.         printf ("Received World %d\\n", request\_nbr);  
    
33.         zmq\_msg\_close (&reply);  
    
34.     \}  
    
35.     zmq\_close (requester);  
    
36.     zmq\_term (context);  
    
37.     return 0;  
    
38. \}

编译：

1.  g\+\+ \-g \-Wall \-fPIC \-I../../include \-I../../utils \-shared \-c client.cpp \-o client.o  
    
2.  cc \-L../../lib \-g \-lstdc\+\+ \-lzmq \-o client client.o

下面运行一下：

1.  \[xxx@xxx\-vm\-fc13 client\]$ ./client  
    
2.  Connecting to hello world server…  
    
3.  Sending Hello 0…  
    
4.  Received World 0  
    
5.  Sending Hello 1…  
    
6.  Received World 1  
    
7.  Sending Hello 2…  
    
8.  Received World 2  
    
9.  Sending Hello 3…  
    
10. Received World 3  
    
11. Sending Hello 4…  
    
12. Received World 4  
    
13. Sending Hello 5…  
    
14. ^C  
    
15. \[xxx@xxx\-vm\-fc13 client\]$

1.  \[xxx@xxx\-vm\-fc13 server\]$ ./server  
    
2.  Received Hello  
    
3.  Received Hello  
    
4.  Received Hello  
    
5.  Received Hello  
    
6.  Received Hello  
    
7.  Received Hello  
    
8.  ^C  
    
9.  \[xxx@xxx\-vm\-fc13 server\]$

虽然使用的是示例程序，但是从代码上看，使用zeromq确实比直接使用socket要简单方便的多。更何况据说还高效。

今天只是简单的试用zeromq，以后就慢慢开始深入了。

参考： [http://zguide.zeromq.org/page:all][http_zguide.zeromq.org_page_all]

[http_zguide.zeromq.org_page_all]: http://zguide.zeromq.org/page:all