【EhCache】JavaキャッシュフレームワークSpring AOPとEhCacheを組み合わせた

10152 ワード

一.Ehcacheの概要    EhCacheは純粋なJavaのプロセス内キャッシュフレームワークであり、以下の特徴がある.    1.高速で簡単で、アプリケーションとの統合が非常に容易です.    2.複数のキャッシュポリシーをサポートします.    3.キャッシュデータには、メモリとディスクの2段階があるので、容量の問題を心配する必要はありません.    4.キャッシュデータは、仮想マシンの再起動中にディスクに書き込まれます.    5.分散キャッシュは、RMI、API挿入可能等により行うことができる.    6.キャッシュマネージャとキャッシュマネージャを備えたリスニングインタフェース.    7.マルチキャッシュマネージャインスタンス、および1つのインスタンスの複数のキャッシュ領域などの特徴をサポートします.二.Ehcache構成の関連パラメータ    Ehcacheの構成は柔軟で、公式に提供されている構成方法はいくつかあります.構成を宣言したり、xmlで構成したり、プログラムで構成したり、構造方法を呼び出したりすることで、異なるパラメータを入力することができます.次に、最も一般的なXML構成を例に、ehcache.xmlは最も一般的なファイルであり、ehcacheは一般的にCacheManagerによってclasspathからファイルをロードすることでCacheのインスタンス化を完了します.        1.ehcache.xmlの構成情報        ehcache.xmlクリップ:
Javaコード
 
      <ehcache>
            <diskStore path="java.io.tmpdir"/>
            <defaultCache
                name="name"
                    maxElementsInMemory="10000"
                    eternal="false"
                    timeToIdleSeconds="120"
                    timeToLiveSeconds="120"
                    overflowToDisk="true"
                    maxElementsOnDisk="10000000"
                    diskPersistent="false"
                    diskExpiryThreadIntervalSeconds="120"
                    memoryStoreEvictionPolicy="LRU"
                    />
        </ehcache>

 
     2.Cacheでよく使われるパラメータの具体的な意味        (1)name:Cacheの一意の識別子.        (2)maxElementsInMemory:メモリ内の最大キャッシュオブジェクト数.        (3)eternal:Elementが永続的に有効かどうかはtrueを設定するとtimeoutは機能しません.        (4)timeToIdleSeconds:Elementが無効になるまでの空き時間を設定します.elementが永続的に有効でない場合にのみ使用されます.オプションのプロパティで、デフォルト値は0です.つまり、アイドル時間は無限です.        (5)timeToLiveSeconds:Elementが失効するまでの生存時間を設定します.最大時間は作成時間と失効時間の間です.elementが永続的に有効でない場合にのみ使用されます.デフォルトは0です.つまり、elementの生存時間は無限です.        (6)overflowToDisk:メモリ内のElement数がmaxElementsInMemoryに達すると、EhcacheはディスクにElementを書き込むように設定します.        (7)maxElementsOnDisk:ディスク内の最大キャッシュオブジェクト数が0の場合無限大となります.        (8) MemoryStoreEveictionPolicy:maxElementsInMemoryの制限に達すると、Ehcacheは指定したポリシーに従ってキャッシュ内のコンテンツをクリーンアップします.デフォルトのポリシーはLRU(最近最も少ない使用)です.FIFO(先進的な先出し)またはLFU(少ない使用)に設定することもできます.    三.SpringとEhcacheの統合    1.ehcache.xml
 <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:noNamespaceSchemaLocation="ehcache.xsd">
       
            <diskStore path="java.io.tmpdir" />
       
            <defaultCache maxElementsInMemory="10000" eternal="false"
                timeToIdleSeconds="600" overflowToDisk="false">
            </defaultCache>
       
            <cache name="levelOneCache" maxElementsInMemory="1000" eternal="false"
                timeToIdleSeconds="300" timeToLiveSeconds="1000" overflowToDisk="false" />
        </ehcache>

 
    2.beans.xmlの構成
 <bean id="cacheManager"
            class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean">
            <property name="configLocation">
                <value>classpath:ehcache.xml</value>
            </property>
        </bean>

        <bean id="levelOneCache" class="org.springframework.cache.ehcache.EhCacheFactoryBean">
            <property name="cacheManager">
                <ref local="cacheManager" />
            </property>
            <property name="cacheName">
                <value>configCache</value>
            </property>
        </bean>

 
    3.テストクラス
