SpringBoot+EhCache整合

﹏ヽ暗。殇╰゛Y 2022-12-15 03:47 205阅读 0赞

对于Ehcache缓存来说，也是初次的和springboot集成一起使用，还有很多不足，请指出，

1.pom文件

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-cache</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.apache.shiro</groupId>
                <artifactId>shiro-ehcache</artifactId>
                <version>1.5.3</version>
            </dependency>

2.对于配置Ehcache来说，读取ehcache.xml文件，之前用

file = ResourceUtils.getFile("classpath:ehcache.xml");来获取 打成jar总是有问题 ，获取不到文件名，传统美德！！！！！

package com.linkcheers.app.configuration;
    
    import org.springframework.cache.annotation.EnableCaching;
    import org.springframework.cache.ehcache.EhCacheCacheManager;
    import org.springframework.cache.ehcache.EhCacheManagerFactoryBean;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.ClassPathResource;
    
    @Configuration
    @EnableCaching
    public class EhCacheConfig {
       /* *//**
         * ehcache 主要的管理器
         *//*
        @Bean
        public EhCacheCacheManager ehCacheCacheManager(EhCacheManagerFactoryBean bean){
            return new EhCacheCacheManager (bean.getObject ());
        }*/
    
        /**
         * 据shared与否的设置,Spring分别通过CacheManager.create()或new CacheManager()方式来创建一个ehcache基地.
         */
        @Bean
        public EhCacheManagerFactoryBean ehCacheManagerFactoryBean(){
            EhCacheManagerFactoryBean cacheManagerFactoryBean = new EhCacheManagerFactoryBean ();
            cacheManagerFactoryBean.setConfigLocation (new ClassPathResource("ehcache.xml"));
            cacheManagerFactoryBean.setShared (true);
            return cacheManagerFactoryBean;
        }
    }

3.进行cache工具类的设置，其中有一个方法getCache是获取Ehcache管理器，注意。

package com.linkcheers.app.utils;
    
    import net.sf.ehcache.Cache;
    import net.sf.ehcache.CacheManager;
    import net.sf.ehcache.Element;
    import org.springframework.cache.ehcache.EhCacheCacheManager;
    
    import java.util.Iterator;
    import java.util.Set;
    
    public class CacheUtils {
    
        private static EhCacheCacheManager ehCacheCacheManager;
    
        private static final String LOGIN_CACHE = "userSession";
    
        private static final String UTIL_CACHE = "utilsCache";
    
    
        /**
         * 写入用户信息LOGIN_CACHE缓存
         *
         * @param key
         * @return
         */
        public static void putUser(String key, Object value) {
            put(LOGIN_CACHE, key, value);
        }
    
        /**
         * 获取用户信息从LOGIN_CACHE缓存
         *
         * @param key
         * @return
         */
        public static Object getUserCache(String key) {
            return getCache(LOGIN_CACHE).get(key).getObjectValue();
        }
    
        /**
         * 写入用户信息UTIL_CACHE缓存
         *
         * @param key
         * @return
         */
        public static void putUtil(String key, Object value) {
            put(UTIL_CACHE, key, value);
        }
    
        /**
         * 获取用户信息从UTIL_CACHE缓存
         *
         * @param key
         * @return
         */
        public static Object getUtilCache(String key) {
            final Object objectValue = getCache(UTIL_CACHE).get(key).getObjectValue();
            return objectValue;
        }
    
    
        /**
         * 获得一个Cache 通用方法。
         * @param cacheName
         * @return
         */
        private static Cache getCache(String cacheName) {
            try {
                EhCacheCacheManager ehCacheCacheManager = ApplicationContextHelper.getBean(EhCacheCacheManager.class);
                final CacheManager cacheManager = ehCacheCacheManager.getCacheManager();
                Cache cache = cacheManager.getCache(cacheName);
                if (cache == null) {
                    throw new RuntimeException("当前系统中没有定义“" + cacheName + "”这个缓存。");
                }
                return cache;
            } catch (Exception ex) {
                ex.printStackTrace();
            }
            return null;
        }
    
        /**
         * 写入缓存 通用方法
         *
         * @param cacheName
         * @param key
         * @param value
         */
        private static void put(String cacheName, String key, Object value) {
            Element element = new Element(key,value);
            Cache cache = getCache(cacheName);
            cache.put(element);
        }
        /**
         * 从缓存中移除 通用方法
         *
         * @param cacheName
         * @param key
         */
        public static void remove(String cacheName, String key) {
            getCache(cacheName).remove(key);
        }
    
        /**
         * 从缓存中移除所有
         *
         * @param cacheName
         */
        public static void removeAll(String cacheName) {
            final Cache cache = getCache(cacheName);
            cache.removeAll();
        }
    
    
    }

4.工具类从spring的工厂中获取bean的工具类

package com.linkcheers.app.utils;
    
    import org.springframework.beans.BeansException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    
    @Component
    public class ApplicationContextHelper implements ApplicationContextAware {
    
        /**
         * 工厂bean工具类 获取想要的service的实例对象
         */
        private static ApplicationContext applicationContext;
    
        public ApplicationContextHelper() {
        }
    
        @Override
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
            ApplicationContextHelper.applicationContext = applicationContext;
        }
    
        public static Object getBean(String beanName) {
            return applicationContext != null?applicationContext.getBean(beanName):null;
        }
        public static <T> T getBean(Class<T> clazz) {
            return applicationContext  != null?applicationContext.getBean(clazz):null;
        }
    }

完结。