go micro transport

micro.newService()中newOptionsgit

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
}

初始化了一堆基礎設置,來看看Transport
transport.DefaultTransport,
在transport/transport.go中的
DefaultTransport Transport = newHTTPTransport()github

func NewTransport(opts ...Option) Transport {
    return newHTTPTransport(opts...)
}

func newHTTPTransport(opts ...Option) *httpTransport {
    var options Options
    for _, o := range opts {
        o(&options)
    }
    return &httpTransport{opts: options}
}

這裏就初始化並設置options,返回了一個httpTransport{}web

手動指定其餘的Transport,兩種方式segmentfault

  1. micro.NewService()中傳入micro.Transport(grpc.NewTransport()),, 便可使用grpc Transport
  2. plugins.go中import加入"github.com/micro/go-plugins/transport/grpc/v2"

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、Grafanaapp

相關文章
相關標籤/搜索