Compare commits
2 Commits
093511bbdd
...
88939869ff
| Author | SHA1 | Date | |
|---|---|---|---|
| 88939869ff | |||
| 843024d7da |
+1
-1
@@ -1 +1 @@
|
|||||||
OPS_MCP_TRANSPORT=sse
|
OPS_MCP_PORT=9090
|
||||||
|
|||||||
+2
-1
@@ -1,5 +1,7 @@
|
|||||||
FROM golang:1.24-alpine AS builder
|
FROM golang:1.24-alpine AS builder
|
||||||
|
|
||||||
|
ENV GOPROXY=https://goproxy.cn,direct
|
||||||
|
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
COPY go.mod go.sum ./
|
COPY go.mod go.sum ./
|
||||||
@@ -15,5 +17,4 @@ RUN apk add --no-cache docker-cli ca-certificates
|
|||||||
COPY --from=builder /server /server
|
COPY --from=builder /server /server
|
||||||
COPY config/ /config/
|
COPY config/ /config/
|
||||||
|
|
||||||
EXPOSE 8080
|
|
||||||
ENTRYPOINT ["/server"]
|
ENTRYPOINT ["/server"]
|
||||||
|
|||||||
@@ -23,13 +23,17 @@ make build && ./ops-mcp
|
|||||||
## Docker Compose 部署
|
## Docker Compose 部署
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
|
# 默认端口 9090
|
||||||
docker compose up -d --build
|
docker compose up -d --build
|
||||||
|
|
||||||
|
# 自定义端口
|
||||||
|
OPS_MCP_PORT=3000 docker compose up -d --build
|
||||||
```
|
```
|
||||||
|
|
||||||
然后 Claude Desktop 通过 SSE 连接:
|
Claude Desktop SSE 连接(端口改成你设置的):
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{ "mcpServers": { "ops-mcp": { "url": "http://<server>:8080/sse" } } }
|
{ "mcpServers": { "ops-mcp": { "url": "http://<server>:9090/sse" } } }
|
||||||
```
|
```
|
||||||
|
|
||||||
## MCP 工具
|
## MCP 工具
|
||||||
|
|||||||
+2
-2
@@ -17,10 +17,10 @@ func main() {
|
|||||||
cfg, err := config.Load()
|
cfg, err := config.Load()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slog.Warn("config load failed, using defaults", "err", err)
|
slog.Warn("config load failed, using defaults", "err", err)
|
||||||
cfg = &config.Config{Transport: "stdio"}
|
cfg = &config.Config{Transport: "stdio", Addr: ":8080"}
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := server.Run(cfg.Transport, tool.NewDockerTool()); err != nil {
|
if err := server.Run(cfg.Transport, cfg.Addr, tool.NewDockerTool()); err != nil {
|
||||||
slog.Error("fatal", "err", err)
|
slog.Error("fatal", "err", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-1
@@ -8,6 +8,7 @@ import (
|
|||||||
|
|
||||||
type Config struct {
|
type Config struct {
|
||||||
Transport string `mapstructure:"transport"` // stdio | sse
|
Transport string `mapstructure:"transport"` // stdio | sse
|
||||||
|
Addr string `mapstructure:"addr"` // 监听地址,默认 :8080
|
||||||
}
|
}
|
||||||
|
|
||||||
func Load() (*Config, error) {
|
func Load() (*Config, error) {
|
||||||
@@ -20,8 +21,8 @@ func Load() (*Config, error) {
|
|||||||
v.SetEnvPrefix("OPS_MCP")
|
v.SetEnvPrefix("OPS_MCP")
|
||||||
v.AutomaticEnv()
|
v.AutomaticEnv()
|
||||||
v.SetDefault("transport", "stdio")
|
v.SetDefault("transport", "stdio")
|
||||||
|
v.SetDefault("addr", ":8080")
|
||||||
|
|
||||||
// 配置文件不存在不算错误,直接用默认值 + 环境变量
|
|
||||||
if err := v.ReadInConfig(); err != nil {
|
if err := v.ReadInConfig(); err != nil {
|
||||||
slog.Warn("no config file found, using defaults and env vars", "err", err)
|
slog.Warn("no config file found, using defaults and env vars", "err", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,7 +6,10 @@ services:
|
|||||||
image: ops-mcp:latest
|
image: ops-mcp:latest
|
||||||
container_name: ops-mcp
|
container_name: ops-mcp
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
ports:
|
||||||
|
- "${OPS_MCP_PORT:-9090}:${OPS_MCP_PORT:-9090}"
|
||||||
environment:
|
environment:
|
||||||
- OPS_MCP_TRANSPORT=sse
|
- OPS_MCP_TRANSPORT=sse
|
||||||
|
- OPS_MCP_ADDR=:${OPS_MCP_PORT:-9090}
|
||||||
volumes:
|
volumes:
|
||||||
- /var/run/docker.sock:/var/run/docker.sock:ro
|
- /var/run/docker.sock:/var/run/docker.sock:ro
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ import (
|
|||||||
const version = "0.1.0"
|
const version = "0.1.0"
|
||||||
|
|
||||||
// Run 启动 MCP Server。
|
// Run 启动 MCP Server。
|
||||||
func Run(transport string, tools ...tool.Tool) error {
|
func Run(transport, addr string, tools ...tool.Tool) error {
|
||||||
ctx, cancel := context.WithCancel(context.Background())
|
ctx, cancel := context.WithCancel(context.Background())
|
||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
||||||
@@ -60,8 +60,8 @@ func Run(transport string, tools ...tool.Tool) error {
|
|||||||
slog.Info("starting MCP server", "transport", "stdio")
|
slog.Info("starting MCP server", "transport", "stdio")
|
||||||
return server.ServeStdio(mcpServer)
|
return server.ServeStdio(mcpServer)
|
||||||
case "sse":
|
case "sse":
|
||||||
slog.Info("starting MCP server", "transport", "sse", "addr", ":8080")
|
slog.Info("starting MCP server", "transport", "sse", "addr", addr)
|
||||||
return server.NewSSEServer(mcpServer).Start(":8080")
|
return server.NewSSEServer(mcpServer).Start(addr)
|
||||||
default:
|
default:
|
||||||
return fmt.Errorf("unknown transport: %s", transport)
|
return fmt.Errorf("unknown transport: %s", transport)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user