主页 / 问题 / 1156504
Accepted
pra_soul_owl
Asked:2020-07-23 23:25:03 +0000 UTC2020-07-23 23:25:03 +0000 UTC

从服务方法调用延迟方法。观察者模式

  • 772

有一个 post 方法putMessage(Some object)将数据作为输入，对其进行处理并向用户返回“文件上传成功”消息。

在方法处理完数据之后，在向用户返回“文件上传成功”之前，我仍然需要运行一个单独的方法void2()来完成大约 2-3 小时的工作。

如何在putMessage(Some object)内部调用此方法，使其执行单独开始，客户端不等待消息 2-3 小时。听说可以通过 Observer 来实现。有这个工具Spring吗？

那些。

String putMessage(Some object){
    // 1. обработка данных object
    // 2. вызов void2() * - вынести в отдельный поток
    // 3. return "загрузка файла прошла успешно";
}
java

1 个回答

  1. Best Answer

    首先，您需要使基础架构能够运行异步方法。

    需要在 java 配置中添加注释@EnableAsync：

    @Configuration
@EnableAsync
public class SpringAsyncConfig { ... }

    或在 xml 中：

    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.2.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd"
>

    <task:annotation-driven executor="myExecutor"/>
    <task:executor id="myExecutor" pool-size="5"/>
     
    ...
</beans>

    然后，使用注释标记您要在单独的线程中运行的方法@Async：

    @Async
public void void2() {
    // этот метод выполнится в отдельном потоке
}

    这是最简单的配置。此外，您还可以：

    1. 配置执行器，例如，异步任务有多少线程可用
    2. 为异步方法添加错误处理程序
    3. 从主方法运行方法（如本例所示putMessage），并等待执行完成并返回工作结果

    好吧，有一个完整的分步示例，并带有俄语解释。

    • 1

相关问题