package com.dxz.cache.memcachedclient;import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;public class TestMemcached {public static void main(String[] args) {/* 初始化SockIOPool，管理memcached的连接池 */String[] servers = { "192.168.8.28:11211" };SockIOPool pool = SockIOPool.getInstance();pool.setServers(servers);pool.setFailover(true);pool.setInitConn(10);pool.setMinConn(5);pool.setMaxConn(250);pool.setMaintSleep(30);pool.setNagle(false);pool.setSocketTO(3000);pool.setAliveCheck(true);pool.initialize();/* 建立MemcachedClient实例 */MemCachedClient memCachedClient = new MemCachedClient();for (int i = 0; i < 3; i++) {/* 将对象加入到memcached缓存 */boolean success = memCachedClient.set("" + i, "Hello!");/* 从memcached缓存中按key值取对象 */String result = (String) memCachedClient.get("" + i);System.out.println(String.format("set( %d ): %s", i, success));System.out.println(String.format("get( %d ): %s", i, result));}}
}

package com.dxz.cache.spymemcached;import java.net.InetSocketAddress;
import java.util.concurrent.Future;import net.spy.memcached.MemcachedClient;public class MClient {public static void main(String[] args) {try {/* 建立MemcachedClient 实例，并指定memcached服务的IP地址和端口号 */MemcachedClient mc = new MemcachedClient(new InetSocketAddress("192.168.8.28", 11211));Future<Boolean> b = null;/* 将key值，过期时间(秒)和要缓存的对象set到memcached中 */b = mc.set("abcd123", 900, "someObject");System.out.println("set():" + b);/* 按照key值从memcached中查找缓存，不存在则返回null */Object c = mc.get("abcd123");System.out.println("get():" + c);if (b.get().booleanValue() == true) {mc.shutdown();}} catch (Exception ex) {ex.printStackTrace();}}
}