关于golang:gomicro使用Consul做服务发现的方法和原理

go-micro v4 默认应用 mdns 做服务发现。不过也反对采纳其它的服务发现中间件，因为多年来始终应用 Consul 做服务发现，为了不便和其它服务集成，所以还是抉择了 Consul。这篇文章将介绍 go-micro 应用 Consul 做服务发现的办法。对于 Consul 的应用形式请参考我的另一篇文章：应用 Consul 做服务发现的若干姿态。

装置 Consul

如果你曾经装置 Consul，或者对 Consul 很相熟了，依照本人的形式解决 Consul 就行了。

这里提供一个通过 docker 疾速装置 Consul 的形式，当然前提是你得装置了 docker。

执行命令：

docker run --name consul1 -p 8500:8500 -p 8300:8300 -p 8301:8301 -p 8302:8302  -d consul:latest

这会在 docker 容器中启动一个最新版本的 Consul 服务，并将相干端口凋谢给主机。

装置 Consul 插件

应用 Consul 作为服务注册和服务发现，须要先装置 go-micro 的 consul 插件：

go get github.com/go-micro/plugins/v4/registry/consul

服务端应用 Consul

服务注册

为了应用 Consul 做服务注册，须要为 go-micro server 显式的指定 Consul Registry。间接看代码吧：

func main() {registry := consul.NewRegistry()

    rpcServer := server.NewServer(server.Name("registry-consul.service"),
        server.Address("0.0.0.0:8001"),
        server.Registry(registry),
    )

    proto.RegisterHelloHandler(rpcServer, &Hello{})

    service := micro.NewService(micro.Server(rpcServer),
    )

    service.Init()

    // Run server
    if err := service.Run(); err != nil {log.Fatal(err)
    }
}

通过 consul.NewRegistry() 创立一个 Consul 注册核心，而后应用 server.NewServer 创立 Server 的时候把它设置进去；同时咱们须要指定服务的名称，这里设置的是 registry-consul.service；另外这里不应用随机端口，指定了一个服务的监听地址。这样根本就 OK 了。

这里并没有指定 Consul 的连贯地址，因为依照举荐的 Consul 部署形式，服务所在机器或者容器中应该部署一个 Consul 的客户端，程序能够间接通过 127.0.0.1:8500 拜访到它。如果要显示指定，能够在 NewRegistry 时设置：

    registry := consul.NewRegistry(registry.Addrs("127.0.0.1:8500"),
    )

注册过程

通过一张图来看一下，go-micro 注册服务到 Consul 时都做了什么。

服务注册要害是实现两个动作：

1、注册： rpcServer 启动的时候，会调用到本身的 Register 办法，Register 办法会调用 consul 插件的 Register 办法，而后调用到 consul 本身 SDK 提供的 Agent.ServiceRegister 办法，将服务注册到 Consul 中。注册的服务名称就是 NewServer 时的 server.Name。

2、衰弱上报： 即刷新 TTL，服务注册胜利后，会启动一个定时器定时调用 consul 插件的 Register 办法，这个办法外部判断服务注册过，则会调用 consul 本身 SDK 提供的 Agent.PassTTL 办法，刷新 Consul 中对应服务的 TTL。

健康检查

go-micro 服务的衰弱状态是通过 TTL 保护的，服务须要定时去刷新 TTL，如果 TTL 超过指定的工夫没有被刷新，则服务会被认为是不衰弱的。默认状况下有三个设置会波及到 TTL，还是先来看代码：

registry := consul.NewRegistry()

    regCheckFunc := func(ctx context.Context) error {fmt.Println(time.Now().Format("2006-01-02 15:04:05") + "do register check")
        if 1+1 == 2 {return nil}
        return errors.New("this not earth")
    }

    rpcServer := server.NewServer(server.Name("registry-consul.service"),
        server.Address("0.0.0.0:8001"),
        server.Registry(registry),
        server.RegisterCheck(regCheckFunc),
        server.RegisterInterval(10*time.Second),
        server.RegisterTTL(20*time.Second),
    )

    proto.RegisterHelloHandler(rpcServer, &Hello{})

    service := micro.NewService(micro.Server(rpcServer),
    )

    //service.Init()

    if err := service.Run(); err != nil {log.Fatal(err)
    }

