我的[基本]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.";
}
}
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秒。因此controller mapped方法正在同步调用用@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);
}
}
这并没有改变行为。Ajax响应仍然在发送请求10秒后到达。我错过了什么?
spring boot的应用程序可以在这里下载。安装了Maven后,可以使用以下简单命令运行项目:
mvn clean spring-boot:run
注由于@Dave Syer在下面提供了答案,这个问题得以解决,他指出我的应用程序中缺少@enableAsync
,尽管我在上面的代码段中有这一行。
您正在从同一类中的另一个方法调用@async
方法。除非您为@enableasync
启用AspectJ代理模式(当然还提供了一个编织器),否则不会工作(google“代理自调用”)。最简单的修复方法是将@async
方法放在另一个@bean
中。
问题内容: 我的[基本] Spring Boot应用程序接受来自浏览器的请求,通过发送,并应立即收到响应-例如“ 您的请求已排队 ”。为此,我编写了一个控制器: 本类实现一个接口,是很简单的。它只有一种方法可以执行耗时的任务。我不需要此服务呼叫返回的任何内容,因为无论工作失败还是成功,都会在工作结束时发送一封电子邮件。因此它实际上看起来像: 我以为这样可以,但是浏览器的Ajax请求在返回响应之前等
someController.java
本文向大家介绍async/await让异步操作同步执行的方法详解,包括了async/await让异步操作同步执行的方法详解的使用技巧和注意事项,需要的朋友参考一下 一.前言 我们经常会遇到这样的麻烦事,多个函数按顺序执行,返回结果却不是我们预期的顺序,原因一般是由于异步操作引起的,所以呢,我们需要一种解决方案来处理这种问题,从而使得异步操作按照同步的方式来执行,这样我们就可以控制异步操作输出结果的
在我看来,将myObject序列化为JSON和f的Spring代码将同时尝试在get()返回时访问myObject。除了返回MyObject的深度副本之外,还有什么方法可以防止这种情况发生吗?
我遇到了一种情况,在处理请求之前,我必须更新它。基本上,我必须用一个可以随时间变化的属性来更新请求。要求消费者随请求一起发送属性是不实际的..所以,我觉得唯一的办法就是..在处理请求之前,更新控制器方法中的请求.. 到目前为止,控制器方法中使用了HttpServletRequest。然后将请求读取为流,然后将其转换为json字符串进行处理。我正在考虑用@RequestBody替换它,并将请求读入p
上下文 主 控制器 服务1 如果我在异步方法中添加,这将按照预期工作,用户将得到响应,而无需等待完成。但仍无法了解原因。