traefik启动流程

traefik的源码抽象的比较好,还是挺容易看懂的,本文我简单过下启动的整体流程,后面在根据每个模块去具体分析

//cmd/traefik/traefik.go
main()
  //初始化配置
  tConfig := cmd.NewTraefikConfiguration()
  //设置日志,用的zerolog(仅维护,停止发版了),社区有商量换zap
  setupLogger(staticConfiguration)
  //设置静态参数,如启动监听EntryPoint端口，Providers动态获取配置有哪些
  staticConfiguration.SetEffectiveConfiguration()
  //开启服务
  svr, err := setupServer(staticConfiguration)
  svr.Start(ctx)
  //优雅中止
  defer svr.Close()
  //健康检查

具体的逻辑都在setupServer/svr.start里

//cmd/traefik/traefik.go
setupServer(staticConfiguration *static.Configuration) (*server.Server, error)
//根据Providers的类型实例化provider,后续会单独一节讲ingress provider
providerAggregator := aggregator.NewProviderAggregator(*staticConfiguration.Providers)

// 指标上报
metricRegistries := registerMetricClients(staticConfiguration.Metrics)
metricsRegistry := metrics.NewMultiRegistry(metricRegistries)

// tcp/udp的entrypoints初始化
serverEntryPointsTCP, err := server.NewTCPEntryPoints(staticConfiguration.EntryPoints, staticConfiguration.HostResolver, metricsRegistry)
serverEntryPointsUDP, err := server.NewUDPEntryPoints(staticConfiguration.EntryPoints)

//加载插件以及pluginBuilder插件
pluginBuilder, err := createPluginBuilder(staticConfiguration)
for name, conf := range staticConfiguration.Providers.Plugin{}
// services管理相关
roundTripperManager := service.NewRoundTripperManager(spiffeX509Source)
dialerManager := tcp.NewDialerManager(spiffeX509Source)
acmeHTTPHandler := getHTTPChallengeHandler(acmeProviders, httpChallengeProvider)
managerFactory := service.NewManagerFactory(*staticConfiguration, routinesPool, metricsRegistry, roundTripperManager, acmeHTTPHandler)

// router路由相关
accessLog := setupAccessLog(staticConfiguration.AccessLog)
tracer, tracerCloser := setupTracing(staticConfiguration.Tracing)
chainBuilder := middleware.NewChainBuilder(metricsRegistry, accessLog, tracer)
routerFactory := server.NewRouterFactory(*staticConfiguration, managerFactory, tlsManager, chainBuilder, pluginBuilder, metricsRegistry, dialerManager)

//创建监听和更新配置,tls,Metrics,Server Transports,router,
watcher := server.NewConfigurationWatcher(
		routinesPool,
		providerAggregator,
		getDefaultsEntrypoints(staticConfiguration),
		"internal",
	)
return server.NewServer(routinesPool, serverEntryPointsTCP, serverEntryPointsUDP, watcher, chainBuilder, accessLog, tracerCloser), nil

//pkg/server/server.go
func (s *Server) Start(ctx context.Context)
    //启动EntryPoints,watcher,以及实现优雅退出
	go func() {
		<-ctx.Done()
		logger := log.Ctx(ctx)
		s.Stop()
    }
    s.tcpEntryPoints.Start()
    s.udpEntryPoints.Start()
    s.watcher.Start()
    //优雅中止,监听到kill信号
    s.routinesPool.GoCtx(s.listenSignals)