前言
Kubernetes 是一个开源的容器编排系统，它可以自动化地部署、扩展和管理容器化的应用程序。Kubernetes 控制器是 Kubernetes 的一个重要组件，它可以根据用户定义的规则监控和管理 Kubernetes 集群中的资源对象。本文将介绍如何使用 Golang 编写 Kubernetes 控制器，帮助初学者更好地理解 Kubernetes 控制器的工作原理和实现方式。
准备工作
在开始编写 Kubernetes 控制器之前，需要先安装以下软件和工具：
- Golang 环境
- Kubernetes 集群或 Minikube
- Kubernetes Go 客户端库
可以通过以下命令安装 Kubernetes Go 客户端库：
go get k8s.io/client-go/...
编写 Kubernetes 控制器
创建控制器
首先，创建一个名为 controller.go 的文件，并在其中引入必要的包和依赖：
-- -------------------- ---- -------
------- ----
------ -
-----
----
-----------
---------
-----------------------------------
-----------------------------
------------------------------
---------------------------------
-然后，创建一个名为 Controller 的结构体，并在其中定义必要的字段：
type Controller struct {
clientset kubernetes.Interface
queue workqueue.RateLimitingInterface
informer cache.SharedIndexInformer
stopCh chan struct{}
}clientset：Kubernetes 客户端，用于与 Kubernetes API 交互。queue：工作队列，用于存储需要处理的资源对象。informer：资源对象的缓存和监控器，用于监控 Kubernetes 集群中的资源对象的变化。stopCh：停止信号，用于停止控制器的运行。
初始化控制器
在 Controller 结构体中添加一个名为 NewController 的函数，用于初始化控制器：
-- -------------------- ---- -------
---- ----------------------- --------------------- ----------- -
----- -- ------------------------------------------------------------------------
-------- -- -----------------------------
-----------------
--------- ------------ ------------------- ---------------- ------ -
------ ------------------------------------------------------ --------
--
---------- ------------ ------------------- ----------------- ------ -
------ ------------------------------------------------------- --------
--
--
----------
--
-----------------
-
---------- -- ------------
---------- ----------
------ ------
--------- ---------
------- --------- ----------
-
---------------------------------------------------------
-------- ----------------------
--
------ ----------
-clientset：Kubernetes 客户端。queue：工作队列。informer：资源对象的缓存和监控器。stopCh：停止信号。ListWatch：定义如何获取资源对象的列表和监视器。Pod：资源对象的类型。AddEventHandler：添加资源对象的事件处理函数。
处理资源对象
在 Controller 结构体中添加一个名为 run 的函数，用于启动控制器并处理资源对象：
-- -------------------- ---- -------
---- -- ------------ ----- -
----- ------------------
--------------------- ------------
-- --------------------------------- --------------------- -
------
-
-- -------------------- ------------ ---------
----------
--------------------- ------------
-queue.ShutDown：关闭工作队列。WaitForCacheSync：等待资源对象的缓存和监控器完成同步。worker：处理资源对象的函数。Wait.Until：等待工作队列中有需要处理的资源对象。<-c.stopCh：等待停止信号。
在 Controller 结构体中添加一个名为 worker 的函数，用于处理资源对象：
-- -------------------- ---- -------
---- -- ------------ -------- -
--- ------------------- -
-
-
---- -- ------------ ----------------- ---- -
---- ---- -- -------------
-- ---- -
------ -----
-
----- -----------------
---- ------- --- -- ----------------------------------------------
-- --- -- --- -
----------------- -------- ------ ---- --- --- ---- ------------- ----
-
-- ------- -
------------------ ---- --- -- ---- --- ------- -------------
-
-- ----- ------- ------
------ ----
-queue.Get：从工作队列中获取下一个需要处理的资源对象。queue.Done：标记资源对象已经被处理。informer.GetIndexer().GetByKey：从资源对象的缓存中获取指定的资源对象。process object：处理资源对象的逻辑。
在 Controller 结构体中添加一个名为 enqueuePod 的函数，用于将需要处理的资源对象加入工作队列：
-- -------------------- ---- -------
---- -- ------------ -------------- ------------ -
---- --- -- -------------------------------
-- --- -- --- -
----------------- ---------- ---- ---- ----
------
-
----------------
-MetaNamespaceKeyFunc：生成资源对象的唯一键。
启动控制器
在 main 函数中，创建 Kubernetes 客户端并启动控制器：
-- -------------------- ---- -------
---- ------ -
------- --- -- ----------------------
-- --- -- --- -
------------------
-
---------- --- -- -------------------------------
-- --- -- --- -
------------------
-
---------- -- ------------------------
------ -- --------- ---------- --
--------------------- --------------- ----------------
-- ----------------
--------
------------------------
-rest.InClusterConfig：获取 Kubernetes 集群的配置。kubernetes.NewForConfig：创建 Kubernetes 客户端。NewController：创建控制器。Notify：注册停止信号。run：启动控制器。close：发送停止信号。
示例代码
完整的示例代码如下：
-- -------------------- ---- -------
------- ----
------ -
---------
-----
----
-----------
---------
------
--------------------
--------------------------------------
-------------------------------
-----------------------------------
-----------------------------
------------------------------
---------------------------------
----------------------------------
-
---- ---------- ------ -
--------- --------------------
----- -------------------------------
-------- -------------------------
------ ---- --------
-
---- ----------------------- --------------------- ----------- -
----- -- ------------------------------------------------------------------------
-------- -- -----------------------------
-----------------
--------- ------------ ------------------- ---------------- ------ -
------ ------------------------------------------------------ --------
--
---------- ------------ ------------------- ----------------- ------ -
------ ------------------------------------------------------- --------
--
--
----------
--
-----------------
-
---------- -- ------------
---------- ----------
------ ------
--------- ---------
------- --------- ----------
-
---------------------------------------------------------
-------- ----------------------
--
------ ----------
-
---- -- ------------ ----- -
----- ------------------
--------------------- ------------
-- --------------------------------- --------------------- -
------
-
-- -------------------- ------------ ---------
----------
--------------------- ------------
-
---- -- ------------ -------- -
--- ------------------- -
-
-
---- -- ------------ ----------------- ---- -
---- ---- -- -------------
-- ---- -
------ -----
-
----- -----------------
---- ------- --- -- ----------------------------------------------
-- --- -- --- -
----------------- -------- ------ ---- --- --- ---- ------------- ----
-
-- ------- -
------------------ ---- --- -- ---- --- ------- -------------
-
---- -- -- -------------
-- --- -
------------------ ---- --- -- -- --- - ----- -------------
------ ----
-
-- ----------------------------------------------- --------------- ---- -
-- -------------------------------- -- --- -
----------------
- ---- -
----------------
-
- ---- -
-------------------
-
------ ----
-
---- -- ------------ ---------------- -------- -
------------------ --------- -- --- --------- ------------------------- --------------------
---------- -- --------------------------------- ---------------
---- -- --------------
-------------------------- - ----------
-- --- -- -------------------------------------------------------------------------------- ----- -------------------
-- --- -- --- -
----------------- ------ --------- -- --- ------ ---- ------------------------- -------------------- ----
-
-
---- -- ------------ ------------- -------- -
-------------------- --- --------- ------------------------- --------------------
---- -- --------------
---------------------------------- - ---------
-- --- -- -------------------------------------------------------------------------------- ----- -------------------
-- --- -- --- -
----------------- -------- --- ------ ---- ------------------------- -------------------- ----
-
-
---- -- ------------ ------------- -------- -
-------------------- --- --------- ------------------------- --------------------
--- -- -------------------------------------------------------------------------------- -------------------- -------------------
-- --- -- --- -
----------------- -------- --- ------ ---- ------------------------- -------------------- ----
-
-
---- -- ------------ -------------- ------------ -
---- --- -- -------------------------------
-- --- -- --- -
----------------- ---------- ---- ---- ----
------
-
----------------
-
---- ------ -
------- --- -- ----------------------
-- --- -- --- -
------------------
-
---------- --- -- -------------------------------
-- --- -- --- -
------------------
-
---------- -- ------------------------
------ -- --------- ---------- --
--------------------- --------------- ----------------
-- ----------------
--------
------------------------
-结论
通过本文的介绍，初学者可以了解 Kubernetes 控制器的工作原理和实现方式，同时也可以学习如何使用 Golang 编写 Kubernetes 控制器。在实践中，需要根据实际需求和场景，对示例代码进行适当修改和扩展。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/67458e65c1a23897eaa00aca
