前言
因为在开发中需要使用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)
{
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);
printf("server Received [%s]rc[%d]\n", buffer, rc);
Sleep(1);
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安装使用教程(最详细)
|