The remote HTTP path (starred default) previously ended at localhost:3000 with no next steps. Adds CF Workers deploy reference, Inspector test commands, user-connection guide, and a versions ledger. Swaps the build-mcp-app scaffold from stdio to streamable-HTTP to match the remote-first stance.
6.9 KiB
Remote Streamable-HTTP MCP Server — Scaffold
Minimal working servers in both recommended frameworks. Start here, then add tools.
TypeScript SDK (@modelcontextprotocol/sdk)
npm init -y
npm install @modelcontextprotocol/sdk zod express
npm install -D typescript @types/express @types/node tsx
src/server.ts
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";
import express from "express";
import { z } from "zod";
const server = new McpServer(
{ name: "my-service", version: "0.1.0" },
{ instructions: "Prefer search_items before calling get_item directly — IDs aren't guessable." },
);
// Pattern A: one tool per action
server.registerTool(
"search_items",
{
description: "Search items by keyword. Returns up to `limit` matches ranked by relevance.",
inputSchema: {
query: z.string().describe("Search keywords"),
limit: z.number().int().min(1).max(50).default(10),
},
annotations: { readOnlyHint: true },
},
async ({ query, limit }, extra) => {
// extra.signal is an AbortSignal — check it in long loops for cancellation
const results = await upstreamApi.search(query, limit);
return {
content: [{ type: "text", text: JSON.stringify(results, null, 2) }],
};
},
);
server.registerTool(
"get_item",
{
description: "Fetch a single item by its ID.",
inputSchema: { id: z.string() },
annotations: { readOnlyHint: true },
},
async ({ id }) => {
const item = await upstreamApi.get(id);
return { content: [{ type: "text", text: JSON.stringify(item) }] };
},
);
// Streamable HTTP transport (stateless mode — simplest)
const app = express();
app.use(express.json());
app.post("/mcp", async (req, res) => {
const transport = new StreamableHTTPServerTransport({
sessionIdGenerator: undefined, // stateless
});
res.on("close", () => transport.close());
await server.connect(transport);
await transport.handleRequest(req, res, req.body);
});
app.listen(process.env.PORT ?? 3000);
Stateless vs stateful: The snippet above creates a fresh transport per request (stateless). Fine for most API-wrapping servers. If tools need to share state across calls in a session (rare), use a session-keyed transport map — see the SDK's examples/server/simpleStreamableHttp.ts.
FastMCP 3.x (Python)
pip install fastmcp
server.py
from fastmcp import FastMCP
mcp = FastMCP(
name="my-service",
instructions="Prefer search_items before calling get_item directly — IDs aren't guessable.",
)
@mcp.tool(annotations={"readOnlyHint": True})
def search_items(query: str, limit: int = 10) -> list[dict]:
"""Search items by keyword. Returns up to `limit` matches ranked by relevance."""
return upstream_api.search(query, limit)
@mcp.tool(annotations={"readOnlyHint": True})
def get_item(id: str) -> dict:
"""Fetch a single item by its ID."""
return upstream_api.get(id)
if __name__ == "__main__":
mcp.run(transport="http", host="0.0.0.0", port=3000)
FastMCP derives the JSON schema from type hints and the docstring becomes the tool description. Keep docstrings terse and action-oriented — they land in Claude's context window verbatim.
Search + execute pattern (large API surface)
When wrapping 50+ endpoints, don't register them all. Two tools:
const CATALOG = loadActionCatalog(); // { id, description, paramSchema }[]
server.registerTool(
"search_actions",
{
description: "Find available actions matching an intent. Call this first to discover what's possible. Returns action IDs, descriptions, and parameter schemas.",
inputSchema: { intent: z.string().describe("What you want to do, in plain English") },
annotations: { readOnlyHint: true },
},
async ({ intent }) => {
const matches = rankActions(CATALOG, intent).slice(0, 10);
return { content: [{ type: "text", text: JSON.stringify(matches, null, 2) }] };
},
);
server.registerTool(
"execute_action",
{
description: "Execute an action by ID. Get the ID and params schema from search_actions first.",
inputSchema: {
action_id: z.string(),
params: z.record(z.unknown()),
},
},
async ({ action_id, params }) => {
const action = CATALOG.find(a => a.id === action_id);
if (!action) throw new Error(`Unknown action: ${action_id}`);
validate(params, action.paramSchema);
const result = await dispatch(action, params);
return { content: [{ type: "text", text: JSON.stringify(result) }] };
},
);
rankActions can be simple keyword matching to start. Upgrade to embeddings if precision matters.
Test it
The MCP Inspector connects to any transport and lets you poke tools interactively.
# Interactive — opens a UI on localhost:6274
npx @modelcontextprotocol/inspector
# → select "Streamable HTTP", paste http://localhost:3000/mcp, Connect
For scripted checks (CI, smoke tests):
npx @modelcontextprotocol/inspector --cli http://localhost:3000/mcp \
--transport http --method tools/list
npx @modelcontextprotocol/inspector --cli http://localhost:3000/mcp \
--transport http --method tools/call --tool-name search_items --tool-arg query=test
Connect users
Once deployed, users add the URL directly — no install step.
| Surface | How |
|---|---|
| Claude Code | claude mcp add --transport http <name> <url> (add --scope user for global, --header "Authorization: Bearer ..." for auth) |
| Claude Desktop / Claude.ai | Settings → Connectors → Add custom connector. Not claude_desktop_config.json — remote servers configured there are ignored. |
| Connector directory | Anthropic maintains a submission guide for listing in the public connector directory. |
Deploy
Fastest path: Cloudflare Workers — two commands from zero to a live https:// URL on the free tier. Uses a Workers-native scaffold (not Express). → deploy-cloudflare-workers.md
This Express scaffold runs on any Node host — Render, Railway, Fly.io, a VPS. Containerize it (node:20-slim, copy, npm ci, node dist/server.js) and ship. FastMCP is the same story with a Python base image.
Deployment checklist
POST /mcpresponds toinitializewith server capabilitiestools/listreturns your tools with complete schemas- Errors return structured MCP errors, not HTTP 500s with HTML bodies
- CORS headers set if browser clients will connect
Originheader validated on/mcp(spec MUST — DNS rebinding prevention)MCP-Protocol-Versionheader honored (return 400 for unsupported versions)instructionsfield set if tool-use needs hints- Health check endpoint separate from
/mcp(hosts poll it) - Secrets from env vars, never hardcoded
- If OAuth: CIMD or DCR endpoint implemented — see
auth.md