项目里面有比较多的导入导出,录音文件加载等功能,但是有个问题是:导入导出客户端可能会频繁的点击,录音文件一次性可能会加载多个。如果导出的excel文件过大,或者加载的录音文件过多,或者一个音频文件过长,可能会出现 这个异常:
org.apache.catalina.connector.ClientAbortException: java.io.IOException: APR error: -32
at org.apache.catalina.connector.OutputBuffer.realWriteBytes(OutputBuffer.java:396)
at org.apache.tomcat.util.buf.ByteChunk.append(ByteChunk.java:344)
at org.apache.catalina.connector.OutputBuffer.writeBytes(OutputBuffer.java:421)
at org.apache.catalina.connector.OutputBuffer.write(OutputBuffer.java:409)
at org.apache.catalina.connector.CoyoteOutputStream.write(CoyoteOutputStream.java:97)
at java.io.BufferedOutputStream.write(BufferedOutputStream.java:122)
at java.io.FilterOutputStream.write(FilterOutputStream.java:97)
at com.zhuanche.serv.punish.DriverPunishClientService.renderVideo(DriverPunishClientService.java:181)
at com.zhuanche.controller.driver.DriverPunishController.render(DriverPunishController.java:138)
at com.zhuanche.controller.driver.DriverPunishController$$FastClassBySpringCGLIB$$1182fa42.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:738)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
at org.apache.shiro.spring.security.interceptor.AopAllianceAnnotationsAuthorizingMethodInterceptor$1.proceed(AopAllianceAnnotationsAuthorizingMethodInterceptor.java:82)
at org.apache.shiro.authz.aop.AuthorizingMethodInterceptor.invoke(AuthorizingMethodInterceptor.java:39)
at org.apache.shiro.spring.security.interceptor.AopAllianceAnnotationsAuthorizingMethodInterceptor.invoke(AopAllianceAnnotationsAuthorizingMethodInterceptor.java:115)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:673)
at com.zhuanche.controller.driver.DriverPunishController$$EnhancerBySpringCGLIB$$fbb8c231.render(<generated>)
at sun.reflect.GeneratedMethodAccessor2068.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:901)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:861)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:622)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846)
这个问题困扰了好久,解决方法有限制过前端的频繁点击的按钮,比如没分钟只允许点击一次,后端有加缓存的限制,比如以用户id+请求条件+请求ip作为key,防止频繁的请求。如果请求频繁,则导出一个空Excel文件以及提示语。但是由于太多地方,仍然会时不时的抛出这个 arp -32的问题。今天想到用异步线程池的方式,参考:
https://blog.csdn.net/Muscleheng/article/details/81409672 。
我是采用的注解+@Async方式,但是发现仍然不管用。特别是加载录音文件,还抛出了空指针异常。自己的代码:Controller
@RequiresPermissions(value = {"punishTripVideo"})
@RequestMapping("/renderVideo")
@ResponseBody
public AjaxResponse render(@RequestParam(name = "filePath") String filePath, HttpServletResponse response) {
if (StringUtils.isBlank(filePath)) {
return AjaxResponse.failMsg(RestErrorCode.HTTP_FORBIDDEN, "缺失路径");
log.info("渲染录音文件, filePath:{}", filePath);
try {
driverPunishService.renderVideo(filePath, response);
} catch (Exception e) {
log.error("渲染失败",e);
return AjaxResponse.failMsg(RestErrorCode.HTTP_FORBIDDEN, "渲染失败");
return AjaxResponse.success(null);
service:
* 渲染行程录音
* @param filePath
* @param response
* @throws IOException
public void renderVideo(String filePath,HttpServletResponse response) throws IOException {
log.info("====threadName==== 异步线程池执行该service方法===");
OutputStream outputStream = null;
try {
byte[] fileBytes = OkHttpStreamUtil.executeForBytes(filePath);
if (Objects.nonNull(fileBytes)) {
//支持范围请求
int fileLength = fileBytes.length;
response.addHeader("Accept-Ranges", "bytes");
response.addHeader("Content-Length", "" + fileLength);
response.addHeader("Content-Range", "bytes 0-" + fileLength);
response.addHeader("Content-Type", "audio/mpeg");
response.addHeader("Content-Length", "" + fileLength);
outputStream = new BufferedOutputStream(response.getOutputStream());
outputStream.write(fileBytes);
outputStream.flush();
} catch (IOException io) {
log.warn("渲染行程录音IOException", io);
} catch (Exception e) {
log.error("渲染行程录音失败", e);
throw e;
} finally {
IoUtil.close(outputStream);
使用异步线程池类:
package com.zhuanche.serv.sync;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.ThreadPoolExecutor;
* @author fanht
* @description 异步线程池
* @date 2021/1/5 上午9:48
* @version 1.0
@Configuration
@EnableAsync
public class SyncThreadPool {
/**核心线程数*/
private static final Integer CORE_POOL_SIZE = 20;
/**最大线程数*/
private static final Integer MAX_POOL_SIZE = 100;
/**允许线程空闲时间 (单位 秒)*/
private static final Integer KEEP_ALIVE_TIME = 10;
/**缓冲队列大小*/
private static final Integer QUEUE_CAPACITY = 200;
/**线程名前缀 主要是在service层使用*/
private static final String THREADNAME_PREFIX = "Async-service-";
@Bean("syncTaskExecutor")
public ThreadPoolTaskExecutor syncTaskExecutor(){
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
taskExecutor.setCorePoolSize(CORE_POOL_SIZE);
taskExecutor.setMaxPoolSize(MAX_POOL_SIZE);
taskExecutor.setKeepAliveSeconds(KEEP_ALIVE_TIME);
taskExecutor.setQueueCapacity(QUEUE_CAPACITY);
taskExecutor.setThreadNamePrefix(THREADNAME_PREFIX);
// 线程池对拒绝任务的处理策略
// CallerRunsPolicy:由调用线程(提交任务的线程)处理该任务
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
taskExecutor.initialize();
return taskExecutor;
然后在service的方法前面加上@Async("syncTaskExecutor"),发现还是不行。而且抛异常了,问题是由于使用了异步线程池后,controller的线程是 tomcat提供的,而server的是使用的异步线程池。传的outputStream 为空了(详见: https://cloud.tencent.com/developer/article/1511820)
不过这也给自己了提示:既然是tomcat超时了,那是不是可以通过调整tomcat的超时时间来延长呢? 我们知道 tomcat的 server.xml的 默认配置是如下:
<Connector port="8080" protocol="HTTP/1.1"
connectionTimeout="20000"
redirectPort="8443" />
会不会是这个默认的超时时间太短了呢?我把时间改成60000试下。