用 Dapr MCP Server 把状态、事件与分布式锁变成 Agent 可调用的工具：组件注册、stdio/HTTP 双通道与鉴权实操

# Linux amd64（官方入门页原样；ARM 用 linux-arm64）
curl -LO https://github.com/dapr/dapr-mcp-server/releases/latest/download/dapr-mcp-server-linux-amd64
curl -LO https://github.com/dapr/dapr-mcp-server/releases/latest/download/checksums.txt
sha256sum --ignore-missing -c checksums.txt
chmod +x dapr-mcp-server-linux-amd64
sudo mv dapr-mcp-server-linux-amd64 /usr/local/bin/dapr-mcp-server

# 确认安装
dapr-mcp-server --version

# 另外两条路线（按需二选一）
docker pull ghcr.io/dapr/dapr-mcp-server:latest
go install github.com/dapr/dapr-mcp-server/cmd/dapr-mcp-server@latest

# 前置：初始化 Dapr self-hosted（已做过可跳过）
dapr init

mkdir -p components

# components/statestore.yaml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.in-memory
  version: v1

# components/pubsub.yaml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
spec:
  type: pubsub.in-memory
  version: v1

# 终端 A：单独起 sidecar，固定 gRPC 端口，保持运行
dapr run --app-id dapr-mcp-server --dapr-grpc-port 50001 --resources-path ./components

# 终端 B：把服务器注册给 Claude Code
claude mcp add dapr --env DAPR_GRPC_PORT=50001 -- /usr/local/bin/dapr-mcp-server

# 或写进 claude_desktop_config.json / ~/.cursor/mcp.json
{
  "mcpServers": {
    "dapr": {
      "command": "/usr/local/bin/dapr-mcp-server",
      "env": { "DAPR_GRPC_PORT": "50001" }
    }
  }
}

# 改完桌面客户端配置要重启客户端才生效

# 起服务（HTTP 端点为 http://localhost:8080/）
dapr run --app-id dapr-mcp-server --resources-path ./components   -- dapr-mcp-server --http localhost:8080

# 探活：200 且 status healthy 表示能连到 sidecar；503 表示 sidecar 不可达
curl http://localhost:8080/readyz
# PowerShell 等价：Invoke-RestMethod http://localhost:8080/readyz

# Claude Code 注册 HTTP 传输
claude mcp add --transport http dapr http://localhost:8080/

# 任意客户端的 mcpServers 写法
{ "mcpServers": { "dapr": { "url": "http://localhost:8080/" } } }

import asyncio
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

async def main():
    # 连上官方 HTTP 端点
    async with streamablehttp_client("http://localhost:8080/") as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()
            tools = await session.list_tools()
            print([tool.name for tool in tools.tools])   # 应含 get_components 与 state/pubsub 工具
            result = await session.call_tool("get_components", {})
            print(result.structuredContent)              # 应列出 statestore 与 pubsub

asyncio.run(main())

# 给 Agent 的系统提示词（示例，组件名按 get_components 返回值替换）
先调用 get_components，找出 state store 与 pub/sub 的名字。
把发布清单维护在 state store 的 release-checklist 这个键下。
每次改动后，把新清单发布到 pubsub 的 checklist 主题。
只允许使用读类工具与 save_state，不要调用 delete_state 或 execute_transaction。

# 等价的客户端调用序列（伪代码，按你用的 SDK 调整）
session.call_tool("get_components", {})
session.call_tool("save_state", {"storeName": "statestore",
                                 "key": "release-checklist",
                                 "value": "update the quickstart README"})
session.call_tool("get_state", {"storeName": "statestore", "key": "release-checklist"})
session.call_tool("publish_event", {"pubsubName": "pubsub",
                                    "topic": "checklist", "data": "..."})

# Deployment 关键片段（官方入门页）
annotations:
  dapr.io/enabled: "true"
  dapr.io/app-id: "dapr-mcp-server"
containers:
  - name: dapr-mcp-server
    image: ghcr.io/dapr/dapr-mcp-server:latest
    ports:
      - containerPort: 8080
    startupProbe:
      httpGet: { path: /startupz, port: 8080 }
      failureThreshold: 30
      periodSeconds: 2
    livenessProbe:
      httpGet: { path: /livez, port: 8080 }
    readinessProbe:
      httpGet: { path: /readyz, port: 8080 }

# 相关环境变量与旗标
# AUTH_MODE=oidc | spiffe | dapr-sentry | hybrid
# DAPR_MCP_CORS_ORIGIN=https://app.example.com   # 仅浏览器跨源客户端需要
# --health-check             # 探测本地 /livez 并以 0/1 退出
# --health-check-addr host:port
# --version                  # 打印版本