一文詳解Golang中consul的基本使用
consul
consul是一個(gè)開(kāi)源服務(wù)注冊(cè)和服務(wù)發(fā)現(xiàn)的中心,可以用于微服務(wù)的注冊(cè)和服務(wù)之間的調(diào)用的發(fā)現(xiàn),幫助上游服務(wù)找到下游服務(wù)的具體ip:port或者是domain,也可以使用dns的方式讓consul幫你去做轉(zhuǎn)發(fā),具體介紹請(qǐng)看consul的官網(wǎng),consul區(qū)分server-agent和client-agent,client-agent的作用一般來(lái)說(shuō)就是用來(lái)轉(zhuǎn)發(fā)到server-agent的,所以本文只啟動(dòng)server-agent,他們的詳細(xì)差距可以在google上查到,本文基于golang實(shí)現(xiàn)一個(gè)服務(wù)注冊(cè)和服務(wù)發(fā)現(xiàn)的demo。demo地址
consul的安裝和部署
consul有兩種部署模式,一種是直接在cvm上安裝consul的bin包,然后以server-agent的模式進(jìn)行啟動(dòng),一種是用docker直接啟動(dòng)鏡像,本文直接使用docker啟動(dòng)鏡像,將這個(gè)鏡像的啟動(dòng)參數(shù)設(shè)置為server-agent,在這種模式下,如果要使用服務(wù)發(fā)現(xiàn)的功能需要區(qū)分主機(jī)ip和容器ip 不能使用127.0.0.1這種ip去讓server維持go服務(wù)的心跳
本文使用的cvm系統(tǒng)為centos8,其他Linux發(fā)行版可以自行用包管理工具去安裝一下的前置依賴
docker安裝
curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun
systemctl start docker
使用上文腳本一鍵安裝docker
consul鏡像的啟動(dòng)
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'
兩步啟動(dòng)一個(gè)consul的server-agent,然后就可以通過(guò)ip:8500訪問(wèn)得到consul的一個(gè)web界面,如果ip訪問(wèn)不通可以使用下文的vscode的代理模式去訪問(wèn)或者是在自己廠商的cvm控制臺(tái)去開(kāi)端口的訪問(wèn)策略,web界面如下
啟動(dòng)一個(gè)tcp_health_check的服務(wù)注冊(cè)
創(chuàng)建一個(gè)go項(xiàng)目
mkdir consul_demo
go mod init consul_demo
go get -u github.com/hashicorp/consul/api
touch main.go
// main.go package main import ( "bufio" "fmt" "net" consulapi "github.com/hashicorp/consul/api" ) type DiscoveryConfig struct { ID string Name string Tags []string Port int Address string } var consulAddress = "127.0.0.1:8500" func RegisterService(dis DiscoveryConfig) error { config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { fmt.Printf("create consul client : %v\n", err.Error()) } registration := &consulapi.AgentServiceRegistration{ ID: dis.ID, Name: dis.Name, Port: dis.Port, Tags: dis.Tags, Address: dis.Address, } // 啟動(dòng)tcp的健康檢測(cè),注意address不能使用127.0.0.1或者localhost,因?yàn)閏onsul-agent在docker容器里,如果用這個(gè)的話, // consul會(huì)訪問(wèn)容器里的port就會(huì)出錯(cuò),一直檢查不到實(shí)例 check := &consulapi.AgentServiceCheck{} check.TCP = fmt.Sprintf("%s:%d", registration.Address, registration.Port) check.Timeout = "5s" check.Interval = "5s" check.DeregisterCriticalServiceAfter = "60s" registration.Check = check if err := client.Agent().ServiceRegister(registration); err != nil { fmt.Printf("register to consul error: %v\n", err.Error()) return err } return nil } func startTcp() { ls, err := net.Listen("tcp", ":10111") if err != nil { fmt.Printf("start tcp listener error: %v\n", err.Error()) return } for { conn, err := ls.Accept() if err != nil { fmt.Printf("connect error: %v\n", err.Error()) } go func(conn net.Conn) { _, err := bufio.NewWriter(conn).WriteString("hello consul") if err != nil { fmt.Printf("write conn error: %v\n", err) } }(conn) } } func main() { ch := make(chan error) dis := DiscoveryConfig{ ID: "9527", Name: "main_service", Tags: []string{"a", "b"}, Port: 10111, Address: "192.168.0.124", //通過(guò)ifconfig查看本機(jī)的eth0的ipv4地址 } go startTcp() RegisterService(dis) // 阻塞等待 <-ch }
然后我們運(yùn)行這個(gè)代碼
go run main.go
就可以看到consul的web界面上多了一個(gè)服務(wù)實(shí)例
http版
如果不使用tcp作為健康檢查的方式,可以使用Http_server去實(shí)現(xiàn),邏輯是一樣的,需要給consul返回一個(gè)消息,讓consul確認(rèn)你的心跳即可
check := &consulapi.AgentServiceCheck{} check.HTTP = fmt.Sprintf("http://%s:%d/", registration.Address, registration.Port)
func startHttp() { http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { fmt.Printf("consul get uri: %s\n", r.RequestURI) w.Write([]byte("hello consul")) }) if err := http.ListenAndServe(":10111", nil); err != nil { fmt.Printf("start http server error: %v\n", err) } }
go startHttp()
服務(wù)發(fā)現(xiàn)
服務(wù)發(fā)現(xiàn)其實(shí)就是通過(guò)http請(qǐng)求向consul請(qǐng)求指定的service下的實(shí)例,獲取到他們對(duì)應(yīng)的ip:port和一些其他的元信息,然后在客戶端根據(jù)需要篩選得出一個(gè)ip:port的實(shí)例進(jìn)行通訊,由于向consul發(fā)起http請(qǐng)求的sdk已經(jīng)在consul官方實(shí)現(xiàn)了,所以我們不需要自己建一個(gè)httpclient去調(diào)用這些api,而是直接構(gòu)建一個(gè)struct交給sdk去查詢即可
package main import ( "fmt" "testing" consulapi "github.com/hashicorp/consul/api" ) func Discovery(serviceName string) []*consulapi.ServiceEntry { config := consulapi.DefaultConfig() config.Address = "127.0.0.1:8500" client, err := consulapi.NewClient(config) if err != nil { fmt.Printf("consul client error: %v", err) } service, _, err := client.Health().Service(serviceName, "", false, nil) if err != nil { fmt.Printf("consul client get serviceIp error: %v", err) } return service } func TestDiscoeryFromConsul(t *testing.T) { t.Logf("client discovery start") se := Discovery("main_service") for i := 0; i < len(se); i++ { t.Logf("the instance Node is %+v\n", se[i].Node) t.Logf("the isntance Service is %+v\n", se[i].Service) t.Logf("\n") } }
ut的結(jié)果如下,證明我們通過(guò)consul找到了下游服務(wù)的ip:port即可發(fā)起通訊
[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)
到此這篇關(guān)于一文詳解Golang中consul的基本使用的文章就介紹到這了,更多相關(guān)Golang consul內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Go語(yǔ)言中io.Reader和io.Writer的詳解與實(shí)現(xiàn)
在Go語(yǔ)言的實(shí)際編程中,幾乎所有的數(shù)據(jù)結(jié)構(gòu)都圍繞接口展開(kāi),接口是Go語(yǔ)言中所有數(shù)據(jù)結(jié)構(gòu)的核心。在使用Go語(yǔ)言的過(guò)程中,無(wú)論你是實(shí)現(xiàn)web應(yīng)用程序,還是控制臺(tái)輸入輸出,又或者是網(wǎng)絡(luò)操作,不可避免的會(huì)遇到IO操作,使用到io.Reader和io.Writer接口。下面來(lái)詳細(xì)看看。2016-09-09Go語(yǔ)言題解LeetCode下一個(gè)更大元素示例詳解
這篇文章主要為大家介紹了Go語(yǔ)言題解LeetCode下一個(gè)更大元素示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-12-12ubuntu下搭建Go語(yǔ)言(golang)環(huán)境
這篇文章主要介紹了ubuntu下搭建Go語(yǔ)言(golang)環(huán)境,需要的朋友可以參考下2015-01-01簡(jiǎn)單談?wù)凣olang中的字符串與字節(jié)數(shù)組
這篇文章主要給大家介紹了關(guān)于Golang中字符串與字節(jié)數(shù)組的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者使用Golang具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03Go語(yǔ)言中如何實(shí)現(xiàn)并發(fā)
Go的并發(fā)機(jī)制通過(guò)協(xié)程和通道的簡(jiǎn)單性和高效性,使得編寫(xiě)并發(fā)代碼變得相對(duì)容易,這種并發(fā)模型被廣泛用于構(gòu)建高性能的網(wǎng)絡(luò)服務(wù)、并行處理任務(wù)和其他需要有效利用多核處理器的應(yīng)用程序,這篇文章主要介紹了在Go中如何實(shí)現(xiàn)并發(fā),需要的朋友可以參考下2023-09-09