在Spring Boot应用中实现Worker进程：MongoTemplate依赖注入问题及架构优化咨询

我来帮你拆解这个问题，结合你的代码场景给出具体的解决方案：

1. 如何将MongoTemplate暴露给第二个Worker进程？ #

你的核心问题在于Worker进程没有加载Spring Boot的自动配置，导致MongoTemplate这类由Spring Boot自动创建的Bean不存在。你当前手动创建AnnotationConfigApplicationContext的方式只会扫描指定包，但不会触发Spring Boot的自动配置逻辑（比如MongoAutoConfiguration），所以容器里没有MongoTemplate实例。

修改方案很简单，把BackgroundWorker改成标准的Spring Boot应用，而不是手动管理上下文：

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.beans.factory.annotation.Autowired;

@SpringBootApplication(scanBasePackages = {"com.a.viz.db", "com.a.viz.workers"})
public class BackgroundWorker implements CommandLineRunner {
    static Logger logger = LoggerFactory.getLogger(BackgroundWorker.class);

    @Autowired
    private TaskHandler handler;

    public static void main(String[] args) {
        SpringApplication.run(BackgroundWorker.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        // 启动后台任务调度器
        handler.initScheduler();
    }
}

同时，你可以去掉TaskHandler上的冗余注解：

@Service
// 以下注解可以移除，因为@SpringBootApplication已经包含了ComponentScan和必要的Repository自动配置
// @EnableMongoRepositories("com.a.viz.db")
// @ComponentScan("com.a.viz.db")
// @EntityScan("com.a.viz.model")
public class TaskHandler {
    @Autowired
    UProductRepository productRepository;

    public void initScheduler() {
        Runnable fetchProducts = () -> {
            Scheduler.fetchProducts(productRepository);
        };
        // 记得实际启动任务，比如用ScheduledExecutorService或者@Scheduled
    }
}

这样修改后，Spring Boot会自动加载Mongo相关的自动配置类，创建MongoTemplate并注入到你的UProductRepositoryImpl中，解决依赖注入错误。

2. 实现此类后台任务分离需求的最佳方式是什么？ #

针对Heroku的Web+Worker Dyno架构，推荐几种主流方案：

• 基础定时任务：用Spring Boot的@Scheduled
  如果你的任务是固定频率执行的（比如每小时同步一次产品数据），直接在TaskHandler里用@Scheduled注解，配合@EnableScheduling开启定时任务支持：

  @Service
  @EnableScheduling
  public class TaskHandler {
      @Autowired
      UProductRepository productRepository;
  
      @Scheduled(fixedRate = 3600000) // 每小时执行一次
      public void fetchProductsTask() {
          Scheduler.fetchProducts(productRepository);
      }
  }
  

  这种方式最简单，不需要额外中间件，适合简单的定时场景。

• 异步任务队列：集成消息中间件（RabbitMQ/Kafka）
  如果你的任务是由Web Dyno触发的（比如用户提交请求后需要发送邮件），或者需要更灵活的任务调度（重试、延迟、批量处理），建议用消息队列解耦：

  1. Web Dyno将任务消息发送到队列
  2. Worker Dyno监听队列并消费任务
     Spring Boot对RabbitMQ和Kafka都有很好的自动支持，只需要引入对应的starter依赖即可。这种方式扩展性更强，能应对高并发场景。

• 轻量任务管理：Spring Cloud Task
  如果你的任务是一次性或者短期运行的（比如数据迁移），可以用Spring Cloud Task来管理任务生命周期，它能自动记录任务执行状态，适合批量处理类任务。

3. 是否应组织应用组件，仅将Worker进程所需的相关组件暴露给它？ #

完全有必要！这样可以让Worker进程更轻量，减少内存占用和启动时间，避免加载Web层的冗余组件（比如Controller、WebMvc配置）。

你可以通过@SpringBootApplication的exclude属性，排除Web相关的自动配置：

@SpringBootApplication(
    scanBasePackages = {"com.a.viz.db", "com.a.viz.workers"},
    exclude = {
        org.springframework.boot.autoconfigure.web.servlet.WebMvcAutoConfiguration.class,
        org.springframework.boot.autoconfigure.web.servlet.ServletWebServerFactoryAutoConfiguration.class
    }
)
public class BackgroundWorker implements CommandLineRunner {
    // ... 代码省略
}

如果你的项目是多模块结构，还可以把Worker相关的代码（任务调度、Repository依赖）拆成单独的模块，Web模块依赖这个模块，Worker模块只引入必要的依赖（比如Spring Data MongoDB、Spring Boot Task），进一步优化结构。

内容的提问来源于stack exchange，提问作者Kanghu