当前位置:首页 >专题 >Go RabbitMQ 消息队列实战专题

Go RabbitMQ 消息队列实战专题
Go RabbitMQ 消息队列

Go RabbitMQ 消息队列实战专题

从 AMQP、可靠投递到重连监控与任务分发
RabbitMQ 的难点不在于把消息发进队列,而在于交换机路由、确认机制、持久化、消费者并发、断线恢复和可观测性如何组合成可靠的 Go 服务。本专题以 RabbitMQ 4.x 官方资料和 amqp091-go 为基线,精选 17Golang 真实文章,串起从本地快速开始到生产排障的实践路线。

站内 Go/RabbitMQ 实战路线

从生产消费到可靠投递、重连、监控与任务分发

Golang rabbitMQ生产者消费者实现示例
文章

Golang rabbitMQ生产者消费者实现示例

演示 Go 使用 RabbitMQ 完成基础生产者和消费者。
RabbitMQ 可靠投递
文章

RabbitMQ 可靠投递

围绕 RabbitMQ 消息确认和可靠投递讨论生产与消费端的处理方式。
关于golang监听rabbitmq消息队列任务断线自动重连接的问题
文章

关于golang监听rabbitmq消息队列任务断线自动重连接的问题

讨论 Go 常驻任务监听 RabbitMQ 时的断线重连与进程管理。
在Golang应用中如何使用RabbitMQ实现消息队列
文章

在Golang应用中如何使用RabbitMQ实现消息队列

从 Go 应用角度介绍 RabbitMQ 消息队列的接入和使用。
Golang中使用RabbitMQ实现任务分发与负载均衡的策略
文章

Golang中使用RabbitMQ实现任务分发与负载均衡的策略

讨论使用 RabbitMQ 进行任务分发和消费者负载均衡。
在 go lang 中 amqp.Dial 是否是线程安全时是否每次都创建连接
文章

在 go lang 中 amqp.Dial 是否是线程安全时是否每次都创建连接

围绕 amqp.Dial、连接复用和并发安全讨论 Go 客户端使用方式。
优化系统韧性:故障恢复与监控在RabbitMQ中的应用
文章

优化系统韧性:故障恢复与监控在RabbitMQ中的应用

从故障恢复和监控角度讨论 RabbitMQ 系统的韧性建设。
Golang与RabbitMQ实现实时数据同步的解决方案
文章

Golang与RabbitMQ实现实时数据同步的解决方案

使用 Go 与 RabbitMQ 组织实时数据同步链路。

RabbitMQ 消息队列常见问题

围绕确认、重连、并发与积压的实用答案

RabbitMQ 的 exchange、queue 和 routing key 如何配合?

生产者把消息发布到 exchange,exchange 根据 binding 和 routing key 将消息路由到一个或多个 queue,消费者只从 queue 获取消息;queue 才是消息等待消费和进行 ack 的位置。

RabbitMQ 怎样减少消息丢失和重复消费?

生产端使用 publisher confirms,消息和队列按业务需要持久化;消费端使用手动 ack,并在业务成功后确认。网络重试和消费者重启仍可能造成重复,因此必须用业务幂等键、重试队列或死信处理重复与失败。

Go RabbitMQ 客户端应该复用 connection 和 channel 吗?

通常应复用长期 connection,并按并发模型管理 channel;不要为每条消息反复 Dial。channel 不是任意并发场景下都可以无约束共享,发布确认、消费和关闭都应配合客户端文档设计生命周期。

RabbitMQ 消费积压时应该先扩容还是先排查?

先确认队列增长速度、消费者处理耗时、prefetch、下游限流、连接状态和节点资源,再判断是否安全增加消费者;盲目扩容可能放大数据库或外部 API 压力,还要关注消息顺序、重试和死信。

微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码