k8s学习（一）——kubectl与api-server之间的交互核心过程

k8s的架构是用户使用kubectl工具对虚拟机资源进行各种各样的控制和定制。

而kubectl本身并不包含对其核心资源的访问与控制。而是通过http通信与api-server进行交互实现资源的管理。

而api-server的核心其实就是etcd数据库，它将各种资源的管理通过对etcd中的数据进行更改实现。这篇文章简要分析一下kubectl对

api-server发起访问的过程。

以kubectl create 指令为例，其指令的相关代码在kubernetes/pkg/kubectl/cmd/create.go这个文件中。

一，参数的构造

稍加分析不难看出，其创建资源的核心函数是func RunCreate（）。

          r := builder.
		Schema(schema).
		ContinueOnError().
		NamespaceParam(cmdNamespace).DefaultNamespace().
		FilenameParam(enforceNamespace, &options.FilenameOptions).
		SelectorParam(options.Selector).
		Flatten().
		Do()

 这段代码调用了builder的一串函数，最后生成一个Result类型的变量r。（Result 定义在 kubernetes/pkg/kubectl/resource/result.go）

这里builder的作用是将之前解析得到的各种参数进行各种分析后填充到builder中，最后再生成一个Result类型的变量r。

此时r中最关键的数据是visitor，这个visitor中包含了多个资源，也就是说一个visitor包含了一个对象（此处存疑）。

接着以一个函数func为参数调用r的Visit函数。经过分析我们可以知道这是一个调用链函数，其中继续对参数进行各种分析，处理。

r.Visit(func(info *resource.Info, err error) error {
.....
})

大致的调用顺序为

Result.Visit()
ContinueOnError.Visit()
Decorated.Visit()
FlattenList.Visit()
EagerVisitorList.Visit()
FileVisitor.Visit()
StreamVisitor.Visit()
在StreamVisitor之前，都是对数据的各种处理，并不会调用func函数，在StreamVisitor.Visit()中一个关键的处理是生成一个临时变量Info。

info, err := v.InfoForData(ext.Raw, v.Source)

这里的ext.Raw和v.Source都是之前对用户的输入进行解析的结果。

ext.Raw是byte[]类型，v.Source是String类型，打印出来：

ext.Raw={
"apiVersion":"v1",
"kind":"Pod",
"metadata":
    {"name":"with-node-affinity-2"},
"spec":
{"affinity":
    {"nodeAffinity":{"preferredDuringSchedulingIgnoredDuringExecution":[{"preference":{"matchExpressions":[{"key":"another-node-label-key","operator":"In","values":["another-node-label-value"]}]},
"weight":1}],
"requiredDuringSchedulingIgnoredDuringExecution":{"nodeSelectorTerms":[{"matchExpressions":[{"key":"kubernetes.io/e2e-az-name","operator":"In","values":["e2e-az1","e2e-az2"]}]}]}}},
"containers":[{"image":"gcr.io/google_containers/pause:2.0","name":"with-node-affinity"}]}},




v.Source=/home/wlh/mywork/yaml_file/pod-with-node-affinity.yaml

可以看到其中存储了生成的资源的各种特性，有了这个info之后执行func(info)。

二，访问api-server

得到了info这个数据结构后，调用func（）函数对api-server发起访问请求。

if !dryRun {
			if err := createAndRefresh(info); err != nil {
				return cmdutil.AddSourceToErr("creating", info.Source, err)
			}
		}

这个dryRun标志位的意思是，只打印出将要创建的资源的各种特性，而不会真正去创建他。

而createAndRefresh函数中的核心调用是

obj, err := resource.NewHelper(info.Client, info.Mapping).Create(info.Namespace, true, info.Object)

 这里创建了一个Helper类型的对象，仔细分析后不难发现Info.Client中定义了访问动作，而info.Mapping中定义了这些动作所要访问的资源。

此时Helper中已经包含了发起一个对api-server请求的所有资源，接着调用Create函数，它创建一个具体去执行这些请求的Request对象。（定义在kubernetes/vendor/k8s.io/client-go/rest/request.go中）

Requeste发起对api-server的请求，并且将访问存储在ResutInfo中，与此同时返回一个Runtime.Object对象。

这样一次完整的访问api-server的流程就完成了。