当前位置: 首页 > 知识库问答 >
问题:

控制器中的spring boot@Async方法正在同步执行

巫马昆琦
2023-03-14

我的[基本]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,尽管我在上面的代码段中有这一行。

共有1个答案

缪坚诚
2023-03-14

您正在从同一类中的另一个方法调用@async方法。除非您为@enableasync启用AspectJ代理模式(当然还提供了一个编织器),否则不会工作(google“代理自调用”)。最简单的修复方法是将@async方法放在另一个@bean中。

 类似资料:
  • 问题内容: 我的[基本] Spring Boot应用程序接受来自浏览器的请求,通过发送,并应立即收到响应-例如“ 您的请求已排队 ”。为此,我编写了一个控制器: 本类实现一个接口,是很简单的。它只有一种方法可以执行耗时的任务。我不需要此服务呼叫返回的任何内容,因为无论工作失败还是成功,都会在工作结束时发送一封电子邮件。因此它实际上看起来像: 我以为这样可以,但是浏览器的Ajax请求在返回响应之前等

  • 本文向大家介绍async/await让异步操作同步执行的方法详解,包括了async/await让异步操作同步执行的方法详解的使用技巧和注意事项,需要的朋友参考一下 一.前言 我们经常会遇到这样的麻烦事,多个函数按顺序执行,返回结果却不是我们预期的顺序,原因一般是由于异步操作引起的,所以呢,我们需要一种解决方案来处理这种问题,从而使得异步操作按照同步的方式来执行,这样我们就可以控制异步操作输出结果的

  • 在我看来,将myObject序列化为JSON和f的Spring代码将同时尝试在get()返回时访问myObject。除了返回MyObject的深度副本之外,还有什么方法可以防止这种情况发生吗?

  • 我遇到了一种情况,在处理请求之前,我必须更新它。基本上,我必须用一个可以随时间变化的属性来更新请求。要求消费者随请求一起发送属性是不实际的..所以,我觉得唯一的办法就是..在处理请求之前,更新控制器方法中的请求.. 到目前为止,控制器方法中使用了HttpServletRequest。然后将请求读取为流,然后将其转换为json字符串进行处理。我正在考虑用@RequestBody替换它,并将请求读入p

  • 上下文 主 控制器 服务1 如果我在异步方法中添加,这将按照预期工作,用户将得到响应,而无需等待完成。但仍无法了解原因。