如何在Spring启动时加载@Cache？

Question

我使用spring cache改进数据库查询，其工作原理如下：

@Bean
public CacheManager cacheManager() {
    return new ConcurrentMapCacheManager("books");
}

@Cacheable("books")
public Book getByIsbn(String isbn) {
    return dao.findByIsbn(isbn);
}

但是现在我想在启动时预填充完整的图书缓存。这意味着我要调用dao。findAll（）并将所有值放入缓存。该例行程序不应仅定期安排。

但是，使用@Cacheable时，如何显式填充缓存？

Answer 1

一个选项是在启动时使用命令行运行程序填充缓存。

根据CommandLineRunner官方文档，它是：

接口用于指示bean在包含在SpringApplication中时应运行。

因此，我们只需要检索所有可用书籍的列表，然后使用CacheManager，填充书籍缓存。

@Component
public class ApplicationRunner implements CommandLineRunner {
    @Autowired
    private BookDao dao;

    @Autowired
    private CacheManager cacheManager;

    @Bean
    public CacheManager cacheManager() {
        return new ConcurrentMapCacheManager("books");
    }

    @Override
    public void run(String... args) throws Exception {

        List<Book> results = dao.findAll();

        results.forEach(book -> 
            cacheManager.getCache("books").put(book.getId(), book));
    }
}

Answer 2

在使用@PostConstruct时，我遇到了以下问题：-即使调用了我想要缓存的方法，但在从swagger调用它之后，它仍然没有使用缓存的值。只是在再次打电话之后。

这是因为@PostConstruct对于缓存某些内容来说太早了。（至少我认为这是问题所在）

现在我在启动过程中使用它更晚，它没有问题：

@Component
public class CacheInit implements ApplicationListener<ApplicationReadyEvent> {

    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
       //call service method
    }

}

Answer 3

只需像以前一样使用缓存，添加一个调度程序来更新缓存，下面是代码片段。

@Service
public class CacheScheduler {
    @Autowired
    BookDao bookDao;
    @Autowired
    CacheManager cacheManager;

    @PostConstruct
    public void init() {
        update();
        scheduleUpdateAsync();
    }

    public void update() {
        for (Book book : bookDao.findAll()) {
            cacheManager.getCache("books").put(book.getIsbn(), book);
        }
    }
}

确保您的KeyGenerator将返回一个参数的对象（默认）。或者，在BookService中公开putToCache方法，以避免直接使用cacheManager。

@CachePut(value = "books", key = "#book.isbn")
public Book putToCache(Book book) {
    return book;
}