Kubernetes apiserver route源码分析

最近刚开始学习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运行起来的具体内容。