nginx的11個處理階段概述

時間 2019-12-01

標籤 nginx 處理階段概述欄目 Nginx 简体版

原文原文鏈接

微信公衆號：鄭爾多斯
關注可瞭解更多的Nginx知識。任何問題或建議，請公衆號留言;
關注公衆號，有趣有內涵的文章第一時間送達！
請關注我的博客, 戳這裏nginx

解析完請求頭部以後調用ngx_http_process_request()函數web

// 進入http的11個階段處理
static void ngx_http_process_request(ngx_http_request_t *r)
{
    ngx_connection_t  *c;

    c = r->connection;

    if (r->plain_http) {
        ngx_log_error(NGX_LOG_INFO, c->log, 0,
                      "client sent plain HTTP request to HTTPS port");
        ngx_http_finalize_request(r, NGX_HTTP_TO_HTTPS);
        return;
    }


    if (c->read->timer_set) {
        ngx_del_timer(c->read);
    }

    c->read->handler = ngx_http_request_handler;
    c->write->handler = ngx_http_request_handler;
    r->read_event_handler = ngx_http_block_reading;

    ngx_http_handler(r);

    ngx_http_run_posted_requests(c);
}
複製代碼

這個函數是在解析完http請求頭以後調用的，咱們分析一下他的功能：
一、刪除定時器，由於http的頭部已經解析完了，要進入http處理階段了，因此能夠刪除原先的定時器了。
二、將connection的讀寫事件回調函數都設置爲ngx_http_request_handler。代碼以下：
當epoll_wait()監控到當前connection上發生了讀寫事件，就會調用ngx_http_request_handler函數，而這個函數根據讀寫事件的類型分別調用http鏈接的read_event_handler和write_event_handler()函數，其實不明白這裏爲何要這麼作。而後調用ngx_http_run_posted_requests()函數處理子請求。也就是說，每當鏈接上面有讀寫事件發生的時候都會調用ngx_http_run_posted_requests來處理子請求。微信

static void ngx_http_request_handler(ngx_event_t *ev)
{
    ngx_connection_t    *c;
    ngx_http_request_t  *r;
    ngx_http_log_ctx_t  *ctx;

    c = ev->data;
    r = c->data;

    ctx = c->log->data;
    ctx->current_request = r;

    ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0,
                   "http run request: \"%V?%V\"", &r->uri, &r->args);

    if (ev->write) {
        r->write_event_handler(r);

    } else {
        r->read_event_handler(r);
    }

    ngx_http_run_posted_requests(c);
}

  3、調用ngx_http_handler()函數
void
ngx_http_handler(ngx_http_request_t *r)
{
    ngx_http_core_main_conf_t  *cmcf;

    r->connection->log->action = NULL;

    r->connection->unexpected_eof = 0;

    if (!r->internal) {
        switch (r->headers_in.connection_type) {
        case 0:
            r->keepalive = (r->http_version > NGX_HTTP_VERSION_10);
            break;

        case NGX_HTTP_CONNECTION_CLOSE:
            r->keepalive = 0;
            break;

        case NGX_HTTP_CONNECTION_KEEP_ALIVE:
            r->keepalive = 1;
            break;
        }

        r->lingering_close = (r->headers_in.content_length_n > 0);
        r->phase_handler = 0;

    } else {
        cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
        r->phase_handler = cmcf->phase_engine.server_rewrite_index;
    }

    r->valid_location = 1;
    r->write_event_handler = ngx_http_core_run_phases;
    ngx_http_core_run_phases(r);
}
複製代碼

這個函數的主要做用就是將http鏈接的write_event_handler設置爲ngx_http_core_run_phases函數，而後調用ngx_http_core_run_phases函數，這個函數就是進入nginx的11個處理階段。app

四、調用ngx_http_run_posted_requests函數處理子請求。函數

綜上所述，當 epoll_wait()監控到 connection上面有讀寫事件的時候會調用 ngx_http_core_run_phase()函數進行11個階段的處理。
在調用 ngx_http_core_run_phases()的過程當中，若是某一個處理階段的 checker函數返回了 NGX_OK，那麼從代碼中能夠看到，就會推出 ngx_http_core_run_phases()函數，這個時候 nginx的控制權就返回給了 epoll模塊，只能等待發生下一個事件的時候繼續調用 ngx_http_core_run_phase()進行處理。

// nginx的核心處理函數
void ngx_http_core_run_phases(ngx_http_request_t *r)
{
    ngx_int_t                   rc;
    ngx_http_phase_handler_t   *ph;
    ngx_http_core_main_conf_t  *cmcf;

    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);

    ph = cmcf->phase_engine.handlers;

    while (ph[r->phase_handler].checker) {

        rc = ph[r->phase_handler].checker(r, &ph[r->phase_handler]);

        if (rc == NGX_OK) {
            return;
        }
    }
}
複製代碼