go micro router

micro.newService()中newOptions

func newOptions(opts ...Option) Options {
    opt := Options{
        Auth:      auth.DefaultAuth,
        Broker:    broker.DefaultBroker,
        Cmd:       cmd.DefaultCmd,
        Config:    config.DefaultConfig,
        Client:    client.DefaultClient,
        Server:    server.DefaultServer,
        Store:     store.DefaultStore,
        Registry:  registry.DefaultRegistry,
        Router:    router.DefaultRouter,
        Runtime:   runtime.DefaultRuntime,
        Transport: transport.DefaultTransport,
        Context:   context.Background(),
        Signal:    true,
    }
    
    for _, o := range opts {
        o(&opt)
    }

    return opt
}

初始化了一堆基础设置，来看看Router
router.DefaultRouter,
在router/router.go中的
DefaultRouter = NewRouter()

// NewRouter creates new Router and returns it
func NewRouter(opts ...Option) Router {
    return newRouter(opts...)
}

// newRouter creates new router and returns it
func newRouter(opts ...Option) Router {
    // get default options
    options := DefaultOptions()

    // apply requested options
    for _, o := range opts {
        o(&options)
    }

    // construct the router
    r := &router{
        options:     options,
        subscribers: make(map[string]chan *Advert),
    }

    // create the new table, passing the fetchRoute method in as a fallback if
    // the table doesn't contain the result for a query.
    r.table = newTable(r.fetchRoutes)

    // start the router and return
    r.start()
    return r
}

这里做了以下事情：

1. 初始化并设置Options
2. 初始化router{}

3. fetchRoutes()检索给定服务的所有路由，并在路由表中创建它们

   1. r.options.Registry.GetService{}获取所有服务

   2. r.manageRoutes(srv, "create", domain)

      1. 每个节点初始化Route{}

      2. r.manageRoute(route, action)

         1. r.table.Create(route)在路由表中创建新的路由
4. 调用newTable()创建新table，返回table{}

5. r.start(),启动路由

   1. r.options.Prewarm是否预热路由表，需要就调用r.manageRegistryRoutes(r.options.Registry, "create")创建所有路由
   2. 添加默认网关到路由表
   3. registry watcher监听服务注册变动
   4. 启动协程，监听退出信号，服务注册变动信号，watchRegistry监视注册表并根据接收到的事件更新路由表。

如果注册表监视程序失败或路由表更新失败，则返回错误。

执行到到router的时候，服务都已经在注册中心注册好了，这里router会获取所有服务，建好路由表了

go micro 分析系列文章
go micro server 启动分析
go micro client
go micro broker
go micro cmd
go micro config
go micro store
go micro registry
go micro router
go micro runtime
go micro transport
go micro web
go micro registry 插件consul
go micro plugin
go micro jwt 网关鉴权
go micro 链路追踪
go micro 熔断与限流
go micro wrapper 中间件
go micro metrics 接入Prometheus、Grafana

有疑问加站长微信联系（非本文作者）