Rocketmq Mcp

基本能力

产品定位

rocketmq-mcp 是一个消息消费代理服务，主要用于与 RocketMQ 消息队列进行交互，提供实时消息推送能力。

核心功能

1. 提供 SSE（Server-Sent Events）接口，允许客户端通过 HTTP 协议实时接收 RocketMQ 的消息。
2. 支持配置 RocketMQ 的 Name Server 地址、Access Key 和 Secret Key。
3. 提供简单的启动和检查接口。

适用场景

1. 需要实时消费 RocketMQ 消息的场景。
2. 需要通过 HTTP 协议与 RocketMQ 交互的场景。
3. 需要轻量级消息代理服务的场景。

工具列表

1. curl：用于检查服务是否正常运行，通过发送 HTTP 请求到 SSE 接口。
2. java -jar：用于启动 rocketmq-mcp 服务。

常见问题解答

1. 如何检查服务是否正常运行？ 使用 curl http://127.0.0.1:6868/sse 命令，如果返回 SSE 格式的数据，则服务正常运行。
2. 如何配置 RocketMQ 的 Name Server 地址？ 在配置文件中设置 NS_ADDR 参数，格式为 1.1.1.1:9876;2.2.2.2:9876。

使用教程

使用依赖

1. 确保已安装 Java 运行环境（JRE 或 JDK）。
2. 确保已安装 RocketMQ 并配置好 Name Server 地址。

安装教程

1. 克隆或下载 rocketmq-mcp 项目。
2. 进入项目目录，运行以下命令构建项目： shell ./build.sh
3. 构建完成后，运行以下命令启动服务： shell java -jar target/rocketmq-mcp-server.jar

调试方式

1. 启动服务后，使用以下命令检查服务是否正常运行： shell curl http://127.0.0.1:6868/sse 如果返回类似以下内容，则服务正常运行： id:8e323b3b-cb73-4b35-8ac5-172b453eae79 event:endpoint data:sse
2. 在客户端配置文件中设置 url 和 env 参数，确保正确连接到 rocketmq-mcp 服务。

许可证

该项目遵循 Apache-2.0 开源许可条款，请参阅 Apache-2.0 了解完整条款。