能量石图片:Integrating Spring and EHCache

来源：百度文库 编辑：九乡新闻网 时间：2024/04/30 11:11:17

Using Spring Modules and EHCache,one can transparently cache method results. Spring Modules uses a proxywhich intercepts call to the method of bean; consults the cache tocheck if method was called with same parameters before, if so willreturn cached result.

EHCache is the actual provider of caching solution and Spring Module handles method interception and result storing in cache.

Since I am using Maven2, so added following dependancies -


01.<dependency>02.    <groupId>net.sf.ehcachegroupId>03.    <artifactId>ehcacheartifactId>04.    <version>1.6.1version>05.dependency>06.<dependency>07.    <groupId>org.springmodulesgroupId>08.    <artifactId>spring-modules-cacheartifactId>09.    <version>0.9version>10.dependency>

My complete pom.xml -


01.xml version="1.0" encoding="UTF-8"?>02.<project xmlns="http://maven.apache.org/POM/4.0.0"03.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"04.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">05.    <modelVersion>4.0.0modelVersion>06.    <groupId>SpringgroupId>07.    <artifactId>SpringartifactId>08.    <version>1.0version>09.    <dependencies>10.        <dependency>11.            <groupId>org.springframeworkgroupId>12.            <artifactId>spring-coreartifactId>13.            <version>3.0.0.RELEASEversion>14.        dependency>15.        <dependency>16.            <groupId>junitgroupId>17.            <artifactId>junitartifactId>18.            <version>4.7version>19.        dependency>20.        <dependency>21.            <groupId>org.springframeworkgroupId>22.            <artifactId>spring-testartifactId>23.            <version>3.0.0.RELEASEversion>24.        dependency>25.        <dependency>26.            <groupId>org.springframeworkgroupId>27.            <artifactId>spring-beansartifactId>28.            <version>3.0.0.RELEASEversion>29.        dependency>30.        <dependency>31.            <groupId>org.springframeworkgroupId>32.            <artifactId>spring-contextartifactId>33.            <version>3.0.0.RELEASEversion>34.        dependency>35.        <dependency>36.            <groupId>cglibgroupId>37.            <artifactId>cglibartifactId>38.            <version>2.2version>39.        dependency>40.        <dependency>41.            <groupId>org.springframeworkgroupId>42.            <artifactId>spring-aopartifactId>43.            <version>3.0.0.RELEASEversion>44.        dependency>45.        <dependency>46.            <groupId>org.aspectjgroupId>47.            <artifactId>aspectjweaverartifactId>48.            <version>1.6.6version>49.        dependency>50.        <dependency>51.            <groupId>mysqlgroupId>52.            <artifactId>mysql-connector-javaartifactId>53.            <version>5.1.10version>54.        dependency>55.        <dependency>56.            <groupId>commons-dbcpgroupId>57.            <artifactId>commons-dbcpartifactId>58.            <version>1.2.2version>59.        dependency>60.        <dependency>61.            <groupId>org.springframeworkgroupId>62.            <artifactId>spring-jdbcartifactId>63.            <version>3.0.0.RELEASEversion>64.        dependency>65.        <dependency>66.            <groupId>net.sf.ehcachegroupId>67.            <artifactId>ehcacheartifactId>68.            <version>1.6.1version>69.        dependency>70.        <dependency>71.            <groupId>org.springmodulesgroupId>72.            <artifactId>spring-modules-cacheartifactId>73.            <version>0.9version>74.        dependency>75.    dependencies>76.project>

Contact Table sql -


1.CREATE TABLE `contact` (2.  `ID` int(15) NOT NULL AUTO_INCREMENT,3.  `FIRSTNAME` varchar(50) DEFAULT NULL,4.  `LASTNAME` varchar(50) DEFAULT NULL,5.  `EMAIL` varchar(150) DEFAULT NULL,6.  PRIMARY KEY (`ID`),7.  UNIQUE KEY `EMAIL` (`EMAIL`)8.) ENGINE=MyISAM AUTO_INCREMENT=4 DEFAULT CHARSET=latin1

Adding ehcache namespace to Spring config file -


