MemcachedClient 使用說明


上一篇介紹了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數組的位置一一對應
		 */
		Integer[] weights = {1,2};
		/**
		 * 這個類用來創建管理客戶端和服務器通訊連接池,客戶端主要的工作包括數據通訊、服務器定位、hash碼生成等都是由這個類完成的。
		 * 獲得連接池的單態方法。這個方法有一個重載方法getInstance( String poolName ),每個poolName只構造一個SockIOPool實例。
		 * 缺省構造的poolName是default。
		 */
		SockIOPool pool = SockIOPool.getInstance();
		//設置memcached服務器
		pool.setServers(servers);
		//設置memcached服務器權重
		pool.setWeights(weights);
		//設置容錯開關設置為TRUE,當當前socket不可用時,程序會自動查找可用連接並返回,否則返回NULL,默認狀態是true,建議保持默認
		pool.setFailover( true );
		//設置開始時每個cache服務器的可用連接數
		pool.setInitConn( 10 ); 
		//設置每個服務器最少可用連接數
		pool.setMinConn( 5 );
		//設置每個服務器最大可用連接數
		pool.setMaxConn( 250 );
		/**
		 * 設置連接池維護線程的睡眠時間
		 * 設置為0,維護線程不啟動
		 * 維護線程主要通過log輸出socket的運行狀況,監測連接數目及空閑等待時間等參數以控制連接創建和關閉。
		 */
		pool.setMaintSleep( 30 );
		/**
		 * 設置是否使用Nagle算法,因為我們的通訊數據量通常都比較大(相對TCP控制數據)而且要求響應及時,因此該值需要設置為false(默認是true)
		 */
		pool.setNagle( false );
		/**
		 * 設置socket的讀取等待超時值
		 */
		pool.setSocketTO( 3000 );
		/**
		 * 設置連接心跳監測開關。
		 * 設為true則每次通信都要進行連接是否有效的監測,造成通信次數倍增,加大網絡負載,因此該參數應該在對HA要求比較高的場合設為TRUE,默認狀態是false。
		 */
		pool.setAliveCheck( true );
		/**
		 * 設置完pool參數后最后調用該方法,啟動pool。
		 */
		pool.initialize();
		
		/**
		 * 創建一個memcached客戶端,所有對memcached中數據操作的方法都在這個類里面
		 */
		MemCachedClient memCachedClient = new MemCachedClient();
		/**
		 * 存儲一個username,值為劉德華,存儲成功返回true
		 */
		boolean success = memCachedClient.set("username", "劉德華");
		System.out.println(success);
		
		/**
		 * 從緩存中獲取一個key為username的數據
		 */
		Object o = memCachedClient.get("username");
		System.out.println(o);
		
		/**
		 * 定義一個p對象,Persion類必須實現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());
		
		/**
		 * 調用add方法添加一個key為p1的對象,值123是不能添加進緩存的,因為p1已經添加過一次了
		 */
		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的數據,無法更新,不會添加
		 */
		memCachedClient.replace("p2", 456);
		System.out.println(memCachedClient.get("p2"));//輸出null
		
		/**
		 * 刪除key為p1的緩存數據
		 */
		memCachedClient.delete("p1");
		System.out.println(memCachedClient.get("p1"));//輸出null
	}
}

  

 

二、常用方法說明

1、SockIOPool 是socket 連接池類

setServers(String[] servers) :設置服務器信息數組;

setWeights(String[] weights) :設置服務器權重數組;

setInitConn(int count) :設置初始連接數;

setMinConn(int minConn) :設置最小連接數;

setMaxConn(int maxConn) :設置最大連接數;

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) :為某個鍵上的值執行+1 操作;

decr(String key) :為某個鍵上的值執行-1 操作;

replace(String key, String value) :將某個鍵的值替換成新的值;

replace(String key, String value, Date expires) :將某個鍵的值替換成新的值,並設置其超時時間。

delete(String key):刪除緩存中一個key的值

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM