在微服務(wù)架構(gòu)里面，每個小服務(wù)都是由很多節(jié)點組成，節(jié)點的添加刪除故障希望能對下游透明，因此有必要引入一種服務(wù)的自動注冊和發(fā)現(xiàn)機制，而 consul 提供了完整的解決方案，并且內(nèi)置了對 GRPC 以及 HTTP 服務(wù)的支持
總體架構(gòu)
- 服務(wù)調(diào)用: client 直連 server 調(diào)用服務(wù)
- 服務(wù)注冊: 服務(wù)端將服務(wù)的信息注冊到 consul 里
- 服務(wù)發(fā)現(xiàn): 客戶端從 consul 里發(fā)現(xiàn)服務(wù)信息，主要是服務(wù)的地址
- 健康檢查: consul 檢查服務(wù)器的健康狀態(tài)
服務(wù)注冊
服務(wù)端將服務(wù)信息注冊到 consul 里，這個注冊可以在服務(wù)啟動可以提供服務(wù)的時候完成
完整代碼參考: 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é)點的名稱
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 會傳到 Health.Check 函數(shù)中
GRPC: fmt.Sprintf("%v:%v/%v", IP, r.Port, r.Service),
DeregisterCriticalServiceAfter: r.DeregisterCriticalServiceAfter.String(), // 注銷時間，相當(dāng)于過期時間
},
}
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à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 接口，實現(xiàn)了對 grpc健康檢查的支持，所以我們只需要實現(xiàn)先這個接口，consul 就能利用這個接口作健康檢查了
完整代碼參考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/cmd/server/main.go
// HealthImpl 健康檢查實現(xiàn)
type HealthImpl struct{}
// Check 實現(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ù)注冊 api: https://www.consul.io/api/agent/service.html
grpc 健康檢查: https://github.com/grpc/grpc/blob/master/doc/health-checking.md
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:- Golang實現(xiàn)的聊天程序服務(wù)端和客戶端代碼分享
- golang實現(xiàn)簡單的udp協(xié)議服務(wù)端與客戶端示例
- 詳解如何熱重啟golang服務(wù)器
- golang搭建靜態(tài)web服務(wù)器的實現(xiàn)方法
- golang websocket 服務(wù)端的實現(xiàn)
- 詳解prometheus監(jiān)控golang服務(wù)實踐記錄
