RocketMQ MCP 服务器

Apache RocketMQ MCP Server 是一个用于管理和查询 RocketMQ 消息的服务器,支持通过自然语言进行消息查询和发送。

  • by weihubeats
  • Java
  • 混合部署
  • 更新于
在 GitHub 查看 weihubeats/rocketmq-mcp

使用说明

rocketmq-mcp

Apache RocketMQ MCP Server

use

  1. 配置集群

  2. 修改application.yaml文件,添加RocketMQ集群配置

rocketmq:
  clusters:
    - id: 1
      name: xiaoZou
      namesrv-addr: 127.0.0.1:9876
  1. 运行 MCPApplication.java

  2. 验证mcp server是否启动成功

  • 安装 inspector
npx @modelcontextprotocol/inspector node build/index.js

配置 mcp server

{
  "mcpServers": {
    "rocketmq-mcp": {
      "url": "http://localhost:8081/sse",
      "disabled": false,
      "autoApprove": []
    }
  }
}

使用自然语言查询消息

查询集群为xiaozou,topic为xiao-zou-topic,消息id为AC1400010D3E068DE14531D104E40176的消息

使用自然语言发送消息

发送消息到集群为`xiaozou`,topic为`xiao-zou-topic`,消息内容为wh-test-send