2016-08-29 5 views
1

내 응용 프로그램에서 ehcache는 다음과 같이 구성됩니다.+ Spring + Struts 응용 프로그램을 사용하는 Ehcache 동시 수정 예외

AppDataRegion.java

//import statements. 

public class AppDataRegion{ 

//Variable for region identifier. 
private String appRegionId; 

// constructor sets the appRegionId; 
//obtained from the system current time. 
public AppDataRegion(){ 
appRegionId = String.valueOf(System.currentTimeMillis()); 
} 

//Variable for cachemanager 
// injected by spring DI from context xml 
Private CacheManager appCacheMngr; 

//necessary getter/setter methods for variable cachemanager 
//necessary getter/setter methods for variable appRegionId 

//method to create a region in cache using the appRegionId value 
private createRegion(){ 
    if (!appCacheMngr.cacheExists(appRegionId)){ 
    try { 
     appCacheMngr.addCache(appRegionId); 
    catch (exc){ 
    //exception handled 
    } 
    } 
} 

public Cache getRegion(){ 
if(appCacheMngr == null || !appCacheMngr.cacheExists(appRegionId)){ 
createRegion(); 
} 
return appCacheMangr.getCache(appRegionId); 
} 
private createCustRegion(){ 
    try{ 
    Cache custCache = appCacheMngr.getCache(“custdiskCache”); 
    If(null == custCache.addCache(custCache); 
    }catch (exp){ 
    //handled the exceptions 
} 
retrun appCacheMngr.getCache(“custdiskCache”); 
} 
} 

Spring 설정 응용 프로그램 데이터를 저장 지역에 대한 서비스 계층이 //

<bean id="appDataStoreService" class="com.app.cache.AppDataStoreService" >  
     <property name="appDataStoreRegion" ref="appDataStoreRegion"/> 
    </bean> 

    <bean id="appDataStoreRegion" class="com.app.cache.AppDataStoreRegion">   
     <property name="appcacheManager" ref="cacheManager"/> 
    </bean> 

<bean id="cacheManager" class="net.sf.ehcache.CacheManager" factory-method="create">  
     <constructor-arg index="0" type="java.net.URL" value="classpath:ehcache-app.xml" /> 
    </bean> 

. 응용 프로그램 내에서

public class AppDataStoreService{ 

//datastoreregion variable declaration 
private AppDataStoreRegion appDataStoreRegion; 


public void storeCustObjInCache(String id, Object obj){ 
    Cache region = appDataStoreRegion.getCustRegion(); 
    If(region != null && id !=null && region.isElementInMemory(id)){ 
    region.remove(id); 
} 
Element ele = new Element(id, obj); 
If(region != null) region.put(ele); 
} 
} 

DTO 객체에 데이터를 채우는 후 나는 디스크에 내용을 작성하는 appDataStoreService 클래스의 storeCustObjInCache() 메서드를 호출합니다.

ehcache는 인스턴스가 아닌 싱글 톤으로 구성됩니다.

웹 응용 프로그램은 웹 흐름을위한 struts (2.3.20) 프레임 워크와 DI 객체 관리를위한 Spring 프레임 워크 (4.1.2)를 사용합니다.

UI 용 JSP 또한 내용을 표시하는 목록이있는 사용 Bean 객체를 반복합니다.

봄 xml 컨텍스트에서 jar 및 구성을 변경하기 만하면 1.2.2에서 ehcache 2.9.0으로 마이그레이션되었습니다. 이전 후 우리는 아래 예외를 자주 받기 시작했습니다.

net.sf.ehcache.CacheException : ConcurrentModificationException으로 인해 요소를 직렬화하지 못했습니다. 이는 종종 스레드 간의 안전하지 않은 스레드 객체 (예 : ArrayList, HashMap 등)를 부적절하게 공유 한 결과입니다. at net.sf.ehcache.store.disk.DiskStorageFactory.serializeElement (DiskStorageFactory.java:405) at net.sf. ehcache.store.disk.DiskStorageFactory.write (DiskStorageFactory.java:385) at net.sf.ehcache.store.disk.DiskStorageFactory $ DiskWriteTask.call (DiskStorageFactory.java:477) at net.sf.ehcache.store. disk.DiskStorageFactory $ PersistentDiskWriteTask.call (DiskStorageFactory.java:1071) at net.sf.ehcache.store.disk.DiskStorageFactory $ PersistentDiskWriteTask.call (DiskStorageFactory.java:1055) at java.util.concurrent.FutureTask.run (FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 201 (ScheduledThread PoolExecutor.java:180) java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:293) java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142에서 ) java.util의에서 에서 . concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:617) 에서 java.lang.Thread.run (Thread.java:745) 발생 원인 : java.util.ConcurrentModificationException at java.util.ArrayList.writeObject (ArrayList 된 .java : 766) sun.reflect.GeneratedMethodAccessor8008.invoke (알 수없는 소스) sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43에서 ) java.lang.reflect.Method.invoke에서 (Method.java에서 : 497) at java.io. ObjectStreamClass.invokeWriteObject (ObjectStreamClass.java:988) at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1496) at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432) at java.io.ObjectOutputStream. (java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548) 에서 writeObject0ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509) at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432) at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178) at java.io.ObjectOutputStream. net.sf.ehcache.Element.writeObject에서 java.io.ObjectOutputStream.defaultWriteObject (ObjectOutputStream.java:441) 에서 defaultWriteFields (ObjectOutputStream.java:1548) (Element.java:875)

나의 이해 왜 이런 일이 일어 났을 때 ehcache가 디스크에 쓰려고 할 때 다른 스레드가 직렬화 된 목록을 수정하고 있습니다. 어떤 스레드와 그 가능성을 찾을 수 없었습니다.

봄 내에 주석없이 프로그래밍 방식으로 ehcache를 사용하는 방법에 대한 예제가 있습니까?

그리고이 문제

답변

2

을 유발하는 스레드를 식별하는 방법에 대한 통찰력을 당신은 두 가지 옵션이 있습니다 : 당신이 그것을 캐시 후

  1. 이 있는지 어떻게 확인 개체를 돌연변이 모든 코드 경로를 찾기를하면 캐시가 변경 불가능합니다

그런 식으로 리팩터링 할 수 있다면 옵션 2를 선호합니다.

이 문제는 제공되는 예제에서 주석을 사용하지 않는 다른 참여자 객체를 연결하는 방법으로 인해 발생하는 것은 아닙니다.