[nginx 소스 코드 분석] nginx handler 모듈 분석

nginx 는 설정 해석 과 초기 화 를 제외 하고 요청 에 따라 상태 기 에 따라 한 걸음 한 걸음 절 차 를 실행 하 는 것 입 니 다. 이 절 은 먼저 전체 nginx 가 클 라 이언 트 에 대한 요청 절 차 를 대체적으로 요청 하 는 것 이 고 그 다음 에 이 절차 에 따라 자신의 handler 모듈 을 쓰 는 것 입 니 다.
nginx 에서 client 요청 호출 프로 세 스 를 받 았 습 니 다:
1 ngx_event_accept 는 주로 accept 연결 생 성 및 connection 초기 화
2 ngx_http_init_connection 함 수 는 주로 rev 와 wev 이벤트 리 셋 함 수 를 설정 합 니 다.
3 ngx_http_init_request 초기 화 request
4 ngx_http_process_request_라인 처리 요청 라인
5 ngx_http_process_request_헤더 처리 요청 헤더
6 ngx_http_process_요청 처리 요청
7 ngx_http_handler
8 ngx_http_core_run_phases
함수 상세:

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;
}
}
}

그리고 전체 요청 상태 기의 11 단 계 를 옮 겨 다 닙 니 다.
번호
단계 이름
단계 설명
0
NGX_HTTP_POST_READ_PHASE
요청 헤더 읽 기 완료 단계
1
NGX_HTTP_SERVER_REWRITE_PHASE
서버 내 요청 주소 재 작성 단계
2
NGX_HTTP_FIND_CONFIG_PHASE
찾기 단계 설정
3
NGX_HTTP_REWRITE_PHASE
위치 내 요청 주소 재 작성 단계
4
NGX_HTTP_POST_REWRITE_PHASE
요청 주소 재 작성 완료 후 단계
5
NGX_HTTP_PREACCESS_PHASE
접근 권한 검사 준비 단계
6
NGX_HTTP_ACCESS_PHASE
접근 권한 검사 단계
7
NGX_HTTP_POST_ACCESS_PHASE
접근 권한 검사 완료 후 단계
8
NGX_HTTP_TRY_FILES_PHASE
설정 항목 try파일 처리 단계
9
NGX_HTTP_CONTENT_PHASE
콘 텐 츠 생 성 단계
10
NGX_HTTP_LOG_PHASE
로그 모듈 처리 단계
보통 저희 가 handler 모듈 을 쓰 는데 NGX 에 있어 요.HTTP_CONTENT_PHASE 단계, 즉 우 리 는 함 수 를 NGX 에 직접 걸 었 다.HTTP_CONTENT_PHASE 는 OK
저희 가 직접 nginx handler 모듈 을 쓰 겠 습 니 다.
config 파일

//config   
ngx_addon_name=ngx_http_read_module
HTTP_MODULES="$HTTP_MODULES ngx_http_read_module"
NGX_ADDON_SRCS="$NGX_ADDON_SRCS $ngx_addon_dir/ngx_http_read_module.c"

ngx_http_read_module. c 파일

/*
 * =====================================================================================
 *
 *       Filename:  ngx_http_read_module.c
 *
 *    Description:          leek       
 *
 *        Version:  1.0
 *        Created:  2013 10 10  11 06 53 
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  [email protected]
 *   Organization:  
 *
 * =====================================================================================
 */
#include 
#include 
#include 

#define TEST_STRING     "This is a static module test string"
typedef struct 
{
        ngx_str_t name;
}ngx_http_test_loc_t;
ngx_str_t g_buf;

static void* ngx_http_leek_create_loc_conf(ngx_conf_t* cf);
static char* ngx_http_leek_merge_loc_conf(ngx_conf_t* cf, void* parent, void* child);
static ngx_int_t ngx_http_leekdump_handler(ngx_http_request_t *r);

/*
 *           ngx_http_test_loc_t  ,       ,          http->ctx->loc_conf        
 */
static void* ngx_http_leek_create_loc_conf(ngx_conf_t* cf) {
        ngx_http_test_loc_t* conf;

        conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_test_loc_t));
        if (conf == NULL) {
                return NGX_CONF_ERROR;
        }
        conf->name.len = 0;
        conf->name.data = NULL;

        return conf;
}
/*             leek             */
char* setvalue(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
        ngx_http_test_loc_t* temp;
        struct stat buf;

        ngx_conf_set_str_slot(cf, cmd, conf);
        
        temp = (ngx_http_test_loc_t*)conf;
        if (access((char*)temp->name.data, F_OK) == -1)
        {
                return NGX_CONF_ERROR;
        }
        if (stat((char*)temp->name.data, &buf))
        {
                return NGX_CONF_ERROR;
        }

        g_buf.data = ngx_alloc(buf.st_size +1, cf->log);
        g_buf.data[buf.st_size] = 0;
        g_buf.len = buf.st_size+1;
        int fd = open((char*)temp->name.data, O_RDONLY);
        if (fd == -1)
        {
                return NGX_CONF_ERROR;
        }

        read(fd, g_buf.data, buf.st_size);
        return NGX_CONF_OK;
}
/*
 * ngx_string(leek) =>      leek  
 * NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1 =>        loc           (NGX_CONF_TAKE1)
 *      setvalue 
 *    LOC   
 *   name    ngx_http_test_loc_t  
 *
 */
