1. 程式人生 > >Memcache叢集環境下快取解決方案

Memcache叢集環境下快取解決方案

Memcache是一個高效能的分散式的記憶體物件快取系統,通過在記憶體裡維護一個統一的巨大的hash表,它能夠用來儲存各種格式的資料,包括影象、視訊、檔案以及資料庫檢索的結果等。簡單的說就是將資料呼叫到記憶體中,然後從記憶體中讀取,從而大大提高讀取速度。  

一、在Linux上安裝memcached:

1. Linux上的memcache需要倆個安裝包:libevent-1.4.12-stable.tar.gz 、memcached-1.4.3.tar.gz 
   解壓安裝:
    	tar -zxf libevent-1.4.12-stable.tar.gz 
    	tar -zxf memcached-1.4.3.tar.gz 
進入libevent並安裝
	# cd libevent-1.4.12-stable
	# ./configure --prefix=/usr/local/libevent
	# make
	# sudo make install 
測試libevent是否安裝成功:
	# ls -al /usr/lib | grep libevent
進入memcache並安裝
	# cd ../ memcached-1.4.3
	# ./configure --prefix=/usr/local/memcached --with-libevent=/usr/local/libevent
	# make
	# sudo make install
2、在Linux上啟動memcached(啟動時指定埠號)

# /usr/local/memcached/bin/memcached -d -m 528 -u ligang -p12131

-m 啟動記憶體 -u 啟動使用者 -p 埠

測試啟動是否成功:

   	telnet  ip port
   	telnet 172.17.3.135 12135
3、檢視memcached程序並關閉memcached
    ps -aux |grep mem

二、Windows下安裝:

1.  首先準備好memcache windows穩定版
2.  以管理員省份執行DOS視窗
3.  memcached.exe -d install
4.  memcached.exe -d start
5.  檢視是否安裝成功services.msc
設定memcached,啟動該服務後,memcached服務預設佔用的埠是11211,佔用的最大記憶體預設是64M。如果需要修改這兩個引數,比如修改埠為10000,記憶體為512,則輸入: 
     D:\memcached\memcached.exe -p 10000 -m 512 -d start 
-p 表示要修改的埠, 
-m表示佔用的最大記憶體(單位為M)。
上述命令無效,通過修改登錄檔實現
HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\memcached Server
其中的ImagePath項的值為:"c:\memcached\memcached.exe" -d runservice
改成:"c:\memcached\memcached.exe" -p 15000 -d runservice
7.常用命令:
A. telnet到memcache伺服器,如:telnet 127.0.0.1 11211(11211是memcache的預設埠)
進入上述環境後,下面命令可用:
B. stats 檢視基本資訊
C. stats items 檢視items
D. get key(key 為 item後面的字串即鍵)
E. -c 最大同時連線數,預設是1024
F. -f 塊大小增長因子,預設是1.25
G. -n 最小分配空間,key+value+flags預設是48
H. -h 顯示幫助

三、JAVA例項

所需要的jiar包:commons-pool-1.5.6.jar、java_memcached-release_2.6.3.jar、slf4j-api-1.6.1.jar、slf4j-simple-1.6.1.jar

package memcachedDemo;

import java.util.Date;

import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;

public class Memcached {
	private static MemCachedClient mcc = new MemCachedClient();
	private static Memcached memcached = new Memcached();
	
	//服務群組
	private static final String[] services = {"127.0.0.1:11211"};
	//伺服器群各自對應的權重
	private static final Integer[] weights = {1};
	//初始化連線數
	private static final Integer init_connection = 5;
	//最小連線數
	private static final Integer min_connection = 5;
	//最大連線數
	private static final Integer max_connection = 250;
	//最大處理時間 60*60
	private static final Long max_idle = 3600L;
	//主程式睡眠時間
	private static final Long maint_sleep = 10L;
	
	static{
		//獲取scoke連線池的例項物件
		SockIOPool pool = SockIOPool.getInstance();
		pool.setServers(services);
		pool.setWeights(weights);
		pool.setInitConn(init_connection);
		pool.setMinConn(min_connection);
		pool.setMaxConn(max_connection);
		pool.setMaxIdle(max_idle);
		pool.setMaintSleep(maint_sleep);
		
		//設定TCP的引數,連線超時等
		pool.setNagle(false);
		pool.setSocketTO(3000);
		pool.setSocketConnectTO(0);
		
		//初始化連線池
		pool.initialize();
		
		//超過指定大小就壓縮
		//mcc.setCompressEnable(true);
		//mcc.setCompressThreshold(65536L);
	}
	
	private Memcached(){}
	
	private static Memcached getInstance(){
		return memcached;
	}
	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); 
    } 
    public Object get(String key){ 
        return mcc.get(key); 
    }
    
    public static void main(String[] args) {
		Memcached memcached = Memcached.getInstance();
		boolean s = memcached.add("abc", new String("123"));
		System.out.println(s);
		System.out.println(memcached.get("abc"));
	}

}

所需JAR和安裝包http://pan.baidu.com/s/1sjjX23r