C++跨平台：ZeroMQ的简单示例

Posted 2022-12-11 CodeBowl

跨平台的IPC：ZeroMQ学习

• • 前言
  • ZeroMQ是什么
  • 本文要做的事情
  • 实验开始！！！！
  • • 一、获取ZeroMQ源码
    • 二、构建ZeroMQ
    • vs配置
    • 简单的Server\\Client
    • 实验结果
  • 参考资料

前言

因为在开发中需要使用zmq来进行跨平台的进程间通信需求的开发，故此学习。

ZeroMQ是什么

ZeroMQ官网
ZeroMQ C++ 版GitHub地址
以下是它对自己的介绍：
总结一下：
ZMQ看起来像是一个嵌入式网络连接库，但实际上是一个并发框架。框架提供的套接字可以满足在多种协议之间传输原子信息，如线程间、进程间、TCP、广播等。

它的优点：

1. 跨平台：能在几乎所有的操作系统上运行。
2. 支持多种语言
3. 有着成熟的社区维护
4. 高速

本文要做的事情

使用最新的ZMQ稳定版本；

实验开始！！！！

一、获取ZeroMQ源码

https://github.com/zeromq/libzmq

二、构建ZeroMQ

有俩种方式

1. 直接下载Released版：ZeroMQ Released
2. 自己构建：VS2019集成zeromq----(编译库)

我用的第一种。

vs配置

将几个文件拷贝到工程中，将俩个dll放到debug目录下。

然后在工程属性里，按照链接静态库的方式调用libzmq-v140-mt-4_3_4.lib，具体步骤不细述。

简单的Server\\Client

Hello World
服务器代码：

#include "zmq.h"
#include <stdio.h>
#include <string.h>
#include <assert.h>
#include <Windows.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];
        memset(buffer, 0x00, sizeof(buffer));
        rc = zmq_recv(responder, buffer, 10, 0);
        //buffer[rc]=0;
        printf("server Received [%s]rc[%d]\\n", buffer, rc);
        Sleep(1);          //  Do some 'work'
        zmq_send(responder, "World1234", 9, 0);
        printf("server send [world]\\n");
    
    return 0;

客户端代码

#include "zmq.h"
#include <string.h>
#include <stdio.h>
#include <iostream>


int main(void)

    printf("Connecting to hello world server\\n");
    void* context = zmq_ctx_new();
    void* client = zmq_socket(context, ZMQ_REQ);
    zmq_connect(client, "tcp://localhost:5555");

    char buffer[10] =  0 ;
    int request_nbr = 0;
    for (request_nbr = 0; request_nbr<1; request_nbr++)
    
        zmq_send(client, "hello", 9, 0);
        printf("client send [hello]\\n");
        memset(buffer, 0x00, 10);
        zmq_recv(client, buffer, 10, 0);
        printf("client recv [%s]\\n", buffer);
    
    zmq_close(client);
    zmq_ctx_destroy(context);

    return 0;

实验结果

启动server，启动client，client发送hello，server收到，并send world

参考资料

中文版zeromq相关资料
zeromq安装使用教程（最详细）