加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

grpc(4):使用 golang 调用consul api 接口,注册user-tomcat

发布时间:2020-12-16 18:18:17 所属栏目:大数据 来源:网络整理
导读:1,关于consul dubbo的注册中心是zookeeper,redis。 motan的注册中心是zookeeper,consul。 kubernetes的注册中心是 etcd。 使用consul的好处是服务发现啥的都支持了。 可以使用域名进行负载均衡。 也是一个不错的 Server-Side Discovery Pattern 。 2,启

1,关于consul


dubbo的注册中心是zookeeper,redis。
motan的注册中心是zookeeper,consul。
kubernetes的注册中心是 etcd。
使用consul的好处是服务发现啥的都支持了。
可以使用域名进行负载均衡。
也是一个不错的 Server-Side Discovery Pattern 。

2,启动consul服务,调用接口


首先要在服务器安装一个consul服务:
http://www.52php.cn/article/p-xgladrhx-bew.html
然后下载go的客户端。
go get github.com/hashicorp/consul
然后就可以使用 consul api服务了。

package src

import (
    "fmt"
    consulapi "github.com/hashicorp/consul/api"
    "log"
    "testing"
)

const Id = "1234567890"

func TestRegister(t *testing.T) {

    fmt.Println("test begin .")
    config := consulapi.DefaultConfig()
    //config.Address = "localhost"
    fmt.Println("defautl config : ",config)
    client,err := consulapi.NewClient(config)
    if err != nil {
        log.Fatal("consul client error : ",err)
    }
    //创建一个新服务。
    registration := new(consulapi.AgentServiceRegistration)
    registration.ID = Id
    registration.Name = "user-tomcat"
    registration.Port = 8080
    registration.Tags = []string{"user-tomcat"}
    registration.Address = "127.0.0.1"

    //增加check。
    check := new(consulapi.AgentServiceCheck)
    check.HTTP = fmt.Sprintf("http://%s:%d%s",registration.Address,registration.Port,"/check")
    //设置超时 5s。
    check.Timeout = "5s"
    //设置间隔 5s。
    check.Interval = "5s"
    //注册check服务。
    registration.Check = check
    log.Println("get check.HTTP:",check)

    err = client.Agent().ServiceRegister(registration)



    if err != nil {
        log.Fatal("register server error : ",err)
    }

}

func TestDregister(t *testing.T){


    fmt.Println("test begin .")
    config := consulapi.DefaultConfig()
    //config.Address = "localhost"
    fmt.Println("defautl config : ",err)
    }

    err = client.Agent().ServiceDeregister(Id)
    if err != nil {
        log.Fatal("register server error : ",err)
    }


}

代码很简单,创建了一个consul的服务,说明tomcat的服务端口,ip。并且声明了一个check方法用来检查服务是否可用。

可以通过ui界面观察服务注册情况:

服务可用。

check失败服务不可用。

3,使用dig命令检查服务


yum install bind-utils

在服务器上面直接查看user-tomcat 服务情况:

# dig @10.0.2.15 -p 8600 user-tomcat.service.consul SRV ; <<>> DiG 9.9.4-RedHat-9.9.4-38.el7_3.2 <<>> @10.0.2.15 -p 8600 user-tomcat.service.consul SRV ; (1 server found)
;; global options: +cmd ;; Got answer: ;; ->>HEADER<<- opcode: QUERY,status: NOERROR,id: 17543 ;; flags: qr aa rd; QUERY: 1,ANSWER: 1,AUTHORITY: 0,ADDITIONAL: 1 ;; WARNING: recursion requested but not available ;; QUESTION SECTION: ;user-tomcat.service.consul.    IN      SRV

;; ANSWER SECTION: user-tomcat.service.consul. 0 IN SRV 1 1 8080 consul-dev.node.dc1.consul. ;; ADDITIONAL SECTION: consul-dev.node.dc1.consul. 0 IN A 127.0.0.1 ;; Query time: 0 msec ;; SERVER: 10.0.2.15#8600(10.0.2.15) ;; WHEN: Sun Mar 05 03:06:06 EST 2017 ;; MSG SIZE  rcvd: 100

consul-dev.node.dc1.consul. 0 IN A 127.0.0.1
可以查询到一个域名节点。

4,总结


本文的原文连接是: http://www.52php.cn/article/p-mdvmpmzo-bew.html
未经博主允许不得转载。
博主地址是:http://blog.csdn.net/freewebsys

总体上感觉 consul 还是非常简单实用的。 在做 Server-side Discovery 的时候是非常的方便的。 可以降低client的代码逻辑。

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读