Windows下 Zmq v4.0.4的使用 (C++)

最近在研究Zero的使用。

我在網上找了一下，發覺大部分博客都寫得亂七八糟，又不寫明什么版本，什么系統下的，我都不知道怎么樣才能弄出個編譯過的程序來，只好自己摸索了。

我是windows下 使用vs2010的，v4.0.4的版本官方 0mq api 好像還沒加上去，我是參照老版本（v3.1)的用法來的。

使用前你要對windows下動態庫的使用有個基本了解。我的上一篇博客有講，但有點亂，有時間再改一改。

這里我是用了動態庫的隱式連接，需要動態庫的 動態庫文件".dll" , 動態庫的LIB文件".lib" , 動態庫的函數引入聲明 "zmq.h" 和 "zmq_utils.h" 中有了（實現方式應該是我上篇博客末尾中的 "預編譯開關切換類的導入導出定義");

本篇要試的是請求--回應模式：

                                                                    

 

使用步驟:

　　1.Zmq動態庫的獲取：

　　首先先下載 Zeromq 下來：http://zeromq.org/area:download，點擊”Windows installers",下完安裝。

　　

 

　　安裝完成后，在安裝目錄   C:\Program Files\ZeroMQ 4.0.4 下面，你能找到剛剛的4個文件：

　　　　　ZeroMQ 4.0.4 \bin 中的  “libzmq-v100-mt-gd-4_0_4.dll”，

　　　　　ZeroMQ 4.0.4 \lib  中的 "libzmq-v100-mt-gd-4_0_4.lib",

　　　　　ZeroMQ 4.0.4 \include  中的"zmq.h" 和 "zmq_utils.h"

　　復制到你 新建要用的 項目工作目錄當中。

　　　　這是服務端的，客戶端也一樣；

如果你的編譯器不是vs2010，需要什么版本請參考：http://zeromq.org/distro:microsoft-windows

 

　　至於Debug版在是帶調試信息的，Release版文件則小很多，兩個都可以用，你個人喜歡。　　

　　2.Zmq動態庫的使用：

　　　　 1.創建server端，win32控制台 ，空項目，把 動態庫文件復制進來。代碼如下：

//2014-4-2  programed by sixbeauty
//zeromp 通訊測試server 端
#include "zmq.h"
#include "zmq_utils.h"            //Zeromq 函數的導入在這里幫我們實現了
#include <iostream>
#pragma comment(lib,"libzmq-v100-mt-gd-4_0_4.lib")
int main()
{
    std::cout << "-------------------Zeromq REP style-----------------------" <<std::endl;
    std::cout << "---------------------Author:SanYue------------------------" <<std::endl;

    void* context=zmq_init(1);    //指定zmq 處理I/0事件的thread pool 為1
    void* z_socket=zmq_socket(context,ZMQ_REP);

    zmq_bind(z_socket,"tcp://*:5555");    // accept connections on a socket

    int recvn=1;
    while(1)    //循環工作
    {    
        //接受部分
        zmq_msg_t recv_msg;
        zmq_msg_init(&recv_msg);
        zmq_msg_recv(&recv_msg,z_socket,0);                            //0表示非阻塞
        std::cout<<"第\t"<<recvn++<<"\t次收到client信息：\t";
        std::cout<<(char*)zmq_msg_data(&recv_msg)<<std::endl;
        zmq_msg_close(&recv_msg);

        //發送部分
        zmq_msg_t send_msg;
        zmq_msg_init_size(&send_msg,6);
        memcpy(zmq_msg_data(&send_msg),"world",6);
        zmq_sendmsg(z_socket,&send_msg,0);
        zmq_msg_close(&send_msg);
    }
    zmq_close(z_socket);
    zmq_term(context);
            
    return 0;
}

 

　　　　　2.client端，一樣是 win32控制台 空項目，把 動態庫文件復制進來。代碼如下：

//2014-4-2  programed by sixbeauty
//zeromp 通訊測試client 端
#include "zmq.h"
#include "zmq_utils.h"            //Zeromq 函數的導入在這里幫我們實現了
#include <iostream>
#pragma comment(lib,"libzmq-v100-mt-gd-4_0_4.lib")
int main()
{
    std::cout << "-------------------Zeromq REB style-----------------------" <<std::endl;
    std::cout << "---------------------Author:SanYue------------------------" <<std::endl;

    void* context=zmq_init(1);    //指定zmq 處理I/0事件的thread pool 為1
    void* z_socket=zmq_socket(context,ZMQ_REQ);

    zmq_connect(z_socket,"tcp://localhost:5555");    // accept connections on a socket

    for(int i=0;i<9;i++)    //循環工作
    {
        system("pause");    //暫停

        //發送部分
        zmq_msg_t send_msg;
        zmq_msg_init_size(&send_msg,6);
        memcpy(zmq_msg_data(&send_msg),"hello",6);
        zmq_msg_send(&send_msg,z_socket,0);
        zmq_msg_close(&send_msg);

        //接受部分
        zmq_msg_t recv_msg;
        zmq_msg_init(&recv_msg);
        zmq_msg_recv(&recv_msg,z_socket,0);                    //0表示非阻塞
        printf("收到Server端回答:\t");
        std::cout<<(char*)zmq_msg_data(&recv_msg)<<std::endl;
        zmq_msg_close(&recv_msg);
    
    
    }
    zmq_close(z_socket);
    zmq_term(context);
            
    return 0;
}

　　　　　　這是 REP/REQ 請求/回應模式的嘗試，這種模式必須同時有  recv 和 send,具體會在下一篇講。