自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

Go使用consul做服務(wù)發(fā)現(xiàn)

作者：雙鬼帶單
開發(fā) 前端
通過使用 consul api 我們可以簡(jiǎn)單的實(shí)現(xiàn)基于 consul 的服務(wù)發(fā)現(xiàn)，在通過結(jié)合 http rpc 就可簡(jiǎn)單的實(shí)現(xiàn)服務(wù)的調(diào)用，下面一章來簡(jiǎn)單講下 go 如何發(fā)起 http 請(qǐng)求，為我們做 rpc 做個(gè)鋪墊

一、目標(biāo)

二、使用步驟

1. 安裝 consul

我們可以直接使用官方提供的二進(jìn)制文件來進(jìn)行安裝部署，其官網(wǎng)地址為 https://www.consul.io/downloads

 

Go 使用 consul 做服務(wù)發(fā)現(xiàn)

下載后為可執(zhí)行文件，在我們開發(fā)試驗(yàn)過程中，可以直接使用 consul agent -dev 命令來啟動(dòng)一個(gè)單節(jié)點(diǎn)的 consul

在啟動(dòng)的打印日志中可以看到 agent: Started HTTP server on 127.0.0.1:8500 (tcp), 我們可以在瀏覽器直接訪問 127.0.0.1:8500 即可看到如下

 

Go 使用 consul 做服務(wù)發(fā)現(xiàn)

這里我們的 consul 就啟動(dòng)成功了

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

在網(wǎng)絡(luò)編程中，一般會(huì)提供項(xiàng)目的 IP、PORT、PROTOCOL，在服務(wù)治理中，我們還需要知道對(duì)應(yīng)的服務(wù)名、實(shí)例名以及一些自定義的擴(kuò)展信息

在這里使用 ServiceInstance 接口來規(guī)定注冊(cè)服務(wù)時(shí)必須的一些信息，同時(shí)用 DefaultServiceInstance 實(shí)現(xiàn)

  1. type ServiceInstance interface { 
  2.     // return The unique instance ID as registered. 
  3.     GetInstanceId() string 
  4.     // return The service ID as registered. 
  5.     GetServiceId() string 
  6.     // return The hostname of the registered service instance. 
  7.     GetHost() string 
  8.     // return The port of the registered service instance. 
  9.     GetPort() int    // return Whether the port of the registered service instance uses HTTPS. 
  10.     IsSecure() bool    // return The key / value pair metadata associated with the service instance. 
  11.     GetMetadata() map[string]string 
  12. }type DefaultServiceInstance struct { 
  13.     InstanceId string 
  14.     ServiceId  string 
  15.     Host       string 
  16.     Port       int    Secure     bool    Metadata   map[string]string 
  17. }func NewDefaultServiceInstance(serviceId string, host string, port int, secure bool, 
  18.     metadata map[string]string, instanceId string) (*DefaultServiceInstance, error) { 
  19.     // 如果沒有傳入 IP 則獲取一下，這個(gè)方法在多網(wǎng)卡的情況下，并不好用    if len(host) == 0 { 
  20.         localIP, err := util.GetLocalIP()        if err != nil { 
  21.             return nil, err 
  22.         }        host = localIP    }    if len(instanceId) == 0 { 
  23.         instanceId = serviceId + "-" + strconv.FormatInt(time.Now().Unix(), 10) + "-" + strconv.Itoa(rand.Intn(9000)+1000) 
  24.     }    return &DefaultServiceInstance{InstanceId: instanceId, ServiceId: serviceId, Host: host, Port: port, Secure: secure, Metadata: metadata}, nil 
  25. }func (serviceInstance DefaultServiceInstance) GetInstanceId() string { 
  26.     return serviceInstance.InstanceId 
  27. }func (serviceInstance DefaultServiceInstance) GetServiceId() string { 
  28.     return serviceInstance.ServiceId 
  29. }func (serviceInstance DefaultServiceInstance) GetHost() string { 
  30.     return serviceInstance.Host 
  31. }func (serviceInstance DefaultServiceInstance) GetPort() int {    return serviceInstance.Port 
  32. }func (serviceInstance DefaultServiceInstance) IsSecure() bool {    return serviceInstance.Secure 
  33. }func (serviceInstance DefaultServiceInstance) GetMetadata() map[string]string { 
  34.     return serviceInstance.Metadata 
  35. } 

