Go Micro

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

特性

Go Micro抽象出分布式系统的细节。以下是主要功能。

  • 服务发现 - 通过服务发现自动注册和名称解析
  • 负载平衡 - 基于发现构建的服务的智能客户端负载平衡
  • 同步通信 - 基于RPC的通信，支持双向流
  • 异步通信 - 为事件驱动架构内置的Pub/Sub接口
  • 消息编码 - 基于带有protobuf和json的内容类型的动态编码
  • 服务接口 - 所有功能都打包在一个简单的高级界面中，用于开发微服务

Go Micro支持服务和功能编程模型。请继续阅读以了解更多信息。

插件

Go-micro使用Go界面进行抽象。由于这个原因，底层实现可以被换出。

我们提供了开箱即用的默认设置。

  • Consul或mDNS服务发现
  • 随机散列客户端负载平衡
  • JSON-RPC 1.0和PROTO-RPC消息编码
  • HTTP通信机制

示例

在示例/函数以及示例/服务可以找到示例服务。

示例目录包含使用诸如中间件/封装器，选择器过滤器，pub/sub，grpc，插件等的示例。对于完整的greeter示例，请查看示例/greeter程序。其他示例可以在整个GitHub存储库中找到。

观看Golang UK Conf 2016视频以获取高级概述。

软件包

Go micro由多个软件包组成。

  • 传输同步消息
  • 代理异步消息
  • 用于消息编码的编解码器
  • 服务发现注册表
  • 选择器进行负载平衡
  • 客户端提出请求
  • 服务器来处理请求

更多细节如下

注册机制

注册机制提供了一个服务发现机制来将名称解析为地址。它可以由consul，etcd，zookeeper，dns，gossip等提供支持。服务应该在启动时使用注册机制进行注册，并在关闭时取消注册。服务可以选择提供一个到期的TTL并在一段时间内重新注册以确保活跃，并且如果服务死亡，服务将被清除。

选择器

选择器是建立在注册表上的负载平衡抽象。它允许使用过滤器功能对“服务”进行“过滤”，并使用诸如random，roundrobin，leastconn等算法选择“选择”服务。客户端在请求时利用选择器。客户端将使用选择器而不是注册表，因为它提供了内置的负载平衡机制。

传输

传输是用于服务之间的同步请求/响应通信的接口。它类似于golang网络包，但提供更高层次的抽象，允许我们切换通信机制，例如http，rabbitmq，websockets，NATS。该传输也支持双向流式传输。这对客户端推送到服务器提供强大的能力。

代理

代理为消息代理提供异步发布/订阅通信的接口。这是事件驱动架构和微服务的基本要求之一。默认情况下，我们使用收件箱样式指向HTTP系统，来最小化基本所需的依赖的数量。但是，在go-plugins中有许多消息代理实现可用，例如RabbitMQ，NATS，NSQ，Google Cloud Pub Sub。

编解码器

编解码器用于编码和解码消息，然后再通过线路传输消息。这可能是json，protobuf，bson，msgpack等。这与其他大多数编解码器不同之处在于我们实际上也支持RPC格式。所以我们有JSON-RPC，PROTO-RPC，BSON-RPC等。它将客户端/服务器的编码分离出来，并提供了一个强大的方法来集成其他系统，如gRPC，Vanadium等。

服务器

服务器是编写服务的构建模块。在这里，您可以命名您的服务，注册请求处理程序，添加middeware等。该服务构建在上述软件包上，为服务请求提供统一接口。内置一个RPC系统的服务器。将来可能会有其他的实现。该服务器还允许您定义多个编解码器以提供不同的编码消息。

客户端

客户端提供一个接口来向服务发出请求。就像服务器一样，它建立在其他软件包上，以提供一个统一的界面，用于使用注册机制，根据名称查找服务，使用选择器进行负载平衡，使用代理进行传输和异步消息传输的同步请求。

上述组件被组合在微服务的顶层。

内部实现

以下是关于核心部件的内部工作的原理。

service.Run()

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

  1. 在启动功能之前执行

      for _, fn := range s.opts.BeforeStart {
          if err := fn(); err != nil {
                  return err
          }
  }

  2. 启动服务

     if err := s.opts.Server.Start(); err != nil {
          return err
 }

  3. 注册和服务发现

      if err := s.opts.Server.Register(); err != nil {
          return err
  }

  4. 在启动功能后执行

     for _, fn := range s.opts.AfterStart {
         if err := fn(); err != nil {
                 return err
         }
 }

server.Start()

server.Start由service.Run调用

  1. 调用transport.Listen监听连接

      ts, err := config.Transport.Listen(config.Address)
  if err != nil {
          return err
  }

  2. 调用transport.Accept开始接收链路

      go ts.Accept(s.accept)

  3. 调用broker.Connect开始处理链路消息

      config.Broker.Connect()

  4. 等待退出信号，关闭运输并断开代理

    
  go func() {
          // wait for exit
          ch := <-s.exit

          // wait for requests to finish
          if wait(s.opts.Context) {
                  s.wg.Wait()
          }

          // close transport listener
          ch <- ts.Close()

          // disconnect the broker
          config.Broker.Disconnect()
  }()

编写服务

查看入门文档

文档更新时间: 2020-05-31 12:25   作者：kuteng