memcache实现网站全局计数器

package com.liu.memcache.tools; import java.io.IOException; import net.rubyeye.xmemcached.Counter; import net.rubyeye.xmemcached.MemcachedClient; import net.rubyeye.xmemcached.MemcachedClientBuilder; import net.rubyeye.xmemcached.XMemcachedClientBuilder; import net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator; import net.rubyeye.xmemcached.utils.AddrUtil; public class MemCachedTools { private static final MemCachedTools instance = new MemCachedTools(); /** * instance * * @return */ public static MemCachedTools getInstance() { return instance; } private static String memcached_address = ConfigUtil.getInstance() .getString("memcached_address"); private static String memcached_head=ConfigUtil.getInstance() .getString("memcached_head"); /** * 值增加1 * @param key * @return */ public long increaseValue(String key){ long addResult=0; String memKey=memcached_head+":"+Md5Hex.getDigestMD5(key); try { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(memcached_address)); builder.setSessionLocator(new KetamaMemcachedSessionLocator()); MemcachedClient memcachedClient = builder.build(); Counter counter=memcachedClient.getCounter(memKey); addResult=counter.incrementAndGet(); try { // close memcached client memcachedClient.shutdown(); } catch (IOException e) { System.err.println("Shutdown MemcachedClient fail"); e.printStackTrace(); } } catch (Exception ex) { ex.printStackTrace(); // return ERROR; } System.out.println("================"+addResult); return addResult; } /** * 初始化计数器 * @param key * @param defaultValue */ public void initCounter(String key,long defaultValue){ String memKey=memcached_head+":"+Md5Hex.getDigestMD5(key); try { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(memcached_address)); builder.setSessionLocator(new KetamaMemcachedSessionLocator()); MemcachedClient memcachedClient = builder.build(); Counter counter=memcachedClient.getCounter(memKey,defaultValue); counter.set(defaultValue); try { // close memcached client memcachedClient.shutdown(); } catch (IOException e) { System.err.println("Shutdown MemcachedClient fail"); e.printStackTrace(); } } catch (Exception ex) { ex.printStackTrace(); // return ERROR; } } /** * 获取计数器的值 * @param key * @return */ public long getCounterValue(String key){ String memKey=memcached_head+":"+Md5Hex.getDigestMD5(key); long ret=0; try { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(memcached_address)); builder.setSessionLocator(new KetamaMemcachedSessionLocator()); MemcachedClient memcachedClient = builder.build(); Counter counter=memcachedClient.getCounter(memKey); ret= counter.get(); try { // close memcached client memcachedClient.shutdown(); } catch (IOException e) { System.err.println("Shutdown MemcachedClient fail"); e.printStackTrace(); } } catch (Exception ex) { ex.printStackTrace(); // return ERROR; } return ret; } }