定義接口

在上面規(guī)定了需要注冊(cè)的服務(wù)的必要信息，下面定義下服務(wù)注冊(cè)和剔除的方法

  1. type ServiceRegistry interface { 
  2.     Register(serviceInstance cloud.ServiceInstance) bool 
  3.     Deregister() 
  4. } 

具體實(shí)現(xiàn)

因?yàn)?consul 提供了 http 接口來對(duì) consul 進(jìn)行操作，我們也可以使用 http 請(qǐng)求方式進(jìn)行注冊(cè)和剔除操作，具體 http 接口文檔見 https://www.consul.io/api-docs, consul 默認(rèn)提供了go 語(yǔ)言的實(shí)現(xiàn)，這里直接使用 github.com/hashicorp/consul/api

  1. import ( 
  2.     "errors" 
  3.     "fmt" 
  4.     "github.com/hashicorp/consul/api" 
  5.     "strconv" 
  6.     "unsafe" 
  7. )type consulServiceRegistry struct { 
  8.     serviceInstances     map[string]map[string]cloud.ServiceInstance 
  9.     client               api.Client    localServiceInstance cloud.ServiceInstance}func (c consulServiceRegistry) Register(serviceInstance cloud.ServiceInstance) bool {    // 創(chuàng)建注冊(cè)到consul的服務(wù)到    registration := new(api.AgentServiceRegistration)    registration.ID = serviceInstance.GetInstanceId()    registration.Name = serviceInstance.GetServiceId()    registration.Port = serviceInstance.GetPort()    var tags []string 
  10.     if serviceInstance.IsSecure() { 
  11.         tags = append(tags, "secure=true") 
  12.     } else { 
  13.         tags = append(tags, "secure=false") 
  14.     }    if serviceInstance.GetMetadata() != nil { 
  15.         var tags []string 
  16.         for key, value := range serviceInstance.GetMetadata() { 
  17.             tags = append(tags, key+"="+value) 
  18.         }        registration.Tags = tags    }    registration.Tags = tags    registration.Address = serviceInstance.GetHost()    // 增加consul健康檢查回調(diào)函數(shù)    check := new(api.AgentServiceCheck)    schema := "http" 
  19.     if serviceInstance.IsSecure() { 
  20.         schema = "https" 
  21.     }    check.HTTP = fmt.Sprintf("%s://%s:%d/actuator/health", schema, registration.Address, registration.Port) 
  22.     check.Timeout = "5s" 
  23.     check.Interval = "5s" 
  24.     check.DeregisterCriticalServiceAfter = "20s" // 故障檢查失敗30s后 consul自動(dòng)將注冊(cè)服務(wù)刪除 
  25.     registration.Check = check    // 注冊(cè)服務(wù)到consul    err := c.client.Agent().ServiceRegister(registration)    if err != nil { 
  26.         fmt.Println(err)        return false 
  27.     }    if c.serviceInstances == nil { 
  28.         c.serviceInstances = map[string]map[string]cloud.ServiceInstance{} 
  29.     }    services := c.serviceInstances[serviceInstance.GetServiceId()]    if services == nil { 
  30.         services = map[string]cloud.ServiceInstance{} 
  31.     }    services[serviceInstance.GetInstanceId()] = serviceInstance    c.serviceInstances[serviceInstance.GetServiceId()] = services    c.localServiceInstance = serviceInstance    return true 
  32. }// deregister a servicefunc (c consulServiceRegistry) Deregister() {    if c.serviceInstances == nil { 
  33.         return 
  34.     }    services := c.serviceInstances[c.localServiceInstance.GetServiceId()]    if services == nil { 
  35.         return 
  36.     }    delete(services, c.localServiceInstance.GetInstanceId())    if len(services) == 0 { 
  37.         delete(c.serviceInstances, c.localServiceInstance.GetServiceId())    }    _ = c.client.Agent().ServiceDeregister(c.localServiceInstance.GetInstanceId())    c.localServiceInstance = nil 
  38. }// new a consulServiceRegistry instance// token is optionalfunc NewConsulServiceRegistry(host string, port int, token string) (*consulServiceRegistry, error) { 
  39.     if len(host) < 3 { 
  40.         return nil, errors.New("check host") 
  41.     }    if port <= 0 || port > 65535 { 
  42.         return nil, errors.New("check port, port should between 1 and 65535") 
  43.     }    config := api.DefaultConfig() 
  44.     config.Address = host + ":" + strconv.Itoa(port) 
  45.     config.Token = token 
  46.     client, err := api.NewClient(config) 
  47.     if err != nil { 
  48.         return nil, err 
  49.     }    return &consulServiceRegistry{client: *client}, nil 
  50. } 

