第springboot利用aop實現(xiàn)接口異步(進度條)的全過程在項目中發(fā)現(xiàn)有接口（excel導(dǎo)入數(shù)據(jù)）處理數(shù)據(jù)需要耗時比較長的時間，是因為數(shù)據(jù)量比較大，同時數(shù)據(jù)的校驗需要耗費一定時間，決定使用一種通用的方法解決這個問題。

解決方案：通過aop使接口異步處理，前端輪詢另外一個接口查詢進度。

目標：

1接口上一個注解即可實現(xiàn)接口異步（優(yōu)化：可以通過header參數(shù)動態(tài)控制是否異步）

2一個方法實現(xiàn)進度條的更新

二、時序圖

三、功能演示

四、關(guān)鍵代碼

Controller

@EnableAsync是自已定義注解更新緩存進度asyncService.updatePercent(per);

@EnableAsync

@RequestMapping(value=test,method=RequestMethod.POST)

@ApiOperation(value=接口測試)

@ApiImplicitParams({

@ApiImplicitParam(name=num,value=數(shù)字,required=true,dataType=int,paramType=query,defaultValue=1)

publicObjectdemo(Integernum)throwsInterruptedException{

for(inti=0;ii++){

Thread.sleep(1000);

//計算百分比

Stringper=BigDecimal.valueOf(i).divide(BigDecimal.valueOf(15),2,RoundingMode.HALF_DOWN).toString();

//更新redis緩存進度

asyncService.updatePercent(per);

Integerb=100;

returnResult.success(String.format(線程變量值:%s,100除以%s的結(jié)果是%s,RequestHolder.get(),num,b/num));

}

AsyncAop

importcn.hutool.core.util.IdUtil;

importmon.Result;

importmon.pojo.RequestHolder;

importcom.asyf.demo.service.AsyncService;

importlombok.extern.slf4j.Slf4j;

importorg.aspectj.lang.ProceedingJoinPoint;

importorg.aspectj.lang.annotation.Around;

importorg.aspectj.lang.annotation.Aspect;

importorg.aspectj.lang.annotation.Pointcut;

importorg.aspectj.lang.reflect.MethodSignature;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.stereotype.Component;

importorg.springframework.web.context.request.RequestContextHolder;

importorg.springframework.web.context.request.ServletRequestAttributes;

importjavax.servlet.http.HttpServletRequest;

@Aspect

@Component

@Slf4j

publicclassAsyncAop{

@Autowired

privateAsyncServiceasyncService;

@Pointcut(@annotation(mon.aop.EnableAsync))

publicvoidcostTimePointCut(){

@Around(costTimePointCut())

publicObjectaround(ProceedingJoinPointpoint)throwsThrowable{

longbeginTime=System.currentTimeMillis();

//請求header

ServletRequestAttributesservletRequestAttributes=(ServletRequestAttributes)RequestContextHolder.getRequestAttributes();

HttpServletRequestrequest=servletRequestAttributes.getRequest();

RequestHolder.set(request.getHeader(dateFormat));

//異步消息

Stringid=IdUtil.simpleUUID();

AsyncMsgasyncMsg=newAsyncMsg();

asyncMsg.setId(id);

//異步返回值

Objectresult=Result.success(asyncMsg);

StringrequestHolder=RequestHolder.get();

//異步執(zhí)行

asyncService.async(requestHolder