01.xml version="1.0" encoding="UTF-8"?>02.<beans xmlns="http://www.springframework.org/schema/beans"03.       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"04.       xmlns:ehcache="http://www.springmodules.org/schema/ehcache"05.       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd06.       http://www.springmodules.org/schema/ehcache http://www.springmodules.org/schema/cache/springmodules-ehcache.xsd07.       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">08....09.beans>

Created ehcache.xml file in classpath.


1.<ehcache>2.    <defaultCache3.            maxElementsInMemory="500" eternal="true" overflowToDisk="false" memoryStoreEvictionPolicy="LFU"/>4.    <cache name="contactCache" maxElementsInMemory="500" eternal="true" overflowToDisk="false"5.           memoryStoreEvictionPolicy="LFU"/>6.ehcache>

Adding caching to application-context.xml –


01.xml version="1.0" encoding="UTF-8"?>02.<beans xmlns="http://www.springframework.org/schema/beans"03.       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"04.       xmlns:ehcache="http://www.springmodules.org/schema/ehcache"05.       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd06.       http://www.springmodules.org/schema/ehcache http://www.springmodules.org/schema/cache/springmodules-ehcache.xsd07.       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">08. 09.    <ehcache:config configLocation="classpath:ehcache.xml" />10. 11.    <ehcache:proxy id="contactDAO" refId="contactDAOTarget">12.        <ehcache:caching cacheName="contactCache" methodName="findAll"/>13.        <ehcache:flushing cacheNames="contactCache" methodName="createContact" when="after"/>14.    ehcache:proxy>15. 16.    <bean id="contactDAOTarget" class="byteco.de.spring.ContactDAOImpl">17.        <property name="namedParameterJdbcTemplate" ref="jdbcTemplate">property>18.    bean>19. 20.    <bean id="datasource" class="org.apache.commons.dbcp.BasicDataSource">21.        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>22.        <property name="username" value="root"/>23.        <property name="password" value="password"/>24.        <property name="initialSize" value="5"/>25.        <property name="url" value="jdbc:mysql://localhost:3306/springjpa"/>26.    bean>27. 28.    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">29.        <constructor-arg type="javax.sql.DataSource" ref="datasource"/>30.    bean>31.beans>

Here is my test class -


