zeromq应用学习(1)——编译zeromq的示例程序

作者：[email protected]

博客：blog.focus-linux.net      linuxfocus.blog.chinaunix.net

前段时间和crazyhadoop聊天中，他推荐了zeromq这个开源库。所以今天开始学习一下。看了一下zeromq的在线文档，感觉确实不错，准备学习一下。

我的目的是阅读zeromq的源代码，那么首先要学会去用zeromq，所以刚开始是zeromq的应用学习，然后再开始阅读其源代码。另外，为了重新拾起以前的C++，所以在学习zeromq的过程中，主要使用C++。

今天先来编译一下其示例程序吧。

首先要先安装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