nginx roundrobin, keepalive, ip_hash 모듈 분석

먼저 ngx_http_upstream_srv_conf_s 구조에도 포함된 다음 구조로 시작합니다.

<code><span>typedef</span><span>struct</span> {
<span>/*typedef ngx_int_t (*ngx_http_upstream_init_pt)(ngx_conf_t*cf,ngx_http_upstream_srv_conf_t *us);*/</span>
    ngx_http_upstream_init_pt        init_upstream;

    ngx_http_upstream_init_peer_pt   init;
    <span>void</span>                            *data;                     
} ngx_http_upstream_peer_t</code>

다음은 두 멤버 변수 init_upstream 및 init를 분석하는 데 중점을 둡니다

init_upstream

업스팀 구성 블록당 한 번 실행됩니다.
keepalive 또는 ip_hash 함수를 구성하여 구성할 수 있습니다. 즉, keepalive 또는 ip_hash 구성이 발생할 때 호출됩니다. 구성이 없으면 기본 구현은 ngx_http_upstream_init_round_robin 함수입니다. 구성 시 호출됩니다. 기본 설정은 메인 기능이 2개

1. us->servers 배열에서 데이터를 가져와 ngx_http_upstream_rr_peers_t 구조를 초기화하고 us->peer.data에 저장하여 사용하도록 구성되어 있습니다. init 함수로
2. init 구성 가능성을 실현하기 위해 init 함수의 값을 설정합니다.

init

init 함수는 oringin에 대한 각 요청에 대해 한 번 실행됩니다. ;
r->upstream->peer 구조를 구성하기 위해 ngx_http_upstream_init_request에서 호출됩니다. keepalive 및 ip_hash 기능에 대해 다양한 get 및 free 기능이 구성됩니다. 기본 구현은 ngx_http_upstream_create_round_robin_peer

<code>struct ngx_peer_connection_s {

    ngx_connection_t                <span>*</span>connection;
    struct sockaddr                 <span>*</span>sockaddr;
    socklen_t                        socklen;
    ngx_str_t                       <span>*</span>name;

    ngx_uint_t                       tries;
    ngx_msec_t                       start_time;

    <span>/*类型typedef ngx_int_t (*ngx_event_get_peer_pt)(ngx_peer_connection_t *pc, void     *data);*/</span><span>/* 上面init的函数中被配置，如果配置了keepalive且从cache中找到了connection将返回NGX_DONE,*/</span><span>/* 且设置复    用已经存在的连接，如果没有配置keepalive或者，没有找到存在的connection，*/</span><span>/*但找到了下一跳地址，将返回NGX_OK，*/</span>
    ngx_event_get_peer_pt            get;

    <span>/*，同样在init中被设置,连接释放时被调用*/</span>
    ngx_event_free_peer_pt           free;
   <span>/* 在init中被设置，用以保存init_upstream中生成的us->peer.data数据，在get和free方法中被使用*/</span><span>void</span><span>*</span><span>data</span>;
   <span>...</span><span>...</span><span>...</span>
   };</code>

init 함수입니다. rr에 대한 연결을 생성할 때 데이터가 사용됩니다. 호출 프로세스는 다음과 같습니다.
ngx_http_upstream_init_request->ngx_http_upstream_connect->ngx_event_connect_peer-> rc = pc->get(pc, pc->데이터)
round_robin, ip_hash, keepalive 모듈 간의 관계
round_robin 및 ip_hash 모듈은 모두 IP 주소를 찾는 데 사용됩니다. keepalive 함수는 IP 주소의 IP 주소를 찾은 다음 해당 IP 주소를 사용하여 사용 가능한 연결이 있는지 확인하는 데 사용됩니다. 두 모듈 중 ip_hash가 현재 사용됩니다. 검색에 실패하면 기본 round_robin 함수를 사용하세요. Keepalive 기능은 IP를 찾은 후에만 사용할 수 있습니다. IP 검색은 ip_hash 방법이나 round_robin에서 제공하는 방법을 사용할 수 있습니다. 아래와 같이


keepalive가 데코레이터 모델과 유사하다는 것을 알 수 있습니다. 즉, 다음 홉 IP에 keepalive 기능을 추가하는 것은 Origin에서 구현한 함수 포인터를 포함합니다

. ip_hash와 round_robin은 전략 모델과 유사할 수 있습니다. 즉, init_upstream에서 IP 찾기 요청에 대해 서로 다른 전략을 설정하는 것입니다.

