我的[基本] Spring Boot应用程序接受来自浏览器的请求,该请求jQuery.get()是通过发送的,并且应该立即收到响应-例如“ 您的请求已排队 ”。为此,我编写了一个控制器:
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."; } }
本DoWorkServiceImpl类实现一个DoWorkService接口,是很简单的。它只有一种方法可以执行耗时的任务。我不需要此服务呼叫返回的任何内容,因为无论工作失败还是成功,都会在工作结束时发送一封电子邮件。因此它实际上看起来像:
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配置中:
@Async
<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响应仍然到达。我想念什么?
SpringBoot应用程序可以在这里下载。安装Maven后,可以使用简单的命令运行项目:
mvn clean spring-boot:run
注意 :由于下面的@Dave Syer提供了答案,该问题得以解决,他指出@EnableAsync即使我的代码段中包含该行,我的应用程序中也缺少我。
@EnableAsync
您正在@Async从同一类中的另一个方法调用该方法。除非您为@EnableAsync将无法使用的(并提供一个编织器)启用AspectJ代理模式(谷歌“代理自我调用”)。最简单的解决@Async方法是将该方法放在另一个方法中@Bean。
@Bean