企业级框架____Ehcache缓存框架(Ehcache和Spring的整合)

╰+哭是因爲堅強的太久メ 2022-06-10 04:52 246阅读 0赞

//======整合结构图

![Center][]![Center 1][]

//==创建项目添加spring依赖和Rhcache的jar包

jdbc的数据源jar包 这是spring启动必备的一个

ehcache.包和它依赖的包sf4j

Ehcache的结构

![Center 2][]

//==配置spring的applicationContext.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:aop="http://www.springframework.org/schema/aop"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:mvc="http://www.springframework.org/schema/mvc"
    	xmlns:tx="http://www.springframework.org/schema/tx"
    	xmlns:c="http://www.springframework.org/schema/c"
    	xmlns:cache="http://www.springframework.org/schema/cache"
    	xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
    		http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd
    		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
    		http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd
    		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
    		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
    		
    
    	
    	
    	<context:annotation-config />
    	<context:component-scan base-package="com.frame"></context:component-scan>
    	
    	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    		<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
    		<property name="url" value="jdbc:oracle:thin:@127.0.0.1:1521:orcl" />
    		<property name="username" value="oracle" />
    		<property name="password" value="123456" />
    	</bean>
    
    
    
    
    
        <bean id="ehcache" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean">  
            <property name="configLocation" value="classpath:ehcache.xml"></property>  
        </bean>  
    	<bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheCacheManager">  
            <property name="cacheManager" ref="ehcache"></property>  
        </bean>  
    	<cache:annotation-driven cache-manager="cacheManager" />
    	
    	
    
    </beans>

配置jdbc文件

#log4j输出选项
    #log4j.rootLogger=info,stdout,file
    log4j.rootLogger=info,file
    #输出到控制台
    #log4j.appender.stdout=org.apache.log4j.ConsoleAppender
    #log4j.appender.stdout.ImmediateFlush=true   
    #log4j.appender.stdout.layout=org.apache.log4j.PatternLayout   
    #log4j.appender.stdout.layout.ConversionPattern=-----------------------------------------------------------------------------------%nLevel:[%p]%nTime:[%d]%nClass:[%c]%nMessage:[%m]%n
    #写入到根目录
    log4j.appender.file=org.apache.log4j.DailyRollingFileAppender
    log4j.appender.file.file=${logpath}/logs/log_info.log
    log4j.appender.file.encoding=UTF-8
    log4j.appender.file.DatePattern='.'yyyy-MM-dd
    log4j.appender.file.layout=org.apache.log4j.PatternLayout
    log4j.appender.file.layout.ConversionPattern=[%-5p] %d{yyyy-MM-dd HH\:mm\:ss,SSS}_%t method\:%l%n%m%n

//配置ehcache.xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <ehcache>
       
        <diskStore path="java.io.tmpdir"/>
    
        
        <defaultCache
                maxElementsInMemory="10000" 
                eternal="false" 
                overflowToDisk="true"
                timeToIdleSeconds="10"
                timeToLiveSeconds="20"
                diskPersistent="false"
                diskExpiryThreadIntervalSeconds="120"/>
    
        <cache name="simpleCache"
            maxElementsInMemory="1000"
            eternal="false"
            overflowToDisk="true"
            timeToIdleSeconds="10"
            timeToLiveSeconds="20"/>
      
    </ehcache>

//配置student实体类

package com.frame.student.bean;
    /**
     * Student entity. @author MyEclipse Persistence Tools
     */
    public class Student implements java.io.Serializable {
    
    	
    	/**
    	 * SRRID
    	 */
    	private static final long serialVersionUID = -5076741984769526094L;
    	
    	// Fields
    	private String stuid;
    	private String stuname;
    	private String stupwd;
    	private String createtime;
    
    	// Constructors
    	/** default constructor */
    	public Student() {
    	}
    
    	/** minimal constructor */
    	public Student(String stuid) {
    		this.stuid = stuid;
    	}
    
    	/** full constructor */
    	public Student(String stuid, String stuname, String stupwd,
    			String createtime) {
    		this.stuid = stuid;
    		this.stuname = stuname;
    		this.stupwd = stupwd;
    		this.createtime = createtime;
    	}
    
    	// Property accessors
    
    	public String getStuid() {
    		return this.stuid;
    	}
    
    	public void setStuid(String stuid) {
    		this.stuid = stuid;
    	}
    
    	public String getStuname() {
    		return this.stuname;
    	}
    
    	public void setStuname(String stuname) {
    		this.stuname = stuname;
    	}
    
    	public String getStupwd() {
    		return this.stupwd;
    	}
    
    	public void setStupwd(String stupwd) {
    		this.stupwd = stupwd;
    	}
    
    	public String getCreatetime() {
    		return this.createtime;
    	}
    
    	public void setCreatetime(String createtime) {
    		this.createtime = createtime;
    	}
    
    }