<code>static ngx_int_t                                                                                                                                                         
ngx_http_upstream_init_keepalive_peer(ngx_http_request_t <span>*</span>r,                                                                                                             
    ngx_http_upstream_srv_conf_t <span>*</span>us)                                                                                                                                    
{                                                                                                                                                                        
    ngx_http_upstream_keepalive_peer_data_t  <span>*</span>kp;                                                                                                                        
    ngx_http_upstream_keepalive_srv_conf_t   <span>*</span>kcf;                                                                                                                       

    ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r<span>-></span>connection<span>-></span><span>log</span>, <span>0</span>,                                                                                                            
                   <span>"init keepalive peer"</span>);                                                                                                                               

    kcf <span>=</span> ngx_http_conf_upstream_srv_conf(us,                                                                                                                            
                                          ngx_http_upstream_keepalive_module);                                                                                           

    kp <span>=</span> ngx_palloc(r<span>-></span>pool, sizeof(ngx_http_upstream_keepalive_peer_data_t));                                                                                           
    <span>if</span> (kp <span>==</span><span>NULL</span>) {                                                                                                                                                    
        <span>return</span> NGX_ERROR;                                                                                                                                                
    }                                                                                                                                                                    

    <span>if</span> (kcf<span>-></span>original_init_peer(r, us) <span>!=</span> NGX_OK) {                                                                                                                      
        <span>return</span> NGX_ERROR;                                                                                                                                                
    }                                                                                                                                                                    

    kp<span>-></span>conf <span>=</span> kcf;                                                                                                                                                      
    kp<span>-></span>upstream <span>=</span> r<span>-></span>upstream;                                                                                                                                          

    <span>/*保存默认的original_get_peer方法，仍将在新的get方法中被调用，r->upstream->peer.get;可以是round_robin,也可以是iphash模块提供的 */</span>    kp<span>-></span>original_get_peer <span>=</span> r<span>-></span>upstream<span>-></span>peer<span>.</span>get;                                                                                                                       
    kp<span>-></span>original_free_peer <span>=</span> r<span>-></span>upstream<span>-></span>peer<span>.</span>free;                                                                                                                     

    <span>...</span><span>...</span><span>/*保存默认的在original_init_peer中初始化好的数据，get和free方法中需要使用*/</span>
    kp<span>-></span><span>data</span><span>=</span> r<span>-></span>upstream<span>-></span>peer<span>.</span><span>data</span>;

    <span>/*可以通过r->upstream->peer.data找到keepalive模块*/</span>
    r<span>-></span>upstream<span>-></span>peer<span>.</span><span>data</span><span>=</span> kp;   
     <span>/*设置新的get和free钩子*/</span>    r<span>-></span>upstream<span>-></span>peer<span>.</span>get <span>=</span> ngx_http_upstream_get_keepalive_peer;
    r<span>-></span>upstream<span>-></span>peer<span>.</span>free <span>=</span> ngx_http_upstream_free_keepalive_peer;                                                                                                                                                        
    <span>return</span> NGX_OK;                                                                                                                                                       
} 
static ngx_int_t
ngx_http_upstream_get_keepalive_peer(ngx_peer_connection_t <span>*</span>pc, <span>void</span><span>*</span><span>data</span>)
{
    ngx_http_upstream_keepalive_peer_data_t  <span>*</span>kp <span>=</span><span>data</span>;
    ngx_http_upstream_keepalive_cache_t      <span>*</span>item;

    ngx_int_t          rc;
    ngx_queue_t       <span>*</span>q, <span>*</span><span>cache</span>;
    ngx_connection_t  <span>*</span>c;
    <span>/* ask balancer 此源码注释应不准确*/</span><span>/*适用round_robin或者ip_hash等功能找到下一跳地址*/</span>
    rc <span>=</span> kp<span>-></span>original_get_peer(pc, kp<span>-></span><span>data</span>);

    <span>if</span> (rc <span>!=</span> NGX_OK) {
        <span>return</span> rc;
    }                                                                                                                                                                      

    <span>/* search cache for suitable connection */</span><span>cache</span><span>=</span><span>&</span>kp<span>-></span>conf<span>-></span><span>cache</span>;</code>

이 세 모듈의 전체적인 관계는 빌더 간의 관계와 유사합니다. 즉, init_upstream, init, get, free 및 기타 기능을 순서대로 구현하고 호출해야 합니다.

추첨:
round_robin은

등을 통해 업스트림에서 확인된 멤버가 설정될 때 사용되는 생성 기능을 제공합니다. Proxy_pass http://$vhost;가 원본 주소로 설정됩니다. 이때 init는 create로 대체되며 keepalive 및 ip_hash 기능을 가질 수 없습니다. Keepalive와 iphash는 모두 업스트림 모듈에서만 사용할 수 있습니다.

').addClass('사전 번호 매기기').hide(); $(this).addClass('has-numbering').parent().append($numbering); for (i = 1; i
').text(i)); }; $numbering.fadeIn(1700); }); });

이상에서는 관련 내용을 포함하여 nginx roundrobin, keepalive 및 ip_hash 모듈에 대한 분석을 소개했습니다. PHP 튜토리얼에 관심이 있는 친구들에게 도움이 되기를 바랍니다.