使用DeferredResult异步处理请求-蒲公英云

使用DeferredResult异步处理请求

冷不防 2022-12-05 02:17 356阅读 0赞

 我们在实际开发的过程中，可能会遇到需要长轮循的情况。
 长轮询指的是客户端向服务端发送一个请求，然后服务端将该请求hold住，另起线程进行处理，处理完后，再返回结果，从而提高服务器的处理能力，但是对于浏览器来说还是同步的，需要等待服务端返回。
可以使用Callable或者DeferredResult进行异步响应。
下面就来演示一下使用spring提供的DeferredResult来提供一个异步处理的接口。
@GetMapping("test")
    public DeferredResult<ResponseEntity<String>> testDeferredResult(){
        DeferredResult<ResponseEntity<String>> deferredResult = new DeferredResult();
        deferredResult.onCompletion(() -> log.info("completion"));
        deferredResult.onTimeout(() -> log.info("timeout"));
        new Thread(() -> {
            try {
                TimeUnit.SECONDS.sleep(30);
            } catch (InterruptedException e) {
                deferredResult.setErrorResult(e.getMessage());
            }
            deferredResult.setResult(ResponseEntity.ok("SUCCESS"));
        }).start();
        return deferredResult;
    }
 然后通过浏览器请求，经过三十秒的等待后获取到了服务端的响应 Success