static ngx_command_t ngx_http_read_commands [] = {
        {
                ngx_string("leek"),
                NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
                setvalue,
                NGX_HTTP_LOC_CONF_OFFSET,
                offsetof(ngx_http_test_loc_t, name),
                NULL
        },
ngx_null_command
};
/*
 *   http      NGX_HTTP_CONTENT_PHASE
 */
static ngx_int_t ngx_http_read_init(ngx_conf_t *cf)
{
    ngx_http_handler_pt        *h;
    ngx_http_core_main_conf_t  *cmcf;

    cmcf = ngx_http_conf_get_module_main_conf(cf, ngx_http_core_module);

    h = ngx_array_push(&cmcf->phases[NGX_HTTP_CONTENT_PHASE].handlers);
    if (h == NULL) {
        return NGX_ERROR;
    }

    *h = ngx_http_leekdump_handler;

        return NGX_OK;
}
ngx_http_module_t  ngx_http_read_module_ctx = {
        NULL,                                  /* preconfiguration */
        ngx_http_read_init,                    /* postconfiguration */
        NULL,                                  /* create main configuration */
        NULL,                                  /* init main configuration */

        NULL,                                  /* create server configuration */
        NULL,                                  /* merge server configuration */

        ngx_http_leek_create_loc_conf,                                      /* create location configuration */
        ngx_http_leek_merge_loc_conf                                   /* merge location configuration */
};

/*
 *     
 */
ngx_module_t ngx_http_read_module = 
{
        NGX_MODULE_V1,
        &ngx_http_read_module_ctx,             /* module context */
        ngx_http_read_commands,                /* module directives */
        NGX_HTTP_MODULE,                       /* module type */
        NULL,                                  /* init master */
        NULL,                                  /* init module */
        NULL,                                  /* init process */
        NULL,                                  /* init thread */
        NULL,                                  /* exit thread */
        NULL,                                  /* exit process */
        NULL,                                  /* exit master */
        NGX_MODULE_V1_PADDING
};
/*
 *      loc    ，          loc  parent loc 
 */
static char* ngx_http_leek_merge_loc_conf(ngx_conf_t* cf, void* parent, void* child) {
        ngx_http_test_loc_t* prev = parent;
        ngx_http_test_loc_t* conf = child;
        ngx_conf_merge_str_value(conf->name, prev->name, "Nginx");
        return NGX_CONF_OK;
}

/*
 *     ，     leek     ，     leek         ，     
 *       
 * 1 ngx_http_send_header
 * 2 ngx_http_output_filter
 */
static ngx_int_t ngx_http_leekdump_handler(ngx_http_request_t *r)
{
        ngx_int_t rc;
        ngx_buf_t* b;
        ngx_chain_t out[3];

    if (ngx_rstrncasecmp((u_char *)"/leek", r->uri.data, 5) != 0) {
        return NGX_DECLINED;
    }

        r->headers_out.content_type.len = sizeof("text/html") - 1;
        r->headers_out.content_type.data = (u_char*)"text/html";

        b = ngx_pcalloc(r->pool, sizeof(ngx_buf_t));

        out[0].buf = b;
        out[0].next = NULL;

        b->pos = (u_char*)g_buf.data;
        b->last = b->pos + g_buf.len;
        b->memory = 1;
        b->last_buf = 1;

        r->headers_out.status = NGX_HTTP_OK;
        r->headers_out.content_length_n = g_buf.len;
        rc = ngx_http_send_header(r);
        if (rc == NGX_ERROR || rc > NGX_OK || r->header_only) {
                return rc;
        }

        return ngx_http_output_filter(r, &out[0]);
}
(END) 

nginx. conf 설정 파일 은 다음 과 같 습 니 다.

worker_processes  1;

events {
    worker_connections  1024;
}


http {
    include       mime.types;
    default_type  application/octet-stream;


    sendfile        on;
    #tcp_nopush     on;

    #keepalive_timeout  0;
    keepalive_timeout  65;

    #gzip  on;

    server {
        listen       80;
        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {
            root   html;
            index  index.html index.htm;
        }

        location /leek {
            leek "/root/hunter/nginx/ngx_gdb/conf/mime.types.default";
        }
        #error_page  404              /404.html;

        # redirect server error pages to the static page /50x.html
        #
        error_page   500 502 503 504  /50x.html;
        location = /50x.html {
            root   html;
        }

    }


}

이 때 content handler 의 주요 기능 은 사용자 가 / "leek" 페이지 에 접근 할 때 파일 (

/root/hunter/nginx/ngx_gdb/conf/mime.types.default

사용자 브 라 우 저 클 라 이언 트 에 게 되 돌려 줍 니 다.