如何通过Ubuntu RabbitMQ消息确认机制，轻松实现高可靠消息传输？

为了更直观地对比， 我整理了一个简单的表格：，未来可期。

RabbitMQ的消息确认机制可以和云平安提供商! Ubuntu上配置RabbitMQ消息确认机制 一 环境准备与启用管理插件 安装组件并启动服 佛系。 务:channel.txSelect → basicPublish → txCommit/txRollback,保证消息到达服务器,但性能较低。

通过在Ubuntu上配置RabbitMQ， 并结合Python中的手动确认机制，我们已经构建了一个相当健壮的消息传输系统。从安装时的sudo apt install rabbitmq-server 有啥说啥... 到代码中auto_ack=False的设置，再到delivery_mode=2的持久化配置，每一步都是为了同一个目标：数据的平安。

先说说确保你已经安装了pika库：

pip install pika

**下面是消费者的核心代码。请注意， 这里我们特意将`auto_ack`设置为`False`， 不忍直视。 这是开启手动确认的第一步：**

import pika
import time
# 连接到RabbitMQ服务器
connection = pika.BlockingConnection)
channel = connection.channel
# 声明一个队列， 确保队列存在
# durable=True 表示队列持久化，防止RabbitMQ重启后队列消失
channel.queue_declare
print
def callback:
    print}")
    # 模拟耗时操作
    time.sleep)
    print
    # 关键步骤：手动发送消息确认
    # delivery_tag是RabbitMQ用来标识这条消息的唯一ID
    ch.basic_ack
# 设置QoS，确保一次只处理一个消息
# 这是为了防止在一个消费者处理繁忙时RabbitMQ把所有消息都塞给它
# 从而导致其他消费者空闲
channel.basic_qos
# 消费消息
# auto_ack=False 显式关闭自动确认
channel.basic_consume
channel.start_consuming

接下来是`channel.basic_qos`。这个配置非常人性化。假设你有两个消费者， 其中一个处理速度特别慢，如果不设置这个参数，RabbitMQ可能会把积压的消息全部发给那个慢的消费者， 太刺激了。 而那个快的消费者却闲着没事干。设置了`prefetch_count=1`后 RabbitMQ在收到前一条消息的确认之前， 不会分发新的消息给该消费者，从而实现了任务的公平分发，火候不够。。

搞一下... 说实话， 很多初学者在接触RabbitMQ时往往只关注了“发消息”和“收消息”这两个动作，却忽略了中间最关键的一环——确认。这就好比你寄了一份极其重要的快递，却只是随手扔进了邮筒，而没有要求回执单。如果快递在路上丢了你根本无从知晓。在Ubuntu这个强大而稳定的Linux发行版上配置RabbitMQ， 配合正确的确认机制，我们完全可以避免这种悲剧的发生，欧了！。

**在构建分布式系统的征途中，你是否曾主要原因是数据的莫名丢失而彻夜难眠？那种看着日志里明明显示“已发送”，下游却迟迟收不到消息的无力感，简直是每一个后端开发者的噩梦。别慌， 今天我们就来深入探讨一下在Ubuntu环境下如何利用RabbitMQ的消息确认机制为你的数据传输穿上“防弹衣”。这不仅仅是一次技术学习，更是为了让你在深夜能睡个安稳觉，试着...。**

境界没到。 在RabbitMQ 中, 消息确认机制 可以 通过 设置消费者的auto_ack参数来 实现 。 默认情况下, auto_ack为True,即自动确认消息。为了启用手动确认,需要将其设置为False。 生产者代码示例 如何发送 消息: import pika # 连接到RabbitMQ 服务器 connection = pika.BlockingConnection) channel = connection.channel # 声明一个队列 channel.queue_declare # 发送 消息 message = Hello World! channel.basic_publish(exchange='', routing_key='task_queue', body=messag...

sudo apt update
sudo apt install rabbitmq-server
sudo systemctl start rabbitmq-server
sudo systemctl status rabbitmq-server
python send.py "First message."
python send.py "Second message.."
python send.py "Third message..."
python receive.py
import pika
connection = pika.BlockingConnection)
channel = connection.channel
message = ' '.join or "Hello World!"
properties=pika.BasicProperties(
        delivery_mode=2,  
    ))
