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()
     }()

编写服务

查看入门文档