Java
        package org.mango.cache.ehcache;
       
        import net.sf.ehcache.Cache;
        import net.sf.ehcache.CacheManager;
        import net.sf.ehcache.Element;
       
        import org.springframework.beans.factory.BeanFactory;
        import org.springframework.beans.factory.xml.XmlBeanFactory;
        import org.springframework.core.io.ClassPathResource;
        import org.springframework.core.io.Resource;
       
        public class EhcacheTest {
       
            public static void main(String[] args) {
                Resource res = new ClassPathResource("beans.xml");
                BeanFactory factory = new XmlBeanFactory(res);
       
                CacheManager cacheManager = (CacheManager) factory.getBean("cacheManager");
                Cache levelOneCache = cacheManager.getCache("levelOneCache");
                CacheObject cacheObject = null;
                for (int i = 0; i < 10; i++) {
                    Element element = levelOneCache.get("key");
       
                    if (element == null) {
                        cacheObject = new CacheObject("test");
                        element = new Element("key", cacheObject);
                        levelOneCache.put(element);
                        System.out.println("cacheObject[" + cacheObject + "]" + ",        ");
                    } else {
                        cacheObject = (CacheObject) element.getValue();
                        System.out.println("cacheObject[" + cacheObject + "]" + ",      ");
                    }
                }
            }
        }
 
        出力は次のとおりです.
 
        cacheObject[name:test],        
        cacheObject[name:test],      
        cacheObject[name:test],      
        cacheObject[name:test],      
        cacheObject[name:test],      
   

        四.Spring AOPとEhcacheを利用してスレッドレベルの方法キャッシュを実現する    複雑なビジネスロジックや1回の計算で同じDAOまたはリモート・サービスを複数回呼び出す必要がある場合、計算結果をキャッシュでき、不要な呼び出し回数を減らすだけでなく、システムの演算性能を向上させることができます.次に、サービスをキャッシュする例を挙げて、その使い方を説明します.        1.TestServiceインタフェース
 public interface TestService {
       
            /**
             *   userId     。
             *
             * @param userId
             * @return 
             */
            public String getUserName(String userId);
        }
 
        2.TestServiceImpl実装クラス
 public class TestServiceImpl implements TestService {
            /*
             * @see  org.mango.cache.ehcache.TestService#getUserName(java.lang.String)
             */
            public String getUserName(String userId) {
                return userId;
            }
        }

 
    3.遮断器の実現
 public class CacheInterceptor implements MethodInterceptor {
       
            private Cache cache;
       
            /**
             * @see  org.aopalliance.intercept.MethodInterceptor#invoke(org.aopalliance.intercept.MethodInvocation)
             */
            public Object invoke(MethodInvocation invocation) throws Throwable {
                Method method = invocation.getMethod();
                String methodName = method.getName();
                Object[] arguments = invocation.getArguments();
                Object result = invocation.proceed();
       
                String targetName = method.getDeclaringClass().getName();
                String key = getCacheKey(targetName, methodName, arguments);
       
                Element element = cache.get(key);
       
                if (element == null) {
       
                    result = invocation.proceed();
                    System.out.println("            :" + result);
                    cache.put(new Element(key, result));
                } else {
                    result = element.getValue();
                    System.out.println("         :" + result);
                }
                return result;
       
            }
       
            /**
             *       KEY 。
             */
            protected String getCacheKey(String targetName, String methodName, Object[] arguments) {
                StringBuffer sb = new StringBuffer();
                sb.append(targetName).append(".").append(methodName);
                if ((arguments != null) && (arguments.length != 0)) {
                    for (int i = 0; i < arguments.length; i++) {
                        sb.append(".").append(arguments[i]);
                    }
                }
                return sb.toString();
            }
       
            public void setCache(Cache cache) {
                this.cache = cache;
            }
       
        }
 
    4.Beanの構成
 <bean id="testService" class="org.mango.cache.ehcache.TestServiceImpl" />
   
        <bean id="serviceMethodInterceptor" class="org.mango.cache.ehcache.CacheInterceptor">
            <property name="cache">
                <ref local="levelOneCache" />
            </property>
        </bean>
   
        <bean id="serviceAutoProxyCreator"
            class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
            <property name="interceptorNames">
                <list>
                    <value>serviceMethodInterceptor</value>
                </list>
            </property>
            <property name="beanNames">
                <value>*Service</value>
            </property>
        </bean>

 
    5.試験方法
 public class ServiceTest {
           public static void main(String[] args) {
                ApplicationContext context = new ClassPathXmlApplicationContext("beans.xml");
                TestService testService = (TestService) context.getBean("testService");
                for (int i = 0; i < 5; i++) {
                    testService.getUserName("mango");
                }
            }
        }

 
        出力結果は次のとおりです.
             :mango
         :mango
         :mango
         :mango
         :mango