使用+ Spring + Struts應用程序的Ehcache併發修改異常

在我的應用程序中，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被配置爲單例而不是實例。

Web應用程序使用struts（2.3.20）框架進行Web流程和Spring框架（4.1.2）進行DI對象管理。

此外JSP的用戶界面我們迭代使用bean對象，其中有列表顯示內容。

我們從1.2.2遷移到ehcache 2.9.0，只是在spring xml上下文中更改jar和配置。遷移後，我們開始經常收到以下異常。

net.sf.ehcache.CacheException：由於ConcurrentModificationException而無法序列化元素。這通常是由net.sf.ehcache.store.disk.DiskStorageFactory.serializeElement（DiskStorageFactory.java:405）處的線程在net.sf之間不恰當地共享線程不安全對象（例如，ArrayList，HashMap等）造成的。 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）在net.sf.ehcache.store.disk.DiskStorageFactory $ PersistentDiskWriteTask.call（DiskStorageFactory.java:1055）在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 在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）在java.io.ObjectOutputStream.writeSerialData（ObjectOutputStream.java:1496）在java.io.ObjectOutputStream.writeOrdinaryObject（ObjectOutputStream.java:1432）在java.io.ObjectOutputStream中。 writeObject0（ObjectOutputStream.java:1178） at java.io.ObjectOutputStream.defaultWriteFields（ObjectOutputStream.java:1548） at java.io.ObjectOutputStream.writeSerialData（ObjectOutputStream.java:1509）在java.io.ObjectOutputStream.writeOrdinaryObject（ObjectOutputStream.java:1432）在java.io.ObjectOutputStream.writeObject0（ObjectOutputStream.java:1178）在java.io.ObjectOutputStream中。 defaultWriteFields（ObjectOutputStream.java:1548）在java.io.ObjectOutputStream.defaultWriteObject（ObjectOutputStream.java:441）在net.sf.ehcache.Element.writeObject（Element.java:875）

我的理解爲什麼會發生這樣的情況，當ehcache試圖寫入磁盤時，另一個線程正在修改序列化的列表。我無法找到哪個線程和它的可能性。

是否有一個關於如何使用ehcache的例子，就像這樣在沒有註解的情況下使用編程方式在spring中使用。

以及如何確定導致此問題

來源

2016-08-29 Tim

線程任何瞭解你有兩個選擇：

找到所有的代碼路徑變異的任何對象，你的緩存後
確保你緩存是不可變的

如果你能以這種方式重構你的應用程序，我會傾向於選項2。

此問題絕對不是由您連接不同參與者對象的方式造成的，而這種方式在所提供的示例中並未使用註釋。

來源

2016-08-31 12:00:57

使用+ Spring + Struts應用程序的Ehcache併發修改異常

回答

相關問題