consul
consul是一个开源服务注册和服务发现的中心,可以用于微服务的注册和服务之间的调用的发现,帮助上游服务找到下游服务的具体ip:port或者是domain,也可以使用dns的方式让consul帮你去做转发,具体介绍请看consul的官网,consul区分server-agent和client-agent,client-agent的作用一般来说就是用来转发到server-agent的,所以本文只启动server-agent,他们的详细差距可以在google上查到,本文基于golang实现一个服务注册和服务发现的demo。demo地址
consul的安装和部署
consul有两种部署模式,一种是直接在cvm上安装consul的bin包,然后以server-agent的模式进行启动,一种是用docker直接启动镜像,本文直接使用docker启动镜像,将这个镜像的启动参数设置为server-agent,在这种模式下,如果要使用服务发现的功能需要区分主机ip和容器ip 不能使用127.0.0.1这种ip去让server维持go服务的心跳
本文使用的cvm系统为centos8,其他Linux发行版可以自行用包管理工具去安装一下的前置依赖
docker安装
curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun
systemctl start docker
使用上文脚本一键安装docker
consul镜像的启动
docker pull consul
docker run -d -p 8500:8500 -v ~/consul:/consul/data -e CONSUL_BIND_INTERFACE='eth0' --name=consul1 consul agent -server -bootstrap -ui -client='0.0.0.0'
两步启动一个consul的server-agent,然后就可以通过ip:8500访问得到consul的一个web界面,如果ip访问不通可以使用下文的vscode的代理模式去访问或者是在自己厂商的cvm控制台去开端口的访问策略,web界面如下
启动一个tcp_health_check的服务注册
创建一个go项目
mkdir consul_demo
go mod init consul_demo
go get -u github.com/hashicorp/consul/api
touch main.go
然后我们运行这个代码
go run main.go
就可以看到consul的web界面上多了一个服务实例
http版
如果不使用tcp作为健康检查的方式,可以使用Http_server去实现,逻辑是一样的,需要给consul返回一个消息,让consul确认你的心跳即可
服务发现
服务发现其实就是通过http请求向consul请求指定的service下的实例,获取到他们对应的ip:port和一些其他的元信息,然后在客户端根据需要筛选得出一个ip:port的实例进行通讯,由于向consul发起http请求的sdk已经在consul官方实现了,所以我们不需要自己建一个httpclient去调用这些api,而是直接构建一个struct交给sdk去查询即可
ut的结果如下,证明我们通过consul找到了下游服务的ip:port即可发起通讯
[root@hecs-74066 consul_demo]# go test -v main_test.go
=== RUN TestDiscoeryFromConsul
main_test.go:25: client discovery start
main_test.go:28: the instance Node is &{ID:278ba4f1-0309-fc92-d641-a312b5797779 Node:241f8a20d7fb Address:172.17.0.2 Datacenter:dc1 TaggedAddresses:map[lan:172.17.0.2 lan_ipv4:172.17.0.2 wan:172.17.0.2 wan_ipv4:172.17.0.2] Meta:map[consul-network-segment:] CreateIndex:13 ModifyIndex:16 Partition: PeerName:}
main_test.go:29: the isntance Service is &{Kind: ID:9527 Service:main_service Tags:[a b] Meta:map[] Port:10111 Address:192.168.0.124 SocketPath: TaggedAddresses:map[lan_ipv4:{Address:192.168.0.124 Port:10111} wan_ipv4:{Address:192.168.0.124 Port:10111}] Weights:{Passing:1 Warning:1} EnableTagOverride:false CreateIndex:43 ModifyIndex:43 ContentHash: Proxy:0xc0000c44d0 Connect:0xc000091a50 PeerName: Namespace: Partition: Datacenter:}
main_test.go:30:
--- PASS: TestDiscoeryFromConsul (0.00s)