热启动的方式缓存数据到redis

代码

两种方式的对比

总结

• 如果需要尽早执行初始化逻辑，可以选择 CommandLineRunner。
• 如果需要确保所有 Bean 已初始化后再执行逻辑，可以选择 ApplicationListener<ApplicationReadyEvent>。
• 两种方式都可以实现热加载数据到 Redis，根据实际需求选择合适的方式。
  以下是使用 CommandLineRunner 和 ApplicationListener 两种方式实现 Spring Boot 启动后热加载数据到 Redis 的示例代码：

1. 使用 CommandLineRunner 实现热加载数据

import org.jeecg.common.util.RedisUtil;
import org.jeecg.modules.train.entity.ZcTrain;
import org.jeecg.modules.train.mapper.ZcTrainMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class RedisDataLoaderWithCommandLineRunner implements CommandLineRunner {
    @Autowired
    private ZcTrainMapper zcTrainMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Override
    public void run(String... args) throws Exception {
        // 缓存列车数据到 Redis
        loadTrainDataToRedis();
    }
    private void loadTrainDataToRedis() {
        // 查询所有列车数据
        List<ZcTrain> zcTrainList = zcTrainMapper.selectList(null);
        // 按列车编号分组
        Map<String, List<ZcTrain>> zcTrainMap = new HashMap<>();
        if (zcTrainList != null && !zcTrainList.isEmpty()) {
            for (ZcTrain zcTrain : zcTrainList) {
                zcTrainMap.computeIfAbsent(zcTrain.getTrainNum(), k -> new ArrayList<>()).add(zcTrain);
            }
        }
        // 存入 Redis
        redisUtil.set("zcTrainMap", zcTrainMap);
        System.out.println("列车数据已加载到 Redis，键为: zcTrainMap");
    }
}

说明：

• CommandLineRunner 是一个函数式接口，实现 run 方法，在 Spring Boot 启动完成后自动执行。
• 示例中加载了列车数据到 Redis，键为 "zcTrainMap"。

2. 使用 ApplicationListener 实现热加载数据

import org.jeecg.common.util.RedisUtil;
import org.jeecg.modules.train.entity.ZcTrain;
import org.jeecg.modules.train.mapper.ZcTrainMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
public class RedisDataLoaderWithApplicationListener implements ApplicationListener<ApplicationReadyEvent> {
    @Autowired
    private ZcTrainMapper zcTrainMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
        // 缓存列车数据到 Redis
        loadTrainDataToRedis();
    }
    private void loadTrainDataToRedis() {
        // 查询所有列车数据
        List<ZcTrain> zcTrainList = zcTrainMapper.selectList(null);
        // 按列车编号分组
        Map<String, List<ZcTrain>> zcTrainMap = new HashMap<>();
        if (zcTrainList != null && !zcTrainList.isEmpty()) {
            for (ZcTrain zcTrain : zcTrainList) {
                zcTrainMap.computeIfAbsent(zcTrain.getTrainNum(), k -> new ArrayList<>()).add(zcTrain);
            }
        }
        // 存入 Redis
        redisUtil.set("zcTrainMap", zcTrainMap);
        System.out.println("列车数据已加载到 Redis，键为: zcTrainMap");
    }
}

说明：

• ApplicationListener<ApplicationReadyEvent> 监听 ApplicationReadyEvent 事件，该事件在 Spring Boot 应用完全启动后触发。
• 示例中同样加载了列车数据到 Redis，键为 "zcTrainMap"。