Go Micro是一个可插拔的RPC框架，用于分布式系统的开发。

架构 - 图1

特性

Go Micro把分布式系统的各种细节抽象出来。下面是它的主要特性。

  • 服务发现（Service Discovery） - 自动服务注册与名称解析。
  • 负载均衡（Load Balancing） - 在服务发现之上构建了智能的负载均衡机制
  • 同步通信（Synchronous Comms） - 基于RPC的通信，支持双向流。
  • 异步通信（Asynchronous Comms） - 内置发布/订阅的事件驱动架构
  • 消息编码（Message Encoding） - 基于content-type的动态编码，支持protobuf、json，开箱即用。
  • 服务接口（Service Interface） - 所有特性都被打包在简单且高级的接口中，方便开发微服务。
    Go Micro支持服务与函数式编程模型。继续往下看了解更多。

相关插件

Go Micro旨在使用接口达到让其抽象化。因此，内部的实现可以被抽离出来。

我们提供了一些默认的完整的开箱即用的插件。

  • Consul或mDNS，用于服务发现
  • Random hashed client side load balancing，哈希随机客户端负载均衡
  • JSON-RPC 1.0及PROTO-RPC的消息编码
  • HTTP，基于HTTP的通信机制

示例

服务示例可查看examples/service。 Function可查看examples/function。

examples的Github目录下包含了各种示例，比如中间件/包装器，选择过滤器，发布/订阅，gRPC，插件等。

greeter示例的完整代码examples/greeter。

所有的示例都可以在GitHub仓库中找到。

观看Golang英国会议2016视频，获得更高级的视角。

相关包

Go micro由下面的几个包组成

  • transport 用于同步消息
  • broker 用于异步消息
  • codec 用于消息编码
  • registry 用于服务发现
  • selector 用于负载均衡
  • client 用于发送请求
  • server 用于处理请求
    下面进一步介绍

注册（Registry）

注册提供了服务发现机制来解析服务名到地址上。它可以使用Consul、etcd、zookeeper、dns、gossip等等提供支持。服务使用启动注册关机卸载的方式注册。服务可以选择性提供过期TTL和定时重注册来保证服务在线，以及在服务不在线时把它清理掉。

选择器（Selector）

选择器是构建在注册这上的负载均衡抽象。它允许服务被过滤函数过滤掉不提供服务，也可以通过选择适当的算法来被选中提供服务，算法可以是随机、轮询（客户端均衡）、最少链接（leastconn）等等。选择器通过客户端创建语法时发生作用。客户端会使用选择器而不是注册表，因为它提供内置的负载均衡机制。

传输（Transport）

Transport是服务与服务之间同步请求/响应的通信接口。和Golang的net包类似，但是提供更高级的抽象，请允许我们可以切换通信机制，比如http、rabbitmq、websockets、NATs。传输也支持双向流，这一强大的功能使得客户端可以向服务端推送数据。

代理（Broker）

Broker提供异步通信的消息发布/订阅接口。对于微服务系统及事件驱动型的架构来说，发布/订阅是基础。一开始，默认我们使用收件箱方式的点到点HTTP系统来最小化依赖的数量。但是，在go-plugins是提供有消息代理实现的，比如RabbitMQ、NATS、NSQ、Google Cloud Pub Sub等等。

编码（Codec）

编码包用于在消息传输到两端时进行编码与解码，可以是json、protobuf、bson、msgpack等等。与其它编码方式不同，我们支持RPC格式。所以我们有JSON-RPC、PROTO-RPC、BSON-RPC等格式。

编码包把客户端与服务端的编码隔离开来，并提供强大的方法来集成其它系统，比如gRPC、Vanadium等等。

Server（服务端）

Server包是使用编写服务的构建包，可以命名服务，注册请求处理器，增加中间件等等。服务构建在以上说的包之上，提供独立的接口来服务请求。现在服务的构建是RPC系统，在未来可能还会有其它的实现。服务端允许定义多个不同的编码来服务不同的编码消息。

Client（客户端）

客户端提供接口来创建向服务端的请求。与服务端类似，它构建在其它包之上，它提供独立的接口，通过注册中心来基于名称发现服务，基于选择器（selector）来负载均衡，使用transport、broker处理同步、异步消息。

上面的这些组件都可以在micro中，从更高的角度看成是服务（Service）

内部机制

下面是说明一下核心功能是如何工作的

service.Run()

Go-micro服务通过调用service.Run()启动。

  • 执行在启动之前的函数
  1.  for _, fn := range s.opts.BeforeStart {
  2.          if err := fn(); err != nil {
  3.                  return err
  4.          }
  5.  }
  • 启动服务
  1.  if err := s.opts.Server.Start(); err != nil {
  2.          return err
  3.  }
  • 在服务发现中心注册服务
  1.  if err := s.opts.Server.Register(); err != nil {
  2.          return err
  3.  }
  • 执行在启动之后的函数
  1.  for _, fn := range s.opts.AfterStart {
  2.          if err := fn(); err != nil {
  3.                  return err
  4.          }
  5.  }

server.Start()

server.Start会被service.Run调用

  • 调用transport.Listen侦听连接
  1.  ts, err := config.Transport.Listen(config.Address)
  2.  if err != nil {
  3.          return err
  4.  }
  • 调用transport.Accept接受连接
  1.  go ts.Accept(s.accept)
  • 调用broker.Connect开始连接消息代理
  1.  config.Broker.Connect()
  • 等待退出信息，关掉transport，断掉broker链接。
  1.  go func() {
  2.          // wait for exit
  3.          ch := <-s.exit
  5.          // wait for requests to finish
  6.          if wait(s.opts.Context) {
  7.                  s.wg.Wait()
  8.          }
  10.          // close transport listener
  11.          ch <- ts.Close()
  13.          // disconnect the broker
  14.          config.Broker.Disconnect()
  15.  }()

如何编写服务

查看编写Go服务