這篇文章給大家介紹golang中怎么利用consul-grpc實(shí)現(xiàn)服務(wù)注冊(cè)與發(fā)現(xiàn)，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

成都創(chuàng)新互聯(lián)公司從2013年成立，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目成都網(wǎng)站制作、成都網(wǎng)站建設(shè)、外貿(mào)營(yíng)銷網(wǎng)站建設(shè)網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢(mèng)想脫穎而出為使命，1280元恩陽(yáng)做網(wǎng)站,已為上家服務(wù),為恩陽(yáng)各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:18980820575

在微服務(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)于過(guò)期時(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è)接口作健康檢查了

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

// Check 實(shí)現(xiàn)健康檢查接口，這里直接返回健康狀態(tài)，這里也可以有更復(fù)雜的健康檢查策略，比如根據(jù)服務(wù)器負(fù)載來(lái)返回
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{})

關(guān)于golang中怎么利用consul-grpc實(shí)現(xiàn)服務(wù)注冊(cè)與發(fā)現(xiàn)就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

文章名稱：golang中怎么利用consul-grpc實(shí)現(xiàn)服務(wù)注冊(cè)與發(fā)現(xiàn)-創(chuàng)新互聯(lián)
網(wǎng)站網(wǎng)址：http://weahome.cn/article/hcsgg.html