1       Memcache是什么

Memcache是danga.com的一個項目，最早是為 LiveJournal 服務的，目前全世界不少人使用這個緩存項目來構建自己大負載的網站，來分擔數據庫的壓力。

它可以應對任意多個連接，使用非阻塞的網絡IO。由于它的工作機制是在內存中開辟一塊空間，然后建立一個HashTable，Memcached自管理這些HashTable。

為什么會有Memcache和memcached兩種名稱？

其實Memcache是這個項目的名稱，而memcached是它服務器端的主程序文件名，

Memcache官方網站：http://www.danga.com/memcached，

2       Memcache工作原理

首先 memcached 是以守護程序方式運行于一個或多個服務器中，隨時接受客戶端的連接操作，客戶端可以由各種語言編寫，目前已知的客戶端 API 包括 Perl/PHP/Python/Ruby/Java/C#/C 等等。客戶端在與 memcached 服務建立連接之后，接下來的事情就是存取對象了，每個被存取的對象都有一個唯一的標識符 key，存取操作均通過這個 key 進行，保存到 memcached 中的對象實際上是放置內存中的，并不是保存在 cache 文件中的，這也是為什么 memcached 能夠如此高效快速的原因。注意，這些對象并不是持久的，服務停止之后，里邊的數據就會丟失。

與許多 cache 工具類似，Memcached 的原理并不復雜。它采用了C/S的模式，在 server 端啟動服務進程，在啟動時可以指定監聽的 ip，自己的端口號，所使用的內存大小等幾個關鍵參數。一旦啟動，服務就一直處于可用狀態。Memcached 的目前版本是通過C實現，采用了單進程，單線程，異步I/O，基于事件 (event_based) 的服務方式.使用 libevent 作為事件通知實現。多個 Server 可以協同工作，但這些 Server 之間是沒有任何通訊聯系的，每個 Server 只是對自己的數據進行管理。Client 端通過指定 Server 端的 ip 地址(通過域名應該也可以)。需要緩存的對象或數據是以 key->value 對的形式保存在Server端。key 的值通過 hash 進行轉換，根據 hash 值把 value 傳遞到對應的具體的某個 Server 上。當需要獲取對象數據時，也根據 key 進行。首先對 key 進行 hash，通過獲得的值可以確定它被保存在了哪臺 Server 上，然后再向該 Server 發出請求。Client 端只需要知道保存 hash(key) 的值在哪臺服務器上就可以了。

        其實說到底，memcache 的工作就是在專門的機器的內存里維護一張巨大的 hash 表，來存儲經常被讀寫的一些數組與文件，從而極大的提高網站的運行效率。

3       如何使用

• 建立Manager類

  

Java代碼

1. package com.alisoft.sme.memcached;  
2.   
3. import java.util.Date;  
4.   
5. import com.danga.MemCached.MemCachedClient;  
6. import com.danga.MemCached.SockIOPool;  
7.   
8. public class MemCachedManager {  
9.   
10.     // 創建全局的唯一實例  
11.     protected static MemCachedClient mcc = new MemCachedClient();  
12.   
13.     protected static MemCachedManager memCachedManager = new MemCachedManager();  
14.   
15.     // 設置與緩存服務器的連接池  
16.     static {  
17.         // 服務器列表和其權重  
18.         String[] servers = { "127.0.0.1:11211" };  
19.         Integer[] weights = { 3 };  
20.   
21.         // 獲取socke連接池的實例對象  
22.         SockIOPool pool = SockIOPool.getInstance();  
23.   
24.         // 設置服務器信息  
25.         pool.setServers(servers);  
26.         pool.setWeights(weights);  
27.   
28.         // 設置初始連接數、最小和最大連接數以及最大處理時間  
29.         pool.setInitConn(5);  
30.         pool.setMinConn(5);  
31.         pool.setMaxConn(250);  
32.         pool.setMaxIdle(1000 * 60 * 60 * 6);  
33.   
34.         // 設置主線程的睡眠時間  
35.         pool.setMaintSleep(30);  
36.   
37.         // 設置TCP的參數，連接超時等  
38.         pool.setNagle(false);  
39.         pool.setSocketTO(3000);  
40.         pool.setSocketConnectTO(0);  
41.   
42.         // 初始化連接池  
43.         pool.initialize();  
44.   
45.         // 壓縮設置，超過指定大小（單位為K）的數據都會被壓縮  
46.         mcc.setCompressEnable(true);  
47.         mcc.setCompressThreshold(64 * 1024);  
48.     }  
49.   
50.     /** 
51.      * 保護型構造方法，不允許實例化！ 
52.      *  
53.      */  
54.     protected MemCachedManager() {  
55.   
56.     }  
57.   
58.     /** 
59.      * 獲取唯一實例. 
60.      *  
61.      * @return 
62.      */  
63.     public static MemCachedManager getInstance() {  
64.         return memCachedManager;  
65.     }  
66.   
67.     /** 
68.      * 添加一個指定的值到緩存中. 
69.      *  
70.      * @param key 
71.      * @param value 
72.      * @return 
73.      */  
74.     public boolean add(String key, Object value) {  
75.         return mcc.add(key, value);  
76.     }  
77.   
78.     public boolean add(String key, Object value, Date expiry) {  
79.         return mcc.add(key, value, expiry);  
80.     }  
81.   
82.     public boolean replace(String key, Object value) {  
83.         return mcc.replace(key, value);  
84.     }  
85.   
86.     public boolean replace(String key, Object value, Date expiry) {  
87.         return mcc.replace(key, value, expiry);  
88.     }  
89.   
90.     /** 
91.      * 根據指定的關鍵字獲取對象. 
92.      *  
93.      * @param key 
94.      * @return 
95.      */  
96.     public Object get(String key) {  
97.         return mcc.get(key);  
98.     }  
99.   
100.     public static void main(String[] args) {  
101.         MemCachedManager cache = MemCachedManager.getInstance();  
102.         cache.add("hello", 234);  
103.         System.out.print("get value : " + cache.get("hello"));  
104.     }  
105. }  

package com.alisoft.sme.memcached;
import java.util.Date;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
public class MemCachedManager {
// 創建全局的唯一實例
protected static MemCachedClient mcc = new MemCachedClient();
protected static MemCachedManager memCachedManager = new MemCachedManager();
// 設置與緩存服務器的連接池
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 MemCachedManager() {
}
/**
* 獲取唯一實例.
*
* @return
*/
public static MemCachedManager getInstance() {
return memCachedManager;
}
/**
* 添加一個指定的值到緩存中.
*
* @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) {
MemCachedManager cache = MemCachedManager.getInstance();
cache.add("hello", 234);
System.out.print("get value : " + cache.get("hello"));
}
}

 建立數據對象

package com.alisoft.sme.memcached;
import java.io.Serializable;
public class TBean implements Serializable {
private static final long serialVersionUID = 1945562032261336919L;
private String name;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}