Spring Boot从bean中的数据库预加载数据

Question

我要求在一个表中具有递归关系的元素：

孩子ID |父 ID

1 |空

2 | 1

3 | 1

4 | 2

等等...查询整个数据结构大约需要 10 秒目前我无法重新设计此表，因为它花费了太多时间（更多信息：Spring Repository performance issues with recursive ORM Class）

现在，我正在考虑在 bean 中在 spring 启动期间预加载所有数据，以便客户端与 bean“通信”，并更新 bean 和数据库中的数据。我认为这次启动需要多长时间并不重要，重要的是用户必须等待多长时间。

到目前为止，我还没有设法预加载它。我试图创建一个这样的 bean：

public class AppConfig extends WebMvcConfigurerAdapter {
...
@Autowired
SkillDAO skillDAO
...
@Bean(name="allSkills")
public List<Skill> allSkills(){
    return skillDAO.findBySkill(null);
}
...

它不起作用，因为我收到一个错误：

原因：org.springframework.beans.factory.BeanCurrentlyInCreationException：创建名为“dataSource”的 bean 时出错：当前正在创建请求的 bean：是否存在无法解析的循环引用？

顺便说一下，我在 AppConfig 中创建了所有的 bean。当我删除这个“allSkills”bean 时，它又可以工作了。

更新

@Component
public class MyListener {

@Autowired
private SkillDAO skillDAO;

@EventListener
public void onApplicationReady(ApplicationReadyEvent ready) {
    System.out.println("++++++++++++++ HALLO +++++++++++++");
    skillDAO.findBySkill(null);
}
}

...

@Bean(name="skillBean")
public MyListener myListener() {
    return new MyListener();
}

Answer 1

您可以监听ApplicationReadyEvent，然后调用该方法（来自@yglodt 的answer）来初始化您的缓存。

示例代码：

@Component
public class MyEventsListener {

    @Autowired
    SkillsService skillsService;

    @EventListener
    public void onApplicationReady(ApplicationReadyEvent ready) {
        skillsService.getAllSkills();
    }
}

还请记住，如果您从 SkillsService bean 本身调用 getAllSkills()，则不会命中缓存，因为该方法仅在类的注入 proxy 上调用时才会被建议。

如果您将应用程序部署为可执行 jar（而不是 war 文件），那么最简单的解决方案是从您的 main method 调用您希望在启动时运行的代码：

public class Application {

    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
        SkillsService skillsService = context.getBean(SkillsService.class);
        skillsService.getAllSkills();
    }

}

Answer 2

Cache 将优雅地解决您的要求。

理想情况下，您应该有一个 Service，它有一个返回技能的方法。

此方法可能如下所示：

import org.springframework.cache.annotation.Cacheable;

@Cacheable(value = "skills", key = "#root.methodName")
public List<Skill> getAllSkills() {
    return ... your skills ...;
}

要在 Spring Boot 中启用缓存，请将 @EnableCaching 注解添加到您的配置类中，并添加 Bean 进行配置：

import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.concurrent.ConcurrentMapCacheManager;

@Bean
public CacheManager cacheManager() {
    return new ConcurrentMapCacheManager("skills", "othercachename");
}

这样，getAllSkills 方法只执行一次，第一次被调用，然后从缓存管理器返回值，甚至不调用该方法。