Registry

cd cmd 
go build -o registry

  -id string
        服务ID，不能为空
  -bind string
        用于注册服务的地址 (默认为":7370")。
  -bind-advertise string
        服务将向其他服务公布的地址 (默认为":7370")。
  -addr string
        用于服务发现的地址 (默认为":9800")。
  -advertise string
        服务向客户端公布的地址以供服务发现 (默认为":9800")。
  -registries string
        注册中心服务器地址，可以为空，多个地址用逗号分隔。
  

# 启动第一个节点
./registry -bind=":7370" \
     -bind-advertise="172.16.3.3:7370" \
     -id=service-1 \
     -addr=":9800" \
     -advertise="172.16.3.3:9800"

# 启动第二个节点
# 第二个节点有一个额外的参数-registries="172.16.3.3:7370"，
# 因为第二个节点需要向第一个节点注册
./registry -bind=":7371" \
     -bind-advertise="172.16.3.3:7371" \
     -id=service-2 \
     -registries="172.16.3.3:7370" \
     -addr=":9801" \
     -advertise="172.16.3.3:9801"

// Create a new registration object
r := register.New(id, bind, advertise, registries, group, addr)

// Start the registration
err = r.Start()
if err != nil {
	panic(err)
}

// 您可以选择已启动的任何一个注册服务器。
registryAddr := "172.16.3.3:9801"
group := "test-group"

// 创建新的RpcClient
client, err := client.NewRpcClient(registryAddr)
if err != nil {
	panic(err)
}

// 使用一致性哈希根据用户ID分配服务
service, err := client.Match(groupName, "user-id-1")
if err != nil {
	panic(err)
}

log.Printf("[INFO] Matched key: %s, Service ID: %s, Service Address: %s\n", key, service.Id, service.Addr)

// 获取该组所有服务
allService, err := client.Members(group)
if err != nil {
      log.Printf("[ERROR] Failed to get all services: %s\n", err)
}
log.Printf("[INFO] All services: %+v\n", allService)

# 注册第一个 Web 服务
cd examples/service
go build -o webservice webservice.go 
./webservice \
	-group=webservice-group \
	-id=webserver1 \
	-registries=172.16.3.3:7370 \
	-bind=":8370"
	-addr="172.16.3.3:8080"

# 注册第二个 Web 服务
cd examples/service
./webservice \
	-group=webservice-group \
	-id=webserver2 \
	-registries=172.16.3.3:7370 \
	-bind=":8371" \
	-addr="172.16.3.3:8081"

cd examples/client
go build -o client main.go
./client