ZeroMQ例項-使用ZMQ(ZeroMQ)進行區域網內網路通訊
阿新 • • 發佈：2018-12-30
本文內容摘要：1）安裝zeromq、2）例項說明使用zmq進行網路間的訊息傳送和接收
首先在機器中安裝zmq庫
步驟如下：
1）下載zeromq的原始碼，ZeroMQ的官方網址：
注：在本文寫作時，ZMQ版本已經升級到4.1.0，不過影響沒多大
2）解壓原始檔
tar zxf zeromq-4.0.3.tar.gz
3）
3.1進入zmq目錄並進行編譯和安裝
cd zeromq-4.0.3
3.2執行配置檔案
./configure
3.3 進行編譯
make
3.4 安裝zmq
make install
4）現在開始使用zmq進行網路通訊
4.1接收端程式碼
1 //包含zmq的標頭檔案 2 #include <zmq.h> 3 #include "stdio.h" 4 5 int main(int argc, char * argv[]) 6 { 7 void * pCtx = NULL; 8 void * pSock = NULL; 9 const char * pAddr = "tcp://*:7766"; 10 11 //建立context，zmq的socket 需要在context上進行建立12 if((pCtx = zmq_ctx_new()) == NULL) 13 { 14 return 0; 15 } 16 //建立zmq socket ，socket目前有6中屬性 ，這裡使用dealer方式 17 //具體使用方式請參考zmq官方文件（zmq手冊） 18 if((pSock = zmq_socket(pCtx, ZMQ_DEALER)) == NULL) 19 { 20 zmq_ctx_destroy(pCtx); 21 return 0; 22 }23 int iRcvTimeout = 5000;// millsecond 24 //設定zmq的接收超時時間為5秒 25 if(zmq_setsockopt(pSock, ZMQ_RCVTIMEO, &iRcvTimeout, sizeof(iRcvTimeout)) < 0) 26 { 27 zmq_close(pSock); 28 zmq_ctx_destroy(pCtx); 29 return 0; 30 } 31 //繫結地址 tcp://*:7766 32 //也就是使用tcp協議進行通訊，使用網路埠 7766 33 if(zmq_bind(pSock, pAddr) < 0) 34 { 35 zmq_close(pSock); 36 zmq_ctx_destroy(pCtx); 37 return 0; 38 } 39 printf("bind at : %s\n", pAddr); 40 while(1) 41 { 42 char szMsg[1024] = {0}; 43 printf("waitting...\n"); 44 errno = 0; 45 //迴圈等待接收到來的訊息，當超過5秒沒有接到訊息時， 46 //zmq_recv函式返回錯誤資訊 ，並使用zmq_strerror函式進行錯誤定位 47 if(zmq_recv(pSock, szMsg, sizeof(szMsg), 0) < 0) 48 { 49 printf("error = %s\n", zmq_strerror(errno)); 50 continue; 51 } 52 printf("received message : %s\n", szMsg); 53 } 54 55 return 0; 56 }
4.2傳送端程式碼
1 //包含zmq的標頭檔案 2 #include <zmq.h> 3 #include "stdio.h" 4 5 int main(int argc, char * argv[]) 6 { 7 void * pCtx = NULL; 8 void * pSock = NULL; 9 //使用tcp協議進行通訊，需要連線的目標機器IP地址為192.168.1.2 10 //通訊使用的網路埠 為7766 11 const char * pAddr = "tcp://192.168.1.2:7766"; 12 13 //建立context 14 if((pCtx = zmq_ctx_new()) == NULL) 15 { 16 return 0; 17 } 18 //建立socket 19 if((pSock = zmq_socket(pCtx, ZMQ_DEALER)) == NULL) 20 { 21 zmq_ctx_destroy(pCtx); 22 return 0; 23 } 24 int iSndTimeout = 5000;// millsecond 25 //設定接收超時 26 if(zmq_setsockopt(pSock, ZMQ_RCVTIMEO, &iSndTimeout, sizeof(iSndTimeout)) < 0) 27 { 28 zmq_close(pSock); 29 zmq_ctx_destroy(pCtx); 30 return 0; 31 } 32 //連線目標IP192.168.1.2，埠7766 33 if(zmq_connect(pSock, pAddr) < 0) 34 { 35 zmq_close(pSock); 36 zmq_ctx_destroy(pCtx); 37 return 0; 38 } 39 //迴圈傳送訊息 40 while(1) 41 { 42 static int i = 0; 43 char szMsg[1024] = {0}; 44 snprintf(szMsg, sizeof(szMsg), "hello world : %3d", i++); 45 printf("Enter to send...\n"); 46 if(zmq_send(pSock, szMsg, sizeof(szMsg), 0) < 0) 47 { 48 fprintf(stderr, "send message faild\n"); 49 continue; 50 } 51 printf("send message : [%s] succeed\n", szMsg); 52 getchar(); 53 } 54 55 return 0; 56 }
5）在CentOS下編譯通過，記得要加zmq的連結庫 -lzmq
1 gcc -o recv recv.c -lzmq 2 gcc -o send send.c -lzmq
6）在機器192.168.1.2上執行recv程式，在同一個區域網的另一臺機器（同一臺機器也可以）上執行send程式，結果如下
6.1接收端
1 $ ./recv 2 bind at : tcp://*:7766 3 waitting... 4 received message : hello world : 0 5 waitting... 6 received message : hello world : 1 7 waitting... 8 received message : hello world : 2 9 waitting... 10 received message : hello world : 3 11 waitting... 12 received message : hello world : 4 13 waitting... 14 received message : hello world : 5 15 waitting...
6.2 傳送端
1 $ ./send 2 Enter to send... 3 send message : [hello world : 0] succeed 4 5 Enter to send... 6 send message : [hello world : 1] succeed 7 8 Enter to send... 9 send message : [hello world : 2] succeed 10 11 Enter to send... 12 send message : [hello world : 3] succeed 13 14 Enter to send... 15 send message : [hello world : 4] succeed 16 17 Enter to send... 18 send message : [hello world : 5] succeed
7）結束語
以上是zmq最基本的網路通訊例項，在此基礎上可以進行更復雜的設計，寫出一些網路聊天、檔案傳輸等的網路軟體。
作者：風波
mail : [email protected]