ZMQ安裝和使用
ZMQ 並不像是一個傳統意義上的消息隊列服務器,事實上,它也根本不是一個服務器,它更像是一個底層的網絡通訊庫,在 Socket API 之上做了一層封裝,將網絡通訊、進程通訊和線程通訊抽象為統一的 API 接口
跟 Socket 的區別是:普通的 socket 是端到端的(1:1的關系),而 ZMQ 卻是可以N:M 的關系,人們對 BSD 套接字的了解較多的是點對點的連接,點對點連接需要顯式地建立連接、銷毀連接、選擇協議(TCP/UDP)和處理錯誤等,而 ZMQ 屏蔽了這些細節,讓你的網絡編程更為簡單。ZMQ 用於 node 與 node 間的通信,node 可以是主機或者是進程。
ZMQ 提供了三個基本的通信模型,分別是“Request-Reply “,”Publisher-Subscriber“,”Parallel Pipeline”,具體內容參見http://news.cnblogs.com/n/154000/
區別:
1、zmq套接字是異步的,可以實現特定模式
2、TCP是一對一,ZeroMQ是多對多的,可以根據套接字類型實現一對多,一對一,多對一,或多對多
3、ZeroMQ傳輸消息,TCP傳輸字節
4、ZeroMQ 隱藏IO細節,ZeroMQ不在乎目的是否存在
5、ZeroMQ可以往多個節點發送數據,可以從多個節點接收數據
一、安裝
在ubuntu上安裝並測試成功,過程見下:
(1)下載最新的ZeroMQ:http://download.zeromq.org/
(2)解壓:tar -xvf zeromq-4.1.2.tar.gz
(3)編譯
./configure 提示
checking for sodium... no configure: error: Package requirements (libsodium) were not met
解決辦法,暫時先屏蔽掉這個庫:
./configure --prefix=/home/libdev/zmq --without-libsodium //紅色部分路徑可以去掉 make make install
安裝成功。
二、測試程序
server端:
#include <stdio.h> #include <unistd.h> #include <string.h> #include <assert.h> #include <zmq.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"); sleep (1); // Do some 'work' zmq_send (responder, "World", 5, 0); } return 0; }
client端:
// 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); /*通過tcp協議,5555端口,連接本機服務端*/ 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; }
編譯:注意加上動態庫
gcc hwserver_.c -o hwserver -lzmq
gcc hwclient_.c -o hwclient -lzmp
運行:出現如下錯誤
[root@localhost hwserver]# ./hwserver ./hwserver: error while loading shared libraries: libzmq.so.5: cannot open shared object file: No such file or directory
解決辦法:加上zmq.so的路徑:
sudo find ./ -depth -name "libzmq.so" -print //找出動態庫路徑 cd /etc sudo vim ld.so.conf // include /usr/local/lib //把zmq.so的路徑加進來 ldconfig //記住執行這句話
然后啟動hwserver和hwclient,執行結果如下所示:
參考:http://www.cnblogs.com/Anker/p/4706244.html