測(cè)試用例

注冊(cè)服務(wù)的代碼基本完成，來測(cè)試一下

  1. func TestConsulServiceRegistry(t *testing.T) { 
  2.     host := "127.0.0.1" 
  3.     port := 8500 
  4.     registryDiscoveryClient, _ := extension.NewConsulServiceRegistry(host, port, "") 
  5.     ip, err := util.GetLocalIP()    if err != nil { 
  6.         t.Error(err)    }    serviceInstanceInfo, _ := cloud.NewDefaultServiceInstance("go-user-server", "", 8090, 
  7.         false, map[string]string{"user":"zyn"}, "") 
  8.     registryDiscoveryClient.Register(serviceInstanceInfo)    r := gin.Default()    // 健康檢測(cè)接口，其實(shí)只要是 200 就認(rèn)為成功了 
  9.     r.GET("/actuator/health", func(c *gin.Context) { 
  10.         c.JSON(200, gin.H{ 
  11.             "message": "pong", 
  12.         }) 
  13.     }) 
  14.     err = r.Run(":8090") 
  15.     if err != nil{ 
  16.         registryDiscoveryClient.Deregister() 
  17.     } 
  18. } 

如果成功，則會(huì)在 consul 看到 go-user-server 這個(gè)服務(wù)

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

在服務(wù)發(fā)現(xiàn)中，一般會(huì)需要兩個(gè)方法

  • 獲取所有的服務(wù)列表
  • 獲取指定的服務(wù)的所有實(shí)例信息

接口定義

  1. type DiscoveryClient interface { 
  2.     /** 
  3.      * Gets all ServiceInstances associated with a particular serviceId. 
  4.      * @param serviceId The serviceId to query. 
  5.      * @return A List of ServiceInstance. 
  6.      */ 
  7.     GetInstances(serviceId string) ([]cloud.ServiceInstance, error)    /** 
  8.      * @return All known service IDs. 
  9.      */ 
  10.     GetServices() ([]string, error)} 

具體實(shí)現(xiàn)

