SpringBoot程序预装载数据的实现方法及实践

import org.springframework.context.ApplicationEvent;

public class CacheEvent   extends ApplicationEvent {

     public CacheEvent(Object source) {

         super (source);

     }

}

import lombok.extern.slf4j.Slf4j;

import org.apache测试数据mons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.ApplicationListener;

import org.springframework.stereotype.Component;

import org.springframework.util.CollectionUtils;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

@Slf4j

@Component

public class CacheEventListener implements ApplicationListener<CacheEvent> {

     @Autowired

     private MaskingService maskingService;

     @Autowired

     private RedisCache redisCache;

     @Override

     public void onApplicationEvent(CacheEvent cacheEvent) {

         log.debug( "CacheEventListener-start" );

         List<SysMasking> maskings = maskingService.selectAllSysMaskings();

         if (!CollectionUtils.isEmpty(maskings)) {

             log.debug( "CacheEventListener-data-not-empty" );

             Map<String, List<SysMasking>> cacheMap = maskings.stream().collect(Collectors.groupingBy(SysMasking::getFieldKey));

             cacheMap.keySet().forEach(x -> {

                 if (StringUtils.isNotEmpty(x)) {

                     log.debug( "CacheEventListener-x={}" , x);

                     List<SysMasking> list = cacheMap.get(x);

                     long count = redisCache.setCacheList(RedisKeyPrefix.MASKING.getPrefix() + x, list);

                     log.debug( "CacheEventListener-count={}" , count);

                 } else {

                     log.debug( "CacheEventListener-x-is-empty" );

                 }

             });

         } else {

             log.debug( "CacheEventListener-data-is-empty" );

         }

         log.debug( "CacheEventListener-end" );

     }

}

@Slf4j

@SpringBootApplication (exclude = {DataSourceAutoConfiguration. class })

public class BAMSApplication {

     public static void main(String[] args) {

         ConfigurableApplicationContext context = SpringApplication.run(BAMSApplication. class , args);

         log.debug( "app-started" );

         context.publishEvent( new CacheEvent( "处理缓存事件" ));

     }

}

package com.ramble.warmupservice.runner;

import lombok.extern.slf4j.Slf4j;

import org.springframework.boot.CommandLineRunner;

import org.springframework.stereotype.Component;

@Slf4j

@Component

public class CacheCommandLineRunner implements CommandLineRunner {

     @Override

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

         log.debug( "CacheCommandLineRunner-start" );

         log.debug( "CacheCommandLineRunner-参数={}" , args);

         // 注入业务 service ，获取需要缓存的数据

         // 注入 redisTemplate ，将需要缓存的数据存放到 redis 中

         log.debug( "CacheCommandLineRunner-end" );

     }

}

package com.ramble.warmupservice.runner;

import com.alibaba.fastjson.JSON;

import lombok.extern.slf4j.Slf4j;

import org.springframework.boot.ApplicationArguments;

import org.springframework.boot.ApplicationRunner;

import org.springframework.stereotype.Component;

@Slf4j

@Component

public class CacheApplicationRunner implements ApplicationRunner {

     @Override

     public void run(ApplicationArguments args) throws Exception {

         log.debug( "CacheApplicationRunner-start" );

         log.debug( "CacheApplicationRunner-参数={}" , JSON.toJSONString(args));

         // 注入业务 service ，获取需要缓存的数据

         // 注入 redisTemplate ，将需要缓存的数据存放到 redis 中

         log.debug( "CacheApplicationRunner-end" );

     }

}