MemCached java 操作

package com.xmail.wm.common.memcache.test;

import java.util.Date;

import com.danga.MemCached.MemCachedClient;

import com.danga.MemCached.SockIOPool;

public class Test {

// 創建全局的唯一實例

protected static MemCachedClient mcc = new MemCachedClient（）；

protected static Test memCached = new Test（）；

// 設置與緩存伺服器的連接池

static {

// 伺服器列表和其權重

String[] servers = {"127.0.0.1:11211"};

Integer[] weights = {3};

// 獲取socke連接池的實例對象

SockIOPool pool = SockIOPool.getInstance（）；

// 設置伺服器信息

pool.setServers（ servers ）；

pool.setWeights（ weights ）；

// 設置初始連接數、最小和最大連接數以及最大處理時間

pool.setInitConn（ 5 ）；

pool.setMinConn（ 5 ）；

pool.setMaxConn（ 250 ）；

pool.setMaxIdle（ 1000 * 60 * 60 * 6 ）；

// 設置主線程的睡眠時間

pool.setMaintSleep（ 30 ）；

// 設置TCP的參數,連接超時等

pool.setNagle（ false ）；

pool.setSocketTO（ 3000 ）；

pool.setSocketConnectTO（ 0 ）；

// 初始化連接池

pool.initialize（）；

// 壓縮設置,超過指定大小（單位為K）的數據都會被壓縮

mcc.setCompressEnable（ true ）；

mcc.setCompressThreshold（ 64 * 1024 ）；

}

/**

* 保護型構造方法,不允許實例化！

*

*/

protected Test（）

{

}

/**

* 獲取唯一實例.

* @return

*/

public static Test getInstance（）

{

return memCached;

}

/**

* 添加一個指定的值到緩存中.

* @param key

* @param value

* @return

*/

public boolean add（String key, Object value）

{

return mcc.add（key, value）；

}

public boolean add（String key, Object value, Date expiry）

{

return mcc.add（key, value, expiry）；

}

public boolean replace（String key, Object value）

{

return mcc.replace（key, value）；

}

public boolean replace（String key, Object value, Date expiry）

{

return mcc.replace（key, value, expiry）；

}

/**

* 根據指定的關鍵字獲取對象.

* @param key

* @return

*/

public Object get（String key）

{

return mcc.get（key）；

}

public static void main（String[] args）

{

Test cache = Test.getInstance（）；

cache.add（"hello", 234）；

System.out.print（"get value : " cache.get（"hello"））；

}

}

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.1.20\", 12111））；

Future<Boolean> b = null;

/*將key值,過期時間（秒）和要緩存的對象set到memcached中*/

b = mc.set（\"neea:testDaF:ksIdno\", 900, \"someObject\"）；

if（b.get（）.booleanValue（）==true）{

mc.shutdown（）；

}

}

catch（Exception ex）{

ex.printStackTrace（）；

}

}

}

Tags: