转自：江南烟雨

IP哈希初始化

IP哈希的初始化函数ngx_http_upstream_init_ip_hash（ngx_http_upstream_ip_hash_module.c）：

static ngx_int_t

ngx_http_upstream_init_ip_hash(ngx_conf_t *cf, ngx_http_upstream_srv_conf_t *us)

{

    //调用了加权轮询

    if (ngx_http_upstream_init_round_robin(cf, us) != NGX_OK) {

        return NGX_ERROR;

    }

    //修改了针对单个请求进行初始化的回调函数

    us->peer.init = ngx_http_upstream_init_ip_hash_peer;

    return NGX_OK;

}

选择后端服务器

当客户端请求过来之后，将会执行初始化函数ngx_http_upstream_init_ip_hash_peer。其中调用了轮询算法中的初始化函数。

static ngx_int_t

ngx_http_upstream_init_ip_hash_peer(ngx_http_request_t *r,

    ngx_http_upstream_srv_conf_t *us)

{

    struct sockaddr_in                     *sin;

    //针对IPv6的支持

#if (NGX_HAVE_INET6)

    struct sockaddr_in6                    *sin6;

#endif

    ngx_http_upstream_ip_hash_peer_data_t  *iphp;

    iphp = ngx_palloc(r->pool, sizeof(ngx_http_upstream_ip_hash_peer_data_t));

    if (iphp == NULL) {

        return NGX_ERROR;

    }

    r->upstream->peer.data = &iphp->rrp;

    //调用了RR算法中的初始化函数

    if (ngx_http_upstream_init_round_robin_peer(r, us) != NGX_OK) {

        return NGX_ERROR;

    }

    //回调函数设置，具体做选择的回调函数

    r->upstream->peer.get = ngx_http_upstream_get_ip_hash_peer;

    switch (r->connection->sockaddr->sa_family) {

    //保存客户端地址

    case AF_INET:

        sin = (struct sockaddr_in *) r->connection->sockaddr;

        iphp->addr = (u_char *) &sin->sin_addr.s_addr;

        //转储IPv4只用到了前3个字节，因为在后面的hash计算过程中只用到了3个字节

        iphp->addrlen = ;

        break;

#if (NGX_HAVE_INET6)

    case AF_INET6:

        sin6 = (struct sockaddr_in6 *) r->connection->sockaddr;

        iphp->addr = (u_char *) &sin6->sin6_addr.s6_addr;

        iphp->addrlen = ;

        break;

#endif

    default:

        iphp->addr = ngx_http_upstream_ip_hash_pseudo_addr;

        iphp->addrlen = ;

    }

    //初始化hash种子

    iphp->hash = ;

    //初始化尝试失败次数

    iphp->tries = ;

    //做RR选择的函数

    iphp->get_rr_peer = ngx_http_upstream_get_round_robin_peer;

    return NGX_OK;

}

其中结构体ngx_http_upstream_ip_hash_peer_data_t：

typedef struct {

    /* the round robin data must be first */

    ngx_http_upstream_rr_peer_data_t   rrp;

    //hash种子值

    ngx_uint_t                         hash;

    //IP地址

    u_char                             addrlen;

    u_char                            *addr;

    //尝试连接的次数

    u_char                             tries;

    ngx_event_get_peer_pt              get_rr_peer;

} ngx_http_upstream_ip_hash_peer_data_t;

typedef struct {

    //指向所有服务器的指针

    ngx_http_upstream_rr_peers_t   *peers;

    //当前服务器

    ngx_uint_t                      current;

    //指向位图的指针

    uintptr_t                      *tried;

    //位图的实际存储位置

    uintptr_t                       data;

} ngx_http_upstream_rr_peer_data_t;

typedef struct ngx_http_upstream_rr_peers_s  ngx_http_upstream_rr_peers_t;

struct ngx_http_upstream_rr_peers_s {

    ngx_uint_t                      number;//所有服务器地址总数

 /* ngx_mutex_t                    *mutex; */

    ngx_uint_t                      total_weight;//所有服务总权重

    unsigned                        single:;//是否只有一个后端服务

    unsigned                        weighted:;//number ！= total_weight ?

    ngx_str_t                      *name;

    ngx_http_upstream_rr_peers_t   *next;

    ngx_http_upstream_rr_peer_t     peer[];

};

具体做选择的函数是ngx_http_upstream_get_ip_hash_peer：

static ngx_int_t

ngx_http_upstream_get_ip_hash_peer(ngx_peer_connection_t *pc, void *data)

