建议收藏 Nginx的DNS解析详细过程分析( 三 )

  1. 得到查询结果时同时超时了
  2. 如果在得到查询结果的同时 , 设置的超时时间也到期了 , 那该怎么办呢?Nginx会先处理各种网络读写事件 , 再处理超时事件 , 在处理网络事件时 , 会相应地把设置的定时器删除 , 所以在执行超时事件时就不会再执行了 。
voidngx_process_events_and_timers(ngx_cycle_t *cycle){ ngx_uint_t flags; ngx_msec_t timer, delta;//处理各种网络事件 (void) ngx_process_events(cycle, timer, flags);//处理各种timer事件 , 其中包含了查询超时 ngx_event_expire_timers();}
  1. 得到查询结果时客户端已经关闭连接
  2. 如果不做任何处理 , 那么在收到dns查询结果后 , 会回调查询时设置的回调方法 , 但因为连接已经被关闭 , 相应的内存已经被释放 , 所以会有非法内存访问的问题 。怎么避免呢?在处理连接关闭事件时 , 同时需要调用ngx_resolve_name_done(ctx)方法,调用时需要把state设为NGX_AGAIN或者NGX_RESOLVE_TIMEDOUT , 这样就会删除查询所设置的回调信息:
void ngx_close_xxx_session(ngx_xxx_session_t *s){ if(s->resolver_ctx != NULL) { s->resolver_ctx->state = NGX_RESOLVE_TIMEDOUT; ngx_resolve_name_done(s->resolver_ctx); s->resolver_ctx = NULL; }} void ngx_resolve_name_done(ngx_resolver_ctx_t *ctx){ uint32_t hash; ngx_resolver_t *r; ngx_resolver_ctx_t *w, **p; ngx_resolver_node_t *rn;r = ctx->resolver; if (ctx->state == NGX_AGAIN || ctx->state == NGX_RESOLVE_TIMEDOUT) { hash = ngx_crc32_short(ctx->name.data, ctx->name.len); rn = ngx_resolver_lookup_name(r, &ctx->name, hash);if (rn) { p = &rn->waiting; w = rn->waiting;while (w) { if (w == ctx) { *p = w->next; goto done; }p = &w->next; w = w->next; } } } done: ngx_resolver_free_locked(r, ctx);}
  1. 本地缓存的地址没有再次被查询
  2. 每次在查询结束的时候(调用ngx_resolve_addr_done) , 都会检查有没有缓存过期 , 如果有 , 就会进行释放 。
static voidngx_resolver_expire(ngx_resolver_t *r, ngx_rbtree_t *tree, ngx_queue_t *queue){ time_t now; ngx_uint_t i; ngx_queue_t *q; ngx_resolver_node_t *rn; now = ngx_time();for (i = 0; i < 2; i++) { if (ngx_queue_empty(queue)) { return; }q = ngx_queue_last(queue); rn = ngx_queue_data(q, ngx_resolver_node_t, queue);if (now <= rn->expire) { return; }ngx_log_debug2(NGX_LOG_DEBUG_CORE, r->log, 0, "resolver expire "%*s"", (size_t) rn->nlen, rn->name);ngx_queue_remove(q); ngx_rbtree_delete(tree, &rn->node); ngx_resolver_free_node(r, rn); }}
  1. 域名对应这多个IP地址
  2. 如果对应的有多个ip,那么在每次查询时 , 会随机的重新排列顺序 , 然后返回 。对于调用者来说 , 只要去第一个地址 , 就可以达到取随机地址的目的了 。
static ngx_int_tngx_resolve_name_locked(ngx_resolver_t *r, ngx_resolver_ctx_t *ctx){ if (naddrs) { if (naddrs != 1) { addr = 0; addrs = ngx_resolver_rotate(r, rn->u.addrs, naddrs); if (addrs == NULL) { return NGX_ERROR; }} else { addr = rn->u.addr; addrs = NULL; } }} static in_addr_t *ngx_resolver_rotate(ngx_resolver_t *r, in_addr_t *src, ngx_uint_t n){ void *dst, *p; ngx_uint_t j;dst = ngx_resolver_alloc(r, n * sizeof(in_addr_t)); j = ngx_random() % n;if (j == 0) { ngx_memcpy(dst, src, n * sizeof(in_addr_t)); return dst; }p = ngx_cpymem(dst, &src[j], (n - j) * sizeof(in_addr_t)); ngx_memcpy(p, src, j * sizeof(in_addr_t));return dst;}
  1. 指定了多个dns server地址会怎么查询
  2. 如果在配置文件里指定了多个dns server地址会发生什么呢?比如
#nginx.confresolver 8.8.8.8 8.8.4.4
  1. 那么nginx 会采用Round Robin 的方式轮流查询各个dns server 。在方法ngx_resolver_send_query中通过在每次调用时改变last_connection来轮流使用不同的dns server进行查询
static ngx_int_tngx_resolver_send_query(ngx_resolver_t *r, ngx_resolver_node_t *rn){ ssize_t n; ngx_udp_connection_t *uc;uc = r->udp_connections.elts;uc = &uc[r->last_connection++]; if (r->last_connection == r->udp_connections.nelts) { r->last_connection = 0; } ...end:如果你觉得本文对你有帮助的话 , 记得关注点赞转发 , 你的支持就是我更新动力 。

【建议收藏 Nginx的DNS解析详细过程分析】


推荐阅读