ibatis加memcached缓存

ftsr

package com.ibatis.sqlmap.engine.cache.memcached;　　import java.io.Serializable;

　　public>　　private static Logger logger = Logger.getLogger(MemcachedManager.class);
　　private static String memcachedDomain = "IBATIS_CACHED"; // memcached 域名
　　private String serverlist;
　　private static MemCachedClient mcc = null;
　　private SockIOPool pool = null;
　　private int initConn = 5;
　　private int minConn = 5;
　　private int maxConn = 50;
　　public void init() {
　　if (mcc != null)
　　return;
　　logger.info("Initializing ibatis memcached start.");
　　if (pool == null) {
　　try {
　　pool = SockIOPool.getInstance(memcachedDomain);
　　pool.setServers(serverlist.split(","));
　　if (!pool.isInitialized()) {
　　pool.setInitConn(initConn);
　　pool.setMinConn(minConn);
　　pool.setMaxConn(maxConn);
　　pool.setMaintSleep(30);
　　pool.setNagle(false);
　　pool.setSocketTO(60 * 60);
　　pool.setSocketConnectTO(0);
　　pool.initialize();
　　}
　　} catch (Exception ex) {
　　logger.error(ex.getMessage());
　　}
　　}
　　if (mcc == null) {
　　mcc = new MemCachedClient(memcachedDomain);
　　mcc.setCompressEnable(false);
　　mcc.setCompressThreshold(0);
　　}
　　logger.info("Initializing youxigu Memcached ok!");
　　}
　　public void closePool() {
　　pool.shutDown();
　　mcc = null;
　　pool = null;
　　logger.info("Ibatis memcached pool closed");
　　}
　　public static boolean set(Object key, Serializable obj) {
　　logger.debug("set key:" + getKey(key) + ", value:" + obj);
　　try {
　　return mcc.set(getKey(key), obj);
　　} catch (Exception e) {
　　logger.error("Pool set error!");
　　e.printStackTrace();
　　}
　　return false;
　　}
　　public static boolean set(Object key, Serializable obj, long cacheTime) {
　　try {
　　return mcc.set(getKey(key), obj, new Date(cacheTime));
　　} catch (Exception e) {
　　logger.error("Pool set error!");
　　e.printStackTrace();
　　}
　　return false;
　　}
　　public static void replace(int key, Serializable value, long cacheTime) {
　　try {
　　mcc.replace(getKey(key), value, new Date(cacheTime));
　　} catch (Exception e) {
　　logger.error(" pool set error!");
　　}
　　}
　　public static Object get(Object key) {
　　Object result = null;
　　String realkey = getKey(key);
　　try {
　　result = mcc.get(realkey);
　　} catch (Exception e) {
　　e.printStackTrace();
　　}
　　logger.debug("get key:" + getKey(key) + ", value:" + result);
　　return result;
　　}
　　public static void setCounter(Object key, long count) {
　　try {
　　mcc.storeCounter(getCountKey(key), count);
　　} catch (Exception e) {
　　logger.error("Pool setCounter error!");
　　}
　　}
　　public static void addCounter(Object key) {
　　if (mcc.get(getCountKey(key)) == null) {
　　mcc.storeCounter(getCountKey(key), 0);
　　}
　　try {
　　mcc.incr(getCountKey(key));
　　} catch (Exception e) {
　　logger.error("Pool setCounter error!");
　　}
　　}
　　public static void decreaseCounter(Object key) {
　　try {
　　mcc.decr(getCountKey(key));
　　} catch (Exception e) {
　　logger.error("Pool setCounter error!");
　　}
　　}
　　public static void addCounter(Object key, long addValue) {
　　try {
　　mcc.incr(getCountKey(key), addValue);
　　} catch (Exception e) {
　　logger.error(" pool setCounter error!");
　　}
　　}
　　public static long getCounter(Object key) {
　　long result = 0;
　　try {
　　result = mcc.getCounter(getCountKey(key));
　　} catch (Exception e) {
　　logger.error(e.getMessage());
　　}
　　return result;
　　}
　　public static boolean delete(Object key) {
　　try {
　　return mcc.delete(getKey(key));
　　} catch (Exception e) {
　　logger.error(e.getMessage());
　　}
　　return false;
　　}
　　public static long deleteCounter(Object key) {
　　try {
　　return mcc.decr(getCountKey(key));
　　} catch (Exception e) {
　　logger.error(" pool setCounter error!");
　　}
　　return 0;
　　}
　　public static void flushAll() {
　　mcc.flushAll();
　　}
　　@SuppressWarnings("unchecked")

　　public static long>
　　long>　　Map status = mcc.statsItems();
　　Collection values = status.values();
　　for (Map state : values) {
　　String num = state.get("items:1:number");
　　if (num == null)
　　continue;

　　>　　}

　　return>　　}
　　private static String getKey(Object key) {
　　return memcachedDomain + "@" + key;
　　}
　　private static String getCountKey(Object key) {
　　return memcachedDomain + "@" + key + "_count";
　　}
　　public void setServerlist(String serverlist) {
　　this.serverlist = serverlist;
　　}
　　public void setInitConn(int initConn) {
　　this.initConn = initConn;
　　}
　　public void setMinConn(int minConn) {
　　this.minConn = minConn;
　　}
　　public void setMaxConn(int maxConn) {
　　this.maxConn = maxConn;
　　}
　　public void setMemcachedDomain(String memcachedKey) {
　　MemcachedManager.memcachedDomain = memcachedKey;
　　}
　　}