//配置dao和实现类

package com.frame.student.dao;
    
    import com.frame.student.bean.Student;
    
    public interface StudentDao {
    
    	/**
    	 * 测试下ehcache的缓存机制
    	 * @param param
    	 * @return
    	 */
    	public Student testEcache(String stuid);
    	
    	
    }

package com.frame.student.dao;
    
    import org.springframework.cache.annotation.Cacheable;
    import org.springframework.stereotype.Repository;
    
    import com.frame.student.bean.Student;
    
    @Repository
    public class StudentDaoImpl implements StudentDao{
    	
    	
    //或者模拟假数据
    	
    	@Cacheable(value = "simpleCache", key = "#stuid")
    	@Override
    	public Student testEcache(String stuid) {
    		System.out.println("开始访问数据库");
    		Student sdf=new Student();
    		sdf.setStuid(stuid);
    		return sdf;
    	}
    
    }

//ehcache简单使用

package com.frame.base.ehcache;
    
    import net.sf.ehcache.Cache;
    import net.sf.ehcache.CacheManager;
    import net.sf.ehcache.Element;
    
    public class TestCache {
    	public static void main(String[] args) throws Exception {
    		//初始化Ehcahce对象
    		CacheManager cacheManager = new CacheManager();
    		//加载自定义cache对象
    		Cache cache = cacheManager.getCache("simpleCache");
    		//把集合放入缓存  存放键值对集合类似map
    		cache.put(new Element("user", "zhangsan"));
    		//取出集合根据key获取值
    		System.out.println("key=user value=:"+cache.get("user").getObjectValue());
    		//更新集合的key=user的值
    		cache.put(new Element("user", "lisi"));
    		System.out.println("key=user value=:"+cache.get("user").getObjectValue());
    		//获取缓存中的原素个数
    		System.out.println("集合个数:"+cache.getSize());
    		//移除cache某个值
    		cache.remove("user");
    		System.out.println("集合个数:"+cache.getSize());
    		// 关闭当前CacheManager对象
    		cacheManager.shutdown();
    	}
    }

![Center 3][]

//测试注解型缓存机制

package com.frame.student.test;
    
    import javax.annotation.Resource;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    import com.frame.student.dao.StudentDao;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration(locations={"classpath:applicationContext.xml"})
    public class StudentTest {
    	
    	@Resource
    	private StudentDao dao;
    
    	@Test
    	public void getUserbyId() throws Exception{
    		String stuid="10086";
    		System.out.println("ehcache.xml配置的超时时间为10秒");
    		
    		System.out.println("第一次调用:"+dao.testEcache(stuid).getStuid());
    		
    		Thread.sleep(2000);
    		System.out.println("2秒后调用:"+dao.testEcache(stuid).getStuid());
    		
    		Thread.sleep(9000);
    		System.out.println("9秒后调用:"+dao.testEcache(stuid).getStuid());
    		
    		Thread.sleep(11000);
    		System.out.println("11秒后调用:"+dao.testEcache(stuid).getStuid());
    		
    	}
    	
    	
    }

![Center 4][]  
  
//源码: http://pan.baidu.com/s/1pLuQre7

[Center]: https://img-blog.csdn.net/20170810145650516?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvcXE4MjcyNDU1NjM=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 1]: /images/20220610/9e219671e275462aab265e95b5d5b30a.png
[Center 2]: /images/20220610/de1866f740b04beabb98267d3442140f.png
[Center 3]: /images/20220610/6285f2b5a22a434986b24e11f20273f9.png
[Center 4]: /images/20220610/4bb84b5ae1264808922143cf4cd18b03.png