來實(shí)現(xiàn)一下

  1. type consulServiceRegistry struct { 
  2.     serviceInstances     map[string]map[string]cloud.ServiceInstance 
  3.     client               api.Client    localServiceInstance cloud.ServiceInstance}func (c consulServiceRegistry) GetInstances(serviceId string) ([]cloud.ServiceInstance, error) { 
  4.     catalogService, _, _ := c.client.Catalog().Service(serviceId, "", nil) 
  5.     if len(catalogService) > 0 { 
  6.         result := make([]cloud.ServiceInstance, len(catalogService)) 
  7.         for index, sever := range catalogService { 
  8.             s := cloud.DefaultServiceInstance{                InstanceId: sever.ServiceID,                ServiceId:  sever.ServiceName,                Host:       sever.Address,                Port:       sever.ServicePort,                Metadata:   sever.ServiceMeta,            }            result[index] = s        }        return result, nil 
  9.     }    return nil, nil 
  10. }func (c consulServiceRegistry) GetServices() ([]string, error) { 
  11.     services, _, _ := c.client.Catalog().Services(nil) 
  12.     result := make([]string, unsafe.Sizeof(services)) 
  13.     index := 0 
  14.     for serviceName, _ := range services { 
  15.         result[index] = serviceName        index++    }    return result, nil 
  16. }// new a consulServiceRegistry instance 
  17. // token is optional 
  18. func NewConsulServiceRegistry(host string, port int, token string) (*consulServiceRegistry, error) { 
  19.     if len(host) < 3 { 
  20.         return nil, errors.New("check host") 
  21.     } 
  22.     if port <= 0 || port > 65535 { 
  23.         return nil, errors.New("check port, port should between 1 and 65535") 
  24.     } 
  25.     config := api.DefaultConfig() 
  26.     config.Address = host + ":" + strconv.Itoa(port) 
  27.     config.Token = token 
  28.     client, err := api.NewClient(config) 
  29.     if err != nil { 
  30.         return nil, err 
  31.     } 
  32.     return &consulServiceRegistry{client: *client}, nil 
  33. } 

測(cè)試用例

  1. func TestConsulServiceDiscovery(t *testing.T) { 
  2.     host := "127.0.0.1" 
  3.     port := 8500 
  4.     token := "" 
  5.     registryDiscoveryClient, err := extension.NewConsulServiceRegistry(host, port, token) 
  6.     if err != nil {        panic(err) 
  7.     }    t.Log(registryDiscoveryClient.GetServices()) 
  8.     t.Log(registryDiscoveryClient.GetInstances("go-user-server")) 
  9. } 

結(jié)果

  1. consul_service_registry_test.go:57: [consul go-user-server      ] <nil> 
  2. consul_service_registry_test.go:59: [{go-user-server-1602590661-56179 go-user-server 127.0.0.1 8090 false map[user:zyn]}] <nil> 

總結(jié)

通過使用 consul api 我們可以簡(jiǎn)單的實(shí)現(xiàn)基于 consul 的服務(wù)發(fā)現(xiàn)，在通過結(jié)合 http rpc 就可簡(jiǎn)單的實(shí)現(xiàn)服務(wù)的調(diào)用，下面一章來簡(jiǎn)單講下 go 如何發(fā)起 http 請(qǐng)求，為我們做 rpc 做個(gè)鋪墊

責(zé)任編輯：未麗燕 來源： 今日頭條
Goconsul接口
相關(guān)推薦

2023-06-02 08:33:43

微服務(wù)架構(gòu)服務(wù)注冊(cè)

2022-01-16 23:10:40

語(yǔ)言服務(wù)注冊(cè)

2017-06-25 13:33:25

Spring Clou微服務(wù)架構(gòu)

2021-07-07 05:46:46

運(yùn)維監(jiān)控Prometheus

2022-01-26 09:36:53

Consul語(yǔ)言微服務(wù)

2018-12-27 09:28:08

Consul服務(wù)Server

2025-01-20 00:10:00

Go語(yǔ)言Kratos

2021-09-30 08:54:58

prometheus監(jiān)控遠(yuǎn)端服務(wù)

2023-07-04 07:45:11

gogRPC服務(wù)

2023-04-03 07:17:34

CP集群AP

2023-09-07 23:25:34

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

2015-06-03 10:01:56

云平臺(tái)發(fā)現(xiàn)服務(wù)ZooKeeper

2015-04-28 15:14:53

云平臺(tái)發(fā)現(xiàn)服務(wù)ZooKeeper

2021-01-08 13:52:15

Consul微服務(wù)服務(wù)注冊(cè)中心

2025-02-04 13:53:18

NixGogRPC

2025-01-09 08:32:50

2018-11-22 15:07:17

代碼github程序

2021-01-21 10:02:45

Consul架構(gòu)安裝

2020-06-29 07:58:18

ZooKeeperConsul 注冊(cè)中心

2019-12-24 09:39:06

Kubernetes工具微服務(wù)
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)