我的[基本] Spring Boot 应用程序接受来自浏览器的请求，通过jQuery.get()并且应该立即收到回复 - 例如“您的请求已排队为了实现这一点，我编写了一个控制器：
@Controller
public class DoSomeWorkController {
@Autowired
private final DoWorkService workService;
@RequestMapping("/doSomeWork")
@ResponseBody
public String doSomeWork() {
workService.doWork(); // time consuming operation
return "Your request has been queued.";
}
}
The DoWorkServiceImpl类实现了一个DoWorkService界面非常简单。它有一个单一的方法来执行耗时的任务。我不需要从此服务调用返回任何内容，因为在工作结束时将发送一封电子邮件，无论是失败还是成功的情况。所以它实际上看起来像：
@Service
public class DoWorkServiceImpl implements DoWorkService {
@Async("workExecutor")
@Override
public void doWork() {
try {
Thread.sleep(10 * 1000);
System.out.println("completed work, sent email");
}
catch (InterruptedException ie) {
System.err.println(ie.getMessage());
}
}
}
我以为这样可以，但是浏览器的 Ajax 请求等待了 10 秒才返回响应。所以控制器映射的方法正在调用带有注释的内部方法@Async看起来是同步的。在传统的 Spring 应用程序中，我通常将其添加到 XML 配置中：
<task:annotation-driven />
<task:executor id="workExecutor" pool-size="1" queue-capacity="0" rejection-policy="DISCARD" />
所以我认为在主应用程序类中编写与此等效的内容会有所帮助：
@SpringBootApplication
@EnableAsync
public class Application {
@Value("${pool.size:1}")
private int poolSize;;
@Value("${queue.capacity:0}")
private int queueCapacity;
@Bean(name="workExecutor")
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
taskExecutor.setMaxPoolSize(poolSize);
taskExecutor.setQueueCapacity(queueCapacity);
taskExecutor.afterPropertiesSet();
return taskExecutor;
}
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
这并没有改变行为。发送请求 10 秒后 Ajax 响应仍然到达。我缺少什么？
Spring Boot 应用程序可以是。安装 Maven 后，可以使用简单的命令运行该项目：
mvn clean spring-boot:run
Note感谢下面@Dave Syer 提供的答案，该问题得到了解决，他指出我失踪了@EnableAsync在我的应用程序中，即使我在上面的代码片段中有这一行。
