最近刚开始学习kubernetes这个工具，从apiserver route开始看一些kubernetes的代码分析执行流程，想从代码里面深入学习一下，刚开始读写的比较简单，希望有不对的地方大家可以提出来，希望可以通过一点点的积累学习这个项目。
这里先从github上面把代码clone到本地，我这里是直接从master上clone下来的目测最新的版本是v1.7.9-alpha.0。
首先apiserver是从cmd命令开始的，一步步执行最终初始化一个webserver。apiserver的执行入口比较好找，从kubernetes/cmd/kube-apiserver/apiserver.go开始的:
func main() {
rand.Seed(time.Now().UTC().UnixNano())
//初始化默认的server配置信息
s := options.NewServerRunOptions()
//通过flag命令行参数重写配置信息,其中包含8080,6443等端口信息
s.AddFlags(pflag.CommandLine)
flag.InitFlags()
logs.InitLogs()
defer logs.FlushLogs()
verflag.PrintAndExitIfRequested()
//这里是具体的server运行函数
if err := app.Run(s); err != nil {
fmt.Fprintf(os.Stderr, "%v\n", err)
os.Exit(1)
}
}
这是apiserver.go的代码比较短就直接复制过来了,在上面加了一些注释，可以看到其他的代码我们都可以忽略，重要的入口在app.Run(s)所以我们可以根据这个端口一路跟踪下去。这个方法的所在位置kubernetes/cmd/kube-apiserver/app/server.go:
func Run(s *options.ServerRunOptions) error {
config, sharedInformers, err := BuildMasterConfig(s)
if err != nil {
return err
}
return RunServer(config, sharedInformers, wait.NeverStop)
}
func RunServer(config *master.Config, sharedInformers informers.SharedInformerFactory, stopCh <-chan struct{}) error {
m, err := config.Complete().New()
if err != nil {
return err
}
sharedInformers.Start(stopCh)
return m.GenericAPIServer.PrepareRun().Run(stopCh)
}
其中BuildMasterConfig是构建了一大堆master的配置信息，能够看到其实RunServer中的Run方法是运行服务的方法继续跟进这个方法就来到了staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go这个文件里面，这里其实是引用了一个kubernetes的apiserver的外部依赖:
func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error {
if s.SecureServingInfo != nil && s.Handler != nil {
if err := s.serveSecurely(stopCh); err != nil {
return err
}
}
if s.InsecureServingInfo != nil && s.InsecureHandler != nil {
if err := s.serveInsecurely(stopCh); err != nil {
return err
}
}
s.RunPostStartHooks()
// err == systemd.SdNotifyNoSocket when not running on a systemd system
if err := systemd.SdNotify("READY=1\n"); err != nil && err != systemd.SdNotifyNoSocket {
glog.Errorf("Unable to send systemd daemon successful start message: %v\n", err)
}
<-stopCh
return nil
}
其中s.serveInsecurely(stopCh)这个方法就是运行8080端口server的方法，通过这个方法跟进到staging/src/k8s.io/apiserver/pkg/server/serve.go这个文件里面:
unc (s *GenericAPIServer) serveInsecurely(stopCh <-chan struct{}) error {
insecureServer := &http.Server{
Addr: s.InsecureServingInfo.BindAddress,
Handler: s.InsecureHandler,
MaxHeaderBytes: 1 << 20,
}
glog.Infof("Serving insecurely on %s", s.InsecureServingInfo.BindAddress)
var err error
s.effectiveInsecurePort, err = runServer(insecureServer, s.InsecureServingInfo.BindNetwork, stopCh)
return err
}
其中s.InsecureServingInfo.BindAddress这个地址就是默认的绑定的127.0.0.1:8080这个地址，可以通过运行apiserver cmd命令的时候修改，而s.InsecureHandler就是这个server对apipath操作对应的一些方法，这个是最核心的东西，下一步我们反过来继续跟进这个东西。可以从上面看到runServer(insecureServer, s.InsecureServingInfo.BindNetwork, stopCh)这个方法，这个方法内部的具体实现比较长，这里就不复制过来了，这个方法内部就是关于把这个http server运行起来的具体内容。
