负载均衡简介

从设备角度实现负载均衡：

  • 硬件负载均衡：
    由专门的 负载均衡器 服务提供商，在你的服务器和外部网络之间架设 服务商的 负载均衡器。服务商提供设备和方案帮你处理流量的均衡，不过因为比较费钱包国内没什么人用
  • 软件负载均衡：
    包括家喻户晓的Nginx，LVS，Tengine（阿里版Nginx）。优点就是成本比较低，但需要运维去配置、维护。会踩坑，但国内都在用基本上网找就有解决方案。

    随机负载均衡

    无论是Nginx，LVS 均衡负载的核心在于 网络 io 复用，负载均衡算法。其中均衡算法又分为 随机，轮询，加权轮询，哈希，而随机负载均衡算法就是本文的重点。
    随机负载均衡：意味没有规律，随机在服务器队列中获得一台服务器处理请求。其代码实现如下：
    1. package main
    2. import (
    3. "fmt"
    4. "math/rand"
    5. )
    6. // 接口定义
    7. type LoadBalance interface {
    8. //选择一个后端Server
    9. //参数remove是需要排除选择的后端Server
    10. Next(remove []string) *Server
    11. //更新可用Server列表
    12. UpdateServers(servers []*Server)
    13. }
    14. // 后端Server定义
    15. type Server struct {
    16. //主机地址
    17. Host string
    18. //主机名
    19. Name string
    20. Id int
    21. //主机是否在线
    22. Online bool
    23. }
    24. type LoadBalanceRandom struct{
    25. servers []*Server
    26. }
    27. // 实例化 随机均衡负载
    28. func NewLoadBalanceRandom(servers []*Server) *LoadBalanceRandom{
    29. newBalance := &LoadBalanceRandom{}
    30. newBalance.UpdateServers(servers)
    31. return newBalance
    32. }
    33. //选择一个后端Server
    34. func (r *LoadBalanceRandom) Next() *Server {
    35. if len(r.servers) == 0 {
    36. return nil
    37. }
    38. curIndex := rand.Intn(len(r.servers))
    39. return r.servers[curIndex]
    40. }
    41. func (r *LoadBalanceRandom) Get(key string) (*Server, error) {
    42. return r.Next(), nil
    43. }
    44. //系统运行过程中，后端可用Server会更新
    45. func (this *LoadBalanceRandom) UpdateServers(servers []*Server) {
    46. newServers:=make([]*Server,0)
    47. for _,e:=range servers {
    48. if e.Online==true {
    49.  newServers=append(newServers,e)
    50. }
    51. }
    52. this.servers=newServers
    53. }

    测试 随机负载均衡

    1. func main() {
    2. count:=make([]int,4)
    3. servers:=make([]*Server,0)
    4. servers=append(servers,&Server{Host:"1",Id:0,Online:true})
    5. servers=append(servers,&Server{Host:"2",Id:1,Online:true})
    6. servers=append(servers,&Server{Host:"3",Id:2,Online:true})
    7. servers=append(servers,&Server{Host:"4",Id:3,Online:true})
    8. lb:=NewLoadBalanceRandom(servers)
    9. // 创建4个Server，随机选择100000次。查看4台机器 被选中次数
    10. for i:=0;i<100000;i++{
    11. c:=lb.Next()
    12. count[c.Id]++
    13. }
    14. fmt.Println(count)
    15. }
    输出
    1. // 4 个服务器选择的次数都是相对平均
    2. [25058 24947 25105 24890]