nginx负载均衡的关闭 - Go语言中文社区

nginx负载均衡的关闭


        在前面的文章中,已经分析了nginx如何结束一个http请求,可以调用http框架的ngx_http_finalize_request或者调用http框架提供的接口ngx_http_terminate_request暴力的终止一个请求。 但结束一个upstream负载均衡请求却不能调用这两个接口,因为调用这两个接口的话,nginx与下游客户端的请求与tcp连接是释放了,但nginx与上游服务器的连接还没有释放,这样将导致内存泄漏的发生。

        对于upstream负载均衡请求的释放,nginx提供了两个接口。一个是ngx_http_upstream_finalize_request, 另一个是ngx_http_upstream_next。

一、ngx_http_upstream_next的实现

        通常nginx在与上游服务器交互失败时,例如建立tcp连接失败,或者接收后端服务器的响应超时等,都会调用ngx_http_upstream_next方法,用于获取一个新的后端服务器。如果所有的后端服务器都不可用时,才会结束这个负载均衡请求,否则重新获取一个服务器。

//尝试选择一个新的后端服务器并与它建立tcp连接。如果尝试完了所有后端服务器都没有找到一个可用的
//后端服务器,则会结束请求
static void ngx_http_upstream_next(ngx_http_request_t *r, ngx_http_upstream_t *u, ngx_uint_t ft_type)
{
	//该后端服务器不可用,则释放这个已经选择的后端服务器,以便下面重新选择一个后端服务器
    if (ft_type != NGX_HTTP_UPSTREAM_FT_NOLIVE) 
	{
        u->peer.free(&u->peer, u->peer.data, state);
    }
    if (status) 
	{
		//如果尝试完所有的后端服务器都没有一个可用的服务器,则给客户端返回错误。当然,
		//如果fastcgi_next_upstream指定了在后端服务器返回对应的错误码时,才寻找下一个后端服务器,否则立即给可以的返回错误
		//,参考ngx_conf_set_bitmask_slot实现
        if (u->peer.tries == 0 || !(u->conf->next_upstream & ft_type)) 
		{
            ngx_http_upstream_finalize_request(r, u, status);
            return;
        }
    }
	//与后端服务器的连接存在,则先关闭, 下面重新选择一个后端服务器并与它建立tcp连接
    if (u->peer.connection)
	{
        ngx_close_connection(u->peer.connection);
    }
	//重新选择一个后端服务器并与它建立tcp连接
    ngx_http_upstream_connect(r, u);
}
        如果所有的后端服务器都不可用时,还是会调用ngx_http_upstream_finalize_request这个接口。现在看下这个接口的实现。

二、ngx_http_upstream_finalize_request的实现

       函数内部会关闭nginx与后端服务器的tcp连接,同时会删除保存来自后端服务器响应包体的临时文件,以及会释放接收后端服务器响应的接收缓冲区,释放发送给后端服务器的发送缓冲区等。最后调用ngx_http_finalize_request接口,用于释放nginx与下游客户端的http请求,但nginx与下游客户端的tcp连接并不一定会关闭。

static void ngx_http_upstream_finalize_request(ngx_http_request_t *r, ngx_http_upstream_t *u, ngx_int_t rc)
{
	//将回调方法设置为空,目的为了防止在ngx_http_finalize_request函数中继续调用ngx_http_upstream_finalize_request本身
    if (u->cleanup)
	{
        *u->cleanup = NULL;
        u->cleanup = NULL;
    }
	//调用http模块负责方法,http模块可能会在upstream请求结束时执行一些操作。
	//如果为fastcgi模块,则什么都不做
    u->finalize_request(r, rc);
	//释放连接资源
    if (u->peer.free) 
	{
        u->peer.free(&u->peer, u->peer.data, 0);
    }
	//nginx与上游服务器连接还存在,则关闭
    if (u->peer.connection) 
	{
        ngx_close_connection(u->peer.connection);
    }
	//删除临时文件
    if (u->store && u->pipe && u->pipe->temp_file
        && u->pipe->temp_file->file.fd != NGX_INVALID_FILE)
    {
        ngx_delete_file(u->pipe->temp_file->file.name.data);
    }
	
	//最后调用http框架提供的方法结束整个请求
    ngx_http_finalize_request(r, rc);
}
        最后以一张负载均衡请求释放的调用图,来结束本篇文章。从图中可以看出,释放一个upstream负载均衡请求包括两个过程,一个是释放nginx与后端服务器的请求,另一个是释放nginx与下游客户端的请求。释放nginx与下游客户端的请求,在前面的文章已经分析过了,读者可以参考前面的文章,这里就不再重复了。




版权声明:本文来源CSDN,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/ApeLife/article/details/78151683
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2020-03-07 23:16:07
  • 阅读 ( 975 )
  • 分类:Go Web框架

0 条评论

请先 登录 后评论

官方社群

GO教程

猜你喜欢