cache-demo-2.5.zip_Cache2.5_DEMO_cache

/** * */ package com.alisoft.xplatform.asf.cache; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Iterator; import java.util.Map; import java.util.Set; import org.junit.AfterClass; import org.junit.Assert; import org.junit.BeforeClass; import org.junit.Ignore; import org.junit.Test; import com.alisoft.xplatform.asf.cache.memcached.CacheUtil; import com.alisoft.xplatform.asf.cache.memcached.MemcacheStats; import com.alisoft.xplatform.asf.cache.memcached.MemcacheStatsSlab; import com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager; import com.alisoft.xplatform.asf.cache.memcached.MemcachedResponse; import com.alisoft.xplatform.asf.cache.memcached.MemcacheStatsSlab.Slab; /** * @author wenchu.cenwc * */ public class IMemcachedCacheTest { static ICacheManager<IMemcachedCache> manager; /** * @throws java.lang.Exception */ @BeforeClass public static void setUpBeforeClass() throws Exception { manager = CacheUtil.getCacheManager(IMemcachedCache.class, MemcachedCacheManager.class.getName()); manager.setConfigFile("memcached1.xml"); manager.setResponseStatInterval(5*1000); manager.start(); } /** * @throws java.lang.Exception */ @AfterClass public static void tearDownAfterClass() throws Exception { manager.stop(); } /** * Test method for {@link com.alisoft.xplatform.asf.cache.ICache#get(java.lang.Object)}. */ @Test public void testGet() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.remove("key2你好"); cache.put("key1", "1"); cache.put("key2你好", "你好123"); Assert.assertEquals(cache.get("key1"),"1"); Assert.assertEquals(cache.get("key2你好"),"你好123"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.ICache#remove(java.lang.Object)}. */ @Test public void testRemove() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.put("key1", "value1"); Assert.assertEquals(cache.get("key1"),"value1"); cache.remove("key1"); Assert.assertNull(cache.get("key1")); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } @Test public void testKeysetValues() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.clear(); Thread.sleep(2000); cache.put("key1", "value1"); cache.put("key2", "value2"); Set<String> keys = cache.keySet(false); String[] c = new String[2]; keys.toArray(c); if ((c[0].equals("key1")&&c[1].equals("key2")) ||(c[0].equals("key2")&&c[1].equals("key1"))) Assert.assertTrue(true); else Assert.assertTrue(false); cache.values().toArray(c); if ((c[0].equals("value1")&&c[1].equals("value2")) ||(c[0].equals("value1")&&c[1].equals("value2"))) Assert.assertTrue(true); else Assert.assertTrue(false); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } @Test public void testcontainsKey() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.put("key1", "value1"); Assert.assertTrue(cache.containsKey("key1")); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#get(java.lang.String, int)}. */ @Test public void testGetStringInt() { try { IMemcachedCache cache1 = manager.getCache("mclient1"); IMemcachedCache cache2 = manager.getCache("mclient2"); cache1.remove("key1"); cache1.remove("key2"); cache2.remove("key1"); cache2.remove("key2"); cache1.put("key1", "value1"); cache1.put("key2", "value2"); Assert.assertEquals(cache1.get("key1",30),"value1"); Assert.assertEquals(cache1.get("key2"),"value2"); Assert.assertEquals(cache2.get("key1",30),"value1"); Assert.assertEquals(cache2.get("key2"),"value2"); cache1.put("key1", "value3"); Assert.assertEquals(cache1.get("key1",30),"value3"); Assert.assertEquals(cache2.get("key1",30),"value1"); Assert.assertEquals(cache2.get("key1"),"value3"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } @Test public void testgetMulti() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.remove("key2"); cache.put("key1", "value1"); cache.put("key2", "value2"); Map<String,Object> result = cache.getMulti(new String[]{"key1","key2"}); Assert.assertEquals(result.get("key1"), "value1"); Assert.assertEquals(result.get("key2"), "value2"); Object[] values = cache.getMultiArray(new String[]{"key1","key2"}); if ((values[0].equals("value1") && values[1].equals("value2")) ||(values[0].equals("value1") && values[1].equals("value2"))) Assert.assertTrue(true); else Assert.assertTrue(false); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#incr(java.lang.String, long)}. */ @Test public void testIncr() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("counter"); cache.storeCounter("counter", 20); Assert.assertEquals(cache.incr("counter", 11),31); cache.remove("counter"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#decr(java.lang.String, long)}. */ @Test public void testDecr() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("counter"); cache.storeCounter("counter", 20); Assert.assertEquals(cache.decr("counter", 11),9); cache.remove("counter"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#addOrIncr(java.lang.String, long)}. */ @Test public void testAddOrIncr() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("counter"); Assert.assertEquals(cache.addOrIncr("counter", 20),20); Assert.assertEquals(cache.addOrIncr("counter", 20),40); cache.remove("counter"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#addOrDecr(java.lang.String, long)}. */ @Test public void testAddOrDecr() { try { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("counter"); Assert.assertEquals(cache.addOrDecr("counter", 20),20); Assert.assertEquals(cache.addOrDecr("counter", 10),10); cache.remove("counter"); } catch(Exception ex) { ex.printStackTrace(); Assert.assertTrue(false); } } /** * Test method for {@link com.alisoft.xplatform.asf.cache.IMemcachedCache#statsSlabs()}. */ @Test public void testStatsSlabs() { IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.remove("key2"); cache.remove("key3"); cache.remove("key4"); cache.remove("key5"); cache.remove("key6"); cache.put("key1", "value1"); cache.put("key2", "value