讲师中心 微信公众号
AI工具推荐 视频效率加速

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

秋涛小哥_9722

秋涛小哥_9722

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

|

755人浏览过

|

来源于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 套接字只接收建立连接之后发布的消息,之前所有广播全丢。不是丢包,是设计如此。

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载
  • 订阅前务必调用 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_SNDMORE:sock.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,电脑产品信息等等,方便需要大家查阅数码产品最新情况,了解产品特性,能够进行对比选择最具性价比的商品。

下载

相关标签:

c++

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

热门AI工具

更多
墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

码上飞
码上飞 Hot

一款基于自然语言的AI应用开发平台,可根据用户描述自动生成应用程序,帮助个人和团队快速完成应用原型与开发。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

相关专题

更多
string转int
string转int

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

7099

2023.08.02

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

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

1858

2023.08.03

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

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

3004

2023.09.04

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

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

6284

2023.10.24

字符串介绍
字符串介绍

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

6229

2023.11.24

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

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

7814

2024.03.22

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

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

11874

2024.04.29

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

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

6139

2025.07.29

DBeaver怎么导入数据
DBeaver怎么导入数据

DBeaver数据导入专题,整理Excel、CSV、SQL、TXT等常见文件的数据导入方法,涵盖目标数据库选择、数据表创建、字段映射、数据类型设置及导入参数配置等操作,帮助用户将本地文件中的数据写入数据库,并了解批量导入、重复数据处理和导入失败等常见问题的解决方法。

0

2026.11.05

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn