mcp-server-rabbitmq
Provides tools for interacting with RabbitMQ, including declaring exchanges, queues, and bindings, publishing and pull-consuming messages, diagnosing queue backlogs, and monitoring cluster, connection, and queue metrics through the RabbitMQ Management HTTP API. It also supports guarded high-risk operations such as purging queues, deleting queues, and unbinding exchanges.
Click on "Deploy Server".
Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state.
In the chat, type
@followed by the MCP server name and your instructions, e.g., "@mcp-server-rabbitmqcheck the current backlog on the orders queue"
That's it! The server will respond to your query, and you can continue using it as needed.
Here is a step-by-step guide with screenshots.
mcp-server-rabbitmq
专为大语言模型(LLM)打造的高性能、安全可控的生产级 RabbitMQ 模型上下文协议(Model Context Protocol, MCP)服务,基于 Python 与 FastMCP 构建。
为大模型提供直观可靠的 AMQP 拓扑声明(Exchange / Queue / Binding)、消息发布与消费拉取、积压诊断、集群与连接状态监控及管理能力。
💡 版本更新日志 (Changelog): 每一个正式版本的详细变动明细、关联 Issue 与贡献者致谢均由
git-cliff自动维护,可直接前往 GitHub Releases 查看最新记录。
✨ 核心特性
🎯 双核驱动支持:
AMQP 0-9-1 协议通道:基于异步驱动高效处理消息生产、消息消费(单条拉取/批量采样)与拓扑管理;
RabbitMQ Management HTTP API:一站式检索集群节点、连接数、Channel 状态与队列堆积指标;
🛡️ 生产级安全守卫:
默认防护与危险操作二次确认:对队列清空(Purge)、队列删除(Delete)、交换机解绑等高危动作实施显式确认机制;
凭据脱敏保护:对外连接与拓扑信息输出自动对敏感凭据实施掩码脱敏,杜绝安全泄露;
📦 开箱即用与跨平台分发:
支持
uvx/pipx零依赖瞬间拉起;提供预构建的生产级多架构 Docker 镜像(支持 AMD64 与 ARM64);
支持 Stdio 标准管道交互与常驻 HTTP SSE 双模通信。
Related MCP server: rabbitmq-mcp
📦 安装与快速运行
方式 1:使用 uvx 免安装直接运行(强烈推荐)
无需手动配置虚拟环境,借助现代 Python 包管理工具 uv 即可直接拉取并启动:
# 启动 Stdio 模式(连接本地 RabbitMQ 默认实例)
uvx atengk-mcp-server-rabbitmq --url "amqp://guest:guest@localhost:5672/"
# 配合 Management HTTP API 启用完整运维监控能力
uvx atengk-mcp-server-rabbitmq \
--url "amqp://guest:guest@localhost:5672/" \
--management-url "http://guest:guest@localhost:15672"方式 2:使用 pip 安装运行
pip install atengk-mcp-server-rabbitmq
# 启动服务
atengk-mcp-server-rabbitmq --url "amqp://guest:guest@localhost:5672/"方式 3:源码本地克隆与开发运行
git clone https://github.com/atengk/mcp-server-rabbitmq.git
cd mcp-server-rabbitmq
# 使用 uv 同步依赖与构建虚拟环境
uv sync
# 本地执行测试与运行
uv run pytest
uv run atengk-mcp-server-rabbitmq --url "amqp://guest:guest@localhost:5672/"方式 4:使用 Docker 容器化运行
# 瞬态交互运行(stdio 管道)
docker run -i --rm \
-e MCP_RABBITMQ_URL="amqp://guest:guest@host.docker.internal:5672/" \
ghcr.io/atengk/mcp-server-rabbitmq:latest --transport stdio
# 常驻后台 HTTP SSE 服务端(暴露 8000 端口)
docker-compose up -d🤝 参与贡献
欢迎任何形式的贡献、Issue 反馈与功能提案!请在发起 PR 前仔细阅读我们的 贡献指南 (CONTRIBUTING.md)。
📄 开源许可证
本项目基于 Apache License 2.0 协议开源。
This server cannot be deployed
Maintenance
Related MCP Connectors
MCP-Native LLM Orchestration Agent
LLM Orchestration Agent (Mcp)
Your org's AI agents, tasks, runs, search, and brain files as MCP tools and resources.
Agent communication platform for agent to agent messaging via MCP. Messages, channels, skills.
Related MCP Servers
- AlicenseBqualityDmaintenanceAn MCP server for RabbitMQ that exposes the RabbitMQ HTTP API as tools, enabling natural language interaction with RabbitMQ management.100251 npm1MIT
- AlicenseNot gradedqualityBmaintenanceEnables LLM agents to manage RabbitMQ queues, exchanges, and shovels via MCP tools, with restricted mode for production environments.Apache 2.0
- AlicenseBqualityAmaintenanceEnables AI agents to manage RabbitMQ message brokers through admin APIs, supporting multiple brokers, OAuth authentication, and mutative tools.39151 PyPI42Apache 2.0
- FlicenseCqualityDmaintenanceEnables management of RabbitMQ clusters, queues, exchanges, bindings, users, and messages through natural language in chat interfaces, using the MCP protocol.201-