上一篇介紹了Memcached基本使用方法《Memcached使用手冊》,下面介紹java如何操作memcached。使用的是java_memcached-release_2.6.6。
一、使用方法
新建項目,添加相關jar包:

直接上代碼了,注釋寫的很詳細,不用多說了啊。
package www.xufei.com;import com.danga.MemCached.MemCachedClient;import com.danga.MemCached.SockIOPool;public class MemcachedDemo {public static void main(String[] args) {//memcached服務器String[] servers = {"127.0.0.1:11211","192.168.1.3:11211"};/** * 設置連接池可用cache服務器的權重,和server數(shù)組的位置一一對應 */Integer[] weights = {1,2};/** * 這個類用來創(chuàng)建管理客戶端和服務器通訊連接池,客戶端主要的工作包括數(shù)據(jù)通訊、服務器定位、hash碼生成等都是由這個類完成的。 * 獲得連接池的單態(tài)方法。這個方法有一個重載方法getInstance( String poolName ),每個poolName只構造一個SockIOPool實例。 * 缺省構造的poolName是default。 */SockIOPool pool = SockIOPool.getInstance();//設置memcached服務器pool.setServers(servers);//設置memcached服務器權重pool.setWeights(weights);//設置容錯開關設置為TRUE,當當前socket不可用時,程序會自動查找可用連接并返回,否則返回NULL,默認狀態(tài)是true,建議保持默認pool.setFailover( true );//設置開始時每個cache服務器的可用連接數(shù)pool.setInitConn( 10 ); //設置每個服務器最少可用連接數(shù)pool.setMinConn( 5 );//設置每個服務器最大可用連接數(shù)pool.setMaxConn( 250 );/** * 設置連接池維護線程的睡眠時間 * 設置為0,維護線程不啟動 * 維護線程主要通過log輸出socket的運行狀況,監(jiān)測連接數(shù)目及空閑等待時間等參數(shù)以控制連接創(chuàng)建和關閉。 */pool.setMaintSleep( 30 );/** * 設置是否使用Nagle算法,因為我們的通訊數(shù)據(jù)量通常都比較大(相對TCP控制數(shù)據(jù))而且要求響應及時,因此該值需要設置為false(默認是true) */pool.setNagle( false );/** * 設置socket的讀取等待超時值 */pool.setSocketTO( 3000 );/** * 設置連接心跳監(jiān)測開關。 * 設為true則每次通信都要進行連接是否有效的監(jiān)測,造成通信次數(shù)倍增,加大網(wǎng)絡負載,因此該參數(shù)應該在對HA要求比較高的場合設為TRUE,默認狀態(tài)是false。 */pool.setAliveCheck( true );/** * 設置完pool參數(shù)后最后調(diào)用該方法,啟動pool。 */pool.initialize();/** * 創(chuàng)建一個memcached客戶端,所有對memcached中數(shù)據(jù)操作的方法都在這個類里面 */MemCachedClient memCachedClient = new MemCachedClient();/** * 存儲一個username,值為劉德華,存儲成功返回true */boolean success = memCachedClient.set("username", "劉德華");System.out.PRintln(success);/** * 從緩存中獲取一個key為username的數(shù)據(jù) */Object o = memCachedClient.get("username");System.out.println(o);/** * 定義一個p對象,Persion類必須實現(xiàn)Serializable接口 */Persion p = new Persion();p.setId("1");p.setName("周杰倫");/** * 緩存一個p對象 */memCachedClient.set("p1", p);/** * 獲取緩存的p對象 */Persion p1 = (Persion) memCachedClient.get("p1");System.out.println(p1.getName());/** * 調(diào)用add方法添加一個key為p1的對象,值123是不能添加進緩存的,因為p1已經(jīng)添加過一次了 */memCachedClient.add("p1", 123);//錯誤!無法更新p1的值System.out.println(memCachedClient.get("p1"));//還是person對象/** * 使用set方法可以更新p1 */memCachedClient.set("p1", 123);System.out.println(memCachedClient.get("p1"));//輸出123/** * 使用replace方法可以更新p1 */memCachedClient.replace("p1", 456);System.out.println(memCachedClient.get("p1"));//輸出456/** * 使用replace方法可以更新p2,緩存中不含有key為p2的數(shù)據(jù),無法更新,不會添加 */memCachedClient.replace("p2", 456);System.out.println(memCachedClient.get("p2"));//輸出null/** * 刪除key為p1的緩存數(shù)據(jù) */memCachedClient.delete("p1");System.out.println(memCachedClient.get("p1"));//輸出null}}
二、常用方法說明
1、SockIOPool是socket連接池類
setServers(String[] servers):設置服務器信息數(shù)組;
setWeights(String[] weights):設置服務器權重數(shù)組;
setInitConn(int count):設置初始連接數(shù);
setMinConn(int minConn):設置最小連接數(shù);
setMaxConn(int maxConn):設置最大連接數(shù);
setMaxIdle(long arg0):設置最大處理時間;
setMaintSleep(long arg0):主線程的睡眠時間;
initialize():初始化連接池。
2、MemCachedClient類及其常用方法
add(String key, Object value):添加一個鍵值對到緩存中;
add(String key, Object value,Date expires):添加一個鍵值對到緩存中,并設置其超時時間;
set(String key, Object value):在緩存中設置一個鍵的值;
set(String key, Object value, Date expires):在緩存中設置一個鍵的值,并設置其超時時間;
get(String key):獲得某個鍵的值。
incr(String key):為某個鍵上的值執(zhí)行+1操作;
decr(String key):為某個鍵上的值執(zhí)行-1操作;
replace(String key, String value):將某個鍵的值替換成新的值;
replace(String key, String value, Date expires):將某個鍵的值替換成新的值,并設置其超時時間。
delete(String key):刪除緩存中一個key的值
新聞熱點
疑難解答