志當(dāng)存高遠(yuǎn),功到自然成!

    Memcached是高性能的，分布式的內(nèi)存對象緩存系統(tǒng)，用于在動態(tài)應(yīng)用中減少數(shù)據(jù)庫負(fù) 載，提升訪問速度。Memcached由Danga Interactive開發(fā)，用于提升LiveJournal.com訪問速度的。LJ每秒動態(tài)頁面訪問量幾千次，用戶700萬。Memcached將數(shù) 據(jù)庫負(fù)載大幅度降低，更好的分配資源，更快速訪問。

    上網(wǎng)baidu了很多東西，幾乎都差不多，而且基于java的說的很少，所有只有在研究了各個其他語言類的應(yīng)用后再來嘗試在java上進(jìn)行簡單的操作應(yīng) 用。先從memcached上進(jìn)行說明，memcached的最新版是采用c語言進(jìn)行開發(fā)和設(shè)計的，據(jù)說舊版的是采用perl語言開發(fā)的，而且它是一個應(yīng) 用軟件來的，是作為緩存服務(wù)器的服務(wù)器端運行在服務(wù)器上的，需要使用特定的語言編寫客戶端與其進(jìn)行通信來進(jìn)行數(shù)據(jù)的緩存和獲取。通常我們是把 memcached安裝運行在web服務(wù)器上，然后通過對需要的數(shù)據(jù)進(jìn)行緩存，據(jù)我目前所知，所有數(shù)據(jù)的緩存設(shè)置和存取操作，以及數(shù)據(jù)的更新后替換操作全 部需要程序來進(jìn)行，而不是自動進(jìn)行的（自動不知道能不能成功，呵呵）。下面從一個實際的例子來應(yīng)用memcached。

    首先到http://danga.com/memcached/下 載memcached的windows版本和java客戶端jar包，目前最新版本是memcached-1.2.1-win32.zip和 java_memcached-release_1.6.zip，分別解壓后即可！首先是安裝運行memcached服務(wù)器，我們將memcached- 1.2.1-win32.zip解壓后，進(jìn)入其目錄，然后運行如下命令：

c:>memcached.exe -d install
c:>memcached.exe -l 127.0.0.1 -m 32 -d start

    第一行是安裝memcached成為服務(wù)，這樣才能正常運行，否則運行失敗！第一行是啟動memcached的，作為測試我們就簡單的只分配32M內(nèi)存 了，然后監(jiān)聽本機端口和以守護(hù)進(jìn)行運行。執(zhí)行完畢后，我們就可以在任務(wù)管理器中見到memcached.exe這個進(jìn)程了。好了，我們的服務(wù)器已經(jīng)正常運 行了， 下面我們就來寫java的客戶端連接程序。

    我們將java_memcached-release_1.6.zip解壓后的目錄中的java_memcached-release_1.6.jar文件復(fù)制到j(luò)ava項目的lib目錄下，然后我們來編寫代碼，比如我提供的一個應(yīng)用類如下：

package utils.cache;

import java.util.Date;

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


/**
* 使用memcached的緩存實用類.
*
* @author 鐵木箱子
*
*/
public class MemCached
{
    // 創(chuàng)建全局的唯一實例
    protected static MemCachedClient mcc = new MemCachedClient();
   
    protected static MemCached memCached = new MemCached();
   
    // 設(shè)置與緩存服務(wù)器的連接池
    static {
        // 服務(wù)器列表和其權(quán)重
        String[] servers = {"127.0.0.1:11211"};
        Integer[] weights = {3};

        // 獲取socke連接池的實例對象
        SockIOPool pool = SockIOPool.getInstance();

        // 設(shè)置服務(wù)器信息
        pool.setServers( servers );
        pool.setWeights( weights );

        // 設(shè)置初始連接數(shù)、最小和最大連接數(shù)以及最大處理時間
        pool.setInitConn( 5 );
        pool.setMinConn( 5 );
        pool.setMaxConn( 250 );
        pool.setMaxIdle( 1000 * 60 * 60 * 6 );

        // 設(shè)置主線程的睡眠時間
        pool.setMaintSleep( 30 );

        // 設(shè)置TCP的參數(shù)，連接超時等
        pool.setNagle( false );
        pool.setSocketTO( 3000 );
        pool.setSocketConnectTO( 0 );

        // 初始化連接池
        pool.initialize();

        // 壓縮設(shè)置，超過指定大小（單位為K）的數(shù)據(jù)都會被壓縮
        mcc.setCompressEnable( true );
        mcc.setCompressThreshold( 64 * 1024 );
    }
   
    /**
     * 保護(hù)型構(gòu)造方法，不允許實例化！
     *
     */
    protected MemCached()
    {
       
    }
   
    /**
     * 獲取唯一實例.
     * @return
     */
    public static MemCached 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);
    }
   
    /**
     * 根據(jù)指定的關(guān)鍵字獲取對象.
     * @param key
     * @return
     */
    public Object get(String key)
    {
        return mcc.get(key);
    }
   
    public static void main(String[] args)
    {
        MemCached cache = MemCached.getInstance();
        cache.add("hello", 234);
        System.out.print("get value : " + cache.get("hello"));
    }
}

    那么我們就可以通過簡單的像main方法中操作的一樣存入一個變量，然后再取出進(jìn)行查看，我們可以看到先調(diào)用了add，然后再進(jìn)行g(shù)et，我們運行一次 后，234這個值已經(jīng)被我們存入了memcached的緩存中的了，我們將main方法中紅色的那一行注釋掉后，我們再運行還是可以看到get到的 value也是234，即緩存中我們已經(jīng)存在了數(shù)據(jù)了。

    對基本的數(shù)據(jù)我們可以操作，對于普通的POJO而言，如果要進(jìn)行存儲的話，那么比如讓其實現(xiàn)java.io.Serializable接口，因為 memcached是一個分布式的緩存服務(wù)器，多臺服務(wù)器間進(jìn)行數(shù)據(jù)共享需要將對象序列化的，所以必須實現(xiàn)該接口，否則會報錯的。比如我們寫一個簡單的測 試Bean如下：

class TBean implements java.io.Serializable
{
    private static final long serialVersionUID = 1945562032261336919L;
   
    private String name;

    public String getName()
    {
        return name;
    }

    public void setName(String name)
    {
        this.name = name;
    }
}

    然后我們在main方法中加入如下幾行代碼：

TBean tb = new TBean();
tb.setName("鐵木箱子");
cache.add("bean", tb);
TBean tb1 = (TBean)cache.get("bean");
System.out.print("name=" + tb1.getName());
tb1.setName("鐵木箱子_修改的");
tb1 = (TBean)cache.get("bean");
System.out.print("name=" + tb1.getName());

    我們首先把TBean的一個實例放入緩存中，然后再取出來，并進(jìn)行名稱的修改，然后我們再取這個對象，我們再看其名稱，發(fā)現(xiàn)修改的對象并不是緩存中的對 象，而是通過序列化過來的一個實例對象，這樣我們就無須擔(dān)心對原生類的無意修改導(dǎo)致緩存數(shù)據(jù)失效了，呵呵~~看來我也是多此一想啊。所以這表明從緩存中獲 取的對象是存入對象的一個副本，對獲取對象的修改并不能真正的修改緩存中的數(shù)據(jù)，而應(yīng)該使用其提供的replace等方法來進(jìn)行修改。

    以上是我在windows下對memcached的一點小學(xué)習(xí)和實踐，在以后的項目開發(fā)過程中將會更深入的學(xué)習(xí)和應(yīng)用這一緩存工具，也希望和有興趣的同行一起討論學(xué)習(xí)該工具的使用~~