服务的注册发现对于微服务来说是一个非常重要的环节，在单一架构应用中，service之间的互相调用，通过一个固定的host和port来发起REST或者RPC来调用，但是在微服务架构中，各个服务往往是动态变化的，所以需要一个服务发现机制来发送客户端的请求到动态的service实例中去。
在利用go micro来实现服务发现便利很多，micro中默认支持使用 来做服务发现，当然它使用插件机制（）还支持 Etcd, Gossip, NATS等其他的第三方服务注册发现工具。在每个服务启动的时候，都将自己注册到registry上，退出时也自动解注册，具体实现我们可以来看一下go-micro/service.go的相关代码片段:
......func (s *service) run(exit chan bool) { if s.opts.RegisterInterval <= time.Duration(0) { return } //定时注册自己 t := time.NewTicker(s.opts.RegisterInterval) for { select { case <-t.C: err := s.opts.Server.Register() if err != nil { log.Log("service run Server.Register error: ", err) } case <-exit: t.Stop() return } }}......func (s *service) Start() error { for _, fn := range s.opts.BeforeStart { if err := fn(); err != nil { return err } } if err := s.opts.Server.Start(); err != nil { return err } // Run() 调用中也会结果run来调到这里来注册 if err := s.opts.Server.Register(); err != nil { return err } for _, fn := range s.opts.AfterStart { if err := fn(); err != nil { return err } } return nil}func (s *service) Stop() error { var gerr error for _, fn := range s.opts.BeforeStop { if err := fn(); err != nil { gerr = err } } // 退出时自动解除注册 if err := s.opts.Server.Deregister(); err != nil { return err } if err := s.opts.Server.Stop(); err != nil { return err } for _, fn := range s.opts.AfterStop { if err := fn(); err != nil { gerr = err } } return gerr}...... 关于Consul的相关使用可以参考 ，下面主要来利用一个酒店预订的示例来看下Go Micro如何使用Consul的集群来做服务发现。
示例中会使用到一个 Micro API，它是Micro组件中的一个微服务API网关的实现，API网关模式可以为服务提供一个入口，该HTTP入口动态路由到合适的后端service，利用它进行服务发现，负载平衡，编码和基于RPC的通信。
Micro API提供的HTTP API 如下 :
- /[service]/[method] # HTTP路径动态映射到services- /rpc # 通过名称和方法显示调用后端service
在示例中使用 Micro API 的 RPC Handler，它是go-micro客户端将请求主体转发为RPC请求的默认处理程序的替代方案，具体Micro API的使用和REST映射规则可以查看文档
该酒店预定服务利用了官方 中的booking示例改写， 具体代码 =>
.├── README.md├── api│ └── hotel # booking service├── data # data│ ├── bindata.go│ ├── customers.json│ ├── locations.json│ ├── profiles.json│ └── rates.json├── docker-compose.yml # docker compose file└── srv # services ├── auth # auth token servce ├── geo # geo service ├── profile # profile service └── rate # rate service
docker-compose.yml
version: '3'services: consul-agent-1: &consul-agent image: consul:latest networks: - consul-cluster command: "agent -retry-join consul-server-bootstrap -client 0.0.0.0" consul-agent-2: <<: *consul-agent consul-agent-3: <<: *consul-agent consul-server-1: &consul-server <<: *consul-agent command: "agent -server -retry-join consul-server-bootstrap -client 0.0.0.0" consul-server-2: <<: *consul-server consul-server-bootstrap: <<: *consul-agent ports: - "8400:8400" - "8500:8500" - "8600:8600" - "8600:8600/udp" command: "agent -server -bootstrap-expect 3 -ui -client 0.0.0.0" auth: build: ./srv/auth networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 links: - consul-server-bootstrap geo: build: ./srv/geo networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 links: - consul-server-bootstrap profile: build: ./srv/profile networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 links: - consul-server-bootstrap rate: build: ./srv/rate networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 links: - consul-server-bootstrap api: build: ./api/hotel networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 links: - consul-server-bootstrap - auth - geo - profile - rate micro: networks: - consul-cluster command: --registry_address=consul-server-bootstrap:8500 api --handler=rpc image: microhq/micro:latest links: - consul-server-bootstrap - api ports: - "8080:8080"networks: consul-cluster:
consul每个数据中心至少必须拥有一台server，建议在一个集群中有3或者5个server.部署单一的server,在出现失败时会不可避免的造成数据丢失.-bootstrap-expect 选项提示Consul我们期待加入的server节点的数量。每一个服务的--registry_address就是设置注册到的服务发现注册表地址。
docker-compose up 后可以通过consul 的web ui来查看Service的状态。
转载请注明： 转载自
如果觉得本篇文章对您十分有益，何不 一下
本文链接地址: