自动装配任务发送到Spring TaskExecutor

Question

你怎么能有一个实现Runnable并提交给弹簧TaskExecutor自动装配的类？

例如,我有一个任务:

public class MyTask implements Runnable {

    @Autowired private MyRepository myRepository;

    @Override
    public void run() {
        myRepository.doSomething();
    }
}

以及将任务发送到spring TaskExecutor的服务:

@Service
public class MyService {

    @Autowired private TaskExecutor taskExecutor;

    public void someMethod() {

        MyTask myTask = new MyTask();
        taskExecutor.execute(myTask);

    }

}

我知道字段没有自动装配,因为MyTask正在使用新的MyTask()进行实例化.但是,我该如何解决这个问题呢？我是否应该访问Spring的ApplicationContext并通过它创建bean？您将如何在Web应用程序环境中执行此操作？

谢谢!

Answer 1

尝试

public class MyTask implements Runnable {
    private MyRepository myRepository;

    public MyTask(MyRepository myRepository) {
         this.myRepository = myRepository;
    }

    @Override
    public void run() {
        myRepository.doSomething();
    }
}

@Service
public class MyService {
    @Autowired private TaskExecutor taskExecutor;
    @Autowired private MyRepository myRepository;


    public void someMethod() {
        MyTask myTask = new MyTask(myRepository);
        taskExecutor.execute(myTask);
    }
}

或者您可以声明MyTask的scope ="prototype"并将MyService更改为

@Service
public class MyService {
    @Autowired private ApplicationContext ctx;

    public void someMethod() {
        MyTask myTask = ctx.getBean(MyTask.class);
        taskExecutor.execute(myTask);
    }
}

Answer 2

使用 Spring 至少有两种好方法可以做到这一点。首先是@Configurable注解。使用它意味着对 AspectJ 的依赖，但它允许您注入不受 Spring 管理的 bean（即您正在使用 new 运算符）。这将涉及使用 @Configurable 注释 MyTask，并向您的 Spring 配置添加几行，如链接中所述。

@Configurable
public class MyTask implements Runnable { ... }

@Service
public class MyService {
   @Autowired private TaskExecutor taskExecutor;

   public void someMethod() {

     // AspectJ would jump in here and inject MyTask transparently
     MyTask myTask = new MyTask();
     taskExecutor.execute(myTask);

}

}

第二种方法涉及使用 Spring 的 ServiceLocatorFactoryBean 功能来创建原型 bean。JavaDoc对此进行了最好的解释，但在这种情况下，您可以将 TaskFactory 注入到 @Service 注解的类中，就像任何其他 bean 一样，然后执行如下操作：

@Service
public class MyService {
  @Autowired private TaskExecutor taskExecutor;
  @Autowired private MyRepository myRepository;
  @Autowired private TaskFactory taskFactory;


public void someMethod() {
    MyTask myTask = taskFactory.getTask("myTask")
    taskExecutor.execute(myTask);
}

}

MyTask 已经被注入到您的存储库中，因为您可以在 XML 映射中对其进行配置。我每天都会使用这两种方法，但我倾向于第二种方法，因为它更容易阅读，并且通过确保开发人员不做不容易测试的事情来帮助保持开发人员的诚实，坦率地说，它更容易对于不经意的观察者来说很清楚。