consul安装和配置

  • 网址传送门 consul官网

  • 使用docker部署 ```bash docker run -d -p 8500:8500 -p 8300:8300 -p 8301:8301 -p 8302:8302 -p 8600:8600/udp consul consul agent -dev -client=0.0.0.0

docker container update —restart=always 容器名字

  1.  consul提供web界面，可以访问ip:8500进行访问（前提 防火墙已配置）
  3. - web展示 
  5. ![image.png](https://cdn.nlark.com/yuque/0/2020/png/280095/1607615636834-e72c52b5-b615-4553-88f9-54c3f6296b15.png#align=left&display=inline&height=164&margin=%5Bobject%20Object%5D&name=image.png&originHeight=328&originWidth=1894&size=33018&status=done&style=none&width=947)<br />看到如上图说是 表示已成功部署，默认已注册一个服务 
  6. <a name="FYoMW"></a>
  7. # consul API接口
  8. <a name="YmJow"></a>
  9. ## go 
  10. ```go
  11. package main
  13. import (
  14.     "fmt"
  16.     "github.com/hashicorp/consul/api"
  17. )
  19. func Register(address string, port int, name string, tags []string, id string) error {
  20.     cfg := api.DefaultConfig()
  21.     // consul 服务地址
  22.     cfg.Address = "127.0.0.1:8500"
  24.     client, err := api.NewClient(cfg)
  25.     if err != nil {
  26.         panic(err)
  27.     }
  28.     //生成对应的检查对象
  29.     check := &api.AgentServiceCheck{
  30.         // 健康检查 API
  31.         HTTP:                           "http://127.0.0.1:port/health", // 健康检查接口
  32.         Timeout:                        "60s",
  33.         Interval:                       "60s",
  34.         DeregisterCriticalServiceAfter: "10s",
  35.     }
  37.     //生成注册对象
  38.     registration := new(api.AgentServiceRegistration)
  39.     registration.Name = name
  40.     registration.ID = id
  41.     registration.Port = port
  42.     registration.Tags = tags
  43.     registration.Address = address
  44.     registration.Check = check
  46.     err = client.Agent().ServiceRegister(registration)
  47.     if err != nil {
  48.         panic(err)
  49.     }
  50.     return nil
  51. }
  53. func AllServices() {
  54.     cfg := api.DefaultConfig()
  55.     // 当然是consul的地址了 
  56.     cfg.Address = "127.0.0.1:8500"
  58.     client, err := api.NewClient(cfg)
  59.     if err != nil {
  60.         panic(err)
  61.     }
  63.     data, err := client.Agent().Services()
  64.     if err != nil {
  65.         panic(err)
  66.     }
  67.     for key := range data {
  68.         fmt.Println(key)
  69.     }
  70. }
  71. func FilterSerivice() {
  72.     cfg := api.DefaultConfig()
  73.     // 当然是consul的地址了 
  74.     cfg.Address = "127.0.0.1:8500"
  77.     client, err := api.NewClient(cfg)
  78.     if err != nil {
  79.         panic(err)
  80.     }
  82.     data, err := client.Agent().ServicesWithFilter(`Service == "user-web"`)
  83.     if err != nil {
  84.         panic(err)
  85.     }
  86.     for key := range data {
  87.         fmt.Println(key)
  89.     }
  90. }
  92. func main() {
  93.     // 这是服务的地址 
  94.     _ = Register("62.234.113.102", 8082, "user-web", []string{"shop", "shinxb"}, "user-web")
  95.     //AllServices()
  96.     //FilterSerivice()
  97. }

Py

  • base.py ```python import abc

class Register(metaclass=abc.ABCMeta): @abc.abstractmethod def register(self, name, service_id, address, port, tags: list,check): pass

@abc.abstractmethod
def deregister(self, service_id):
    pass

@abc.abstractmethod
def get_all_service(self, service_id):
    pass

@abc.abstractmethod
def filter_service(self, filter):
    pass


- consul.py
```python
import requests
from loguru import logger
from common.register.base import Register


class ConsulRegister(Register):
    def __init__(self, host, port):
        self.host = host
        self.port = port
        self.headers = {
            "contentType": "application/json"
        }

    def register(self, name, service_id, address, port, tags: list,check=None):
        url = f"http://{self.host}:{self.port}/v1/agent/service/register"
        if check is None:
            check = {
                "GRPC": f'{address}:{port}',
                "GRPCUseTLS": False,
                "Timeout": "5s",
                "Interval": "5s",
                "DeregisterCriticalServiceAfter": "5s",
            }
        rsp = requests.put(url, headers=self.headers, json={
            "Name": name,
            "ID": service_id,
            "Tags": tags,
            "Address": address,
            "Port": port,
            "Check":check,
        })
        if rsp.status_code == 200:
            logger.info("注册成功")
        else:
            logger.info(f"注册失败：{rsp.status_code}")

    def deregister(self, service_id):
        url = f"http://{self.host}:{self.port}/v1/agent/service/deregister/{service_id}"
        rsp = requests.put(url, headers=self.headers)
        if rsp.status_code == 200:
            print("注销成功")
        else:
            print(f"注销失败：{rsp.status_code}")

    def get_all_service(self, service_id):
        url = f"http://{self.host}:{self.port}/v1/agent/service"
        rsp = requests.get(url, headers=self.headers)
        if rsp.status_code == 200:
            print("获取服务列表成功")
        else:
            print(f"获取服务成功列表失败：{rsp.status_code}")

    def filter_service(self, filter):
        url = f"http://{self.host}:{self.port}/v1/agent/services"
        params = {
            "filter": filter
        }
        rsp = requests.get(url, params=params).json()
        for key, value in rsp.items():
            print(key)