1. package main
    3. import (
    4.     "fmt"
    6.     "github.com/hashicorp/consul/api"
    7.     )
    9. func Register(address string, port int, name string, tags []string, id string) error {
    10.     cfg := api.DefaultConfig()
    11.     cfg.Address = "192.168.1.103:8500"
    13.     client, err := api.NewClient(cfg)
    14.     if err != nil {
    15.         panic(err)
    16.     }
    17.     //生成对应的检查对象
    18.     check := &api.AgentServiceCheck{
    19.         HTTP: "http://192.168.1.102:8021/health",
    20.         Timeout: "5s",
    21.         Interval: "5s",
    22.         DeregisterCriticalServiceAfter: "10s",
    23.     }
    25.     //生成注册对象
    26.     registration := new(api.AgentServiceRegistration)
    27.     registration.Name = name
    28.     registration.ID = id
    29.     registration.Port = port
    30.     registration.Tags = tags
    31.     registration.Address = address
    32.     registration.Check = check
    34.     err = client.Agent().ServiceRegister(registration)
    35.     if err != nil {
    36.         panic(err)
    37.     }
    38.     return nil
    39. }
    41. func AllServices(){
    42.     cfg := api.DefaultConfig()
    43.     cfg.Address = "192.168.1.103:8500"
    45.     client, err := api.NewClient(cfg)
    46.     if err != nil {
    47.         panic(err)
    48.     }
    50.     data, err := client.Agent().Services()
    51.     if err != nil {
    52.         panic(err)
    53.     }
    54.     for key, _ := range data{
    55.         fmt.Println(key)
    56.     }
    57. }
    58. func FilterSerivice(){
    59.     cfg := api.DefaultConfig()
    60.     cfg.Address = "192.168.1.103:8500"
    62.     client, err := api.NewClient(cfg)
    63.     if err != nil {
    64.         panic(err)
    65.     }
    67.     data, err := client.Agent().ServicesWithFilter(`Service == "user-web"`)
    68.     if err != nil {
    69.         panic(err)
    70.     }
    71.     for key, _ := range data{
    72.         fmt.Println(key)
    73.     }
    74. }
    77. func main(){
    78.     //_ = Register("192.168.1.102", 8021, "user-web", []string{"mxshop", "bobby"}, "user-web")
    79.     //AllServices()
    80.     FilterSerivice()
    81. }