0

0

C++如何调用ZeroMQ进行消息传递?(高性能通信)

冰火之心

冰火之心

发布时间:2026-02-18 17:41:02

|

695人浏览过

|

来源于php中文网

原创

应全局唯一初始化zmq::context_t context(1),再用其创建socket;req/rep须严格send→recv或recv→send;pub/sub需订阅后发消息并设超时;发结构体或protobuf需确保内存连续且预分配缓冲区;务必显式close socket和context。

c++如何调用zeromq进行消息传递?(高性能通信)

怎么初始化 ZeroMQ 上下文和套接字?

一个进程只该有一个 zmq::context_t,它管理 I/O 线程和底层资源;多建几个不仅没用,还会抢端口、耗句柄。常见错误是每次发消息都 new 一个 context,结果跑几天就 Too many open files

  • zmq::context_t context(1):1 个 I/O 线程够大多数单机场景;高吞吐服务可试 4,但别盲目堆核数,ZeroMQ 的 I/O 线程不等于 CPU 核心数
  • 套接字必须从 context 构造:zmq::socket_t sock(context, ZMQ_REQ),不能脱离 context 单独 new
  • 线程安全边界要记清:context 可被多线程共享,但 socket 绝对不能跨线程复用(除非显式启用 ZMQ_THREAD_SAFE,且 cppzmq 版本 ≥ 4.10)

REQ/REP 模式为什么总卡死?

这不是 bug,是协议强制要求的交互节奏。REQ 客户端发完不立刻 recv,或 REP 服务端收完不马上 send,连接就会挂起——ZeroMQ 不会报错,只是永远等下去。

  • 顺序铁律:send → recv(客户端),recv → send(服务端),一步都不能跳
  • 别在 REP 端做耗时操作(比如读文件、调远程 API),否则整个队列阻塞;真要异步,改用 ZMQ_ROUTER/ZMQ_DEALER 配合线程池
  • 超时必须自己加:sock.setsockopt(ZMQ_RCVTIMEO, 5000),否则 recv 会永久阻塞

PUB/SUB 模式收不到第一条消息?

这是 ZeroMQ 最常被吐槽的“特性”:SUB 套接字只接收建立连接之后发布的消息,之前所有广播全丢。不是丢包,是设计如此。

editGPT
editGPT

一款浏览器插件,让ChatGPT修改、校对英语文章

下载
  • 订阅前务必调用 sock.setsockopt(ZMQ_SUBSCRIBE, "", 0)(空字符串表示订阅所有主题),否则默认不收任何消息
  • 如果需要“历史消息”,得靠外部机制(比如先连 Redis 拉快照,再连 PUB);ZeroMQ 本身不存消息
  • TCP 连接建立有毫秒级延迟,PUB 端 bind 后立刻发消息,SUB 还没 connect 完,那条就没了——加 std::this_thread::sleep_for(10ms) 不是优雅解法,而是暴露了架构依赖时序

发送结构体或 Protobuf 怎么保证二进制安全?

ZeroMQ 传的是裸字节,不关心内容格式,所以你传什么它就发什么。问题出在序列化和内存生命周期上。

立即学习C++免费学习笔记(深入)”;

  • 发结构体:确保没指针、没虚函数、字段内存连续;用 zmq::message_t msg(&data, sizeof(data)),别传栈变量地址后就 return
  • 发 Protobuf:先 SerializeToArray(buf, size) 到预分配缓冲区,再传 zmq::message_t msg(buf, len);别直接传 SerializeAsString() 返回的临时 string.data()
  • 多段消息(如 header+body)必须用 ZMQ_SNDMOREsock.send(header, ZMQ_SNDMORE); sock.send(body);接收端靠 msg.more() 判断是否继续 recv

最容易被忽略的是资源释放:socket 忘 close 会占 TCP 端口和 fd,context 忘 close 会导致整个进程残留 I/O 线程。哪怕程序只跑几秒,也得写 sock.close(); context.close();——这不是防御性编程,是 ZeroMQ 的契约。

相关文章

数码产品性能查询
数码产品性能查询

该软件包括了市面上所有手机CPU,手机跑分情况,电脑CPU,电脑产品信息等等,方便需要大家查阅数码产品最新情况,了解产品特性,能够进行对比选择最具性价比的商品。

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

770

2023.08.02

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

553

2023.08.03

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

216

2023.09.04

java基础知识汇总
java基础知识汇总

java基础知识有Java的历史和特点、Java的开发环境、Java的基本数据类型、变量和常量、运算符和表达式、控制语句、数组和字符串等等知识点。想要知道更多关于java基础知识的朋友,请阅读本专题下面的的有关文章,欢迎大家来php中文网学习。

1553

2023.10.24

字符串介绍
字符串介绍

字符串是一种数据类型,它可以是任何文本,包括字母、数字、符号等。字符串可以由不同的字符组成,例如空格、标点符号、数字等。在编程中,字符串通常用引号括起来,如单引号、双引号或反引号。想了解更多字符串的相关内容,可以阅读本专题下面的文章。

640

2023.11.24

java读取文件转成字符串的方法
java读取文件转成字符串的方法

Java8引入了新的文件I/O API,使用java.nio.file.Files类读取文件内容更加方便。对于较旧版本的Java,可以使用java.io.FileReader和java.io.BufferedReader来读取文件。在这些方法中,你需要将文件路径替换为你的实际文件路径,并且可能需要处理可能的IOException异常。想了解更多java的相关内容,可以阅读本专题下面的文章。

945

2024.03.22

php中定义字符串的方式
php中定义字符串的方式

php中定义字符串的方式:单引号;双引号;heredoc语法等等。想了解更多字符串的相关内容,可以阅读本专题下面的文章。

896

2024.04.29

go语言字符串相关教程
go语言字符串相关教程

本专题整合了go语言字符串相关教程,阅读专题下面的文章了解更多详细内容。

185

2025.07.29

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

561

2026.02.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 9.7万人学习

C 教程
C 教程

共75课时 | 4.8万人学习

C++教程
C++教程

共115课时 | 18.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号