/* * Copyright (C) Igor Sysoev * Copyright (C) Sergey A. Osokin */ #define NGX_ESCAPE_REDIS 4 #include #include #include #include typedef struct { ngx_http_upstream_conf_t upstream; ngx_int_t index; ngx_int_t db; ngx_uint_t gzip_flag; ngx_http_complex_value_t *complex_target; /* for redis_pass */ } ngx_http_redis_loc_conf_t; typedef struct { size_t rest; ngx_http_request_t *request; ngx_str_t key; } ngx_http_redis_ctx_t; static ngx_int_t ngx_http_redis_create_request(ngx_http_request_t *r); static ngx_int_t ngx_http_redis_reinit_request(ngx_http_request_t *r); static ngx_int_t ngx_http_redis_process_header(ngx_http_request_t *r); static ngx_int_t ngx_http_redis_filter_init(void *data); static ngx_int_t ngx_http_redis_filter(void *data, ssize_t bytes); static void ngx_http_redis_abort_request(ngx_http_request_t *r); static void ngx_http_redis_finalize_request(ngx_http_request_t *r, ngx_int_t rc); static ngx_int_t ngx_http_redis_add_variables(ngx_conf_t *cf); static void *ngx_http_redis_create_loc_conf(ngx_conf_t *cf); static char *ngx_http_redis_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child); static char *ngx_http_redis_pass(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); static ngx_http_upstream_srv_conf_t * ngx_http_redis_upstream_add(ngx_http_request_t *r, ngx_url_t *url); static ngx_conf_bitmask_t ngx_http_redis_next_upstream_masks[] = { { ngx_string("error"), NGX_HTTP_UPSTREAM_FT_ERROR }, { ngx_string("timeout"), NGX_HTTP_UPSTREAM_FT_TIMEOUT }, { ngx_string("invalid_response"), NGX_HTTP_UPSTREAM_FT_INVALID_HEADER }, { ngx_string("not_found"), NGX_HTTP_UPSTREAM_FT_HTTP_404 }, { ngx_string("off"), NGX_HTTP_UPSTREAM_FT_OFF }, { ngx_null_string, 0 } }; static ngx_command_t ngx_http_redis_commands[] = { { ngx_string("redis_pass"), NGX_HTTP_LOC_CONF|NGX_HTTP_LIF_CONF|NGX_CONF_TAKE1, ngx_http_redis_pass, NGX_HTTP_LOC_CONF_OFFSET, 0, NULL }, #if defined nginx_version && nginx_version >= 8022 { ngx_string("redis_bind"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_http_upstream_bind_set_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.local), NULL }, #endif { ngx_string("redis_connect_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.connect_timeout), NULL }, { ngx_string("redis_send_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.send_timeout), NULL }, { ngx_string("redis_buffer_size"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_size_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.buffer_size), NULL }, { ngx_string("redis_read_timeout"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_msec_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.read_timeout), NULL }, { ngx_string("redis_next_upstream"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, ngx_conf_set_bitmask_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, upstream.next_upstream), &ngx_http_redis_next_upstream_masks }, { ngx_string("redis_gzip_flag"), NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, ngx_conf_set_num_slot, NGX_HTTP_LOC_CONF_OFFSET, offsetof(ngx_http_redis_loc_conf_t, gzip_flag), NULL }, ngx_null_command }; static ngx_http_module_t ngx_http_redis_module_ctx = { ngx_http_redis_add_variables, /* preconfiguration */ NULL, /* postconfiguration */ NULL, /* create main configuration */ NULL, /* init main configuration */ NULL, /* create server configuration */ NULL, /* merge server configuration */ ngx_http_redis_create_loc_conf, /* create location configration */ ngx_http_redis_merge_loc_conf /* merge location configration */ }; ngx_module_t ngx_http_redis_module = { NGX_MODULE_V1, &ngx_http_redis_module_ctx, /* module context */ ngx_http_redis_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 }; /* Initialize additional var for hide "Content-Enconding: gzip" header */ static ngx_str_t ngx_http_redis_hide_headers[] = { ngx_null_string }; static ngx_str_t ngx_http_redis_key = ngx_string("redis_key"); static ngx_str_t ngx_http_redis_db = ngx_string("redis_db"); static ngx_uint_t ngx_http_redis_db_index; #define NGX_HTTP_REDIS_END (sizeof(ngx_http_redis_end) - 1) static u_char ngx_http_redis_end[] = CRLF; static ngx_int_t ngx_http_redis_handler(ngx_http_request_t *r) { ngx_int_t rc; ngx_http_upstream_t *u; ngx_http_redis_ctx_t *ctx; ngx_http_redis_loc_conf_t *rlcf; if (!(r->method & (NGX_HTTP_GET|NGX_HTTP_HEAD))) { return NGX_HTTP_NOT_ALLOWED; } rc = ngx_http_discard_request_body(r); if (rc != NGX_OK) { return rc; } if (ngx_http_set_content_type(r) != NGX_OK) { return NGX_HTTP_INTERNAL_SERVER_ERROR; } rlcf = ngx_http_get_module_loc_conf(r, ngx_http_redis_module); if (rlcf->complex_target) { ngx_str_t target; ngx_url_t url; /* variables used in the redis_pass directive */ if (ngx_http_complex_value(r, rlcf->complex_target, &target) != NGX_OK) { return NGX_ERROR; } if (target.len == 0) { ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "handler: empty \"redis_pass\" target"); return NGX_HTTP_INTERNAL_SERVER_ERROR; } url.host = target; url.port = 0; url.default_port = 6379; url.no_resolve = 1; rlcf->upstream.upstream = ngx_http_redis_upstream_add(r, &url); if (rlcf->upstream.upstream == NULL) { ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "redis: upstream \"%V\" not found", &target); return NGX_HTTP_INTERNAL_SERVER_ERROR; } } #if defined nginx_version && nginx_version >= 8011 if (ngx_http_upstream_create(r) != NGX_OK) { #else u = ngx_pcalloc(r->pool, sizeof(ngx_http_upstream_t)); if (u == NULL) { #endif return NGX_HTTP_INTERNAL_SERVER_ERROR; } #if defined nginx_version && nginx_version >= 8011 u = r->upstream; #endif #if defined nginx_version && nginx_version >= 8037 ngx_str_set(&u->schema, "redis://"); #else u->schema.len = sizeof("redis://") - 1; u->schema.data = (u_char *) "redis://"; #endif #if defined nginx_version && nginx_version >= 8011 u->output.tag = (ngx_buf_tag_t) &ngx_http_redis_module; #else u->peer.log = r->connection->log; u->peer.log_error = NGX_ERROR_ERR; #endif #if !defined(nginx_version) || nginx_version < 8011 u->output.tag = (ngx_buf_tag_t) &ngx_http_redis_module; #endif u->conf = &rlcf->upstream; u->create_request = ngx_http_redis_create_request; u->reinit_request = ngx_http_redis_reinit_request; u->process_header = ngx_http_redis_process_header; u->abort_request = ngx_http_redis_abort_request; u->finalize_request = ngx_http_redis_finalize_request; #if defined nginx_version && nginx_version < 8011 r->upstream = u; #endif ctx = ngx_palloc(r->pool, sizeof(ngx_http_redis_ctx_t)); if (ctx == NULL) { return NGX_HTTP_INTERNAL_SERVER_ERROR; } ctx->rest = NGX_HTTP_REDIS_END; ctx->request = r; ngx_http_set_ctx(r, ctx, ngx_http_redis_module); u->input_filter_init = ngx_http_redis_filter_init; u->input_filter = ngx_http_redis_filter; u->input_filter_ctx = ctx; #if defined nginx_version && nginx_version >= 8011 r->main->count++; #endif ngx_http_upstream_init(r); return NGX_DONE; } static ngx_int_t ngx_http_redis_create_request(ngx_http_request_t *r) { size_t len; uintptr_t escape; ngx_buf_t *b; ngx_chain_t *cl; ngx_http_redis_ctx_t *ctx; ngx_http_variable_value_t *vv[2]; ngx_http_redis_loc_conf_t *rlcf; rlcf = ngx_http_get_module_loc_conf(r, ngx_http_redis_module); vv[0] = ngx_http_get_indexed_variable(r, ngx_http_redis_db_index); /* * If user do not select redis database in nginx.conf by redis_db * variable, just add size of "select 0" to request. This is add * some overhead in talk with redis, but this way simplify parsing * the redis answer in ngx_http_redis_process_header(). */ if (vv[0] == NULL || vv[0]->not_found || vv[0]->len == 0) { ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "select 0 redis database" ); len = sizeof("select 0") - 1; } else { len = sizeof("select ") - 1 + vv[0]->len; ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "select %s redis database", vv[0]->data); } len += sizeof(CRLF) - 1; vv[1] = ngx_http_get_indexed_variable(r, rlcf->index); /* If nginx.conf have no redis_key return error. */ if (vv[1] == NULL || vv[1]->not_found || vv[1]->len == 0) { ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "the \"$redis_key\" variable is not set"); return NGX_ERROR; } /* Count have space required escape symbols. */ escape = 2 * ngx_escape_uri(NULL, vv[1]->data, vv[1]->len, NGX_ESCAPE_REDIS); len += sizeof("get ") - 1 + vv[1]->len + escape + sizeof(CRLF) - 1; /* Create temporary buffer for request with size len. */ b = ngx_create_temp_buf(r->pool, len); if (b == NULL) { return NGX_ERROR; } cl = ngx_alloc_chain_link(r->pool); if (cl == NULL) { return NGX_ERROR; } cl->buf = b; cl->next = NULL; r->upstream->request_bufs = cl; /* Add "select " for request. */ *b->last++ = 's'; *b->last++ = 'e'; *b->last++ = 'l'; *b->last++ = 'e'; *b->last++ = 'c'; *b->last++ = 't'; *b->last++ = ' '; /* Get context redis_db from configuration file. */ ctx = ngx_http_get_module_ctx(r, ngx_http_redis_module); ctx->key.data = b->last; /* * Add "0" as redis number db to request if redis_db undefined, * othervise add real number from context. */ if (vv[0] == NULL || vv[0]->not_found || vv[0]->len == 0) { ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "select 0 redis database" ); *b->last++ = '0'; } else { b->last = ngx_copy(b->last, vv[0]->data, vv[0]->len); ctx->key.len = b->last - ctx->key.data; ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "select %V redis database", &ctx->key); } /* Add "\r\n". */ *b->last++ = CR; *b->last++ = LF; /* Add "get" command with space. */ *b->last++ = 'g'; *b->last++ = 'e'; *b->last++ = 't'; *b->last++ = ' '; /* Get context redis_key from nginx.conf. */ ctx = ngx_http_get_module_ctx(r, ngx_http_redis_module); ctx->key.data = b->last; /* * If no escape symbols then copy data as is, othervise use * escape-copy function. */ if (escape == 0) { b->last = ngx_copy(b->last, vv[1]->data, vv[1]->len); } else { b->last = (u_char *) ngx_escape_uri(b->last, vv[1]->data, vv[1]->len, NGX_ESCAPE_REDIS); } ctx->key.len = b->last - ctx->key.data; ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "http redis request: \"%V\"", &ctx->key); /* Add one more "\r\n". */ *b->last++ = CR; *b->last++ = LF; /* * Summary, the request looks like this: * "select $redis_db\r\nget $redis_key\r\n", where * $redis_db and $redis_key are variable's values. */ return NGX_OK; } static ngx_int_t ngx_http_redis_reinit_request(ngx_http_request_t *r) { return NGX_OK; } static ngx_int_t ngx_http_redis_process_header(ngx_http_request_t *r) { u_char *p, *len; u_int c, try; ngx_str_t line; ngx_table_elt_t *h; ngx_http_upstream_t *u; ngx_http_redis_ctx_t *ctx; ngx_http_redis_loc_conf_t *rlcf; c = try = 0; u = r->upstream; p = u->buffer.pos; /* * Good answer from redis should looks like this: * "+OK\r\n$8\r\n12345678\r\n" * * Here is: * "+OK" is answer for first command "select 0". * Next two strings are answer for command "get $redis_key", where * * "$8" is length of following next string and * "12345678" is value of $redis_key, the string. * * So, if the first symbol is: * "+" (good answer) - try to find 2 strings; * "-" (bad answer) - try to find 1 string; * othervise answer is invalid. */ if (*p == '+') { try = 2; } else if (*p == '-') { try = 1; } else { goto no_valid; } for (p = u->buffer.pos; p < u->buffer.last; p++) { if (*p == LF) { c++; if (c == try) { goto found; } } } return NGX_AGAIN; found: *p = '\0'; line.len = p - u->buffer.pos - 1; line.data = u->buffer.pos; ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "redis: \"%V\"", &line); p = u->buffer.pos; /* Get context of redis_key for future error messages, i.e. ctx->key */ ctx = ngx_http_get_module_ctx(r, ngx_http_redis_module); rlcf = ngx_http_get_module_loc_conf(r, ngx_http_redis_module); /* Compare pointer and error message, if yes set 502 and return */ if (ngx_strncmp(p, "-ERR", sizeof("-ERR") - 1) == 0) { ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "redis sent error in response \"%V\" " "for key \"%V\"", &line, &ctx->key); u->headers_in.status_n = 502; u->state->status = 502; return NGX_OK; } /* Compare pointer and good message, if yes move on the pointer */ if (ngx_strncmp(p, "+OK\r\n", sizeof("+OK\r\n") - 1) == 0) { p += sizeof("+OK\r\n") - 1; } /* * Compare pointer and "get" answer. As said before, "$" means, that * next symbols are length for upcoming key, "-1" means no key. * Set 404 and return. */ if (ngx_strncmp(p, "$-1", sizeof("$-1") - 1) == 0) { ngx_log_error(NGX_LOG_INFO, r->connection->log, 0, "key: \"%V\" was not found by redis", &ctx->key); u->headers_in.status_n = 404; u->state->status = 404; #if defined nginx_version && nginx_version >= 1001004 u->keepalive = 1; #endif return NGX_OK; } /* Compare pointer and "get" answer, if "$"... */ if (ngx_strncmp(p, "$", sizeof("$") - 1) == 0) { /* move on pointer */ p += sizeof("$") - 1; /* set len to pointer */ len = p; /* if defined gzip_flag... */ if (rlcf->gzip_flag) { /* hash init */ h = ngx_list_push(&r->upstream->headers_in.headers); if (h == NULL) { return NGX_ERROR; } /* * add Content-Encoding header for future gunzipping * with ngx_http_gunzip_filter module */ h->hash = ngx_hash(ngx_hash(ngx_hash(ngx_hash( ngx_hash(ngx_hash(ngx_hash( ngx_hash(ngx_hash(ngx_hash( ngx_hash(ngx_hash(ngx_hash( ngx_hash(ngx_hash('c', 'o'), 'n'), 't'), 'e'), 'n'), 't'), '-'), 'e'), 'n'), 'c'), 'o'), 'd'), 'i'), 'n'), 'g'); ngx_str_set(&h->key, "Content-Encoding"); ngx_str_set(&h->value, "gzip"); h->lowcase_key = (u_char*) "content-encoding"; u->headers_in.content_encoding = h; } /* try to find end of string */ while (*p && *p++ != CR) { /* void */ } /* * get the length of upcoming redis_key value, convert from ascii * if the length is empty, return */ #if defined nginx_version && nginx_version < 1001004 r->headers_out.content_length_n = ngx_atoof(len, p - len - 1); if (r->headers_out.content_length_n == -1) { #else u->headers_in.content_length_n = ngx_atoof(len, p - len - 1); if (u->headers_in.content_length_n == -1) { #endif ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "redis sent invalid length in response \"%V\" " "for key \"%V\"", &line, &ctx->key); return NGX_HTTP_UPSTREAM_INVALID_HEADER; } /* The length of answer is not empty, set 200 */ u->headers_in.status_n = 200; u->state->status = 200; /* Set position to the first symbol of data and return */ u->buffer.pos = p + 1; return NGX_OK; } no_valid: ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, "redis sent invalid response: \"%V\"", &line); return NGX_HTTP_UPSTREAM_INVALID_HEADER; } static ngx_int_t ngx_http_redis_filter_init(void *data) { ngx_http_redis_ctx_t *ctx = data; ngx_http_upstream_t *u; u = ctx->request->upstream; #if defined nginx_version && nginx_version < 1005003 u->length += NGX_HTTP_REDIS_END; #else if (u->headers_in.status_n != 404) { u->length = u->headers_in.content_length_n + NGX_HTTP_REDIS_END; ctx->rest = NGX_HTTP_REDIS_END; } else { u->length = 0; } #endif return NGX_OK; } static ngx_int_t ngx_http_redis_filter(void *data, ssize_t bytes) { ngx_http_redis_ctx_t *ctx = data; u_char *last; ngx_buf_t *b; ngx_chain_t *cl, **ll; ngx_http_upstream_t *u; u = ctx->request->upstream; b = &u->buffer; #if defined nginx_version && nginx_version < 1001004 if (u->length == ctx->rest) { #else if (u->length == (ssize_t) ctx->rest) { #endif if (ngx_strncmp(b->last, ngx_http_redis_end + NGX_HTTP_REDIS_END - ctx->rest, bytes) != 0) { ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0, "redis sent invalid trailer"); u->length = 0; ctx->rest = 0; return NGX_OK; } u->length -= bytes; ctx->rest -= bytes; #if defined nginx_version && nginx_version >= 1001004 if (u->length == 0) { u->keepalive = 1; } #endif return NGX_OK; } for (cl = u->out_bufs, ll = &u->out_bufs; cl; cl = cl->next) { ll = &cl->next; } cl = ngx_chain_get_free_buf(ctx->request->pool, &u->free_bufs); if (cl == NULL) { return NGX_ERROR; } cl->buf->flush = 1; cl->buf->memory = 1; *ll = cl; last = b->last; cl->buf->pos = last; b->last += bytes; cl->buf->last = b->last; cl->buf->tag = u->output.tag; ngx_log_debug4(NGX_LOG_DEBUG_HTTP, ctx->request->connection->log, 0, "redis filter bytes:%z size:%z length:%z rest:%z", bytes, b->last - b->pos, u->length, ctx->rest); if (bytes <= (ssize_t) (u->length - NGX_HTTP_REDIS_END)) { u->length -= bytes; return NGX_OK; } last += (size_t) (u->length - NGX_HTTP_REDIS_END); if (ngx_strncmp(last, ngx_http_redis_end, b->last - last) != 0) { ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0, "redis sent invalid trailer"); #if defined nginx_version && nginx_version >= 1001004 b->last = last; cl->buf->last = last; u->length = 0; ctx->rest = 0; return NGX_OK; #endif } ctx->rest -= b->last - last; b->last = last; cl->buf->last = last; u->length = ctx->rest; #if defined nginx_version && nginx_version >= 1001004 if (u->length == 0) { u->keepalive = 1; } #endif return NGX_OK; } static void ngx_http_redis_abort_request(ngx_http_request_t *r) { ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "abort http redis request"); return; } static void ngx_http_redis_finalize_request(ngx_http_request_t *r, ngx_int_t rc) { ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, "finalize http redis request"); return; } static void * ngx_http_redis_create_loc_conf(ngx_conf_t *cf) { ngx_http_redis_loc_conf_t *conf; conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_redis_loc_conf_t)); if (conf == NULL) { #if defined nginx_version && nginx_version >= 8011 return NULL; #else return NGX_CONF_ERROR; #endif } /* * set by ngx_pcalloc(): * * conf->upstream.bufs.num = 0; * conf->upstream.next_upstream = 0; * conf->upstream.temp_path = NULL; * conf->upstream.uri = { 0, NULL }; * conf->upstream.location = NULL; */ conf->upstream.connect_timeout = NGX_CONF_UNSET_MSEC; conf->upstream.send_timeout = NGX_CONF_UNSET_MSEC; conf->upstream.read_timeout = NGX_CONF_UNSET_MSEC; conf->upstream.buffer_size = NGX_CONF_UNSET_SIZE; /* the hardcoded values */ conf->upstream.cyclic_temp_file = 0; conf->upstream.buffering = 0; conf->upstream.ignore_client_abort = 0; conf->upstream.send_lowat = 0; conf->upstream.bufs.num = 0; conf->upstream.busy_buffers_size = 0; conf->upstream.max_temp_file_size = 0; conf->upstream.temp_file_write_size = 0; conf->upstream.intercept_errors = 1; conf->upstream.intercept_404 = 1; conf->upstream.pass_request_headers = 0; conf->upstream.pass_request_body = 0; /* * initialize additional parameters for hide * "Content-Encoding: gzip" header */ conf->upstream.hide_headers = NGX_CONF_UNSET_PTR; conf->upstream.pass_headers = NGX_CONF_UNSET_PTR; conf->index = NGX_CONF_UNSET; conf->db = NGX_CONF_UNSET; conf->gzip_flag = NGX_CONF_UNSET_UINT; return conf; } static char * ngx_http_redis_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child) { ngx_hash_init_t hash; ngx_http_redis_loc_conf_t *prev = parent; ngx_http_redis_loc_conf_t *conf = child; ngx_conf_merge_msec_value(conf->upstream.connect_timeout, prev->upstream.connect_timeout, 60000); ngx_conf_merge_msec_value(conf->upstream.send_timeout, prev->upstream.send_timeout, 60000); ngx_conf_merge_msec_value(conf->upstream.read_timeout, prev->upstream.read_timeout, 60000); ngx_conf_merge_size_value(conf->upstream.buffer_size, prev->upstream.buffer_size, (size_t) ngx_pagesize); ngx_conf_merge_bitmask_value(conf->upstream.next_upstream, prev->upstream.next_upstream, (NGX_CONF_BITMASK_SET |NGX_HTTP_UPSTREAM_FT_ERROR |NGX_HTTP_UPSTREAM_FT_TIMEOUT)); if (conf->upstream.next_upstream & NGX_HTTP_UPSTREAM_FT_OFF) { conf->upstream.next_upstream = NGX_CONF_BITMASK_SET |NGX_HTTP_UPSTREAM_FT_OFF; } /* Initialize hash for hide "Content-Encoding" header */ hash.max_size = 512; hash.bucket_size = ngx_align(64, ngx_cacheline_size); hash.name = "redis_hide_headers_hash"; if (ngx_http_upstream_hide_headers_hash(cf, &conf->upstream, &prev->upstream, ngx_http_redis_hide_headers, &hash) != NGX_OK) { return NGX_CONF_ERROR; } if (conf->upstream.upstream == NULL) { conf->upstream.upstream = prev->upstream.upstream; } if (conf->index == NGX_CONF_UNSET) { conf->index = prev->index; } if (conf->db == NGX_CONF_UNSET) { conf->db = prev->db; } ngx_conf_merge_uint_value(conf->gzip_flag, prev->gzip_flag, 0); return NGX_CONF_OK; } static char * ngx_http_redis_pass(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) { ngx_http_redis_loc_conf_t *rlcf = conf; ngx_str_t *value; ngx_url_t u; ngx_uint_t n; ngx_http_core_loc_conf_t *clcf; ngx_http_compile_complex_value_t ccv; if (rlcf->upstream.upstream) { return "is duplicate"; } clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module); clcf->handler = ngx_http_redis_handler; if (clcf->name.data[clcf->name.len - 1] == '/') { clcf->auto_redirect = 1; } rlcf->index = ngx_http_get_variable_index(cf, &ngx_http_redis_key); if (rlcf->index == NGX_ERROR) { return NGX_CONF_ERROR; } rlcf->db = ngx_http_get_variable_index(cf, &ngx_http_redis_db); value = cf->args->elts; n = ngx_http_script_variables_count(&value[1]); if (n) { rlcf->complex_target = ngx_palloc(cf->pool, sizeof(ngx_http_complex_value_t)); if (rlcf->complex_target == NULL) { return NGX_CONF_ERROR; } ngx_memzero(&ccv, sizeof(ngx_http_compile_complex_value_t)); ccv.cf = cf; ccv.value = &value[1]; ccv.complex_value = rlcf->complex_target; if (ngx_http_compile_complex_value(&ccv) != NGX_OK) { return NGX_CONF_ERROR; } return NGX_CONF_OK; } rlcf->complex_target = NULL; ngx_memzero(&u, sizeof(ngx_url_t)); u.url = value[1]; u.no_resolve = 1; rlcf->upstream.upstream = ngx_http_upstream_add(cf, &u, 0); if (rlcf->upstream.upstream == NULL) { return NGX_CONF_ERROR; } return NGX_CONF_OK; } static ngx_int_t ngx_http_redis_reset_variable(ngx_http_request_t *r, ngx_http_variable_value_t *v, uintptr_t data) { *v = ngx_http_variable_null_value; return NGX_OK; } static ngx_int_t ngx_http_redis_add_variables(ngx_conf_t *cf) { ngx_int_t n; ngx_http_variable_t *var; var = ngx_http_add_variable(cf, &ngx_http_redis_db, NGX_HTTP_VAR_CHANGEABLE); if (var == NULL) { return NGX_ERROR; } var->get_handler = ngx_http_redis_reset_variable; n = ngx_http_get_variable_index(cf, &ngx_http_redis_db); if (n == NGX_ERROR) { return NGX_ERROR; } ngx_http_redis_db_index = n; return NGX_OK; } static ngx_http_upstream_srv_conf_t * ngx_http_redis_upstream_add(ngx_http_request_t *r, ngx_url_t *url) { ngx_http_upstream_main_conf_t *umcf; ngx_http_upstream_srv_conf_t **uscfp; ngx_uint_t i; umcf = ngx_http_get_module_main_conf(r, ngx_http_upstream_module); uscfp = umcf->upstreams.elts; for (i = 0; i < umcf->upstreams.nelts; i++) { if (uscfp[i]->host.len != url->host.len || ngx_strncasecmp(uscfp[i]->host.data, url->host.data, url->host.len) != 0) { continue; } if (uscfp[i]->port != url->port) { continue; } if (uscfp[i]->default_port && url->default_port && uscfp[i]->default_port != url->default_port) { continue; } return uscfp[i]; } return NULL; }