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" 内容来自zvvq

func main() {

zvvq.cn

router := mux.NewRouter()

内容来自samhan666

// 添加多个后端地址 本文来自zvvq

backend1 := "http://localhost:8081" zvvq

backend2 := "http://localhost:8082" 内容来自zvvq，别采集哟

// EnableGorilla Mux Load Balancing

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

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

backend := mux.RandomBackend(backend1, backend2)

内容来自samhan

r.URL.Host = backend 内容来自zvvq

}))

内容来自zvvq，别采集哟

// 注册路由，并将请求代理到正确后端 内容来自zvvq，别采集哟

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

// 本地处理逻辑 zvvq.cn

}) 内容来自zvvq，别采集哟

http.ListenAndServe(":8080", router)

} copyright zvvq

import "github.com/caddyserver/caddy" 内容来自zvvq，别采集哟

func init() {

copyright zvvq

// 使用Caddyfile配置 内容来自samhan

caddy.RegisterPlugin("loadbalance", caddy.Plugin{ 本文来自zvvq

ServerType: "http", 内容来自samhan

Action: func(c caddy.Controller) error {

copyright zvvq

for c.Next() { 内容来自samhan666

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

内容来自zvvq，别采集哟

lb := caddy.NewPlugin("loadbalance") 本文来自zvvq

c.Apply(lb)

内容来自samhan

}

return nil

内容来自samhan

}, 本文来自zvvq

})

} zvvq

// Consul Service 发现地址

zvvq

const ConsulServiceDiscovery = "consul:8500" zvvq好，好zvvq

func main() {

// Envoy config配置

cfg := envoy.NewConfig()

// 设置 Consul 服务发现 内容来自zvvq，别采集哟

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

内容来自samhan

cluster.ConnectConfig.TransportSocket copyright zvvq

.Set(envoy.SocketOption{"name": "envoy.transport_sockets.tls", copyright zvvq

"config": envoy.NewDownstreamTlsContext( 内容来自zvvq

envoy.NewCertificateProviderInstance( 内容来自zvvq

envoy.NewFileBasedCertificateConfig(

zvvq

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

cluster.LbPolicy = "RoundRobin"

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) copyright zvvq

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

内容来自samhan

log.Fatal(err) zvvq.cn

} 内容来自samhan666

}

zvvq