使用Future和Callable创建异步接口

向右看齐 2022-02-26 14:48 371阅读 0赞

要求：

由于程序执行时间较长，所以要求在发送请求后，不要等待程序执行完成，及时返回，但要向数据库中保存实时的执行进度，所以有下面的实现：

//controller 
    public BaseResponsev1 modelSynchronize(@ApiParam @RequestParam String uri) {
            BaseResponsev1 response = new BaseResponsev1();
    
            try {
                //校验：有问题直接报异常
                if (!Tools.checkUriFormat(uri)) {
                    throw new OpcOperationException("modelUri format is wrong.");
                }
    
                //第1：在这里完成执行的开始记录
                //TODO 将执行开始信息保存到数据库
                //使用FutureTask作为线程的target
                FutureTask<Integer> task = new FutureTask<Integer>((Callable<Integer>)()->{
                    try {
                        //实际要执行的方法
                        service.modelSynchronize(uri);
                        
                        //第2：执行完成，更新执行完成信息到数据库
                        //TODO 更新执行信息
                    }catch (Exception e){
                        //必须在这里捕捉异常，否则，异常被忽略
                        e.printStackTrace();
                        //第3：异常，更新执行完成信息到数据库
                        //TODO 更新执行信息
                    }
                    //最终执行结果不能在这里更新，因为不论成功还是失败这里都能执行到。
                    return null;
                });
                //线程启动之后，直接向下执行
                new Thread(task).start();
    
            } catch (Exception e) {
                logger.error("execute modelSynchronize exception : ", e);
                response.setCode("0x80000000");
                response.setMsg("Interface call failed，the exception is: " + e.toString());
            }
    
            return response;
        }