print
connection.close
   

**这是RabbitMQ的默认模式。在这种模式下 一旦消息被写入到TCP套接字并发送给消费者，RabbitMQ就认为这条消息已经被送达了。 稳了！ 它根本不管消费者到底有没有处理完，甚至不管消费者是不是真的收到了。**

**这种模式的好处是性能极高， 吞吐量大，主要原因是没有额外的确认开销。但是正如我们前面提到的，风险极高。它就像是一个没有责任心的快递员， 只要把包裹扔到你家门口， 尊嘟假嘟？ 他就跑路了不管包裹是不是被风吹走了还是被雨淋湿了。通常，这种模式只适合对数据一致性要求不高的场景，比如大量的非关键日志收集。**

**光说不练假把式。让我们用Python的`pika`库来演示如何在实际代码中实现手动确认。我们将创建一个消费者，它不仅会接收消息，还会在处理完成后发送ACK。**  正常情况下消费者会依次接收并打印消。现在让我们来点“暴力”测试。当消费 在我看来... 者正在处理一条带有多个点的消时直接按`CTRL+C`强制停止消费者进程。

**想象一下这样的场景：你的消费者接收到一条消 ， 刚开始处 ，突然间，进崩溃了或者网络连接断开了。此 RabbitM 已经认为这条消 处完毕， 并将其从队 删除 后来啊就是这 数据永久失 业逻辑出 了断层，是个狼人。。**  为了解决这个问题， RabbitM 了消认制 简单 就是消费 者在 处完任 后需要给 RabbitM 回一个 “收条”，告诉它：“嘿，我搞定了你可以把这条消 除。”如 RabbitM 没收到这个收条，它就会把消重新分 给其他的消费 者。这才是我们想要的高可靠性。

sudo apt update
   

虽然我们主要讨论的是消费者的确 但一个完整的高可靠链路离不开生产者的配 如果生产者发送的消息本身就不持久化， 蚌埠住了... 那么费者做得再好也是徒劳。

**当然 这里有一个极端情况需要提及：如果费者在处完消、 ACK之前， RabbitM 服务器挂 或者网络彻底断 ACK不过 去 消 会被重新入 。这会导致消 被重复处 在业务逻辑中，我们需要做好幂等性设计，即同一条消 被 处多次不会产生副 。比如 在数据库中先查 該ID是否存在再决定是否插入 。** 文章浏 量1.5k次, 点赞2次, 收藏4次。本文深 入探讨 RabbitM 中的 消息确 制 ,包括AMQP事务模式与Confirm模 ,阐述其重要性,即确 消息 可靠传输 及防丢。 文章详细解 了在生产者与费端 如何配 确 制 ,提供三种编程方式 实现 Confirm模 ,并对 了不同模 的特点。 一、理论基础 1.1、什么是 消息确 制 ？ RabbitM 在传递消 程中充当 了代理人角色, 生产者 发送 消 到代理服 broker默情況下是不 会返回任何消 给生产者的, 生产者不知道消 有没有正常到达代理服 MQ提供 了两种方式 实现 消息确 : AMQP事模 、将信道 channel设置为Con... 打开两个终 。在一 个终 运行生 者： 在第 二个终 运行费 者： 这就是 我们要重点推荐 的 “高可靠”模 。 在这 种模 下 RabbitM 会等待费 者显式地 发送 一个确 号， 才会将 消 从队 中移 ，别怕...。 下面是一个改进后的生 者代 示例 ，展 示 了 如何 发送 持 久化的 消 ：， 对吧，你看。 请注意 `properties=pika.BasicProperties `这一行。这 代码告 RabbitM ：“这 条 消 很重要，请把它写 到磁盘 上，别只放在内存 里。”虽然写入 磁盘 会带来一定的性能损耗 ， 但对于订单支付、用 注册等核 业 这点性能损耗 是完全值得 的。 在使用 Ubuntu上的 RabbitM 消息确 制 你需要确保你的应用程序正确地处 消 确 。 RabbitM 的 消息确 制 ,你需要确保你的应用 程 ... 在这个示例 中 ,费 者会在接收 到 消 后打 印 出 消 内容 ,并 发送 一个 消 确 给 RabbitM ,告 它这个 消 已经成 功 处 理,可以 从队 列 中移 除。这是 通 过 调 用 basic_ack 方 法 并传 入 delivery_tag 参数 来完 成 的, delivery_tag 是 消 的唯 一标识 符。 请注 意,如 果费 者 在 处 理 消 时崩溃 ,而 没有 发送 确 ... 持 久 化 : RabbitM 支持 将 消息 持 久 化 到磁 盘 , 以 确 保 即使 在代 理重 启 后 , 消息 也 不 会丢 失 。 它 还允 许 将队 列 和交换 机设 置 为 持 久 化 , 以 提 高系 统 的 可靠 性。 集 群 和 高 可 用 性 : 支持构建具有高可用性和可伸缩性的集 群 。 通 过 将 多 个节点 组 成 集 群 , 可以 实 现 消息 的 负载均衡 和 故 障 转 移 , 从而提高系统的 可靠 性 和 性 能。 消息确 制 : R 支持 消息确 制 , 即 生 者 可以选 择 在 消息 发送 到队 列 后 等 待 对 消息 确认 , 以 确 保 被成功 處 理 。 这种制 可以保 不会丢失 , 并且 可以防止 重复 處 理 。 插 件 系 : R 提供 了丰 富 的插 件 系 , 可以 通 过 件 ... 为了验证它真的有效呢？我们可以。 ### **1. 安 装 RabbitM 先说说,确保你已经在 Ubuntu 上安 装 了 RabbitM 。如果还没有安 装 ,可以使用以下命令 ...领 先 的全 球 云计 算 和 云 平安 提供 商 !**

