Nginx服務(wù)器中的模塊編寫及相關(guān)內(nèi)核源碼初探

更新時間：2015年12月24日 14:25:40 作者：SmartMZ

這篇文章主要介紹了Nginx服務(wù)器中的模塊編寫及相關(guān)源碼初探,文中以一個簡單的Hello world模塊的編寫來深入分析Nginx內(nèi)核所用到的基礎(chǔ)函數(shù),需要的朋友可以參考下

1.nginx模塊
首先nginx和apache最大的不同就是nginx的模塊不能夠動態(tài)添加，需要在編譯時，指定要添加的模塊路徑，與nginx源碼一起編譯。
nginx模塊的處理流程：
a.客戶端發(fā)送http請求到nginx服務(wù)器
b.nginx基于配置文件中的位置選擇一個合適的處理模塊
c.負(fù)載均衡模塊選擇一臺后端服務(wù)器(反向代理情況下)
d.處理模塊進(jìn)行處理并把輸出緩沖放到第一個過濾模塊上
e.第一個過濾模塊處理后輸出給第二個過濾模塊
f.然后第二個過濾模塊又到第三個過濾模塊
g.第N個過濾模塊。。。
h.處理結(jié)果發(fā)給客戶端

2.nginx模塊編寫
a、創(chuàng)建模塊文件夾

mkdir -p /opt/nginx_hello_world 
cd /op/nginx_hello_word

b、創(chuàng)建模塊配置文件

vi /opt/nginx_hello_word/config

c、創(chuàng)建模塊主文件

vi /opt/nginx_hello_world/ngx_http_hello_world_module.c

寫入如下內(nèi)容：

#include <ngx_config.h> 
#include <ngx_core.h> 
#include <ngx_http.h> 
 
 
static char *ngx_http_hello_world(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);

寫的helloworld模塊

/* Commands */ 
static ngx_command_t ngx_http_hello_world_commands[] = { 
 { ngx_string("hello_world"), 
  NGX_HTTP_LOC_CONF|NGX_CONF_NOARGS, 
  ngx_http_hello_world, 
  0, 
  0, 
  NULL }, 
 ngx_null_command 
}; 
 
static u_char ngx_hello_world[] = "hello world"; 
 
static ngx_http_module_t ngx_http_hello_world_module_ctx = { 
 NULL,         /* preconfiguration */ 
 NULL,          /* postconfiguration */ 
 NULL,         /* create main configuration */ 
 NULL,         /* init main configuration */ 
 NULL,         /* create server configuration */ 
 NULL,         /* merge server configuration */ 
 NULL,         /* create location configuration */ 
 NULL         /* merge location configuration */ 
}; 
/* hook */ 
ngx_module_t ngx_http_hello_world_module = { 
 NGX_MODULE_V1, 
 &ngx_http_hello_world_module_ctx,    /* module context */ 
 ngx_http_hello_world_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 
}; 
static ngx_int_t 
ngx_http_hello_world_handler(ngx_http_request_t *r) 
{ 
 ngx_int_t  rc; 
 ngx_buf_t *b; 
 ngx_chain_t out; 
 /* Http Output Buffer */ 
 r->headers_out.content_type.len = sizeof("text/plain") - 1; 
 r->headers_out.content_type.data = (u_char *) "text/plain"; 
  
 b = ngx_pcalloc(r->pool, sizeof(ngx_buf_t)); 
  
 out.buf = b; 
 out.next = NULL; 
  
 b->pos = ngx_hello_world; 
 b->last = ngx_hello_world + sizeof(ngx_hello_world); 
 b->memory = 1; 
 b->last_buf = 1; 
  
 r->headers_out.status = NGX_HTTP_OK; 
 r->headers_out.content_length_n = sizeof(ngx_hello_world); 
 ngx_http_send_header(r); 
  
 return ngx_http_output_filter(r, &out); 
} 
static char * 
ngx_http_hello_world(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) 
{ 
 ngx_http_core_loc_conf_t *clcf ; 
 /* register hanlder */ 
 clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module); 
 clcf->handler = ngx_http_hello_world_handler; 
 return NGX_CONF_OK; 
}

d、下載nginx源碼包，我下載的是nginx-1.0.13.tar.gz
這里注意在編譯helloworld模塊前首先確認(rèn)，nginx是否可以獨(dú)立編譯成功，是否安裝了所需的所有模塊。
與helloworld模塊一起編譯nginx：

./configure --prefix=/usr/local/nginx --add-module=/opt/nginx_hello_world/ 
make 
make install

e、配置nginx.conf

