Golang微服务与Kubernetes集成示例

/health

/greet

// main.go
package main

import (
    "fmt"
    "log"
    "net/http"
    "os"
)

func healthHandler(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "OK")
    log.Println("Health check performed.")
}

func greetHandler(w http.ResponseWriter, r *http.Request) {
    name := r.URL.Query().Get("name")
    if name == "" {
        name = "World"
    }
    fmt.Fprintf(w, "Hello, %s!", name)
    log.Printf("Greeted %s.", name)
}

func main() {
    port := os.Getenv("PORT")
    if port == "" {
        port = "8080" // Default port
    }

    http.HandleFunc("/health", healthHandler)
    http.HandleFunc("/greet", greetHandler)

    log.Printf("Server starting on port %s...", port)
    if err := http.ListenAndServe(":"+port, nil); err != nil {
        log.Fatalf("Server failed to start: %v", err)
    }
}

Dockerfile

# Dockerfile
# 阶段1: 构建Go应用
FROM golang:1.22-alpine AS builder

WORKDIR /app

COPY go.mod go.sum ./
RUN go mod download

COPY . .
RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o my-go-service .

# 阶段2: 构建最终的轻量级镜像
FROM alpine:latest

WORKDIR /root/

# 安装ca-certificates以支持HTTPS请求
RUN apk add --no-cache ca-certificates

COPY --from=builder /app/my-go-service .

EXPOSE 8080

CMD ["./my-go-service"]

Deployment

Service

deployment.yaml

# deployment.yaml
apiVersion: apps/v1
kind: Deployment
metadata:
  name: my-go-service-deployment
  labels:
    app: my-go-service
spec:
  replicas: 2 # 启动两个Pod实例
  selector:
    matchLabels:
      app: my-go-service
  template:
    metadata:
      labels:
        app: my-go-service
    spec:
      containers:
      - name: my-go-service
        image: your-dockerhub-username/my-go-service:latest # 替换为你的Docker镜像地址
        ports:
        - containerPort: 8080
        env:
        - name: PORT
          value: "8080"
        livenessProbe: # 活性探针，检查应用是否运行正常
          httpGet:
            path: /health
            port: 8080
          initialDelaySeconds: 5
          periodSeconds: 5
        readinessProbe: # 就绪探针，检查应用是否可以接收流量
          httpGet:
            path: /health
            port: 8080
          initialDelaySeconds: 5
          periodSeconds: 5
        resources: # 资源限制，避免资源滥用
          requests:
            memory: "64Mi"
            cpu: "100m"
          limits:
            memory: "128Mi"
            cpu: "200m"

service.yaml

# service.yaml
apiVersion: v1
kind: Service
metadata:
  name: my-go-service-service
spec:
  selector:
    app: my-go-service
  ports:
    - protocol: TCP
      port: 80 # Service的端口
      targetPort: 8080 # Pod内部的端口
  type: LoadBalancer # 或者NodePort，取决于你的K8s环境和需求

kubectl get services

go fmt

go test

go pprof

alpine

scratch

scratch

Deployment

Service

/health

deployment.yaml

requests

limits

ConfigMap

Secret

ConfigMap

Secret

SIGTERM

// 优雅停机示例（简化版）
func main() {
    // ... 其他初始化代码 ...

    server := &http.Server{Addr: ":" + port, Handler: nil}

    // 启动一个goroutine来监听中断信号
    go func() {
        sigChan := make(chan os.Signal, 1)
        signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
        <-sigChan // 阻塞直到接收到信号
        log.Println("Received shutdown signal, shutting down gracefully...")

        ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) // 30秒优雅停机时间
        defer cancel()

        if err := server.Shutdown(ctx); err != nil {
            log.Fatalf("Server shutdown failed: %v", err)
        }
        log.Println("Server gracefully stopped.")
    }()

    log.Printf("Server starting on port %s...", port)
    if err := server.ListenAndServe(); err != http.ErrServerClosed {
        log.Fatalf("Server failed to start or shut down unexpectedly: %v", err)
    }
}

sony/gokini

logrus

zap

request_id

user_id

service_name

prometheus/client_go

OpenTelemetry