C++跨平台:ZeroMQ的简单示例
Posted CodeBowl
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了C++跨平台:ZeroMQ的简单示例相关的知识,希望对你有一定的参考价值。
前言
因为在开发中需要使用zmq来进行跨平台的进程间通信需求的开发,故此学习。
ZeroMQ是什么
ZeroMQ官网
ZeroMQ C++ 版GitHub地址
以下是它对自己的介绍:
总结一下:
ZMQ看起来像是一个嵌入式网络连接库,但实际上是一个并发框架。框架提供的套接字可以满足在多种协议之间传输原子信息,如线程间、进程间、TCP、广播等。
它的优点:
- 跨平台:能在几乎所有的操作系统上运行。
- 支持多种语言
- 有着成熟的社区维护
- 高速
本文要做的事情
使用最新的ZMQ稳定版本;
实验开始!!!!
一、获取ZeroMQ源码
https://github.com/zeromq/libzmq
二、构建ZeroMQ
有俩种方式
- 直接下载Released版:ZeroMQ Released
- 自己构建: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
参考资料
以上是关于C++跨平台:ZeroMQ的简单示例的主要内容,如果未能解决你的问题,请参考以下文章
什么是在 C++ 中获取总内核数量的跨平台代码片段? [复制]