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
}
初始化了一堆根底设置,先来看看cmd cmd.DefaultCmd,
在config/cmd/cmd.go DefaultCmd = newCmd()
type Cmd interface {
// The cli app within this cmd
App() *cli.App
// Adds options, parses flags and initialise
// exits on error
Init(opts ...Option) error
// Options set within this command
Options() Options
}
type cmd struct {
opts Options
app *cli.App
}
type Option func(o *Options)
func newCmd(opts ...Option) Cmd {
options := Options{
Auth: &auth.DefaultAuth,
Broker: &broker.DefaultBroker,
Client: &client.DefaultClient,
Registry: ®istry.DefaultRegistry,
Server: &server.DefaultServer,
Selector: &selector.DefaultSelector,
Transport: &transport.DefaultTransport,
Router: &router.DefaultRouter,
Runtime: &runtime.DefaultRuntime,
Store: &store.DefaultStore,
Tracer: &trace.DefaultTracer,
Profile: &profile.DefaultProfile,
Config: &config.DefaultConfig,
Brokers: DefaultBrokers,
Clients: DefaultClients,
Registries: DefaultRegistries,
Selectors: DefaultSelectors,
Servers: DefaultServers,
Transports: DefaultTransports,
Routers: DefaultRouters,
Runtimes: DefaultRuntimes,
Stores: DefaultStores,
Tracers: DefaultTracers,
Auths: DefaultAuths,
Profiles: DefaultProfiles,
Configs: DefaultConfigs,
}
for _, o := range opts {
o(&options)
}
if len(options.Description) == 0 {
options.Description = "a go-micro service"
}
cmd := new(cmd)
cmd.opts = options
cmd.app = cli.NewApp()
cmd.app.Name = cmd.opts.Name
cmd.app.Version = cmd.opts.Version
cmd.app.Usage = cmd.opts.Description
cmd.app.Before = cmd.Before
cmd.app.Flags = DefaultFlags
cmd.app.Action = func(c *cli.Context) error {
return nil
}
if len(options.Version) == 0 {
cmd.app.HideVersion = true
}
return cmd
}
这里的cmd构造体中
- opts就是options.go中定义的各种属性,基本上micro中每个模块的option都在options.go中,而后是一堆设置属性的函数(函数选项模式)
- app是cli.app实例,这个cli是fork的一个开源cli库urfave/cli , 文档
- newCmd()也初始化了很多Options,承受参数赋值o(&options)
- 初始化cmd,设置一些根底值,包含DefaultFlags,这些能够在命令行帮忙文本呈现,另外还有
cmd.app.Before = cmd.Before
func (c *cmd) Before(ctx *cli.Context) error
{
//...太长省略
//这里上面第三步正文
authFn := func() auth.Auth { return *c.opts.Auth }
cacheFn := func() *client.Cache { return (*c.opts.Client).Options().Cache }
microClient := wrapper.CacheClient(cacheFn, grpc.NewClient())
microClient = wrapper.AuthClient(authFn, microClient)
//...太长省略
}
这里做了很多事件
- 设置clientOpts []client.Option,从命令行取以下参数放入数组:client_retries,client_request_timeout,client_pool_size,client_pool_ttl,
- 设置serverOpts []server.Option,从命令行取以下参数放入数组:server_metadata(数组),server_name,server_version,server_id,server_address,server_advertise,register_ttl,register_interval,
- 设置microClient,先定义了authFn,cacheFn用于初始化client.client,相当于在client上wrapper包装auth和cache,默认的cache是memory
- 设置authOpts,auth的options,从命令行取以下参数放入数组:auth_address,auth_id,auth_public_key,auth_private_key,service_namespace,auth_provider,auth_provider_client_id,auth_provider_endpoint,auth_provider_redirect,auth_provider_scope
- 设置auth,如果命令行参数auth给了指定的auth,就初始化指定的,没有就应用默认的noop(没有验证)
- 生成服务serverID
- 设置broker options:brokerOpts,命令行参数broker_address
- 设置registry options:registryOpts,命令行参数registry_address。设置服务注册registry,命令行参数registry,命令行有指定就初始化指定的服务注册核心,不然就用默认的,目前默认是mdns(单机无效)
- 设置selector,命令行参数selector,命令行有指定就初始化指定的selector(目前2.x版本是长期状态,v3有较大变动)
- 设置路由router,命令行参数service_namespace,router_address,router,命令行有指定就初始化指定的
- 设置store options,storeOpts命令行参数store_address,store_database,store_table,store,默认memory,基于patrickmn/go-cache
- 设置runtime options,runtimeOpts,命令行参数runtime_source,runtime,命令行有指定就初始化指定的
- 设置tracer,profile,命令行参数tracer,profile
- 设置broker,命令行参数broker,这里如果有自定义命令行参数,会同步增加到serverOpts,clientOpts
- 设置transport options,命令行参数transport_address,transport这里如果有自定义命令行参数,会同步增加到serverOpts,clientOpts
- 设置config源,命令行参数config,service_namespace,如果config设为service会有非凡设置
- 设置client,命令行参数client
- 设置server,命令行参数client
终于设置完了。。。
总结,micro 微服务启动过程中,通过cmd设置好了许多组件,cmd.Options()
即可获取
发表回复