go micro store

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
}

初始化了一堆基礎設置，來看看Store
store.DefaultStore,
這裏不要直接去看store/store.go中的
DefaultStore Store = new(noopStore)，
由於在micro/defaults.go中已經初始化了，默認使用的是
store.DefaultStore = memoryStore.NewStore()

// NewStore returns a memory store
func NewStore(opts ...store.Option) store.Store {
    s := &memoryStore{
        options: store.Options{
            Database: "micro",
            Table:    "micro",
        },
        store: cache.New(cache.NoExpiration, 5*time.Minute),
    }
    for _, o := range opts {
        o(&s.options)
    }
    return s
}

type memoryStore struct {
    options store.Options

    store *cache.Cache
}

1. 初始化了memoryStore{}，store是使用的patrickmn/go-cache
2. 設置options，返回memoryStore實例

功能比較簡單，在store/memory/memory.go封裝了讀寫刪改等操做函數

其餘store有cache，cockroach，file，service，實現都比較簡單，有興趣能夠自行翻看

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