谈谈 Go 语言在微服务架构开发中的常见网络通信问题

package main

import (
    "fmt"
    "github.com/hashicorp/consul/api"
)

func main() {
    config := api.DefaultConfig()
    client, err := api.NewClient(config)
    if err != nil {
        panic(err)
    }

    // 注册服务
    registration := new(api.AgentServiceRegistration)
    registration.Name = "my-service"
    registration.ID = "my-service-1"
    registration.Address = "127.0.0.1"
    registration.Port = 8080
    err = client.Agent().ServiceRegister(registration)
    if err != nil {
        panic(err)
    }

    // 发现服务
    services, _, err := client.Health().Service("my-service", "", true, nil)
    if err != nil {
        panic(err)
    }

    for _, service := range services {
        fmt.Printf("Found service: %s at %s:%d\n", service.Service.ID, service.Service.Address, service.Service.Port)
    }
}

package main

import (
    "fmt"
    "sync"
)

type LoadBalancer struct {
    servers []string
    current int
    mutex   sync.Mutex
}

func NewLoadBalancer(servers []string) *LoadBalancer {
    return &LoadBalancer{
        servers: servers,
        current: 0,
    }
}

func (lb *LoadBalancer) GetServer() string {
    lb.mutex.Lock()
    defer lb.mutex.Unlock()

    server := lb.servers[lb.current]
    lb.current = (lb.current + 1) % len(lb.servers)
    return server
}

func main() {
    servers := []string{"server1", "server2", "server3"}
    lb := NewLoadBalancer(servers)

    for i := 0; i < 10; i++ {
        fmt.Println(lb.GetServer())
    }
}

package main

import (
    "fmt"
    "net/http"
    "time"
)

func makeRequest(url string, timeout time.Duration, maxRetries int) (*http.Response, error) {
    client := &http.Client{Timeout: timeout}

    for i := 0; i <= maxRetries; i++ {
        resp, err := client.Get(url)
        if err == nil {
            return resp, nil
        }
        fmt.Printf("Request failed, retrying... (Attempt %d/%d)\n", i+1, maxRetries)
        time.Sleep(1 * time.Second) // 等待一段时间再重试
    }

    return nil, fmt.Errorf("all retries failed")
}

func main() {
    url := "http://example.com"
    timeout := 2 * time.Second
    maxRetries := 3

    resp, err := makeRequest(url, timeout, maxRetries)
    if err != nil {
        fmt.Println("Error:", err)
    } else {
        fmt.Println("Response received:", resp.Status)
    }
}