Spring上的Async Rest方法不是异步执行的

我正在运行Spring Boot并启用了Async配置。Spring上的Async Rest方法不是异步执行的

这是休息控制器：

@RestController 
@RequestMapping("/logCentralLoja") 
@Component 
public class LogCentralLojaController { 

    private final LogCentralLojaCompactoRepository logRepo; 
    private final Logger logger = LoggerFactory.getLogger(this.getClass()); 

    @Autowired 
    public LogCentralLojaController(LogCentralLojaCompactoRepository logRepo) { 
     this.logRepo = logRepo; 
    } 

    @CrossOrigin 
    @RequestMapping(value = "/getLogCompacto", method = RequestMethod.GET) 
    public DeferredResult<ResponseEntity<?>> getLogCompacto(@PathParam(value = "cd_filial") int cd_filial, 
     @PathParam(value = "cd_log") long cd_log) { 

     DeferredResult<ResponseEntity<?>> deferredResult = new DeferredResult<>(); 

     logger.info("/getLogCompacto -> Início"); 

     ListenableFuture<List<LogCentralLojaCompactoEntity>> logsFuture = logRepo 
      .getByCdLogGreaterThanAndCdFilial(cd_log, cd_filial); 

     logsFuture.addCallback(
      new ListenableFutureCallback<List<LogCentralLojaCompactoEntity>>() { 
       @Override 
       public void onSuccess(List<LogCentralLojaCompactoEntity> logs) { 
        logger.info("/getLogCompacto -> Callback -> onSucess"); 

        if (logs.size() == 0) { 
         ResponseEntity<Void> not_modified = new ResponseEntity<>(HttpStatus.NOT_MODIFIED); 
         deferredResult.setResult(not_modified); 
        } else { 
         deferredResult.setResult(ResponseEntity.ok(new LogCentralCompactoLojaCollectionDto(logs))); 
        } 
       } 

       @Override 
       public void onFailure(Throwable t) { 
        logger.info("/getLogCompacto -> Callback -> onFailure"); 
        ResponseEntity<Void> responseEntity = new ResponseEntity<>(HttpStatus.SERVICE_UNAVAILABLE); 
        deferredResult.setResult(responseEntity); 
       } 
      } 
     ); 

     logger.info("/getLogCompacto -> Fim"); 

     return deferredResult; 
    } 
}

这是日志输出中：

 
2017-04-17 11:26:30.410 INFO 2776 --- [nio-8080-exec-4] b.c.c.d.c.LogCentralLojaController  : /getLogCompacto -> Início 
2017-04-17 11:26:31.641 INFO 2776 --- [nio-8080-exec-4] b.c.c.d.c.LogCentralLojaController  : /getLogCompacto -> Callback -> onSucess 
2017-04-17 11:26:31.641 INFO 2776 --- [nio-8080-exec-4] b.c.c.d.c.LogCentralLojaController  : /getLogCompacto -> Fim

我期待看到 “/ getLogCompacto - >鱼翅” 前“/ getLogCompacto - >回调 - > onSucess“。我对吗？我错过了什么？

的logRepo.getByCdLogGreaterThanAndCdFilial看起来是这样的：

public interface LogCentralLojaCompactoRepository extends CrudRepository<LogCentralLojaCompactoEntity, Long>, 
    LogCentralLojaCompactoRepositoryCustom { 

    @Async 
    ListenableFuture<List<LogCentralLojaCompactoEntity>> getByCdLogGreaterThanAndCdFilial(long cdLog, int cdFilial); 
}

异步配置：

@Configuration 
@EnableAsync 
public class AsyncConfiguration extends AsyncConfigurerSupport { 

    @Override 
    public Executor getAsyncExecutor() { 
     ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); 
     executor.setCorePoolSize(4); 
     executor.setMaxPoolSize(4); 
     executor.setQueueCapacity(40); 
     executor.setThreadNamePrefix("Thread-"); 
     executor.initialize(); 

     return executor; 
    } 
}

谢谢！

来源

2017-04-17 Thiago Sayão

它不是异步运行，日志中的所有条目都来自同一个线程。 Async的配置是什么？ – jny

已更新为异步配置。谢谢。 –

改变这样的春天启动配置解决了这个问题：

@Bean 
public TaskExecutor getTaskExecutor() { 
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); 
    executor.setCorePoolSize(4); 
    executor.setMaxPoolSize(4); 
    executor.setQueueCapacity(40); 
    executor.setThreadNamePrefix("Thread-"); 
    executor.initialize(); 

    return executor; 
}

类声明有一个@EnableAsync。

来源

2017-04-17 16:22:16

Spring上的Async Rest方法不是异步执行的

回答

相关问题