zeromq學習記錄(一)最初的簡單示例使用ZMQ_REQ ZMQ_REP

閱讀zeromq guide的一些學習記錄 

 zeromq官方例子 在VC下運行會有些跨平台的錯誤

我這里有做修改 稍后會發布出來

相關的代碼與庫 

http://download.zeromq.org/zeromq-3.2.5.zip

http://download.zeromq.org/czmq-1.4.0.zip

示例代碼

https://github.com/imatix/zguide

/**************************************************************

技術博客

http://www.cnblogs.com/itdef/

 

技術交流群

群號碼：324164944

 

歡迎c c++ windows驅動愛好者 服務器程序員溝通交流

**************************************************************/

 

zeromq是對對常用的網絡通訊的收發、轉發、訂閱、推送等模式在socket底層通訊進行封裝。

指南頁面 http://zguide.zeromq.org/page:all

首先是最簡單的一對一收發模式

socket在代碼中標記為ZMQ_REQ ZMQ_REP 

ZMQ_REQ 由客戶端使用 用來發送請求和收取服務器的回復。此種標記僅允許發送請求並緊跟接受回復的處理序列模式

ZMQ_REP 由服務器使用 用來接受請求並且發送給與客戶端的回復。此種標記僅允許接受請求並緊跟發送回復的處理序列模式

代碼如下:

// hwserver.cpp : 定義控制台應用程序的入口點。
//

#include "stdafx.h"
#include <zmq.h>
#include <string.h>

int main()
{
    void* context = zmq_ctx_new();
    void* responder = zmq_socket(context, ZMQ_REP);
    zmq_bind(responder, "tcp://*:5555");

    while (1)
    {
        zmq_msg_t request;
        zmq_msg_init(&request);
        zmq_msg_recv(&request,responder,0);
        printf("received Hello\n");
        zmq_msg_close(&request);

        Sleep(1);
        zmq_msg_t reply;
        zmq_msg_init_size(&reply, 5);
        memcpy(zmq_msg_data(&reply), "World", 5);
        zmq_msg_send(&reply, responder, 0);
        zmq_msg_close(&reply);
    }
    // should not arrive here
    zmq_close(responder);
    zmq_ctx_destroy(context);
    return 0;
}

// hwclient_c.cpp : 定義控制台應用程序的入口點。
//

#include "stdafx.h"
#include <zmq.h>
#include <string.h>

int main()
{
    void* context = zmq_ctx_new();

    printf("Connecting to hello world server...\n");

    void* requester = zmq_socket(context, ZMQ_REQ);
    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;
}

關於zeromq的消息字符串需要注意以下地方

僅僅傳輸字符串的文字部分而沒有c語言用來結尾的'\0'

字符串結構如圖