一、存活探针
Kubernetes 可以通过存活探针(liveness probe)检查容器是否还在运行。 可以为 pod 中的每个容器单独指定存活探针。如果探测失败，Kubernetes 将定期执行探针并重新启动容器。Kubernetes 有以下三种探测容器的机制：
- HTTP GET 探针：对容器的 IP 地址执行 HTTP GET 请求。如果探测器收到响应，并且响应状态码不代表错误（响应状态码是2xx或3xx),则认为探测成功。如果服务器返回错误响应状态码或者根本没有响应，那么探测就被认为是失败的，容器将被重新启动。
- TCP套接字探针：尝试与容器指定端口建立 TCP 连接。如果连接成功建立，则探测成功。否则，容器重新启动。
- Exec探针：在容器内执行任意命令，并检查命令的退出状态码。如果状态码是 0 则探测成功。所有其他状态码都被认为失败。
1.1. 创建基于 HTTP 的存活探针
将存活探针添加到 pod (kubia-liveness-probe.yaml)：
apiVersion: v1
kind: Pod
metadata:
name: kubia-liveness
spec:
containers:
- image: luksa/kubia-unhealthy
name: kubia
livenessProbe:
httpGet:
path: /
port: 8080
initialDelaySeconds: 15 # 等待 15 秒后才进行第一次探测
luksa/kubia-unhealthy 这个镜像是为了演示存活探针：在第五个请求之后，返回 HTTP 状态码 500：
const http = require('http');
const os = require('os');
console.log("Kubia server starting...");
var requestCount = 0;
var handler = function(request, response) {
console.log("Received request from " + request.connection.remoteAddress);
requestCount++;
if (requestCount > 5) {
response.writeHead(500);
response.end("I'm not well. Please restart me!");
return;
}
response.writeHead(200);
response.end("You've hit " + os.hostname() + "
");
};
var www = http.createServer(handler);
www.listen(8080);
1.2. 使用存活探针
创建 pod:
kubectl create -f kubia-liveness-probe.yaml
查看 pod：
kubectl get pod kubia-liveness
容器启动后，多次执行查看命令，可以看到 RESTARTS > 1
查看 pod 重启原因：
kubectl describe pod kubia-liveness
二、 ReplicaSet
我们在前面创建的基本都是未托管的 pod，可以使用控制器创建托管的 pod，可以保证 pod 不管因任何原因消失，都会自动创建替代 pod。最初 ReplicationController 是用于复制和在异常时重新调度节点的唯一组件， 后来又引入了 ReplicaSet, 而 ReplicationController 最终也将被弃用。
注：通常我们不会直接创建 ReplicaSet 或 ReplicationController，而是在创建更高层级的 Deployment 资源时自动创建他们。
2.1. 创建 RelicaSet
kubia-replicaset.yaml：
apiVersion: apps/v1 # 不是 v1 版本 API 的一部分，属于 apps API 组的 v1 版本
kind: ReplicaSet
metadata:
name: kubia
spec:
replicas: 3
selector:
matchLabels:
app: kubia # matchLabels 选择器
template:
metadata:
labels:
app: kubia # 标签
spec:
containers:
- name: kubia
image: luksa/kubia
创建：
kubectl create -f kubia-replicaset.yaml
查看：
kubectl get rs # rs 是 replicaset 的简写
删除：
kubectl delete rs kubia
2.2. ReplicaSet 的标签选择器
- In: Label 的值必须与其中一个指定的 values 匹配。
- NotIn: Label 的值与任何指定的 values 不匹配。
- Exists: pod 必须包含一个指定名称的标签。使用此运算符时，不应指定 values 字段。
- DoesNotExist: pod 不得包含有指定名称的标签。values属性不得指定。
如果指定了多个表达式，则所有这些表达式都必须为 true 才能使选择器与 pod 匹配。如果同时指定 matchLabels 和 matchExpressions, 则所有标签都必须匹配，并且所有表达式必须计算为 true 以使该 pod 与选择器匹配。
示例：
... ...
selector:
matchExpressions:
- key: app
operator: In
values:
- kubia
... ...
三、DaemonSet
Replicationcontroller 和 ReplicaSet 都用于在 Kubernetes 集群上运行部署特定数量的 pod（随机分布在集群上）。DaemonSet 则可以实现在每个节点或者指定的节点上运行一个 pod。适用于比如 pod 执行系统级别的与基础结构相关的操作，例如，希望在每个节点上运行日志收集器和资源监控器；另一个典型的例子是 Kubernetes 自己的 kube-proxy 进程，它需要运行在所有节点上才能使服务工作。
DaemonSet 配置示例：
apiVersion: apps/v1
kind: DaemonSet
metadata:
name: ssd-monitor
spec:
selector:
matchLabels:
app: ssd-monitor
template:
metadata:
labels:
app: ssd-monitor
spec:
nodeSelector:
disk: ssd # 选择标签 disk=ssd 的 node
containers:
- name: main
image: luksa/ssd-monitor
四、执行单个任务的 pod
4.1. 创建 job
apiVersion: batch/v1 # Job 属于 batch API 组
kind: Job
metadata:
name: batch-job
spec:
template:
metadata:
labels:
app: batch-job
spec:
restartPolicy: OnFailure # Job 不能使用 Always 为默认的重启启动策略，应该为 OnFailure 或 Never
containers:
- name: main
image: luksa/batch-job
查看：
kubectl get jobs
kubectl get pods
4.2. 在 Job 中运行多个 pod 实例
顺序运行：
... ...
metadata:
name: multi-completion-batch-job
spec:
completions: 5 # 此作业顺序运行 5 个 pod
... ...
并行运行：
... ...
metadata:
name: multi-completion-batch-job
spec:
completions: 5 # 这项任务必须确保 5 个 pod 成功完成
parallelism: 2 # 最多 2 个 pod 可以并行运行
... ...
可以在 job 运行的时候 更改 parallelism 属性，缩放 job：
kubectl scale job multi-completion-batch-job --replicas 3
其他属性：
- activeDeadlineSeconds：限制 pod的时间，如果 pod 运行时间超过此时间，系统将尝试终止 pod, 并将 Job 标记为失败。
- spec.backoffLimit：Job 在被标记为失败之前重试的次数，默认值为 6
4.3. CronJob
apiVersion: batch/v1
kind: CronJob
metadata:
name: batch-job-every-fifteen-minutes
spec:
schedule: "0,15,30,45 * * * *" # cron 表达式
jobTemplate:
spec:
template:
metadata:
labels:
app: periodic-batch-job
spec:
restartPolicy: OnFailure
containers:
- name: main
image: luksa/batch-job