如何处理长API请求

Question

我有一个在数据库上运行查询的API。由于查询执行时间可能很长，比如3分钟到10分钟，我的负载平衡器返回“上游请求超时”，但我可以看到查询已提交到数据源，但对最终用户来说，它显示了错误的消息。如何应对这种情况？

我的职能

@PostMapping("/run/{QueryId}")
public void runQuery(@PathVariable String QueryId) {
     // This method takes long time
     querySchedulerService.runQuery(QueryId);
} 

Answer 1

控制器：

class SomeController{
 @PostMapping("/run/{QueryId}")
    public ResponseEntity<Void> runQuery(@PathVariable String QueryId) {
         // This method takes long time
         querySchedulerService.runQuery(QueryId);
         return new ResponseEntity<>(HTTP_STATUS.ACCEPTED);
    } 
}

服务：

@Service
class QuerySchedulerService{

    @Async
    public void runQuery(Query query){
    // Do somthing
    }
}

通过在主应用程序类中添加@EnableAsync注释，可以使用@Async注释

每次调用runQuery时，它都将在新线程中运行。

@EnableAsync
class Application{

}