ehcache使用，以及集群配置

package com.ehcache; import java.io.IOException; import java.io.InputStream; import java.util.List; import net.sf.ehcache.Cache; import net.sf.ehcache.CacheManager; import net.sf.ehcache.Ehcache; import net.sf.ehcache.Element; import net.sf.ehcache.distribution.CacheManagerPeerProvider; public class MyDataAccessClass { private Ehcache cache=null; private static MyDataAccessClass myDataAccessClass=new MyDataAccessClass(); private MyDataAccessClass() { this.cache=getCache(); } /* read some data, check cache first, otherwise read from sor */ public Object readSomeData(Object key) { Element element; Object value=null; if ((element = cache.get(key)) != null) { return element.getObjectValue(); } // note here you should decide whether your cache // will cache 'nulls' or not // if (value = readDataFromDataStore(key)) != null) { // cache.put(new Element(key, value)); // } return value; } /* write some data, write to sor, then update cache */ public void writeSomeData(Object key, Object value) { // writeDataToDataStore(key, value); cache.put(new Element(key, value)); } public static MyDataAccessClass getInstance(){ return myDataAccessClass; } private static Cache getCache(){ InputStream fis = MyDataAccessClass.class.getClassLoader().getResourceAsStream("ehcache.xml"); CacheManager manager=null; try { manager=CacheManager.create(fis); // manager = CacheManager.newInstance(fis); Cache oneCache = manager.getCache("myCache"); return oneCache; } finally { try { if(fis!=null){ fis.close(); fis=null; } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public static void main(String[] args) { InputStream fis = MyDataAccessClass.class.getClassLoader().getResourceAsStream("ehcache.xml"); CacheManager manager=null; try { manager=CacheManager.create(fis); } finally { try { if(fis!=null){ fis.close(); fis=null; } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } Cache cache=manager.getCache("myCache"); CacheManagerPeerProvider provider = manager.getCacheManagerPeerProvider("RMI"); System.out.println(manager.getCacheManagerPeerProviders().size()); System.out.println(provider); List list=provider.listRemoteCachePeers(cache); System.out.println(list.size()); manager.shutdown(); } }