1. 项目背景推广中台联调第三天现场出现「三套真相」开发用 pika 声明了ex.orders自己机器上能发。测试在 CI 容器里跑 Java 客户端报 NOT_FOUND。事后发现 CI 连的是另一套 VHostJava 封装把/编码错了。运维只开了 5672 防火墙办公网访问不了 15672只能让开发截图「队列是空的」。空是没消费者还是根本没声明截图看不出来。没有语言无关的操作面验收就被 SDK 绑死开发 SDK 声明拓扑 │ CI 不会用这个 SDK ▼ 测试「环境不对」 │ 运维不会看 AMQP 抓包 ▼ 运维「端口通了就是好的」周末值班还发生过营销同学用 UI 把q.promo.sms改成非持久「先试试」周一订单组 Java 客户端带着 durabletrue 再 declare直接 406整个发布列车失败。UI 手滑改拓扑没有 PR、没有审计这就是「菜单屏当施工图」的现场代价。管理平面必须规定谁可以改、用什么工具改、怎么验收。RabbitMQ 管理平面正好是三部门的公共语言工具典型使用者擅长rabbitmqctl运维用户、权限、关连接、节点级操作rabbitmq-diagnostics运维 / 测试健康、监听、内存、配置是否生效rabbitmq-plugins运维插件名单Management UI全员观察连接、堆积、点选声明不适合自动化HTTP API/api/*测试 / GitOps可 curl、可进 CI、可导出 definitionsrabbitmqadminv2运维脚本比原始 curl 更少编码坑本章规定拓扑验收以 HTTP API 为准人眼确认用 UI危险操作删用户、关节点用 ctl 且进审计。开发 SDK 只是数据面的一种客户端不是真相源。源码上HTTP 路由集中在rabbit_mgmt_dispatcher.erlCowboy 把/api/overview、/api/exchanges/.../publish等编进同一张表——你在 curl 里敲的路径就是这张表里的字符串。还有一层组织痛点推广中台同时服务订单、营销、数据三个事业部各部都要「看一眼队列深不深」。若人人 administrator一次误点 Purge 就能让大促积分对账对空。管理平面的用户标签和 AMQP 权限是两套闸门必须一起设计不能只开 15672 端口就算对测试友好。2. 项目设计小胖已经打开了 15672正准备用鼠标把交换机点出来。小胖这不就是食堂的电子菜单屏吗点一点菜就出来了为啥还要 curl测试同学学几个按钮不香吗大师菜单屏适合值班看「今天窗口堵不堵」。你用鼠标点出来的队列没有 diff、没有 PR、没有重复执行。大促当天凌晨三点测试要在干净 VHost 里一键铺拓扑只能 API 或 definitions 导入。UI 是观察窗不是施工图。技术映射UI 和 HTTP API 走同一套rabbit_mgmt_wm_*资源但 CI 只能打 API不能打按钮。小白那rabbitmqctl和 HTTP API 会不会改到不同的元数据有没有最终一致延迟用户标签monitoring能不能声明队列policymaker呢万一 CI 用了 administrator会不会误删生产 definitions另外 vhost 名叫promo还好名叫/时 URL 怎么写大师单节点上 ctl 和 API 改的是同一套 Khepri 元数据通常立刻可见你要担心的不是延迟是权限模型administrator 全能monitoring 只读监控policymaker 能改 policy 不能当超级管理员乱用management 能进 UI 看自己权限范围内的对象。CI 必须用最小标签铺拓扑用单独的promo_ci账号configure/write/read 限制在promoVHost不要administrator。VHost/在 URL 里编码为%2F这是历史上最多的 404 来源——我们默认业务 VHost 用promo就是为了少踩这个坑。小胖那我用 API 发消息和用 AMQP publish 有啥不一样测试能不能只测 API 就算测过 MQ大师API 的 publish/get 是管理通道上的短请求走 HTTP确认语义、性能、流控和 AMQP 数据面不同。可以用来做拓扑与浅显投递验收不能替代消费者 Ack、Confirm、prefetch 测试。小胖记住API 发一条只证明「路由存在」不证明「大促 3000 TPS 数据面正常」。技术映射/api/exchanges/{vhost}/{ex}/publish是管理面basic.publish才是数据面。小白definitions 导出导入能当备份吗健康检查该打/api/aliveness-test还是新的/api/health/checks/*dispatcher 里我看到 aliveness 还在也有一堆 health/checks。大师definitions 适合拓扑搬迁不是 WAL不能当消息备份。aliveness-test 会在目标 VHost真的声明临时队列并收发有副作用高频率探针可能留下垃圾或抢锁4.x 推荐细粒度/api/health/checks/alarms、local-alarms、virtual-hosts等给 K8s 探针。第 29 章再接到 Operator。今天测试把 checks 写进冒烟把 aliveness 留作偶尔的「深检」。小胖闭环实验就一句话curl 把菜谱写上墙再夹一筷子尝尝UI 围观ctl 查户口。大师对。再加一条用whoami证明 CI 账号不是 administrator。这比任何规范 PDF 都硬。小白HTTP API 的 Basic Auth 走明文办公网中间人能不能偷到promo_cipublish 接口会不会被当成后门绕过应用鉴权直接灌消息测试环境暴露 15672 到公网是否可接受大师预发也必须把 15672 绑在内网或跳板生产叠加 TLS第 25 章。管理面 publish就是一条能灌消息的后门所以 CI 账号可以 write值班只读账号绝不能 write。应用鉴权在业务服务Broker 只认 AMQP/HTTP 用户。两套鉴权都要有缺管理面闸门时拿到密码等于拿到路由权。技术映射15672 的 publish 持有 write 权限的管理通道不是「只读监控端口」。3. 项目实战3.1 环境准备节点第 3 章基线容器rabbit-promo-1用户promo/promo_dev_2026VHostpromo该用户目前是管理员仅限本章演示。工具curlWindows 可用 Git Bash 或curl.exe、浏览器、docker exec。约定环境变量Git BashexportMQAPIhttp://127.0.0.1:15672/apiexportMQUSERpromo:promo_dev_2026exportVHpromoWindows PowerShell$mqhttp://127.0.0.1:15672/api$pairpromo:promo_dev_2026$vhpromo3.2 步骤一CLI 户口与诊断步骤目标分清 ctl / diagnostics / plugins并列出即将用于 CI 的最小权限用户。dockerexecrabbit-promo-1 rabbitmq-diagnosticspingdockerexecrabbit-promo-1 rabbitmq-diagnostics listenersdockerexecrabbit-promo-1 rabbitmqctl list_usersdockerexecrabbit-promo-1 rabbitmqctl list_vhostsdockerexecrabbit-promo-1 rabbitmqctl list_user_permissions promodockerexecrabbit-promo-1 rabbitmq-plugins list-E创建测试专用账号不要再给 administratordockerexecrabbit-promo-1 rabbitmqctl add_user promo_ci ci_dev_2026dockerexecrabbit-promo-1 rabbitmqctl set_user_tags promo_ci managementdockerexecrabbit-promo-1 rabbitmqctl set_permissions-ppromo promo_ci.*.*.*只读观察账号dockerexecrabbit-promo-1 rabbitmqctl add_user promo_watch watch_dev_2026dockerexecrabbit-promo-1 rabbitmqctl set_user_tags promo_watch monitoringdockerexecrabbit-promo-1 rabbitmqctl set_permissions-ppromo promo_watch^$^$.*monitoring 空 configure/write只能看不能声明。下一步用 API 验证拒绝。坑set_user_tags覆盖标签列表不是追加。写两次后者为准。坑权限三个正则依次是 configure、write、read。promo_watch的^$表示空串才匹配即不能声明任何对象。标签对照讲给安全评审听tag能进 UI典型能力administrator是全 VHost、全管理操作monitoring是看全局统计不能乱改拓扑policymaker是管 policymanagement是仅自己有权限的对象无 tag否纯 AMQP 应用账号生产推荐3.3 步骤二UI 走查人眼不写进 CI打开http://localhost:15672用promo登录。必看页面Overview节点、告警、Connections、Channels、Exchanges、Queues、Admin → Users / Vhosts。右上角 VHost 切到promo。用promo_watch再登录一次尝试 Add queue应失败或无入口。把截图贴 Wiki「最小权限证据」。坑浏览器缓存了旧用户 cookie表现为「明明改了权限还是管理员」。无痕窗口。3.4 步骤三HTTP API 拓扑闭环本章核心步骤目标声明直连交换机、持久队列、绑定、发布、拉取全程 curl。健康与身份curl-s-u$MQUSER$MQAPI/whoamicurl-s-u$MQUSER$MQAPI/overview|rg-o\cluster_name\:\[^\]\curl-s-u$MQUSER$MQAPI/health/checks/alarmscurl-s-u$MQUSER$MQAPI/health/checks/virtual-hostswhoami期望含name:promo。alarms在无告警时应是 ok 类响应HTTP 200。运行结果示例{name:promo,tags:[administrator]} # health/checks/alarms 无告警时 HTTP 200body 类似 {status:ok}若whoami返回 401先查用户是否只在/存在而请求打到了别的认证链若 200 但 tags 为空该用户进不了部分 UI 菜单但 AMQP 仍可能可连。声明交换机与队列PUT 幂等curl-s-u$MQUSER-Hcontent-type: application/json\-XPUT$MQAPI/exchanges/$VH/ex.promo.direct\-d{type:direct,durable:true,auto_delete:false,internal:false,arguments:{}}curl-s-u$MQUSER-Hcontent-type: application/json\-XPUT$MQAPI/queues/$VH/q.promo.sms\-d{durable:true,auto_delete:false,arguments:{}}绑定smsrouting keycurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/bindings/$VH/e/ex.promo.direct/q/q.promo.sms\-d{routing_key:sms,arguments:{}}发布curl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/exchanges/$VH/ex.promo.direct/publish\-d{ properties: {delivery_mode: 2, content_type: application/json}, routing_key: sms, payload: {\orderId\:\P20260828001\,\type\:\PAY_OK\}, payload_encoding: string }期望 body 含routed: true。若routed: false绑定错了或 VHost 错了——这就是不靠 SDK 的路由验收。拉取管理面 get会真正把消息取出注意 ack_modecurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/queues/$VH/q.promo.sms/get\-d{count:1,ackmode:ack_requeue_false,encoding:auto,truncate:50000}期望 payload 里看到P20260828001。ack_requeue_false表示取出并确认队列应回到 0。再发一条用错误 keycurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/exchanges/$VH/ex.promo.direct/publish\-d{properties:{},routing_key:no-such,payload:lost?,payload_encoding:string}期望routed: false。默认交换器之外无法路由的消息被丢弃除非 AMQPmandatoryAPI 这条短发布不提供完整 mandatory 语义。测试把routed: false写成明确用例避免开发以为「HTTP 200 就是送到了」。坑 1VHost/必须写成%2Fhttp://127.0.0.1:15672/api/queues/%2F/my-queue漏编码会 404。坑 2名字里的/、中文必须 URL encode。坑 3PUT 队列时 JSON 字段名是durable不是Durable。坑 4get的ackmode拼写是ackmode小写值如ack_requeue_true/reject_requeue_false。写错返回 400。坑 5PowerShellcurl是Invoke-WebRequest别名请用curl.exe。对照 dispatcher 源码确认路径不是文档写错dispatcher() - [{/overview, rabbit_mgmt_wm_overview, []}, {/cluster-name, rabbit_mgmt_wm_cluster_name, []}, ... {/exchanges/:vhost/:exchange/publish, rabbit_mgmt_wm_exchange_publish, []}, ... {/queues/:vhost/:queue/get, rabbit_mgmt_wm_queue_get, []},{/aliveness-test/:vhost, rabbit_mgmt_wm_aliveness_test, []}, {/health/checks/alarms, rabbit_mgmt_wm_health_check_alarms, []}, {/health/checks/local-alarms, rabbit_mgmt_wm_health_check_local_alarms, []}, {/health/checks/virtual-hosts, rabbit_mgmt_wm_health_check_virtual_hosts, []},实际 HTTP 路径会加上/api前缀build_module_routes里拼接。3.5 步骤四用最小权限账号证明拒绝# monitoring 不能 PUT 队列curl-s-o/tmp/watch-body-w%{http_code}-upromo_watch:watch_dev_2026\-Hcontent-type: application/json\-XPUT$MQAPI/queues/$VH/q.should.fail\-d{durable:true}echocat/tmp/watch-body期望 HTTP401 或 403队列不存在curl-s-o/dev/null-w%{http_code}-u$MQUSER$MQAPI/queues/$VH/q.should.fail应为 404。promo_cimanagement 三权限.*应能完成与步骤三相同的 PUT。3.6 步骤五definitions 导出拓扑版本化curl-s-u$MQUSER$MQAPI/definitions/$VHpromo-vhost-definitions.json rgex.promo.direct|q.promo.smspromo-vhost-definitions.json把该文件纳入 Git先检查没有密码字段泄露。导入curl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/definitions/$VH\--data-binary promo-vhost-definitions.json坑全集群/api/definitions含用户哈希不能当公开附件。按 VHost 导出更安全。坑导入不会删除「文件里没有但 Broker 上有」的队列不是 Terraform apply。3.7 完整代码清单promo-mq/ch05/smoke.sh#!/usr/bin/env bashset-euopipefailAPIhttp://127.0.0.1:15672/apiAUTHpromo:promo_dev_2026VHpromocurl-sf-u$AUTH$API/whoami/dev/nullcurl-sf-u$AUTH$API/health/checks/alarms/dev/nullcurl-sf-u$AUTH-Hcontent-type: application/json\-XPUT$API/exchanges/$VH/ex.promo.direct\-d{type:direct,durable:true,arguments:{}}curl-sf-u$AUTH-Hcontent-type: application/json\-XPUT$API/queues/$VH/q.promo.sms\-d{durable:true,arguments:{}}curl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/bindings/$VH/e/ex.promo.direct/q/q.promo.sms\-d{routing_key:sms,arguments:{}}routed$(curl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/exchanges/$VH/ex.promo.direct/publish\-d{properties:{delivery_mode:2},routing_key:sms,payload:hello-promo,payload_encoding:string})echo$routed|rg-qrouted:truecurl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/queues/$VH/q.promo.sms/get\-d{count:1,ackmode:ack_requeue_false,encoding:auto}|rg-qhello-promoechoCH05 smoke OKpromo-mq/ch05/ smoke.sh promo-vhost-definitions.json # 导出产物脱敏后入库3.8 测试验证编号步骤期望TC-CH05-01whoami返回当前用户TC-CH05-02smoke.sh退出码 0TC-CH05-03错误 routing_key publishrouted: falseTC-CH05-04promo_watchPUT 队列4xxTC-CH05-05health/checks/alarms无告警时 200TC-CH05-06definitions 含ex.promo.direct导出可 grep 到PowerShell 等价冒烟注意curl.execurl.exe-s-upromo:promo_dev_2026http://127.0.0.1:15672/api/whoami4. 项目总结优点与缺点工具优点缺点HTTP API语言无关、可进 CI、路径与源码 dispatcher 一致不是数据面publish/get 语义不完整Management UI直观、适合值班不可审计施工、易手滑rabbitmqctl节点级能力强、可进运维脚本输出文本要解析要 erlang cookieSDK 声明拓扑与应用一起发布环境漂移、CI 语言绑死管理平面优点1三部门共用验收语言。2definitions 让拓扑可版本化。3细粒度 health checks 适合编排探针。缺点1administrator 太好用导致滥用。2/VHost 编码坑。3API 200 routed false 被误当成成功。适用场景环境冒烟、拓扑验收、权限回归。GitOps 导入 VHost definitions。无 SDK 的跳板机排障。不适用用/publish打满大促流量用 UI 当配置存储把 aliveness-test 每秒打一次当存活探针。注意事项4.x 健康检查优先health/checks/*aliveness 有副作用。rabbitmqadminv1 下载端点在 4.3 已移除脚本迁 v2 或固定从旧分支取。应用生产账号不要打 management 标签减少攻击面。HTTP API 默认无 CSRF token 需求于基础认证场景但仍应只在内网或 mTLS第 25 章。删除队列DELETE /api/queues/{vhost}/{name}会丢掉堆积消息测试清理要显式允许。安全边界15672 与 5672 权限模型不同监控账号有 management 标签不等于有 AMQP write反之亦然评审要两张表一起看。版本兼容不同 4.x 的 health check 路径略有增减CI 不要写死「必须返回某个英文句子」只断言 HTTP 状态与 JSON 字段。常见踩坑生产K8s liveness 打 aliveness-test。节点稍慢时探针失败重启重启又让 aliveness 更慢形成死亡循环。根因选了有副作用的深检。处理liveness 用diagnostics ping或health/checks/local-alarms。CI 用 administrator 导入全量 definitions把预发用户覆盖成旧哈希。根因导出文件含 users。处理按 VHost 导出剥离 users。监控账号误配 write 权限看板点击 Purge。根因标签与 AMQP 权限两套模型没一起审。处理monitoring 空 write。思考题为什么routed: true仍不能推出「消费者处理成功」列出至少三条缺口持久化、Ack、死信。若 VHost 名包含/和空格你如何写一套「永远正确」的 URL 构造函数对 encodings 做哪些单测题 1 在第 8–10 章展开题 2 作为测试基础库作业。推广计划提示部门本章怎么用协作测试主责smoke.sh与权限拒绝用例API 作为环境门禁向开发要一份「期望拓扑」JSON而不是口头交换机名运维主责用户标签、防火墙 15672 仅办公网/跳板、definitions 备份策略提供无 administrator 的 CI 账号开发停止在 README 只写 SDK 示例补充等价 curl数据面仍用 AMQP不要把 HTTP publish 写进订单热路径安全审 whoami、标签、definitions 是否含凭据预发定期扫描 administrator 数量基础篇接下来进入消息模型第 6 章四种 Exchange 与 Binding。本章留下的ex.promo.directq.promo.sms会作为 Direct 路由的第一个对照物。附录 A完整清单与仓库位置rabbitmq-server/column/samples/ch05/smoke.sh即正文脚本。Git 钩子可在 CI 对预发执行不要在生产每分钟跑get会把消息掏走。常用 API 速查均前缀/api方法路径用途GET/whoami当前用户GET/overview节点摘要PUT/exchanges/{vhost}/{name}声明交换机PUT/queues/{vhost}/{name}声明队列POST/bindings/{vhost}/e/{ex}/q/{q}绑定POST/exchanges/{vhost}/{ex}/publish管理面发布POST/queues/{vhost}/{q}/get管理面拉取GET/definitions/{vhost}导出拓扑GET/health/checks/alarms告警探针附录 B第 4 章思考题参考答案题 1Confirm 序号与重连。Confirm 序号按Channel从 1 递增连接重建后通道是新的旧序号作废。未收到 Confirm 的消息必须靠业务message_id/订单号幂等重发不能靠「记住上次 delivery-tag」。只恢复 Connection 不重开 Channel、不重开 confirm.select等于发布可靠性归零。题 2内存告警 blocking 时 basic.get资源告警主要阻塞发布connection blocked消费与 get 通常仍允许以便排水。但 Channel 进程是否立刻响应还受流控与客户端心跳影响。第 14 章会用压测把 Overview 上的 Alarm 点亮做实验若 get 也卡住优先查磁盘告警和连接是否已被 throttle。延伸阅读与资源Dify 从入门到进阶LLM 应用平台实战修炼Java 工程师进阶从 JVM 生产排障到OpenJDK原理NumPy 从入门到生产落地全链路实战指南科学计算/向量化Redis 8 实战精讲从 CRUD 到源码构建高可用缓存系统Redis 实战修炼与原理进阶Python 3实战精进从脚本到高并发订单引擎python入门Rquests从菜鸟脚本到企业级SDK的网络实战圣经Milvus向量数据库实战修炼从 0 到 1精通向量检索与生产落地MongoDB 实战进阶与内核修炼后端工程师的 AI 转型第一课Ollama 与私有化大模型实战10倍开发者的 Dify 魔法书从零构建全栈 AI 应用后端工程师转型AI第一课-Ollama 与私有化大模型实战大型语言模型(LLM) vLLM 高性能推理落地实战Agent开发之LlamaIndex 实战修炼与源码进阶大语言模型Transformers 实战修炼与源码剖析 第5章：RabbitMQ管理平面——CLI、Management UI 与 HTTP API
1. 项目背景推广中台联调第三天现场出现「三套真相」开发用 pika 声明了ex.orders自己机器上能发。测试在 CI 容器里跑 Java 客户端报 NOT_FOUND。事后发现 CI 连的是另一套 VHostJava 封装把/编码错了。运维只开了 5672 防火墙办公网访问不了 15672只能让开发截图「队列是空的」。空是没消费者还是根本没声明截图看不出来。没有语言无关的操作面验收就被 SDK 绑死开发 SDK 声明拓扑 │ CI 不会用这个 SDK ▼ 测试「环境不对」 │ 运维不会看 AMQP 抓包 ▼ 运维「端口通了就是好的」周末值班还发生过营销同学用 UI 把q.promo.sms改成非持久「先试试」周一订单组 Java 客户端带着 durabletrue 再 declare直接 406整个发布列车失败。UI 手滑改拓扑没有 PR、没有审计这就是「菜单屏当施工图」的现场代价。管理平面必须规定谁可以改、用什么工具改、怎么验收。RabbitMQ 管理平面正好是三部门的公共语言工具典型使用者擅长rabbitmqctl运维用户、权限、关连接、节点级操作rabbitmq-diagnostics运维 / 测试健康、监听、内存、配置是否生效rabbitmq-plugins运维插件名单Management UI全员观察连接、堆积、点选声明不适合自动化HTTP API/api/*测试 / GitOps可 curl、可进 CI、可导出 definitionsrabbitmqadminv2运维脚本比原始 curl 更少编码坑本章规定拓扑验收以 HTTP API 为准人眼确认用 UI危险操作删用户、关节点用 ctl 且进审计。开发 SDK 只是数据面的一种客户端不是真相源。源码上HTTP 路由集中在rabbit_mgmt_dispatcher.erlCowboy 把/api/overview、/api/exchanges/.../publish等编进同一张表——你在 curl 里敲的路径就是这张表里的字符串。还有一层组织痛点推广中台同时服务订单、营销、数据三个事业部各部都要「看一眼队列深不深」。若人人 administrator一次误点 Purge 就能让大促积分对账对空。管理平面的用户标签和 AMQP 权限是两套闸门必须一起设计不能只开 15672 端口就算对测试友好。2. 项目设计小胖已经打开了 15672正准备用鼠标把交换机点出来。小胖这不就是食堂的电子菜单屏吗点一点菜就出来了为啥还要 curl测试同学学几个按钮不香吗大师菜单屏适合值班看「今天窗口堵不堵」。你用鼠标点出来的队列没有 diff、没有 PR、没有重复执行。大促当天凌晨三点测试要在干净 VHost 里一键铺拓扑只能 API 或 definitions 导入。UI 是观察窗不是施工图。技术映射UI 和 HTTP API 走同一套rabbit_mgmt_wm_*资源但 CI 只能打 API不能打按钮。小白那rabbitmqctl和 HTTP API 会不会改到不同的元数据有没有最终一致延迟用户标签monitoring能不能声明队列policymaker呢万一 CI 用了 administrator会不会误删生产 definitions另外 vhost 名叫promo还好名叫/时 URL 怎么写大师单节点上 ctl 和 API 改的是同一套 Khepri 元数据通常立刻可见你要担心的不是延迟是权限模型administrator 全能monitoring 只读监控policymaker 能改 policy 不能当超级管理员乱用management 能进 UI 看自己权限范围内的对象。CI 必须用最小标签铺拓扑用单独的promo_ci账号configure/write/read 限制在promoVHost不要administrator。VHost/在 URL 里编码为%2F这是历史上最多的 404 来源——我们默认业务 VHost 用promo就是为了少踩这个坑。小胖那我用 API 发消息和用 AMQP publish 有啥不一样测试能不能只测 API 就算测过 MQ大师API 的 publish/get 是管理通道上的短请求走 HTTP确认语义、性能、流控和 AMQP 数据面不同。可以用来做拓扑与浅显投递验收不能替代消费者 Ack、Confirm、prefetch 测试。小胖记住API 发一条只证明「路由存在」不证明「大促 3000 TPS 数据面正常」。技术映射/api/exchanges/{vhost}/{ex}/publish是管理面basic.publish才是数据面。小白definitions 导出导入能当备份吗健康检查该打/api/aliveness-test还是新的/api/health/checks/*dispatcher 里我看到 aliveness 还在也有一堆 health/checks。大师definitions 适合拓扑搬迁不是 WAL不能当消息备份。aliveness-test 会在目标 VHost真的声明临时队列并收发有副作用高频率探针可能留下垃圾或抢锁4.x 推荐细粒度/api/health/checks/alarms、local-alarms、virtual-hosts等给 K8s 探针。第 29 章再接到 Operator。今天测试把 checks 写进冒烟把 aliveness 留作偶尔的「深检」。小胖闭环实验就一句话curl 把菜谱写上墙再夹一筷子尝尝UI 围观ctl 查户口。大师对。再加一条用whoami证明 CI 账号不是 administrator。这比任何规范 PDF 都硬。小白HTTP API 的 Basic Auth 走明文办公网中间人能不能偷到promo_cipublish 接口会不会被当成后门绕过应用鉴权直接灌消息测试环境暴露 15672 到公网是否可接受大师预发也必须把 15672 绑在内网或跳板生产叠加 TLS第 25 章。管理面 publish就是一条能灌消息的后门所以 CI 账号可以 write值班只读账号绝不能 write。应用鉴权在业务服务Broker 只认 AMQP/HTTP 用户。两套鉴权都要有缺管理面闸门时拿到密码等于拿到路由权。技术映射15672 的 publish 持有 write 权限的管理通道不是「只读监控端口」。3. 项目实战3.1 环境准备节点第 3 章基线容器rabbit-promo-1用户promo/promo_dev_2026VHostpromo该用户目前是管理员仅限本章演示。工具curlWindows 可用 Git Bash 或curl.exe、浏览器、docker exec。约定环境变量Git BashexportMQAPIhttp://127.0.0.1:15672/apiexportMQUSERpromo:promo_dev_2026exportVHpromoWindows PowerShell$mqhttp://127.0.0.1:15672/api$pairpromo:promo_dev_2026$vhpromo3.2 步骤一CLI 户口与诊断步骤目标分清 ctl / diagnostics / plugins并列出即将用于 CI 的最小权限用户。dockerexecrabbit-promo-1 rabbitmq-diagnosticspingdockerexecrabbit-promo-1 rabbitmq-diagnostics listenersdockerexecrabbit-promo-1 rabbitmqctl list_usersdockerexecrabbit-promo-1 rabbitmqctl list_vhostsdockerexecrabbit-promo-1 rabbitmqctl list_user_permissions promodockerexecrabbit-promo-1 rabbitmq-plugins list-E创建测试专用账号不要再给 administratordockerexecrabbit-promo-1 rabbitmqctl add_user promo_ci ci_dev_2026dockerexecrabbit-promo-1 rabbitmqctl set_user_tags promo_ci managementdockerexecrabbit-promo-1 rabbitmqctl set_permissions-ppromo promo_ci.*.*.*只读观察账号dockerexecrabbit-promo-1 rabbitmqctl add_user promo_watch watch_dev_2026dockerexecrabbit-promo-1 rabbitmqctl set_user_tags promo_watch monitoringdockerexecrabbit-promo-1 rabbitmqctl set_permissions-ppromo promo_watch^$^$.*monitoring 空 configure/write只能看不能声明。下一步用 API 验证拒绝。坑set_user_tags覆盖标签列表不是追加。写两次后者为准。坑权限三个正则依次是 configure、write、read。promo_watch的^$表示空串才匹配即不能声明任何对象。标签对照讲给安全评审听tag能进 UI典型能力administrator是全 VHost、全管理操作monitoring是看全局统计不能乱改拓扑policymaker是管 policymanagement是仅自己有权限的对象无 tag否纯 AMQP 应用账号生产推荐3.3 步骤二UI 走查人眼不写进 CI打开http://localhost:15672用promo登录。必看页面Overview节点、告警、Connections、Channels、Exchanges、Queues、Admin → Users / Vhosts。右上角 VHost 切到promo。用promo_watch再登录一次尝试 Add queue应失败或无入口。把截图贴 Wiki「最小权限证据」。坑浏览器缓存了旧用户 cookie表现为「明明改了权限还是管理员」。无痕窗口。3.4 步骤三HTTP API 拓扑闭环本章核心步骤目标声明直连交换机、持久队列、绑定、发布、拉取全程 curl。健康与身份curl-s-u$MQUSER$MQAPI/whoamicurl-s-u$MQUSER$MQAPI/overview|rg-o\cluster_name\:\[^\]\curl-s-u$MQUSER$MQAPI/health/checks/alarmscurl-s-u$MQUSER$MQAPI/health/checks/virtual-hostswhoami期望含name:promo。alarms在无告警时应是 ok 类响应HTTP 200。运行结果示例{name:promo,tags:[administrator]} # health/checks/alarms 无告警时 HTTP 200body 类似 {status:ok}若whoami返回 401先查用户是否只在/存在而请求打到了别的认证链若 200 但 tags 为空该用户进不了部分 UI 菜单但 AMQP 仍可能可连。声明交换机与队列PUT 幂等curl-s-u$MQUSER-Hcontent-type: application/json\-XPUT$MQAPI/exchanges/$VH/ex.promo.direct\-d{type:direct,durable:true,auto_delete:false,internal:false,arguments:{}}curl-s-u$MQUSER-Hcontent-type: application/json\-XPUT$MQAPI/queues/$VH/q.promo.sms\-d{durable:true,auto_delete:false,arguments:{}}绑定smsrouting keycurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/bindings/$VH/e/ex.promo.direct/q/q.promo.sms\-d{routing_key:sms,arguments:{}}发布curl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/exchanges/$VH/ex.promo.direct/publish\-d{ properties: {delivery_mode: 2, content_type: application/json}, routing_key: sms, payload: {\orderId\:\P20260828001\,\type\:\PAY_OK\}, payload_encoding: string }期望 body 含routed: true。若routed: false绑定错了或 VHost 错了——这就是不靠 SDK 的路由验收。拉取管理面 get会真正把消息取出注意 ack_modecurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/queues/$VH/q.promo.sms/get\-d{count:1,ackmode:ack_requeue_false,encoding:auto,truncate:50000}期望 payload 里看到P20260828001。ack_requeue_false表示取出并确认队列应回到 0。再发一条用错误 keycurl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/exchanges/$VH/ex.promo.direct/publish\-d{properties:{},routing_key:no-such,payload:lost?,payload_encoding:string}期望routed: false。默认交换器之外无法路由的消息被丢弃除非 AMQPmandatoryAPI 这条短发布不提供完整 mandatory 语义。测试把routed: false写成明确用例避免开发以为「HTTP 200 就是送到了」。坑 1VHost/必须写成%2Fhttp://127.0.0.1:15672/api/queues/%2F/my-queue漏编码会 404。坑 2名字里的/、中文必须 URL encode。坑 3PUT 队列时 JSON 字段名是durable不是Durable。坑 4get的ackmode拼写是ackmode小写值如ack_requeue_true/reject_requeue_false。写错返回 400。坑 5PowerShellcurl是Invoke-WebRequest别名请用curl.exe。对照 dispatcher 源码确认路径不是文档写错dispatcher() - [{/overview, rabbit_mgmt_wm_overview, []}, {/cluster-name, rabbit_mgmt_wm_cluster_name, []}, ... {/exchanges/:vhost/:exchange/publish, rabbit_mgmt_wm_exchange_publish, []}, ... {/queues/:vhost/:queue/get, rabbit_mgmt_wm_queue_get, []},{/aliveness-test/:vhost, rabbit_mgmt_wm_aliveness_test, []}, {/health/checks/alarms, rabbit_mgmt_wm_health_check_alarms, []}, {/health/checks/local-alarms, rabbit_mgmt_wm_health_check_local_alarms, []}, {/health/checks/virtual-hosts, rabbit_mgmt_wm_health_check_virtual_hosts, []},实际 HTTP 路径会加上/api前缀build_module_routes里拼接。3.5 步骤四用最小权限账号证明拒绝# monitoring 不能 PUT 队列curl-s-o/tmp/watch-body-w%{http_code}-upromo_watch:watch_dev_2026\-Hcontent-type: application/json\-XPUT$MQAPI/queues/$VH/q.should.fail\-d{durable:true}echocat/tmp/watch-body期望 HTTP401 或 403队列不存在curl-s-o/dev/null-w%{http_code}-u$MQUSER$MQAPI/queues/$VH/q.should.fail应为 404。promo_cimanagement 三权限.*应能完成与步骤三相同的 PUT。3.6 步骤五definitions 导出拓扑版本化curl-s-u$MQUSER$MQAPI/definitions/$VHpromo-vhost-definitions.json rgex.promo.direct|q.promo.smspromo-vhost-definitions.json把该文件纳入 Git先检查没有密码字段泄露。导入curl-s-u$MQUSER-Hcontent-type: application/json\-XPOST$MQAPI/definitions/$VH\--data-binary promo-vhost-definitions.json坑全集群/api/definitions含用户哈希不能当公开附件。按 VHost 导出更安全。坑导入不会删除「文件里没有但 Broker 上有」的队列不是 Terraform apply。3.7 完整代码清单promo-mq/ch05/smoke.sh#!/usr/bin/env bashset-euopipefailAPIhttp://127.0.0.1:15672/apiAUTHpromo:promo_dev_2026VHpromocurl-sf-u$AUTH$API/whoami/dev/nullcurl-sf-u$AUTH$API/health/checks/alarms/dev/nullcurl-sf-u$AUTH-Hcontent-type: application/json\-XPUT$API/exchanges/$VH/ex.promo.direct\-d{type:direct,durable:true,arguments:{}}curl-sf-u$AUTH-Hcontent-type: application/json\-XPUT$API/queues/$VH/q.promo.sms\-d{durable:true,arguments:{}}curl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/bindings/$VH/e/ex.promo.direct/q/q.promo.sms\-d{routing_key:sms,arguments:{}}routed$(curl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/exchanges/$VH/ex.promo.direct/publish\-d{properties:{delivery_mode:2},routing_key:sms,payload:hello-promo,payload_encoding:string})echo$routed|rg-qrouted:truecurl-sf-u$AUTH-Hcontent-type: application/json\-XPOST$API/queues/$VH/q.promo.sms/get\-d{count:1,ackmode:ack_requeue_false,encoding:auto}|rg-qhello-promoechoCH05 smoke OKpromo-mq/ch05/ smoke.sh promo-vhost-definitions.json # 导出产物脱敏后入库3.8 测试验证编号步骤期望TC-CH05-01whoami返回当前用户TC-CH05-02smoke.sh退出码 0TC-CH05-03错误 routing_key publishrouted: falseTC-CH05-04promo_watchPUT 队列4xxTC-CH05-05health/checks/alarms无告警时 200TC-CH05-06definitions 含ex.promo.direct导出可 grep 到PowerShell 等价冒烟注意curl.execurl.exe-s-upromo:promo_dev_2026http://127.0.0.1:15672/api/whoami4. 项目总结优点与缺点工具优点缺点HTTP API语言无关、可进 CI、路径与源码 dispatcher 一致不是数据面publish/get 语义不完整Management UI直观、适合值班不可审计施工、易手滑rabbitmqctl节点级能力强、可进运维脚本输出文本要解析要 erlang cookieSDK 声明拓扑与应用一起发布环境漂移、CI 语言绑死管理平面优点1三部门共用验收语言。2definitions 让拓扑可版本化。3细粒度 health checks 适合编排探针。缺点1administrator 太好用导致滥用。2/VHost 编码坑。3API 200 routed false 被误当成成功。适用场景环境冒烟、拓扑验收、权限回归。GitOps 导入 VHost definitions。无 SDK 的跳板机排障。不适用用/publish打满大促流量用 UI 当配置存储把 aliveness-test 每秒打一次当存活探针。注意事项4.x 健康检查优先health/checks/*aliveness 有副作用。rabbitmqadminv1 下载端点在 4.3 已移除脚本迁 v2 或固定从旧分支取。应用生产账号不要打 management 标签减少攻击面。HTTP API 默认无 CSRF token 需求于基础认证场景但仍应只在内网或 mTLS第 25 章。删除队列DELETE /api/queues/{vhost}/{name}会丢掉堆积消息测试清理要显式允许。安全边界15672 与 5672 权限模型不同监控账号有 management 标签不等于有 AMQP write反之亦然评审要两张表一起看。版本兼容不同 4.x 的 health check 路径略有增减CI 不要写死「必须返回某个英文句子」只断言 HTTP 状态与 JSON 字段。常见踩坑生产K8s liveness 打 aliveness-test。节点稍慢时探针失败重启重启又让 aliveness 更慢形成死亡循环。根因选了有副作用的深检。处理liveness 用diagnostics ping或health/checks/local-alarms。CI 用 administrator 导入全量 definitions把预发用户覆盖成旧哈希。根因导出文件含 users。处理按 VHost 导出剥离 users。监控账号误配 write 权限看板点击 Purge。根因标签与 AMQP 权限两套模型没一起审。处理monitoring 空 write。思考题为什么routed: true仍不能推出「消费者处理成功」列出至少三条缺口持久化、Ack、死信。若 VHost 名包含/和空格你如何写一套「永远正确」的 URL 构造函数对 encodings 做哪些单测题 1 在第 8–10 章展开题 2 作为测试基础库作业。推广计划提示部门本章怎么用协作测试主责smoke.sh与权限拒绝用例API 作为环境门禁向开发要一份「期望拓扑」JSON而不是口头交换机名运维主责用户标签、防火墙 15672 仅办公网/跳板、definitions 备份策略提供无 administrator 的 CI 账号开发停止在 README 只写 SDK 示例补充等价 curl数据面仍用 AMQP不要把 HTTP publish 写进订单热路径安全审 whoami、标签、definitions 是否含凭据预发定期扫描 administrator 数量基础篇接下来进入消息模型第 6 章四种 Exchange 与 Binding。本章留下的ex.promo.directq.promo.sms会作为 Direct 路由的第一个对照物。附录 A完整清单与仓库位置rabbitmq-server/column/samples/ch05/smoke.sh即正文脚本。Git 钩子可在 CI 对预发执行不要在生产每分钟跑get会把消息掏走。常用 API 速查均前缀/api方法路径用途GET/whoami当前用户GET/overview节点摘要PUT/exchanges/{vhost}/{name}声明交换机PUT/queues/{vhost}/{name}声明队列POST/bindings/{vhost}/e/{ex}/q/{q}绑定POST/exchanges/{vhost}/{ex}/publish管理面发布POST/queues/{vhost}/{q}/get管理面拉取GET/definitions/{vhost}导出拓扑GET/health/checks/alarms告警探针附录 B第 4 章思考题参考答案题 1Confirm 序号与重连。Confirm 序号按Channel从 1 递增连接重建后通道是新的旧序号作废。未收到 Confirm 的消息必须靠业务message_id/订单号幂等重发不能靠「记住上次 delivery-tag」。只恢复 Connection 不重开 Channel、不重开 confirm.select等于发布可靠性归零。题 2内存告警 blocking 时 basic.get资源告警主要阻塞发布connection blocked消费与 get 通常仍允许以便排水。但 Channel 进程是否立刻响应还受流控与客户端心跳影响。第 14 章会用压测把 Overview 上的 Alarm 点亮做实验若 get 也卡住优先查磁盘告警和连接是否已被 throttle。延伸阅读与资源Dify 从入门到进阶LLM 应用平台实战修炼Java 工程师进阶从 JVM 生产排障到OpenJDK原理NumPy 从入门到生产落地全链路实战指南科学计算/向量化Redis 8 实战精讲从 CRUD 到源码构建高可用缓存系统Redis 实战修炼与原理进阶Python 3实战精进从脚本到高并发订单引擎python入门Rquests从菜鸟脚本到企业级SDK的网络实战圣经Milvus向量数据库实战修炼从 0 到 1精通向量检索与生产落地MongoDB 实战进阶与内核修炼后端工程师的 AI 转型第一课Ollama 与私有化大模型实战10倍开发者的 Dify 魔法书从零构建全栈 AI 应用后端工程师转型AI第一课-Ollama 与私有化大模型实战大型语言模型(LLM) vLLM 高性能推理落地实战Agent开发之LlamaIndex 实战修炼与源码进阶大语言模型Transformers 实战修炼与源码剖析 RELATED READING
延伸阅读
更多一线实战笔记与深度复盘，助您持续精进
