主頁 > 知識(shí)庫 > 詳解golang consul-grpc 服務(wù)注冊(cè)與發(fā)現(xiàn)

詳解golang consul-grpc 服務(wù)注冊(cè)與發(fā)現(xiàn)

熱門標(biāo)簽:濱州自動(dòng)電銷機(jī)器人排名 黃岡人工智能電銷機(jī)器人哪個(gè)好 汕頭小型外呼系統(tǒng) 浙江高頻外呼系統(tǒng)多少錢一個(gè)月 惠州電銷防封電話卡 阿里云ai電話機(jī)器人 釘釘有地圖標(biāo)注功能嗎 鄭州亮點(diǎn)科技用的什么外呼系統(tǒng) 建造者2地圖標(biāo)注

在微服務(wù)架構(gòu)里面,每個(gè)小服務(wù)都是由很多節(jié)點(diǎn)組成,節(jié)點(diǎn)的添加刪除故障希望能對(duì)下游透明,因此有必要引入一種服務(wù)的自動(dòng)注冊(cè)和發(fā)現(xiàn)機(jī)制,而 consul 提供了完整的解決方案,并且內(nèi)置了對(duì) GRPC 以及 HTTP 服務(wù)的支持

總體架構(gòu)

  1. 服務(wù)調(diào)用: client 直連 server 調(diào)用服務(wù)
  2. 服務(wù)注冊(cè): 服務(wù)端將服務(wù)的信息注冊(cè)到 consul 里
  3. 服務(wù)發(fā)現(xiàn): 客戶端從 consul 里發(fā)現(xiàn)服務(wù)信息,主要是服務(wù)的地址
  4. 健康檢查: consul 檢查服務(wù)器的健康狀態(tài)

服務(wù)注冊(cè)

服務(wù)端將服務(wù)信息注冊(cè)到 consul 里,這個(gè)注冊(cè)可以在服務(wù)啟動(dòng)可以提供服務(wù)的時(shí)候完成

完整代碼參考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/internal/grpcsr/consul_register.go

config := api.DefaultConfig()
config.Address = r.Address
client, err := api.NewClient(config)
if err != nil {
 panic(err)
}
agent := client.Agent()

IP := localIP()
reg := api.AgentServiceRegistration{
  ID:  fmt.Sprintf("%v-%v-%v", r.Service, IP, r.Port), // 服務(wù)節(jié)點(diǎn)的名稱
  Name: fmt.Sprintf("grpc.health.v1.%v", r.Service), // 服務(wù)名稱
  Tags: r.Tag,           // tag,可以為空
  Port: r.Port,           // 服務(wù)端口
  Address: IP,            // 服務(wù) IP
  Check: api.AgentServiceCheck{  // 健康檢查
   Interval: r.Interval.String(), // 健康檢查間隔
   // grpc 支持,執(zhí)行健康檢查的地址,service 會(huì)傳到 Health.Check 函數(shù)中
   GRPC:  fmt.Sprintf("%v:%v/%v", IP, r.Port, r.Service), 
   DeregisterCriticalServiceAfter: r.DeregisterCriticalServiceAfter.String(), // 注銷時(shí)間,相當(dāng)于過期時(shí)間
  },
 }

if err := agent.ServiceRegister(reg); err != nil {
 panic(err)
}

服務(wù)發(fā)現(xiàn)

客戶端從 consul 里發(fā)現(xiàn)服務(wù)信息,主要是服務(wù)的地址

完整代碼參考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/internal/grpclb/consul_resolver.go

services, metainfo, err := w.client.Health().Service(w.service, "", true, api.QueryOptions{
 WaitIndex: w.lastIndex, // 同步點(diǎn),這個(gè)調(diào)用將一直阻塞,直到有新的更新
})
if err != nil {
 logrus.Warn("error retrieving instances from Consul: %v", err)
}
w.lastIndex = metainfo.LastIndex

addrs := map[string]struct{}{}
for _, service := range services {
 addrs[net.JoinHostPort(service.Service.Address, strconv.Itoa(service.Service.Port))] = struct{}{}
}

健康檢查

consul 檢查服務(wù)器的健康狀態(tài),consul 用 google.golang.org/grpc/health/grpc_health_v1.HealthServer 接口,實(shí)現(xiàn)了對(duì) grpc健康檢查的支持,所以我們只需要實(shí)現(xiàn)先這個(gè)接口,consul 就能利用這個(gè)接口作健康檢查了

完整代碼參考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/cmd/server/main.go

// HealthImpl 健康檢查實(shí)現(xiàn)
type HealthImpl struct{}

// Check 實(shí)現(xiàn)健康檢查接口,這里直接返回健康狀態(tài),這里也可以有更復(fù)雜的健康檢查策略,比如根據(jù)服務(wù)器負(fù)載來返回
func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error) {
 return grpc_health_v1.HealthCheckResponse{
  Status: grpc_health_v1.HealthCheckResponse_SERVING,
 }, nil
}

grpc_health_v1.RegisterHealthServer(server, HealthImpl{})

參考鏈接

完整工程代碼: https://github.com/hatlonely/hellogolang/tree/master/sample/addservice
consul 健康檢查 api: https://www.consul.io/api/agent/check.html
consul 服務(wù)注冊(cè) api: https://www.consul.io/api/agent/service.html
grpc 健康檢查: https://github.com/grpc/grpc/blob/master/doc/health-checking.md

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

您可能感興趣的文章:
  • Golang實(shí)現(xiàn)的聊天程序服務(wù)端和客戶端代碼分享
  • golang實(shí)現(xiàn)簡(jiǎn)單的udp協(xié)議服務(wù)端與客戶端示例
  • 詳解如何熱重啟golang服務(wù)器
  • golang搭建靜態(tài)web服務(wù)器的實(shí)現(xiàn)方法
  • golang websocket 服務(wù)端的實(shí)現(xiàn)
  • 詳解prometheus監(jiān)控golang服務(wù)實(shí)踐記錄

標(biāo)簽:駐馬店 泰安 阿壩 東營 瀘州 滄州 晉中 昭通

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《詳解golang consul-grpc 服務(wù)注冊(cè)與發(fā)現(xiàn)》,本文關(guān)鍵詞  詳解,golang,consul-grpc,服務(wù),;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《詳解golang consul-grpc 服務(wù)注冊(cè)與發(fā)現(xiàn)》相關(guān)的同類信息!
  • 本頁收集關(guān)于詳解golang consul-grpc 服務(wù)注冊(cè)與發(fā)現(xiàn)的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章