前言
项目中为了提高系统响应速度经常把热数据存入缓存中如redis，memcached中。本文介绍一种使用的项目启动加载缓存的方法
基本配置
1.思路
应用启动时加载缓存常用的方法有：
- 编写linstener监听应用启动
- Bean实现InitializingBean接口，并实现afterPropertiesSet()方法
- 在Bean的init-method中进行逻辑代码编写
- 。。。。。
2.相关配置
本文采用实现InitializingBean接口，并实现afterPropertiesSet()方法的方式。
spring初始化bean的时候，如果bean实现了InitializingBean接口，会自动调用afterPropertiesSet方法，并且afterPropertiesSet方法优先于init-method方法执行
可参考Spring AbstractAutowireCapableBeanFactory中的实现
protected void invokeInitMethods(String beanName, final Object bean, RootBeanDefinition mbd) throws Throwable {
boolean isInitializingBean = bean instanceof InitializingBean;
if (isInitializingBean && (mbd == null || !mbd.isExternallyManagedInitMethod("afterPropertiesSet"))) {
if (this.logger.isDebugEnabled()) {
this.logger.debug("Invoking afterPropertiesSet() on bean with name '" + beanName + "'");
}
if (System.getSecurityManager() != null) {
try {
AccessController.doPrivileged(new PrivilegedExceptionAction<Object>() {
public Object run() throws Exception {
((InitializingBean)bean).afterPropertiesSet();
return null;
}
}, this.getAccessControlContext());
} catch (PrivilegedActionException var6) {
throw var6.getException();
}
} else {
((InitializingBean)bean).afterPropertiesSet();
}
}
if (mbd != null) {
String initMethodName = mbd.getInitMethodName();
if (initMethodName != null && (!isInitializingBean || !"afterPropertiesSet".equals(initMethodName)) && !mbd.isExternallyManagedInitMethod(initMethodName)) {
this.invokeCustomInitMethod(beanName, bean, mbd);
}
}
}
3.代码实现
为了代码的可用性，设计CacheInterface接口
public interface CacheInterface {
/**
* 实现接口在应用启动时加载热数据
*
* @return
*/
boolean loadCache();
boolean deleteCache();
}
加载热数据时实现CacheInterface接口
@Service
public class DemoLoadCache implements CacheInterface {
@Override
public boolean loadCache() {
//TODO 从关系型数据库中查询相关的数据并存储到缓存中。
return true;
}
@Override
public boolean deleteCache() {
return false;
}
}
将所有实现CacheInterface接口的加载热数据类注入到处理类中，实际应用中考虑使用线程池。
@Service
public class CacheLoadService implements Runnable, InitializingBean {
private static final Logger logger = LoggerFactory.getLogger(CacheLoadService.class);
@Autowired
private List<CacheInterface> cacheInterfaceList;
@Override
public void run() {
logger.info("start load cache");
long start = System.currentTimeMillis();
if (cacheInterfaceList != null && cacheInterfaceList.size() > 0) {
for (CacheInterface cacheInterface : cacheInterfaceList) {
cacheInterface.loadCache();
}
}
long end = System.currentTimeMillis();
logger.info("load cache finished in {}秒 ", (end - start) / 1000);
}
@Override
public void afterPropertiesSet() throws Exception {
Thread t = new Thread(this);
t.start();
}
}
Spring应用启动的时候，调用CacheLoadService中afterPropertiesSet方法启动线程加载热数据。
结尾
实际应用中考虑真是场景考虑加载数据的方式。对热数据的增删改也要同步到缓存中。