location= /hello { 
 hello_world; 
}

f、啟動nginx，訪問http://localhost/hello ，可以看到編寫的helloworld模塊輸出的文字。

3.hello world模塊分析
a.ngx_command_t函數(shù)用于定義包含模塊指令的靜態(tài)數(shù)組ngx_http_hello_world_commands

static ngx_command_t ngx_http_hello_world_commands[] = { 
 { ngx_string("hello_world"), //設(shè)置指令名稱字符串，注意不能包含空格，數(shù)據(jù)類型ngx_str_t之后會詳細(xì)講解。 
  NGX_HTTP_LOC_CONF|NGX_CONF_NOARGS, //配置指令的合法位置，這里表示：location部分合法，并且指令沒有參數(shù)。 
  ngx_http_hello_world,//回調(diào)函數(shù)，三個參數(shù)（ngx_conf_t *cf，ngx_command_t *cmd, void *conf） 
  0,//后面的參數(shù)有待發(fā)掘，我還沒有用到 
  0, 
  NULL }, 
 ngx_null_command 
};

b.static u_char ngx_hello_world[] ="hello world" 則是輸出到屏幕的字符串。
c.ngx_http_module_t用來定義結(jié)構(gòu)體ngx_http_hello_world_module_ctx:

static ngx_http_module_t ngx_http_hello_world_module_ctx = { 
 NULL,         /* 讀入配置前調(diào)用*/ 
 NULL,          /* 讀入配置后調(diào)用*/ 
 NULL,         /* 創(chuàng)建全局部分配置時調(diào)用 */ 
 NULL,         /* 初始化全局部分的配置時調(diào)用*/ 
 NULL,         /* 創(chuàng)建虛擬主機(jī)部分的配置時調(diào)用*/ 
 NULL,         /* 與全局部分配置合并時調(diào)用 */ 
 NULL,         /* 創(chuàng)建位置部分的配置時調(diào)用 */ 
 NULL         /* 與主機(jī)部分配置合并時調(diào)用*/ 
};

d.ngx_module_t定義結(jié)構(gòu)體ngx_http_hello_world_module

ngx_module_t ngx_http_hello_world_module = { 
 NGX_MODULE_V1, 
 &ngx_http_hello_world_module_ctx,    /* module context */ 
 ngx_http_hello_world_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 
};

e.處理函數(shù)，ngx_http_hello_world_handler，也是hello world 模塊的核心部分。

static ngx_int_t 
ngx_http_hello_world_handler(ngx_http_request_t *r)//ngx_http_request_t *r 
//可以訪問到客戶端的頭部和不久要發(fā)送的回復(fù)頭部 
{ 
 ngx_int_t  rc; 
 ngx_buf_t *b; 
 ngx_chain_t out; 
 /* Http Output Buffer */ 
 r->headers_out.content_type.len = sizeof("text/plain") - 1; 
 r->headers_out.content_type.data = (u_char *) "text/plain"; 
  
 b = ngx_pcalloc(r->pool, sizeof(ngx_buf_t)); 
  
 out.buf = b; 
 out.next = NULL; 
  
 b->pos = ngx_hello_world; 
 b->last = ngx_hello_world + sizeof(ngx_hello_world); 
 b->memory = 1; 
 b->last_buf = 1; 
  
 r->headers_out.status = NGX_HTTP_OK; 
 r->headers_out.content_length_n = sizeof(ngx_hello_world); 
 ngx_http_send_header(r); 
  
 return ngx_http_output_filter(r, &out); 
}

