存活探针

在生产中，有时候因为某些 bug 导致应用死锁或者线程耗尽了，最终会导致应用无法继续提供服务，这个时候如果没有手段来自动监控和处理这一问题的话，可能会导致很长一段时间无人发现。kubelet 使用存活探测器 (livenessProb) 来确定什么时候要重启容器。

我们写一个 /healthz 接口来说明 livenessProb 如何使用。 /healthz 接口会在启动成功的 15s 内正常返回 200 状态码，在 15s 后，会一直返回 500 的状态码。

package main

import (
    "fmt"
    "io"
    "net/http"
    "time"
)

func hello(w http.ResponseWriter, r *http.Request) {
    io.WriteString(w, "[v2] Hello, Kubernetes!")
}

func main() {
    started := time.Now()
    http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
        duration := time.Since(started)
        if duration.Seconds() > 15 {
            w.WriteHeader(500)
            w.Write([]byte(fmt.Sprintf("error: %v", duration.Seconds())))
        } else {
            w.WriteHeader(200)
            w.Write([]byte("ok"))
        }
    })

    http.HandleFunc("/", hello)
    http.ListenAndServe(":3000", nil)
}

docker build . -t guangzhengli/hellok8s:liveness
docker push guangzhengli/hellok8s:liveness

apiVersion: apps/v1
kind: Deployment
metadata:
  name: hellok8s-deployment
spec:
  strategy:
     rollingUpdate:
      maxSurge: 1
      maxUnavailable: 1
  replicas: 3
  selector:
    matchLabels:
      app: hellok8s
  template:
    metadata:
      labels:
        app: hellok8s
    spec:
      containers:
        - image: guangzhengli/hellok8s:liveness
          name: hellok8s-container
          ## livenessProbe
          livenessProbe:
            httpGet:
              path: /healthz
              port: 3000
            initialDelaySeconds: 3
            periodSeconds: 3

initialDelaySeconds 字段告诉 kubelet 在执行第一次探测前应该等待 3 秒

periodSeconds 字段指定了 kubelet 每隔 3 秒执行一次存活探测