服务治理

1// Consul 服务注册
2func registerService(client *consul.Client, name string, port int) error {
3    return client.Agent().ServiceRegister(&consul.AgentServiceRegistration{
4        ID:      fmt.Sprintf("%s-%d", name, port),
5        Name:    name,
6        Port:    port,
7        Address: "localhost",
8        Check: &consul.AgentServiceCheck{
9            HTTP:     fmt.Sprintf("http://localhost:%d/health", port),
10            Interval: "10s",
11        },
12    })
13}

1// 使用 hystrix-go
2hystrix.ConfigureCommand("my-command", hystrix.CommandConfig{
3    Timeout:               1000,
4    MaxConcurrentRequests: 100,
5    ErrorPercentThreshold: 50,
6})
7 
8err := hystrix.Do("my-command", func() error {
9    return callRemoteService()
10}, func(err error) error {
11    return fallback()
12})