01.package byteco.de.spring;02. 03.import org.junit.Test;04.import org.junit.runner.RunWith;05.import org.springframework.beans.factory.annotation.Autowired;06.import org.springframework.dao.DuplicateKeyException;07.import org.springframework.test.annotation.ExpectedException;08.import org.springframework.test.context.ContextConfiguration;09.import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;10. 11.import java.util.List;12. 13.import static org.junit.Assert.assertTrue;14. 15.@RunWith(SpringJUnit4ClassRunner.class)16.@ContextConfiguration(value = "/application-context.xml")17.public class ContactDAOTest {18. 19.    @Autowired20.    ContactDAO contactDAO;21. 22.    @Test23.    public void shouldCreateNewContact(){24.         assertTrue(contactDAO.createContact("gabbar","singh","gabbar@singh.com"));25.         assertTrue(contactDAO.createContact("kalia","singh","kalia@singh.com"));26.    }27. 28.    @Test29.    public void shouldReturnListOfContact(){30.        assertTrue(contactDAO.findAll().size()>0);31.        assertTrue(contactDAO.findAll().size()>0);32.        assertTrue(contactDAO.findAll().size()>0);33.        // This will cause the cache to be cleared. refer to logs.34.        assertTrue(contactDAO.createContact("samba","singh","samba@singh.com"));35.        assertTrue(contactDAO.findAll().size()>0);36.        assertTrue(contactDAO.findAll().size()>0);37.        assertTrue(contactDAO.findAll().size()>0);38.    }39.}

Executed test shouldCreateNewContact first then shouldReturnListOfContact. Below is the console output -


01.DEBUG[org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor]- Autowiring by type from bean name 'byteco.de.spring.ContactDAOTest'to bean named 'contactDAO'02.DEBUG[org.springframework.beans.factory.support.DefaultListableBeanFactory] -Returning cached instance of singleton bean'org.springframework.aop.aspectj.AspectJPointcutAdvisor#0'03.DEBUG[org.springframework.beans.factory.support.DefaultListableBeanFactory] -Returning cached instance of singleton bean'org.springframework.aop.aspectj.AspectJPointcutAdvisor#0'04.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel05.DEBUG [org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrieved cache element 06.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQL query07.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQL statement [select * from contact]08.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Fetching JDBC Connection from DataSource09.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Returning JDBC Connection to DataSource10.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt tostore the object <[0. 1 gabbar singh , 1. 2 kalia singh ]> in thecache using key <2056181503|2056171012> and model11.DEBUG [org.springmodules.cache.provider.ehcache.EhCacheFacade] - Object was successfully stored in the cache12.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel13.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrievedcache element <[0. 1 gabbar singh , 1. 2 kalia singh ]>14.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel15.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrievedcache element <[0. 1 gabbar singh , 1. 2 kalia singh ]>16.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQL update17.DEBUG[org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQLstatement [insert into contact (firstname,lastname,email) values(?,?,?)]18.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Fetching JDBC Connection from DataSource19.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - SQL update affected 1 rows20.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Returning JDBC Connection to DataSource21.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toflush the cache using model22.DEBUG [org.springmodules.cache.provider.ehcache.EhCacheFacade] - Cache has been flushed.23.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel24.DEBUG [org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrieved cache element 25.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQL query26.DEBUG [org.springframework.jdbc.core.JdbcTemplate] - Executing prepared SQL statement [select * from contact]27.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Fetching JDBC Connection from DataSource28.DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Returning JDBC Connection to DataSource29.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt tostore the object <[0. 1 gabbar singh , 1. 2 kalia singh , 2. 3 sambasingh ]> in the cache using key <2056181503|2056171012> andmodel30.DEBUG [org.springmodules.cache.provider.ehcache.EhCacheFacade] - Object was successfully stored in the cache31.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel32.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrievedcache element <[0. 1 gabbar singh , 1. 2 kalia singh , 2. 3 sambasingh ]>33.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Attempt toretrieve a cache entry using key <2056181503|2056171012> and cachemodel34.DEBUG[org.springmodules.cache.provider.ehcache.EhCacheFacade] - Retrievedcache element <[0. 1 gabbar singh , 1. 2 kalia singh , 2. 3 sambasingh ]>

Here are my DAO classes –


1.package byteco.de.spring;2.import java.util.List;3.public interface ContactDAO {4.    boolean createContact(String firstName, String lastName, String email);5.    List findAll();6.}

01.package byteco.de.spring;02. 03.import org.springframework.jdbc.core.JdbcTemplate;04.import org.springframework.jdbc.core.RowMapper;05.import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;06. 07.import java.sql.ResultSet;08.import java.sql.SQLException;09.import java.util.HashMap;10.import java.util.List;11.import java.util.Map;12. 13.public class ContactDAOImpl implements ContactDAO {14. 15.    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;16. 17.    public void setNamedParameterJdbcTemplate(NamedParameterJdbcTemplate namedParameterJdbcTemplate) {18.        this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;19.    }20. 21.    public boolean createContact(String firstName, String lastName, String email) {22.        Map map = new HashMap();23.        map.put("firstname",firstName);24.        map.put("lastname",lastName);25.        map.put("email",email);26.        int i = namedParameterJdbcTemplate.update("insert into contact (firstname,lastname,email) values (:firstname,:lastname,:email)", map);27.        return i>0;28.    }29. 30.    public List findAll() {31.        return namedParameterJdbcTemplate.query("select * from contact", (Map) null, new RowMapper() {32.            public Object mapRow(ResultSet resultSet, int i) throws SQLException {33.                return i + ". " + resultSet.getString(1) + " " + resultSet.getString(2) + " " + resultSet.getString(3) + " ";34.            }35.        });36.    }37.}

We are caching the result of findAll and clearing cache when createContact is executed.


Integrating Spring and EHCache Integrating Hive and HBase 配置Spring+hibernate使用ehcache作为second-level cache Ehcache Spring and Struts 2 Spring的好处，避免硬编码，处理依赖 二级 ehcache iBATIS中使用EHCache Ehcache 中ehcache.xml 配置详解和示例 spring festival Spring colors 【引用】Spring spring 定时器 Spring入门教程 Spring 入门教程 Spring定时器 Spring 系列: Spring 框架简介 Integrating Grammar into Communication in English Teaching Spring 系列: Spring 框架简介IBM Spring 中的JdbcTemplate使用 Spring定时器1 Spring定时器111 Spring文件加载方法 Spring定时器a Spring定时器B