golang框架中如何进行负载均衡之常用负载均衡中

import "<a style=color:f60; text-decoration:underline; href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/gorilla/mux"

func main() { zvvq.cn

router := mux.NewRouter() zvvq

// 添加多个后端地址

backend1 := "http://localhost:8081" 内容来自samhan

backend2 := "http://localhost:8082"

// EnableGorilla Mux Load Balancing zvvq.cn

router.Use(mux.MiddlewareDirector(func(r http.Request) {

本文来自zvvq

// 根据轮询算法选择后端地址 zvvq.cn

backend := mux.RandomBackend(backend1, backend2)

内容来自zvvq

r.URL.Host = backend

}))

copyright zvvq

// 注册路由，并将请求代理到正确后端

router.HandleFunc("/", func(w http.ResponseWriter, r http.Request) {

本文来自zvvq

// 本地处理逻辑

zvvq

})

http.ListenAndServe(":8080", router)

}

import "github.com/caddyserver/caddy"

内容来自samhan

func init() { 内容来自samhan666

// 使用Caddyfile配置

内容来自samhan666

caddy.RegisterPlugin("loadbalance", caddy.Plugin{

copyright zvvq

ServerType: "http", zvvq好，好zvvq

Action: func(c caddy.Controller) error {

for c.Next() {

// 根据所需算法(如 round_robin、hash)配置负载均衡 zvvq

lb := caddy.NewPlugin("loadbalance")

c.Apply(lb) 内容来自samhan666

} 内容来自samhan

return nil

内容来自zvvq

},

内容来自zvvq

}) copyright zvvq

}

zvvq.cn

// Consul Service 发现地址

const ConsulServiceDiscovery = "consul:8500" zvvq.cn

func main() {

内容来自zvvq，别采集哟

// Envoy config配置 内容来自samhan666

cfg := envoy.NewConfig()

// 设置 Consul 服务发现 内容来自samhan

cluster := cfg.Clusters.Add("consul-cluster")

cluster.ConnectConfig.TransportSocket 内容来自zvvq，别采集哟

.Set(envoy.SocketOption{"name": "envoy.transport_sockets.tls", 内容来自samhan

"config": envoy.NewDownstreamTlsContext(

envoy.NewCertificateProviderInstance( 内容来自samhan666

envoy.NewFileBasedCertificateConfig(

copyright zvvq

"cert", "key")))} 内容来自zvvq

cluster.LbPolicy = "RoundRobin" zvvq好，好zvvq

// 设置Consul服务发现

cluster.DiscoveryType = envoy.ServiceDiscoveryConfigType_CONSUL

内容来自samhan

cluster.DiscoveryConfig.Set(envoy.NewDiscoveryConfigConsul(

ConsulServiceDiscovery, "service-consul-id")) 内容来自samhan

// 启动Envoy Proxy zvvq.cn

proxy := envoy.NewServer(cfg) 本文来自zvvq

if err := proxy.Run(); err != nil {

内容来自samhan

log.Fatal(err)

zvvq好，好zvvq

}

内容来自zvvq

} zvvq