对于这三个设置，这里简略介绍下：

1、server.RegisterCheck(regCheckFunc) 服务刷新 TTL 之前，会调用一个函数查看服务的状态，这个函数的返回值是 error 类型。默认的函数不进行任何查看，间接返回 nil，代表服务状态失常；咱们能够本人写一个函数，进行一些查看逻辑，比方是否要下线保护。如果返回的 error 不是 nil，go-micro 会尝试在 Consul 中登记服务，则调用方将不会再拜访到这个服务节点。

2、server.RegisterInterval(10*time.Second) 这个设置指定程序去刷新 TLL 的频率。

3、server.RegisterTTL(20*time.Second) 这个设置指定 TTL 的生存周期，如果超过这个工夫没有刷新 TTL，则 Consul 会认为服务是不衰弱。

另外须要留神 不要应用 service.Init()，因为这里边会笼罩 RegisterInterval 和 RegisterTTL 的设置，除非你不关怀这两个参数。对于这个问题能够参考：https://github.com/asim/go-mi…

客户端应用 Consul

调用服务

为了应用 Consul 做服务发现，须要为 go-micro service 显式的指定 Consul Registry。还是间接看代码：

    registry := consul.NewRegistry()

    service := micro.NewService(micro.Client(client.NewClient()),
        micro.Registry(registry),
    )

    service.Init()
    client := proto.NewHelloService("registry-consul.service", service.Client())

    rsp, err := client.Say(context.TODO(), &proto.SayRequest{Name: "BOSSMA"})
    if err != nil {fmt.Println(err)
    }

    fmt.Println(rsp)

代码很简略，指定 consul 作为服务发现组件后，调用服务的时候传递的服务名称就会应用 consul 进行解析，获取到 IP、端口后，再进行理论调用。

发现过程

还是先来看张图，从调用 XXXService 的办法 YYY 开始：

整个过程分为两个大的步骤，第一步获取要调用服务的地址，第二步通过 http 申请调用服务。咱们重点看第一步通过 Consul 获取服务这块。

首先进入一个 Selector，就是选择器的意思。Selector 首先看缓存中有没有缓存申请服务的地址信息，如果没有就去 Consul 查问，查问到之后再通过指定的抉择策略选出来一个地址，用于后续 http 申请。这里默认的抉择策略是随机抉择，比方查问到这个服务有三个部署节点，随机策略会随机返回其中某一个地址。

除了随机策略，go-micro 还提供了一个轮询策略，这时候须要本人创立一个 Selector：

    registry := consul.NewRegistry()
    selector := selector.NewSelector(selector.SetStrategy(selector.RoundRobin),
        selector.Registry(registry),
    )

    service := micro.NewService(micro.Client(client.NewClient()),
        micro.Selector(selector),
        //micro.Registry(registry),
    )

另外从下面的示意图中，咱们能够看到 Selector 调用了 Registry，所以这里创立 Selector 的时候，咱们把 Registry 设置了进去，而后再把创立的 Selector 设置到 Service 中。其实还有另一种形式，把设置 Registry 放到设置 Selector 后边，同样能够把 Registry 注册到 Selector 中，然而这样比拟费解，还须要留神设置程序，我不举荐。不过如果在 Selector 之外须要应用 Registry 的时候，还是须要应用 micro.Registry(registry)进行注册，这个例子中并没有相干场景。

成果展现

先启动服务端，而后启动客户端，截图如下：

以上就是本文的次要内容，如有错漏欢送反馈。

演示代码已上传到 Github：https://github.com/bosima/go-…

播种更多架构常识，请关注微信公众号 萤火架构。原创内容，转载请注明出处。