一.前言 我们在使用 kubectl 操作 k8s 时，可以在命令中加入 -w来观察资源变化，比如 kubectl get pod -w 观察 pod 状态变化。...出了使用控制台，还可以编写代码和 k8s 交互来获取 pod 变更。...二.代码实现 k8s client-go：https://github.com/kubernetes/client-go 安装 package: go get k8s.io/client-go config...= nil { log.Fatal(err) } // 创建 client clientSet, err := kubernetes.NewForConfig(config) if err !...Demo：https://github.com/stulzq/blog-demo-go/tree/main/k8s/watch-pod
[1] 滚动更新会出现的问题 在 k8s 执行 Rolling-Update 的时，默认会向旧的 pod 发生一个 SIGTERM 信号，如果业务应用没有对 SIGTERM 信号做处理的话，有可能导致程序退出后也没有处理完请求...[2] 滚动更新图解 [3] 注：绿色Pod 为当前已运行Pod ， 紫色Pod 为新创建Pod 当前 Service A 把流量分给4个 绿色Pod ?...管理员更新完 Deployment 部署文件，触发 Rolling-Update 操作，根据 k8s 调度算法选出一个 Node ，在这台 Node上创建一个 紫色Pod ?...循环替换，直到把所有 绿色Pod 替换成 紫色Pod，紫色Pod 达到 Deployment 部署文件中定义的副本数，则滚动更新完成 ?...滚动更新允许以下操作： 将应用程序从准上线环境升级到生产环境（通过更新容器镜像） 回滚到以前的版本 持续集成和持续交付应用程序，无需停机 解决方法 通过容器生命周期 hook 来优雅停止 Pod 停止前
这种架构部署和运维都十分简单方便，但是在应用更新或者升级时可能会存在服务中断，引发线上问题。...今天我们来详细分析下这种架构为何在更新应用时会发生服务中断以及如何避免服务中断; 业务部署图 image.png 2 为何会发生服务中断 Deployment 滚动更新时会先创建新 pod，等待新...Deployment更新时序图 image.png 2.3 Pod 1 . Pod状态变更: 将Pod设置为Terminating状态,并从所有Service的Endpoints列表中删除。...protocol: TCP targetPort: 80 selector: run: nginx type: LoadBalancer 容器服务会将集群中所有节点挂载到 SLB 的后端（使用...rolling update # * UpdateStrategy可以设置Max Unavailable为0，保证有新的Pod启动后才停止之前的pod # * 先对固定的几个节点打上label用来调度 # * 使用
更新应用 用户需求：需要应用始终正常运行，开发人员每天需要部署新的版本（一个简单例子，大家在玩游戏时常常碰到这类公告：8月8日凌晨：2点-6点服务升级，暂停所有服务.....）。...在Kubernetes中可以通过滚动更新（Rolling updates ）来完成。...滚动更新通过Deployments实现应用实例在不中断、不停机情况下更新，新的Pod会逐步调度到可用的资源Node节点上。 在前面的模块中，我们对应用进行了伸缩，以运行多个实例。...这是在不影响应用可用性的情况下执行更新的需求。更新时的Pod数量可以是数字或百分数(pod)来表示。在Kubernetes更新中，支持升级 / 回滚（恢复）更新。 滚动更新概述 （1） ?...与应用伸缩相似，滚动更新是实现流量负载均衡方式。 滚动更新允许以下操作： 将应用从一个环境升级到另一个环境（通过容器镜像更新） 回滚到之前的版本 持续集成和持续交付应用的零停机
但是，用client-go库访问这些资源有点麻烦，官方也没有完整的文档。...client-go包来访问这些自定义资源。...然后，使用从informer接收的初始对象列表和更新来构建本地缓存，该缓存允许快速访问任何自定义资源，而无需每次都访问API服务器。...这种模式非常普遍，以至于client-go库为此提供了一个cache包：来自包的Informerk8s.io/client-go/tools/cache。...总结 虽然现在很多工具给我们写CRD controller带来了极大的便捷，但是对于client-go这些基本的使用还是非常必要的，而官方client-go的开发文档和事例真的是少之又少，基本仅包含非常基本的操作
kubernetes 的 client-go 根据具体使用的方式进行了基础库封装和另外 4 种（书上介绍 3 种，我认为 scale client 也是一种 client）类型的 client 封装，分别针对不同的应用场景...listers 为每个 k8s 资源提供 lister 功能，提供了只读缓存功能 metadata pkg 主要是一些功能函数，比如版本函数 rest 这是最基础的 client，其它的 client...client 封装 client-go 的 rest client 实际上在很多时候使用起来还是不方便的，而且在逐步的发展中 对 client 的要求会有多种多样，所以针对这一需求 client-go...又进行了抽象和封装，把常用到的 client 类型进行专门封装，形成独立的库，以方便直接使用，这样避免了直接使用基础 rest client 时又要进行再次编码封装。...实际上公司内有同学开发了一个对 k8s 事件收集的模块，这个模块的代码我也是参与开发了一部分，从编译执行上来说是没问题，之前是没有从 client-go 这部分代码上去理解，现在感觉对这部分代码的认识更深了一些
资源操作对象工厂的工厂 clientset 就是资源操作对象工厂的工厂，其图解和相关源码如下： // staging/src/k8s.io/client-go/kubernetes/clientset.go...*internalv1alpha1.InternalV1alpha1Client appsV1 *appsv1.AppsV1Client....AppsV1beta2Client ...... } func (c *Clientset) AppsV1() appsv1.AppsV1Interface { return c.appsV1...Clientset对象的实例化 clientset 对象的创建相关源码如下： // staging/src/k8s.io/client-go/kubernetes/clientset.go func NewForConfig...目前我们先写到这里，在下一篇文章中我们继续介绍 client go 中的相关存储组件。
接口定义 staging/src/k8s.io/client-go/rest/client.go 源码文件中 Interface 定义了接口， 其相关的图解和源码如下： // staging/src/...k8s.io/client-go/rest/client.go type Interface interface { GetRateLimiter() flowcontrol.RateLimiter...表示在该 Request 对象中， 我们可以有能力去使用 http 相应的 Get/Post/Put/Delete 等方法访问某一组下的某一版本中的资源。...图解和源码如下： // staging/src/k8s.io/client-go/rest/client.go type ClientContentConfig struct { AcceptContentTypes...RESTClient 结构体 该结构体主要实现了开头介绍的接口，用来生成 Request 对象，图解和源码如下： // staging/src/k8s.io/client-go/rest/client.go
如果我们没有在 k8s 上运行的应用程序考虑正常关闭，它可能会在滚动更新期间立即返回 502 错误（Bad Gateway）。 首先，我将简要说明滚动更新开始后旧 pod 将如何终止。...因此，滚动更新可能会导致短暂的停机时间，直到所有到来的请求都被路由到新的 pod。 让我们通过两个实验进一步了解这一点。...我通过 minikube 创建了一个本地 k8s 集群，并使用vegeta[2] 向我的应用程序发送 HTTP 请求。您可以在Gist[3] 上查看 k8s 清单文件和 Dockerfile 。...Codes [code:count] 200:59779 502:221 Error Set: 502 Bad Gateway 我发送了 60 秒的请求，并在 30 秒内开始滚动更新...结论 为了避免在滚动更新期间停机，我们必须在服务器开始关闭之前通过一些方法（例如 preStop 或信号处理）实现优雅关闭。
前言 这部分还是以 client-go 为基础的代码测试，今天这里分享的一个是我测试过的 client-go 代码例子， package main import ( "context" "flag.../kubernetes" "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/util/homedir" ) var clientset...go mod 编译，但是 go mod 默认获取的 client-go 版本有问题，需要自己调整，才能编译过。...我使用的 go.mod 文件。...默认 gomod 的编译引入的库是有版本冲突的，需要核对使用的版本并修改 go.mod 中的相应版本号才能编译通过。
下面的example也是client-go官方的例子。通过这个简单的例子正好把之前的源码分析的一个个模块都串起来了。.../kubernetes" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/util.../workqueue" ) // Controller demonstrates how to implement a controller with client-go. type Controller...\___go_build_k8s_io_client_go_examples_workqueue.exe k8s.io/client-go/examples/workqueue #gosetup C:\...Users\hanwei\AppData\Local\Temp\GoLand\___go_build_k8s_io_client_go_examples_workqueue.exe I1206 13:33
滚动更新 image.png 这是我们预期中的发布流程，要在 kubernetes 使用该功能也非常简单，只需要在 spec 下配置相关策略即可： spec: strategy: rollingUpdate...: maxSurge: 25% maxUnavailable: 25% type: RollingUpdate 这个配置的含义是： 使用滚动更新，当然还有 Recreate...maxSurge：滚动更新过程中可以最多超过预期 Pod 数量的百分比，当然也可以填整数。 maxUnavailable：滚动更新过程中最大不可用 Pod 数量超过预期的百分比。...停机之后不能再有请求路由到已经停机的 Pod 第一个问题如果我们使用的是 Go，可以使用一个钩子来监听 kubernetes 发出的退出信号： quit := make(chan os.Signal)...k rollout restart deployment/nginx 使用 kubernetes 的滚动更新确实要比我们以往的传统运维简单许多，就几个命令的事情之前得写一些复杂的运维脚本才能实现。
6部署策略 滚动更新部署Rolling Update 滚动部署是 Kubernetes 中的默认部署策略。它用新版本的 pod 一个一个地替换我们应用程序的先前版本的 pod，而没有任何集群停机时间。...然后使用 kubectl 命令更新现有运行部署的镜像。...滚动部署通常会在缩小旧组件之前通过就绪检查等待新 Pod 准备就绪。如果发生重大问题，可以中止滚动部署。如果出现问题，可以中止滚动更新或部署，而无需关闭整个集群。...kubectl 命令再次创建服务： $ kubectl apply -f service.yaml 因此得出结论，我们可以看到蓝绿部署是全有或全无，不像滚动更新部署，我们无法逐步推出新版本。...当我们对新版本不是 100% 有信心时，应该使用 Canary 部署；我们预测我们失败的可能性很小。当我们进行重大更新时，通常会使用此策略，例如添加新功能或实验性功能。
概述 使用 k8s 相关 sdk 做二次开发时，经常用到 apimachinery、api、client-go 这三个库，一直对他们的职责不是很清楚，网上也没有找到合适的文章做分析，笔者通过研究三个库的源码...的内置资源，以及注册到 Scheme 的接口，这些资源比如：Pod、Service、Deployment、Namespace client-go 库，这个库依赖前两个库，提供了访问k8s 内置资源的sdk...高清地址 api api 库提供了k8s的内置资源，以及注册到 Scheme 的接口，这些资源比如：Pod、Service、Deployment、Namespace 高清地址 client-go client-go...关于 client-go 中最重要的 Informer 机制和原理，请参考本人另一篇文章: k8s源码分析- Informer机制，里面有一张详细的源码调用关系图。...很多资料直接搜索博客是找不到答案的，通过研究源码可以帮助你建立独立思考的能力 apimachinery 再往下依赖的内容更多是一些工具库，就不再这里做分析 三个库的依赖关系依次是：apimachinery -> api -> client-go
上一篇文章里，我们主要介绍了 kubernetes 世界中 client go 这个基础组件，它的主要职责是负责与 API server 进行通讯交互。
获取安装程序可执行文件 下载 KubeKey 可执行文件发布页面 下载解压后可直接使用。...Nov 07, 2021 02:56 UTC ca k8s-master1 front-proxy-client.crt...更新K8S证书 ....kubernetes v1.15以上更新证书的方法 更新/etc/kubernetes/pki目录下的所有证书（不包含ca证书） 注意：需要在每一个节点上都更新 # 查看现有证书到期时间 $ kubeadm...alpha certs check-expiration # 使用二进制更新证书 $ kubeadm alpha certs renew all # 每月的最后1天 crontab -e * *
背景 最近在看client-go源码最基础的部分，client-go的四类客户端，RestClient、ClientSet、DynamicClient、DiscoveryClient。...本文通过分析ClientSet代码和client-go客户端调用Kubernetes集群的方式来演示下整个交互过程。...准备工作 已经安装Kubernetes集群和配置本地IDE环境 根据kubernetes集群版本选择clone client-go到本地：https://github.com/kubernetes/client-go...client-go连接ApiServer进行Pod的增删改查 获取APIserver连接地址、认证配置等信息 var kubeconfig *string //获取当前用户home文件夹，并获取kubeconfig...看到这里之后，ClientSet之所以只能处理预先声明的原生资源类型，是因为对象都是使用的内置元数据类型，不存在的自然没有办法使用了，这时我们在看下DynamicClient，部分代码如下所示，它使用unstructured.Unstructured
上一篇文章里，我们主要介绍了 client go 这个基础组件相关的 request 和 result 对象，这两个对象主要用来发送资源操作的请求，以及处理相关的响应。...其图解和相关源码如下： //staging/src/k8s.io/client-go/kubernetes/typed/apps/v1/deployment.go type DeploymentInterface...对于 apps 组下的 v1 版本中所有的资源操作对象聚合图解和相关源码如下： // k8s.io/client-go/kubernetes/typed/apps/v1/apps_client.go...资源操作对象工厂的实例化 我们还是以 apps 组下的 v1 版本中的资源操作对象工厂为例，来介绍该工厂是如何被创建的，其相关的源代码如下： // k8s.io/client-go/kubernetes.../typed/apps/v1/apps_client.go func NewForConfig(c *rest.Config) (*AppsV1Client, error) { config :=
client-go实战之二:RESTClient client-go实战之三：Clientset client-go实战之四：dynamicClient client-go实战之五：DiscoveryClient...client-go实战之六:时隔两年，刷新版本继续实战 client-go实战之七：准备一个工程管理后续实战的代码 本篇概览 本文是《client-go实战》系列的第七篇，来了解一个常见的错误：版本冲突...《client-go实战之七：准备一个工程管理后续实战的代码 》创建的client-go-tutorials工程，将代码写在这个工程中 在client-go-tutorials工程中新增名为的conflict.go...还好，client-go帮我们解决了这个问题，按照kubernetes官方的指导方向，将重试逻辑进行了封装，让使用者可以很方便的实现完成失败重试 版本冲突的实际解决手段（from client-go官方...，当然了，实际场景中，大量并发同时修改同一个资源对象的情况并不多见，所以大多数时候可以直接使用client-go官方的推荐值 至此，kubernetes资源更新时的版本冲突问题，经过实战咱们都已经了解了
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