{

    ngx_http_upstream_ip_hash_peer_data_t  *iphp = data;

    time_t                        now;

    ngx_int_t                     w;

    uintptr_t                     m;

    ngx_uint_t                    i, n, p, hash;

    ngx_http_upstream_rr_peer_t  *peer;

    ngx_log_debug1(NGX_LOG_DEBUG_HTTP, pc->log, ,

                   "get ip hash peer, try: %ui", pc->tries);

    /* TODO: cached */

    //如果失败次数太多，或者只有一个后端服务，那么直接做RR选择

    if (iphp->tries >  || iphp->rrp.peers->single) {

        return iphp->get_rr_peer(pc, &iphp->rrp);

    }

    now = ngx_time();

    pc->cached = ;

    pc->connection = NULL;

    hash = iphp->hash;

    for ( ;; ) {

        //计算IP的hash值

        for (i = ; i < iphp->addrlen; i++) {

            //113质数，可以让哈希结果更散列

            hash = (hash *  + iphp->addr[i]) % ;

        }

        //根据哈希结果得到被选中的后端服务器

        if (!iphp->rrp.peers->weighted) {

            p = hash % iphp->rrp.peers->number;

        } else {

            w = hash % iphp->rrp.peers->total_weight;

            for (i = ; i < iphp->rrp.peers->number; i++) {

                w -= iphp->rrp.peers->peer[i].weight;

                if (w < ) {

                    break;

                }

            }

            p = i;

        }

        //服务器对应在位图中的位置计算

        n = p / ( * sizeof(uintptr_t));

        m = (uintptr_t)  << p % ( * sizeof(uintptr_t));

        if (!(iphp->rrp.tried[n] & m)) {

            ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, ,

                           "get ip hash peer, hash: %ui %04XA", p, m);

            //获取服务器

            peer = &iphp->rrp.peers->peer[p];

            /* ngx_lock_mutex(iphp->rrp.peers->mutex); */

            //服务器未挂掉

            if (!peer->down) {

                //失败次数已达上限

                if (peer->max_fails ==  || peer->fails < peer->max_fails) {

                    break;

                }

                if (now - peer->checked > peer->fail_timeout) {

                    peer->checked = now;

                    break;

                }

            }

            //更改位图标记值

            iphp->rrp.tried[n] |= m;

            /* ngx_unlock_mutex(iphp->rrp.peers->mutex); */

            //在连接一个远端服务器时，当前连接异常失败后可以尝试的次数

            pc->tries--;

        }

        //已经尝试的次数超过阈值，采用RR轮询

        if (++iphp->tries >= ) {

            return iphp->get_rr_peer(pc, &iphp->rrp);

        }

    }

    //当前服务索引

    iphp->rrp.current = p;

    //服务器地址及名字保存

    pc->sockaddr = peer->sockaddr;

    pc->socklen = peer->socklen;

    pc->name = &peer->name;

    /* ngx_unlock_mutex(iphp->rrp.peers->mutex); */

    //位图更新

    iphp->rrp.tried[n] |= m;

    //保留种子，使下次get_ip_hash_peer的时候能够选到同一个peer上

    iphp->hash = hash;

    return NGX_OK;

}

流程图如下：

ip-hash原理：

for(i=;i<;i++)

{

    hash = (hash *  + iphp->addr[i]) % //iphp->addr[i]为ip的点分十进制法的第i段

}

for循环 i取 012三个值，而ip的点分十进制表示方法将ip分成四段（如：192.168.1.1），但是这里循环时只是将ip的前三个端作为参数加入hash函数。这样做的目的是保证ip地址前三位相同的用户经过hash计算将分配到相同的后端server。

作者的这个考虑是极为可取的，因此ip地址前三位相同通常意味着来着同一个局域网或者相邻区域，使用相同的后端服务让nginx在一定程度上更具有一致性。

哈希函数：hash = (hash * 113 + iphp->addr[i]) % 6271,其中113为质数，可以让哈希结果更散列

轮询策略和IP哈希策略对比

加权轮询策略
优点：适用性更强，不依赖于客户端的任何信息，完全依靠后端服务器的情况来进行选择。能把客户端请求更合理更均匀地分配到各个后端服务器处理。
缺点：同一个客户端的多次请求可能会被分配到不同的后端服务器进行处理，无法满足做会话保持的应用的需求。
IP哈希策略
优点：能较好地把同一个客户端的多次请求分配到同一台服务器处理，避免了加权轮询无法适用会话保持的需求。
缺点：当某个时刻来自某个IP地址的请求特别多，那么将导致某台后端服务器的压力可能非常大，而其他后端服务器却空闲的不均衡情况、

最新文章

  1. click事件的累加绑定，绑定一次点击事件，执行多次
  2. windows下如何安装和启动MySQL
  3. jarsigner 签名android apk
  4. 【Java】JDBC连接MySQL
  5. vc 判断哪个按键 被按下 消息 按键 状态
  6. 6.24 AppCan移动开发者大会：议程重大更新，报名即将关闭
  7. [OOD]违反里氏替换原则的解决方案
  8. SVM原理简介
  9. [转载]tcp可靠性的好文
  10. setPixel抛出java.lang.IllegalStateException
  11. 使用WordPress快速建站
  12. 控制结构(3) 状态机(state machine)
  13. 宝藏（树形DP）
  14. 从 JavaScript 到 TypeScript 系列
  15. WebService WSDL结构分析
  16. RabbitMQ消息队列（十三）-VirtualHost与权限管理
  17. Java_Number(装箱和拆箱)
  18. Java中关于CountDownLatch的使用
  19. 【POJ1509】Glass Beads
  20. SpringBoot war包部署到Tomcat服务器

热门文章

  1. JS获取服务器端控件ID
  2. elasticsearch.yml 配置说明
  3. 4K屏选购秘诀
  4. leetcode_1014. Capacity To Ship Packages Within D Days
  5. A C compiler that parses this code will contain at least the following symbol table entries
  6. 为什么 [\000-\177]匹配任意7bit ascii码 ？
  7. 在 XML 中有 5 个预定义的实体引用
  8. UML-画类图与交互图的顺序
  9. Android图像处理之Bitmap类(1)
  10. svn in xcode5