1.2 Go在云原生时代的战略地位¶

// Docker核心概念示例
type Container struct {
    ID     string
    Image  string
    Status string
    Config *Config
}

func (c *Container) Start() error {
    // 启动容器逻辑
    return nil
}

// Kubernetes控制器模式示例
type Controller struct {
    client    kubernetes.Interface
    workqueue workqueue.RateLimitingInterface
}

func (c *Controller) processNextWorkItem() bool {
    obj, shutdown := c.workqueue.Get()
    if shutdown {
        return false
    }
    defer c.workqueue.Done(obj)

    // 处理业务逻辑
    return c.syncHandler(obj.(string))
}

// etcd客户端示例
client, err := clientv3.New(clientv3.Config{
    Endpoints:   []string{"localhost:2379"},
    DialTimeout: 5 * time.Second,
})

ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel()

_, err = client.Put(ctx, "key", "value")

// Prometheus指标定义
var (
    httpRequests = prometheus.NewCounterVec(
        prometheus.CounterOpts{
            Name: "http_requests_total",
            Help: "Total number of HTTP requests",
        },
        []string{"method", "endpoint"},
    )
)

func init() {
    prometheus.MustRegister(httpRequests)
}

// 高并发HTTP服务示例
func main() {
    http.HandleFunc("/api/users", func(w http.ResponseWriter, r *http.Request) {
        // 处理请求
        users := getUsersFromDB()
        json.NewEncoder(w).Encode(users)
    })

    log.Println("Server starting on :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

// goroutine并发处理
func processRequests(requests <-chan Request, responses chan<- Response) {
    for req := range requests {
        go func(r Request) {
            // 并发处理请求
            resp := handleRequest(r)
            responses <- resp
        }(req)
    }
}