Golang学习之Web服务端的负载均衡

type Proxy struct {
    urls []*url.URL
    mu   sync.Mutex
}
 
func (p *Proxy) addUrl(addr string) error {
    u, err := url.Parse(addr)
    if err != nil {
        return err
    }
    p.mu.Lock()
    p.urls = append(p.urls, u)
    p.mu.Unlock()
    return nil
}
 
func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request) {
    p.mu.Lock()
    defer p.mu.Unlock()
    if len(p.urls) == 0 {
        http.Error(w, "No upstream server", http.StatusServiceUnavailable)
        return
    }
    u := p.urls[rand.Intn(len(p.urls))]
    proxy := httputil.NewSingleHostReverseProxy(u)
    proxy.ServeHTTP(w, r)
}

type WeightedNode struct {
    URL         string
    Weight      int
    Current     int
}
 
type WeightedRoundRobinBalancer struct {
    nodes   []*WeightedNode
    total   int
    current int
    mu      sync.Mutex
}
 
func (b *WeightedRoundRobinBalancer) nextNode() *WeightedNode {
    if b.total == 0 {
        return nil
    }
    for i := 0; i < b.total; i++ {
        node := b.nodes[b.current]
        node.Current = node.Current + node.Weight
        b.current = (b.current + 1) % b.total
        if node.Current >= b.total {
            node.Current = node.Current - b.total
            return node
        }
    }
    return nil
}
 
func (b *WeightedRoundRobinBalancer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
    b.mu.Lock()
    node := b.nextNode()
    b.mu.Unlock()
    if node == nil {
        http.Error(w, "No upstream server", http.StatusServiceUnavailable)
        return
    }
    proxy := httputil.NewSingleHostReverseProxy(node.URL)
    proxy.ServeHTTP(w, r)
}