Spring Boot 基于WebAsync的异步服务在异步的web服务开发中，也是属于比较常见的模式。
- 在pom.xml中引入配置
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
- 建立Service层接口
public interface PiceaService {
//无返回参数方法
void task() throws Exception;
//有返回参数方法
String task2() throws Exception;
}
- 建立Service层实现
Service层接口与实现，跟其他正常同步请求一样，没有差别。
@Service
public class PiceaServiceImpl implements PiceaService {
@Override
public void task() throws Exception {
System.out.println("------------------------在看貂蝉，不要打扰--------------");
Thread.sleep(1000);
}
@Override
public String task2 () throws Exception {
int k = 1;
System.out.println("------------------------在看鱼，不要打扰--------------");
Thread.sleep(1000);
return (String.valueOf(k));
}
}
- 建立Contoller层方法
基于WebAsync的方式也可以定义超时，定义完成时调用的方法。
@RestController
public class PiceaServletContoller {
@Autowired
private PiceaService piceaService;
@RequestMapping("/webAsyncTask")
public WebAsyncTask<String> deferredResult() throws Exception {
System.out.println("控制层执行线程:" + Thread.currentThread().getName());
WebAsyncTask<String> result = new WebAsyncTask<String>(10 * 1000L, new Callable<String>() {
@Override
public String call() throws Exception {
System.out.println("异步执行线程:" + Thread.currentThread().getName());
String str = piceaService.task2();
Thread.sleep(1000);
return ("这是【异步】的请求返回: " + str);
}
});
//定义超时
result.onTimeout(new Callable<String>() {
@Override
public String call() throws Exception {
System.out.println("异步线程执行超时");
return ("线程执行超时");
}
});
//定义完成,即使是超时，也会运行此方法
result.onCompletion(new Runnable() {
@Override
public void run() {
System.out.println("异步执行完毕");
}
});
return result;
}
}
- 测试结果及方法
浏览器中访问http://localhost:2001/webAsyncTask测试结果。
Spring-boot-async-webAsync.png
其它注意
本文章样例：
工程名：spring-boot-async-webasync
GitHub：https://github.com/zzyjb/SpringBootLearning
