讲师中心 微信公众号

工具推荐

视频效率加速
立刻MV
立刻MV

低成本歌曲 MV、视频生成

剧云
剧云

中文短剧剧本制作平台

Seko
Seko

AI短剧一键生成成片

AniShort
AniShort

AI短剧协同制作平台

c++如何连接rabbitmq消息队列_c++ SimpleAmqpClient库引入与生产消费【实战】

老墨君_8378

老墨君_8378

发布时间:2026-01-07 16:15:08

|

428人浏览过

|

来源于php中文网

原创

SimpleAmqpClient 已不推荐用于新项目,因其底层 librabbitmq-c 停更、无异步I/O、无自动重连、易fd泄漏;AMQP-CPP 成主流替代,支持自动资源管理、回调重试、免轮询消费及publisher confirms。

c++如何连接rabbitmq消息队列_c++ simpleamqpclient库引入与生产消费【实战】

直接用 SimpleAmqpClient 库连接 RabbitMQ 是可行的,但 2025 年底它已**不再推荐用于新项目**——底层依赖的 librabbitmq-c 停更多年,不支持 AMQP 1.0、无异步 I/O、在高并发或断网重连场景下极易崩溃(比如 amqp_login 返回 AMQP_STATUS_SOCKET_ERROR 后未清理 socket 导致 fd 泄露)。

为什么 SimpleAmqpClient 在 C++ 项目中越来越难用

它本质是 rabbitmq-c 的薄封装,没解决核心痛点:

  • 连接失败后 amqp_new_connection() + amqp_tcp_socket_new() 需手动配对释放,漏一步就内存泄漏
  • 没有内置重连逻辑:网络抖动时 amqp_basic_publish() 可能静默失败,返回 AMQP_STATUS_CONNECTION_CLOSED 却不抛异常
  • 消费者端用 amqp_basic_consume() 后,必须自己轮询 amqp_simple_wait_frame_noblock(),阻塞模式下线程卡死风险高
  • 不支持消息确认(ack)的自动重发补偿,basic.nack 语义需手写状态机

替代方案:AMQP-CPP(轻量 + 异步 + 线程安全)

2025 年主流 C++ 项目已转向 AMQP-CPP,它用纯 C++11 实现,头文件即用,且天然适配现代构建系统。关键差异:

  • 连接对象 AMQP::TcpConnection 析构时自动关闭 socket 和 channel
  • 提供 AMQP::Channel::publish() 的回调式重试(通过 onError 捕获 AMQP::error_t::connection_error)
  • 消费用 channel.consume("queue", [](const AMQP::Message &msg, uint64_t deliveryTag) { ... }),消息到达即触发,无需轮询
  • 默认启用 publisher confirms,publish() 返回 bool 表示是否进服务端队列,比 SimpleAmqpClient::Channel::BasicPublish() 更可靠

安装只需:

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

git clone https://github.com/CopernicaMarketingSoftware/AMQP-CPP.git
cd AMQP-CPP && make && sudo make install

CMakeLists.txt 中加一行:target_link_libraries(your_app AMQP-CPP)

GitHub一键发布助手(专业版)
GitHub一键发布助手(专业版)

本地项目发布到GitHub的完整工作流助手。自动执行:安全检查(.gitignore、排除敏感.env/凭据文件)、补齐开源文件(LICENSE、.gitignore)、git init/commit/branch、创建远程仓库、首次推送、可选打tag。支持git filter-repo历史敏感信息重写、force push、tag管理。Windows下走Credential Manager自动认证。触发词:"发布到GitHub"、"上传到github"、"

下载

生产者代码精简示例(AMQP-CPP)

对比 SimpleAmqpClient 动辄 50 行的连接+声明+发布流程,AMQP-CPP 15 行搞定且自带错误兜底:

#include <AMQP-CPP.h>
#include <iostream>

int main() {
    AMQP::TcpConnection connection("amqp://guest:guest@localhost:5672/");
    AMQP::TcpChannel channel(connection);

    channel.declareQueue("task_queue", AMQP::durable);
    
    auto ok = channel.publish("", "task_queue", "Hello World!", AMQP::confirmable);
    if (!ok) std::cerr << "publish failed" << std::endl;
    
    connection.close(); // 自动 wait for close ack
    return 0;
}

注意:"" 作 exchange 名表示使用默认 direct exchange;AMQP::confirmable 开启发布确认,避免消息丢失。

消费者要小心“公平分发”陷阱

很多人照搬 Java 教程设 channel.qos(1) 就以为能实现“能者多劳”,但在 C++ 里:

  • AMQP::Channel::setQos() 必须在 consume() 之前调用,否则无效
  • 若用 channel.consume(..., AMQP::noack),则 qos 完全失效(RabbitMQ 不做 unack 计数)
  • 真正生效的写法是:channel.consume("queue", callback, AMQP::manual),然后在 callback 里显式调用 channel.ack(deliveryTag)

否则两个消费者启动后,RabbitMQ 会把所有消息预取给第一个连上的 consumer,第二个 consumer 一直空转。

最常被忽略的一点:RabbitMQ 的 C++ 客户端不是“连上就能发”,而是“连上→开 channel →声明 queue/exchange →设置 qos(如需)→再 publish/consume”。少任何一环,错误码都藏在 AMQP::error_t 或 amqp_status_enum 里,不打印日志根本看不出哪步挂了。

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

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

热门AI工具

更多
豆包大模型

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

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

创客贴AI

创客贴AI是一款AI图像与设计工具,AI辅助的智能在线设计工具。

Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

DeepSeek

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

墨刀AI
墨刀AI Hot

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

WorkBuddy

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

相关专题

更多
rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

684

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

1188

2026.01.28

RabbitMQ使用教程合集
RabbitMQ使用教程合集

RabbitMQ使用教程合集整理 RabbitMQ 基础教程、消息队列开发案例、生产者消费者、交换机与队列实战内容。

224

2026.05.20

RabbitMQ集群部署指南
RabbitMQ集群部署指南

RabbitMQ集群部署指南聚合 RabbitMQ 集群部署、高可用架构、镜像队列、故障恢复、监控与运维优化内容。

137

2026.05.20

RabbitMQ Docker实战指南
RabbitMQ Docker实战指南

RabbitMQ Docker实战指南提供 RabbitMQ Docker 镜像部署、Docker Compose、Kubernetes Operator 与云原生实践教程。

162

2026.05.20

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

2438

2023.09.20

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

2438

2023.09.20

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

4818

2023.08.10

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

0

2026.11.12

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Postman Native Git工作流指南
Postman Native Git工作流指南

共0课时 | 0人学习

vscode手册
vscode手册

共0课时 | 0人学习

Git 教程
Git 教程

共21课时 | 8.2万人学习

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

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