sudo apt update && sudo apt install rabbitmq-server -y && sudo systemctl start rabbitmq-server && sudo systemctl enable rabbitmq-server && sudo systemctl status rabbitm q-server --no-pager | grep Active && echo "Rabbit MQ installation and setup completed."

当你看到绿色的“active ”字样时恭喜 你，你的消息队列引擎已经轰隆隆 地转起来 了。这时候 ， 你甚至可以尝试启 用管理插件，通过Web界面 来可 管理你的队 ，但这属于锦上添花的功能，我们今天的重 是代码层面的可靠性 ，调整一下。。 根据我们的配 置 ， 由于费 者在崩溃前没有发送 `basic_ack `， RabbitM 会认为这 条 消 没有被 處 理。当你重新启 动费 者 时 你会发现 把这 条 消 投递给你。这就是 我们梦寐以求 的 “不失 ”保证，总来说...！ ### **这里有一个非常棒的设计： RabbitM 对未确 的消 不设超 时限 。这意味着 ， 如果你的费 者 處 理一条消 需要花费很长 时 间 ， 会耐心地 等待，直到 你告 它 處 理完毕。这给了开发者极大的灵活性，不用担心主要原 时 间过长而导致消 被错误 地重新入 。** 希望这篇文章能帮助你彻底搞懂 **下次当你再面 对 “消 失 ”这个棘手的问 题 时 你可以自 地微笑，主要原 因是你已经掌握 了让数据乖乖听话的关键 。去试试吧，让你的 Ubuntu 服务成为最可靠的消息中转站 ！** ### **开始写代码之前，我们得先把“战场”布置好。 Ubuntu 以其出色的稳定性和社区支持，成为 部 署 的首选系统之一。虽然安 装过程看起来只是几条命令，但每一步都至关重要，研究研究。。** ### **主要提供了两种消 确 模 ：自动确 和手 动确 。 翻旧账。 理解它们的区别，是掌握高可靠传输的关键 。** 虽然 技术不 是冰冷的代码，它承载着 我们对业务稳定性的承诺。虽然 还提供 了事务机 ， 也能 我们更推荐使用今天介绍 的这种 “确 机 +持 久 化”的组合拳。 我懂了。 先说说 我们需要更新软件包列表，确保 我们能下载 到最新的版本 。打开你的终 端 ， 输入以下命令 ： 为了更直观地对 ， 我整理了一个简单的表 格 ：未来可期。 技术不 是冰冷的代码，它承载 着 我们对业 稳定性的承 。 虽然 还提供了事务机，也能我们 更推 荣使 用今 天介 介绍的这种 “ 确认机 制 +持 久 化 ” 组 合拳 。... ## **我满足。了默 然情况下的行为可能和 你想 象的不一 样。一旦 ## 从队 列 中被 分 发出 去 ## 内 部 就 会立 ## 将 其标 记 为 “已使 用 ” 并 从 内 存 中移除。这种 “即 发 即忘”的模 式 ## 处 理 简 单任 务 ## 高 ## 处 理 关 键 业 数 据 ## 灾 难。... 希望 这 篇文 章 能帮 助 你彻 底搞懂 ## 下 次 当 你再 面 对 “ ## 失 ” 这个棘 手 的 问题 时 你可以 自信 地微 笑，主 要 原 因 是 你 已经掌 握 了 让数 据乖乖听 话 的关 键。... ### **为了验 它真 的有效呢？我们可以。。。** ### **当然 这里有一个极 端情 需要提 及：如果 ## CTRL+C 强 制停 ## 进 崩溃 前没 有发 basic_ack ## 服务器挂 或 网络彻底断 ACK 不过 去 ## 会被重 新入 ## 重复 處 理... ## 业逻 辑 中， 我们需 要做好幂 等 性设 计，即 同一条 数 据 被 處 多 次 不会产生副 .... 人们总是倾 向 于低估自 己的能力... 最简单也是最有效的办 法往往就藏 在那些 看似平凡无奇的日子里... 数据安 全就像是一场永无止境的接力赛... 每一次成功的传输都意味着又一 关险隘被攻克... 别让那些所谓的‘最佳实践’束 缚住你的手脚... 真正的高手总是能在细节中寻找到突破口... 当一切似乎 都已准备就绪... 真正考验才刚刚开始... 每一次失败都是一次宝贵的学机会... 前提是你足够勇敢去面对它... 高可用性就像是一座大厦... 而每一次成功的消 都相当于 为它增添了一块坚实的砖瓦...