helloworld模塊里面涉及最重要的數(shù)據(jù)就是ngx_module_t指針數(shù)組，這個指針數(shù)組包含了當(dāng)前編譯版本支持的所有模塊，這個指針數(shù)組定義實(shí)在自動腳本生成的objs/ngx_modules.c中，如下：

 extern ngx_module_t ngx_core_module; 
 extern ngx_module_t ngx_errlog_module; 
 extern ngx_module_t ngx_conf_module; 
 extern ngx_module_t ngx_events_module; 
 extern ngx_module_t ngx_event_core_module; 
 extern ngx_module_t ngx_epoll_module; 
 extern ngx_module_t ngx_http_module; 
 extern ngx_module_t ngx_http_core_module; 
 extern ngx_module_t ngx_http_log_module; 
 extern ngx_module_t ngx_http_upstream_module; 
 extern ngx_module_t ngx_http_static_module; 
 extern ngx_module_t ngx_http_autoindex_module; 
 extern ngx_module_t ngx_http_index_module; 
 extern ngx_module_t ngx_http_auth_basic_module; 
 extern ngx_module_t ngx_http_access_module; 
 extern ngx_module_t ngx_http_limit_zone_module; 
 extern ngx_module_t ngx_http_limit_req_module; 
 extern ngx_module_t ngx_http_geo_module; 
 extern ngx_module_t ngx_http_map_module; 
 extern ngx_module_t ngx_http_split_clients_module; 
 extern ngx_module_t ngx_http_referer_module; 
 extern ngx_module_t ngx_http_rewrite_module; 
 extern ngx_module_t ngx_http_proxy_module; 
 extern ngx_module_t ngx_http_fastcgi_module; 
 extern ngx_module_t ngx_http_uwsgi_module; 
 extern ngx_module_t ngx_http_scgi_module; 
 extern ngx_module_t ngx_http_memcached_module; 
 extern ngx_module_t ngx_http_empty_gif_module; 
 extern ngx_module_t ngx_http_browser_module; 
 extern ngx_module_t ngx_http_upstream_ip_hash_module; 
 extern ngx_module_t ngx_http_cache_purge_module; 
 extern ngx_module_t ngx_http_write_filter_module; 
 extern ngx_module_t ngx_http_header_filter_module; 
 extern ngx_module_t ngx_http_chunked_filter_module; 
 extern ngx_module_t ngx_http_range_header_filter_module; 
 extern ngx_module_t ngx_http_gzip_filter_module; 
 extern ngx_module_t ngx_http_postpone_filter_module; 
 extern ngx_module_t ngx_http_ssi_filter_module; 
 extern ngx_module_t ngx_http_charset_filter_module; 
 extern ngx_module_t ngx_http_userid_filter_module; 
 extern ngx_module_t ngx_http_headers_filter_module; 
 extern ngx_module_t ngx_http_copy_filter_module; 
 extern ngx_module_t ngx_http_range_body_filter_module; 
 extern ngx_module_t ngx_http_not_modified_filter_module; 
  
 ngx_module_t *ngx_modules[] = { 
  &ngx_core_module, 
  &ngx_errlog_module, 
  &ngx_conf_module, 
  &ngx_events_module, 
  &ngx_event_core_module, 
  &ngx_epoll_module, 
  &ngx_http_module, 
  &ngx_http_core_module, 
  &ngx_http_log_module, 
  &ngx_http_upstream_module, 
  &ngx_http_static_module, 
  &ngx_http_autoindex_module, 
  &ngx_http_index_module, 
  &ngx_http_auth_basic_module, 
  &ngx_http_access_module, 
  &ngx_http_limit_zone_module, 
  &ngx_http_limit_req_module, 
  &ngx_http_geo_module, 
  &ngx_http_map_module, 
  &ngx_http_split_clients_module, 
  &ngx_http_referer_module, 
  &ngx_http_rewrite_module, 
  &ngx_http_proxy_module, 
  &ngx_http_fastcgi_module, 
  &ngx_http_uwsgi_module, 
  &ngx_http_scgi_module, 
  &ngx_http_memcached_module, 
  &ngx_http_empty_gif_module, 
  &ngx_http_browser_module, 
  &ngx_http_upstream_ip_hash_module, 
  &ngx_http_cache_purge_module, 
  &ngx_http_write_filter_module, 
  &ngx_http_header_filter_module, 
  &ngx_http_chunked_filter_module, 
  &ngx_http_range_header_filter_module, 
  &ngx_http_gzip_filter_module, 
  &ngx_http_postpone_filter_module, 
  &ngx_http_ssi_filter_module, 
  &ngx_http_charset_filter_module, 
  &ngx_http_userid_filter_module, 
  &ngx_http_headers_filter_module, 
  &ngx_http_copy_filter_module, 
  &ngx_http_range_body_filter_module, 
  &ngx_http_not_modified_filter_module, 
  NULL 
 };

這里只有每個模塊變量的聲明，并且每個模塊的定義都包含在自己的模塊文件當(dāng)中，比如ngx_core_module定義在src/core/nginx.c中：

ngx_module_t ngx_core_module = { 
 NGX_MODULE_V1, 
 &ngx_core_module_ctx,     /* module context */ 
 ngx_core_commands,      /* module directives */ 
 NGX_CORE_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 
};

是不是跟helloworld里面非常相似了，沒錯，他們都是模塊，唯一的不同點(diǎn)就是helloworld是你另外加進(jìn)去的。
到現(xiàn)在位置也只是初探nginx的模塊，最后提一張別人畫的nginx的模塊圖，有助于接下來的學(xué)習(xí)。

您可能感興趣的文章: