import net.sf.ehcache.CacheManager;
import net.sf.ehcache.config.CacheConfiguration;
import net.sf.ehcache.config.Configuration;
import net.sf.ehcache.config.ConfigurationFactory;

public class LocalCacheReplicationExample {

    public static void main(String[] args) {
        // Ehcache 설정 파일 로드
        Configuration configuration = ConfigurationFactory.parseConfiguration(new File("ehcache.xml"));

        // 캐시 매니저 생성
        CacheManager cacheManager = new CacheManager(configuration);

        // 복제할 캐시 설정
        CacheConfiguration cacheConfiguration = new CacheConfiguration("myCache", 1000)
                .eternal(false)
                .timeToLiveSeconds(60)
                .timeToIdleSeconds(30)
                .diskExpiryThreadIntervalSeconds(0)
                .memoryStoreEvictionPolicy("LRU")
                .persistence(new PersistenceConfiguration().strategy(PersistenceConfiguration.Strategy.NONE));

        // 로컬 캐시 복제 설정
        cacheConfiguration.addCachePeer(new CachePeerConfiguration()
                .name("replica1")
                .uri("rmi://localhost:40001/myCache")
                .replicateAsynchronously(true)
                .replicatePuts(true)
                .replicateUpdates(true)
                .replicateRemovals(true));

        // 로컬 캐시 생성
        cacheManager.addCache(new Cache(cacheConfiguration));

        // 캐시 사용 예시
        Cache cache = cacheManager.getCache("myCache");
        cache.put(new Element("key1", "value1"));
        Element element = cache.get("key1");

        System.out.println(element.getObjectValue());

        // 캐시 매니저 종료
        cacheManager.shutdown();
    }
}