Ubuntu 上 配置Rab bit MQ的消息确 机

* 安 组件 并启 动服 - 更新索引…领先的全 球 云计 算 和 云安 全 提供 商 ! * 可 投递 常 组 合 事 :ch ann el.txS elect → ba sic Publish → t xCommi t /tx Rollback ,保证 消 到达服 但性能较 低。 * 发布 者 确认 Publi sher Con firms :ch ann el.co nfirm Select ,配 合 wai tForC onfir ms 或 ad d_confi rm_li stene r 确认 消 被服 接 收 并 落盘。 * Java 示例 … 通 过 在 Ubunt 上 配置 Rab bit MQ ， 并 结 合 Python 中的 手 动 确认 机 ， 我 们 已 经构 建了一 个 相 当健 状的消息 传 输 系统。 从 安 装时的 `sudo ap t in stall rab bit mq- server ` 开始… 到 代 码 中 `au to_ac k=Fal se ` 的设 置 … 再 到 `de livery _mode =2 ` 的持 久 化 配 置 … 每 一 步 都 是 为 了 同 一 个 目 标 : 数 据 安 全。 别 让 那 些 所谓的最佳 实 践束 缚 住 你 手脚 … 真正的高 手 总 是 能 在细 节 中找 到 突破 口 …… 人们 总 是倾 向 于 低估 自己 能 力 … 最 简单也 是 最有 …… 数 据 平安 就像是一 场 永 无止境 接 力赛…… 每一次成 传 输 都意味 又一 关险 被攻 克 …… 当一切似乎 都 已准 就绪 …… 真正考验 才刚 开 …… 每一次失败都是一 次宝贵 学机会…… 前提是你足够勇敢去 面对 它 …… 高可用 性就像是一座 大厦…… 而每一次成 消 都相 当 于为它增添了一块坚实 砖瓦 ……