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-...

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