RocketMQ

You deploy the RocketMQ MCP Server to bridge your RocketMQ MCP endpoints with clients, enabling real-time data and control flows through a lightweight server that can be started from a build artifact and configured to connect to your MCP endpoints.

How to use

You use the MCP server by pointing your MCP client at the server’s HTTP endpoint or by running the server locally and connecting via the provided interface. The server exposes a streaming endpoint you can monitor and a management path to integrate your RocketMQ MCP server with your existing infrastructure. To start exchanging data, ensure your client is configured to reach the MCP server URL and that the server has access to your RocketMQ name servers.

How to install

# Prerequisites
- Java Runtime Environment (JRE) or JDK 8+ installed on your system
- A Unix-like shell to run build and start commands

# Step 1: Build the MCP server package
./build.sh

# Step 2: Run the MCP server
java -jar target/rocketmq-mcp-server.jar

# Step 3: Verify the running server (in another terminal)
curl http://127.0.0.1:6868/sse

Additional content

Configure your MCP client to connect to the server by providing the server URL and credentials as shown in the usage example. The server URL should point to the HTTP endpoint where the MCP server exposes its services. You can supply a name server address list and authentication keys as environment values when configuring your client. The following example demonstrates how to specify the server URL and environment values for your client connection.

{
  "mcpServers": {
    "rocketmq_mcp": {
      "url": "http://your-rocketmq-mcp-server-ip:6868/sse",
      "env": {
        "NS_ADDR": "1.1.1.1:9876;2.2.2.2:9876", 
        "AK": "",
        "SK": ""
      }
    }
  }
}

NS_ADDR: name server address list
AK: access key
SK: secret key