安装注册插件
go get -u github.com/isfk/go-micro-plugins/registry/nacos/v3
使用
import(
"github.com/asim/go-micro/v3"
"github.com/isfk/go-micro-plugins/registry/nacos/v3"
)
nacosNamespace := "my_namespace"
registry := nacos.NewRegistry(func(options *registry.Options) {
options.Addrs = []string{"127.0.0.1:8848"}
// 支持 namespace
options.Context = context.WithValue(context.Background(), &nacos.NacosNamespaceContextKey{}, nacosNamespace)
})
service := micro.NewService(
micro.Name("go.micro.src.demo"),
micro.Registry(registry),
)
service.Run()
输出
2021-02-02 16:55:27 file=v3@v3.5.0/service.go:192 level=info Starting [service] go.micro.srv.demo
2021-02-02 16:55:27 file=server/rpc_server.go:820 level=info service=server Transport [http] Listening on [::]:51065
2021-02-02 16:55:27 file=server/rpc_server.go:840 level=info service=server Broker [http] Connected to 127.0.0.1:51066
2021-02-02 16:55:27 file=server/rpc_server.go:654 level=info service=server Registry [nacos] Registering node: go.micro.srv.demo-046e9809-87fb-4fbe-86a4-ca13bd996b3a
2021-02-02 16:55:27 file=server/rpc_server.go:706 level=info service=server Subscribing to topic: go.micro.srv.demo
2021-02-02 16:55:27 file=server/rpc_server.go:706 level=info service=server Subscribing to topic: go.micro.srv.demo