RabbitMQ MCP 服务器

RabbitMQ MCP 服务器

借助 RabbitMQ MCP 服务器为 FlowHunt,实现 AI 智能体的自动化 RabbitMQ 队列管理、监控和代理管理。

“RabbitMQ” MCP 服务器能做什么?

RabbitMQ MCP 服务器是一种模型上下文协议(MCP)服务器实现,旨在让 AI 助手能够管理并与 RabbitMQ 消息代理交互。通过将 RabbitMQ 代理的管理 API 封装为 MCP 工具,并利用 Pika 库进行消息级别的交互,该服务器允许 AI 智能体执行如队列管理、消息收发、代理状态监控等任务。RabbitMQ MCP 服务器支持与 MCP 客户端的无缝集成,提供 FastMCP 的 BearerAuthProvider 可流式 HTTP,并允许用户在会话中切换不同的 RabbitMQ 代理。它通过赋能 AI 智能体自动化消息队列操作,简化开发流程,使开发者更容易构建和管理健壮的分布式系统。

提示词模板列表

在仓库中未发现文档化的提示词模板。

资源列表

在仓库中未发现显式资源定义。

工具列表

  • 管理 API 封装:将 RabbitMQ 管理 API 作为 MCP 工具暴露,支持 AI 客户端执行代理管理任务。
  • 基于 Pika 的消息操作:利用 Pika 库与 RabbitMQ 消息级别交互,支持队列/消息的创建、消费和删除。
  • 代理切换工具:允许在对话过程中指定不同的 RabbitMQ 代理,实现动态上下文切换。
    (描述基于 README 推断;server.py 中未列出显式工具函数名。)

该 MCP 服务器的应用场景

  • 自动化队列管理:开发者可通过 AI 智能体以编程方式创建、删除或配置消息队列,简化基础设施管理。
  • 消息监控与消费:AI 助手可监控队列状态、消费消息,并提供实时分析或告警,提升可观测性。
  • 代理管理:如用户管理、权限设置、代理健康检查等日常管理操作可通过 MCP 工具自动化完成。
  • 动态代理切换:在多环境流程(如预生产到生产)中,AI 智能体可动态切换 RabbitMQ 端点,无需重新部署。
  • 集成测试:开发者可通过 AI 驱动的 MCP 操作脚本化自动测试分布式应用,模拟消息流并验证队列状态。

如何进行设置

Windsurf

  1. 确保你的系统已安装 Node.js 和 uvx
  2. 打开 Windsurf 配置文件。
  3. mcpServers 配置中添加 RabbitMQ MCP 服务器。
  4. 保存修改并重启 Windsurf。
  5. 通过查看 MCP 服务器日志和 Windsurf 界面验证连接。

JSON 示例:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uvx",
      "args": [
        "mcp-server-rabbitmq@latest",
        "--rabbitmq-host", "<hostname>",
        "--port", "<port number>",
        "--username", "<rabbitmq username>",
        "--password", "<rabbitmq password>",
        "--use-tls", "<true|false>"
      ]
    }
  }
}

API Key 安全存储(环境变量示例):

{
  "env": {
    "RABBITMQ_USERNAME": "<rabbitmq username>",
    "RABBITMQ_PASSWORD": "<rabbitmq password>"
  },
  "inputs": {
    "username": "${RABBITMQ_USERNAME}",
    "password": "${RABBITMQ_PASSWORD}"
  }
}

Claude

  1. 安装 uvx 并确保 Claude 已更新到最新版。
  2. 打开 Claude 配置文件。
  3. mcpServers 区块中插入 RabbitMQ MCP 服务器配置。
  4. 保存文件并重启 Claude。
  5. 通过向 RabbitMQ MCP 服务器发送测试命令确认设置成功。

JSON 示例:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uvx",
      "args": [
        "mcp-server-rabbitmq@latest",
        "--rabbitmq-host", "<hostname>",
        "--port", "<port number>",
        "--username", "<rabbitmq username>",
        "--password", "<rabbitmq password>",
        "--use-tls", "<true|false>"
      ]
    }
  }
}

凭据安全存储请参考上方环境变量示例。

Cursor

  1. 安装最新版 Cursor,并确保 uvx 可用。
  2. 找到 Cursor 的配置文件。
  3. mcpServers 下添加 RabbitMQ MCP 服务器条目。
  4. 保存配置并重新启动 Cursor。
  5. 通过发起 MCP 命令测试集成。

JSON 示例:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uvx",
      "args": [
        "mcp-server-rabbitmq@latest",
        "--rabbitmq-host", "<hostname>",
        "--port", "<port number>",
        "--username", "<rabbitmq username>",
        "--password", "<rabbitmq password>",
        "--use-tls", "<true|false>"
      ]
    }
  }
}

敏感信息请参考前述环境变量方式存储。

