背景:Nginx做反向代理,springboot为后端服务。
问题:通过浏览器向后台发起请求够,由于后台处理时间长,出现504 Gateway Time–out,实际后台程序依然在执行。如何解决?
如果你恰好在寻找这种问题的解决方案,并且不喜欢啰嗦,直接移动到:两种解决方案
Syntax: | proxy_read_timeout |
---|---|
Default: |
proxy_read_timeout 60s; |
Context: | http , server , location |
官方地址:Module ngx_http_proxy_module (nginx.org)
官方描述如下:Defines a timeout for reading a response from the proxied server. The timeout is set only between two successive read operations, not for the transmission of the whole response. If the proxied server does not transmit anything within this time, the connection is closed.
504的错误码是有nginx返回的。结合官网的解释,我们可以得出结论:
当nginx与后台的链接两次读取有效数据之间超过配置的时间时,就会产生504超时。nginx会主动关闭与后台服务器的链接。注意是两次成功读取的间隔,不是整个reponse的时间。
如果你百度或google,通常解决方式有两种:提高后台处理效率 或 增大proxy_read_timeout。
增大方法很简单,proxy_read_timeout [你期望的时间]。
But,后台效率提升总是有极限的。而proxy_read_timeout是固定值。总会有些正常业务场景,超过了设置的timeout值。
两种解决方案
本人解决的问题:上传excel文件后,由于文件大小无法预计,所以后台处理时间也无法预计。同时还要支持大文件的上传。上传后由后台解析处理。post请求,返回的是json。
一,关闭read-timout,可以实现,但是生产环境下你敢不设置超时时间么?所以不建议。
二,既然nginx只要从reponse成功读取数据两次的间隔在proxy_read_timeout设置的时间内,就不会超时。那么我们是不是可以通过持续的向response中写入数据来保证不超时呢。
答案是肯定的。
1,正常上传文件。
2,新建一个线程。持有response的引用,含有标志位,满足条件时循环执行,程序开始处理数据前,启动线程。
3,线程的功能只有一个,以固定间隔向response中写入数据。使nginx与后台链接不超时。
4,这里就需要注意,我的方法是返回json,同时要持续向response写入数据,所以我手动拼装json字符串。相当于在之前返回的json中增加一个属性,名称随意,我的叫pending,值随意,非空即可。我是用英文半角的句号” . “。
5,数据处理完后,回调线程的stop方法,终止线程中的循环。
注意:如有雷同纯属巧合。如果已经有大佬讲过这种解决方式,请艾特我,我立即删除本文。
#上下文代码
//获取鲜橙池executor,具体方式看个人。不会的直接百度,有很多
response.setContentType(ContentType.APPLICATION_JSON.getMimeType());
ResponseKeeper responseKeeper = new ResponseKeeper(response);
executorService.execute(responseKeeper);
#上下文代码
public class ResponseKeeper implements Runnable {
/**
* 循环标志:true时停止循环,终止线程
*/
private boolean done = false;
private HttpServletResponse response;
public void stop(){
done = true;
}
public ResponseKeeper(HttpServletResponse response) {
this.response = response;
}
@Override
public void run() {
try {
response.getWriter().write("{"pending":"");
while(!done){
response.getWriter().write(".");
response.getWriter().flush();
LOGGER.error("flush-{}", System.currentTimeMillis());
Thread.sleep(1000);
}
response.getWriter().write("", "status": "0", "msg":"success"}");
} catch (Exception e) {
e.printStackTrace();
}
}
}
其他问题:
IllegalStateException – if the getOutputStream method has already been called for this response object
那就说明你的程序中有地方调用过了,response.getOutputStream();
即将response.getWriter() 提换成 response.getOutputStream();
原因简单来讲就是这两个方法互斥。调用了一个就不能调用另一个。
补充:
如果你的应用前端不止一层nginx,整体组成是:客户端,nginx,nginx,服务端,本方案可能会失效,此时需要在第二个nginx中增加配置:
具体位置为:localtion / {} 中增加 proxy_buffering off;
proxy_buffering关闭后可能会影响性能。具体位置应该可以再细化到具体的请求,有兴趣的可以自己试试。
原文地址:https://blog.csdn.net/fox_mt/article/details/125249100
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_50338.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!