Cline

  1. 确认已安装 Cline 和 uvx
  2. 编辑 Cline 配置文件。
  3. mcpServers 下注册 RabbitMQ MCP 服务器。
  4. 重启 Cline 应用更改。
  5. 通过连接 RabbitMQ MCP 服务器检查运行情况。

JSON 示例:

{
  "mcpServers": {
    "rabbitmq": {
      "command": "uvx",
      "args": [
        "mcp-server-rabbitmq@latest",
        "--rabbitmq-host", "<hostname>",
        "--port", "<port number>",
        "--username", "<rabbitmq username>",
        "--password", "<rabbitmq password>",
        "--use-tls", "<true|false>"
      ]
    }
  }
}

环境变量配置方式同前述说明。

如何在流程中使用此 MCP

在 FlowHunt 中使用 MCP

要将 MCP 服务器集成到你的 FlowHunt 工作流中,请先在流程中添加 MCP 组件,并将其连接到你的 AI 智能体:

FlowHunt MCP flow

点击 MCP 组件打开配置面板。在系统 MCP 配置区,按以下 JSON 格式填写你的 MCP 服务器信息:

{
  "rabbitmq": {
    "transport": "streamable_http",
    "url": "https://yourmcpserver.example/pathtothemcp/url"
  }
}

配置完成后,AI 智能体即可将此 MCP 作为工具使用,获得其全部功能。请将 “rabbitmq” 替换为你实际的 MCP 服务器名称,并将 URL 替换为你自己的 MCP 服务器地址。


概览

部分可用性说明
概览README 中有描述
提示词模板列表没有发现提示模板
资源列表没有发现显式资源定义
工具列表工具描述可从 README 推断
API Key 安全存储README/配置示例中有环境变量用法
采样支持(评估不重要)未提及采样支持

综上,RabbitMQ MCP 服务器在集成和设置文档上表现良好,注重工具使用与安全,但在公开文档中缺少明确的提示词模板和资源定义。Roots 和采样支持暂未记录。


MCP 评分

是否有 LICENSE✅ (Apache-2.0)
至少有一个工具
Fork 数量8
Star 数量28

评分:
我给该 MCP 服务器的评分为 7/10。文档完整,适合工具型 RabbitMQ 集成,但如能补充明确的提示词模板、资源定义及 Roots 和采样的文档支持会更佳。

常见问题

什么是 RabbitMQ MCP 服务器?

RabbitMQ MCP 服务器是一款模型上下文协议(MCP)服务器,使 AI 助手能够自动化并管理 RabbitMQ 消息代理。它通过 MCP 工具提供队列管理、消息操作和代理管理,并可与 FlowHunt 工作流无缝集成。

AI 智能体可以用该服务器完成哪些任务?

AI 智能体可以管理队列、发送和接收消息、监控代理状态、执行管理操作、动态切换 RabbitMQ 代理,并自动化分布式系统的集成测试。

如何保护我的 RabbitMQ 凭据安全?

建议使用环境变量存储用户名和密码等敏感信息。请参考设置示例,了解如何在配置中安全注入凭据。

这个 MCP 服务器支持不同的 MCP 客户端吗?

支持,RabbitMQ MCP 服务器可集成多种 MCP 客户端,包括 Windsurf、Claude、Cursor 和 Cline。每个客户端的具体配置步骤请参考文档。

RabbitMQ MCP 服务器支持动态代理切换吗?

支持,你可以在对话过程中指定不同的 RabbitMQ 代理,让 AI 智能体无需重启或重新配置服务器即可在(如预发与生产)环境间切换。

使用 FlowHunt 体验 RabbitMQ MCP 服务器

无缝集成 RabbitMQ 自动化至你的 AI 工作流。让智能体管理队列、监控消息并自动化代理操作——无需人工干预。

了解更多

MCP 代理服务器
MCP 代理服务器

MCP 代理服务器

MCP 代理服务器将多个 MCP 资源服务器聚合为一个 HTTP 服务器,为 AI 助手和开发者简化连接。它实现了对多样化工具、API 和数据源的统一访问,支持实时流式传输与集中式认证。...

2 分钟阅读
AI Infrastructure +4
OpenRPC MCP 服务器
OpenRPC MCP 服务器

OpenRPC MCP 服务器

OpenRPC MCP 服务器通过 OpenRPC 规范将 AI 助手与支持 JSON-RPC 的系统连接,实现与外部 API 和服务的可编程、动态集成。它使开发者和 AI 代理能够发现、调用和自动化远程过程,提升工作流、调试和服务编排能力。...

2 分钟阅读
MCP Server OpenRPC +5
Kubernetes MCP 服务器
Kubernetes MCP 服务器

Kubernetes MCP 服务器

Kubernetes MCP 服务器连接 AI 助手与 Kubernetes/OpenShift 集群,实现通过自然语言工作流进行资源管理、Pod 操作和 DevOps 自动化。...

2 分钟阅读
Kubernetes MCP Server +4