java中Memcached的使用(包括與Spring整合)


一、什么是Memcached?

        Memcached是danga.com開發的分布式內存對象緩存系統,所謂分布式,意味着它不是本地的,而是基於網絡連接完成服務。Memcached把一些數據通過key=value數據存儲到內存中,這樣訪問更加方便快捷。但是隨之而來的問題是如果Memcached關閉或者Memcached的服務器關閉那么所保存的內容也就沒有了。

二、安裝Memcached服務端

          我是在Win下做的實驗。

          首先下載Win下的Memcached,解壓到指定目錄。

            memcached.exe -d install 安裝memcached服務

           然后通過Memcached  start  memcached就啟動了。

           常用命令:

              -p 監聽的端口 
               -l 連接的IP地址, 默認是本機 
               -d start 啟動memcached服務 
               -d restart 重起memcached服務 
               -d stop|shutdown 關閉正在運行的memcached服務 
               -d install 安裝memcached服務 
               -d uninstall 卸載memcached服務 
               -u 以的身份運行 (僅在以root運行的時候有效) 
               -m 最大內存使用,單位MB。默認64MB 
               -M 內存耗盡時返回錯誤,而不是刪除項 
               -c 最大同時連接數,默認是1024 
               -f 塊大小增長因子,默認是1.25 
               -n 最小分配空間,key+value+flags默認是48 
               -h 顯示幫助 

三、java下使用Memcached(java客戶端程序)

          目前常用客戶端有三種,我使用的是java_memcached-release_2.6.6,該系列是最早推出也應用最為廣泛的客戶端。 

           所需全部的jar:commons-pool-1.5.6.jar、java_memcached-release_2.6.6.jar、slf4j-api-1.6.1.jar、slf4j-simple-1.6.1.jar

          1、基本使用:

 

    @Test
    public  void show(){
        MemCachedClient client=new MemCachedClient();
        //使用的服務器,由於是在本地測試,只有一個服務器地址。默認端口是11211
        //格式為 服務器IP:端口號
        String [] addr={"127.0.0.1:11211"};
        /**
         * 設置權重,與設定的服務器一一對應
         */
        Integer[] weight={3};

        //建立通信的連接池
        SockIOPool pool=SockIOPool.getInstance();
        //設置連接池可用cache服務器列表,服務器構成形式:ip地址+端口號
        pool.setServers(addr);
        //設置連接池可用cache服務器的權重,和server數組的位置一一對應
        pool.setWeights(weight);


        //設置初始連接數
        pool.setInitConn(5);
        //設置最小連接數
        pool.setMinConn(5);
        //設置最大連接數
        pool.setMaxConn(200);
        //設置可用連接的最長等待時間
        pool.setMaxIdle(1000*30*30);
        //設置連接池維護線程的睡眠時間,設置為0,維護線程不啟動
        pool.setMaintSleep(30);
        //設置Nagle算法,設置為false,因為通訊數據量比較大要求相應及時
        pool.setNagle(false);
        //設置socket讀取等待超時時間
        pool.setSocketTO(30);
        //設置連接等待超時值
        pool.setSocketConnectTO(0);
        //設置完參數后,啟動pool
        pool.initialize();

        client.set("value","Ok");
        String value= (String) client.get("value");

         //設置定時時間2s后消失
        client.set("value1","OK2",new Date(2000));
        String value2= (String) client.get("value1");
        System.out.println(value);
        System.out.println(value2);
    }

            2、spring整合memcached       

 

 

    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:property/memcached.properties</value>
            </list>
        </property>
    </bean>
    <!--spring整合memched-->
    <bean id="memcachedPool" class="com.danga.MemCached.SockIOPool" factory-method="getInstance"
          init-method="initialize"   destroy-method="shutDown">
        <property name="servers">
            <list>
                <value>${memcached.server}</value>
            </list>
        </property>

        <property name="maxConn" value="${memcached.maxConn}"></property>
        <property name="maintSleep" value="${memcached.maniSleep}"></property>
        <property name="nagle" value="${memcached.nagle}"></property>
        <property name="socketTO" value="${memcached.socketTO}"></property>
    </bean>


              properties配置文件:

#服務器地址
memcached.server=127.0.0.1:11211
#初始連接數目
memcached.initConn=20
#每個服務器建立最大連接數
memcached.maxConn=50
#自查線程周期工作,其每次休眠時間
memcached.maniSleep=3000
#是否使用nagle算法(Socket參數,如果是true,寫數據不緩沖,直接發送)
memcached.nagle=false
#Socket阻塞讀取數據的超時時間
memcached.socketTO=3000

              測試:

 

 

@RunWith(SpringJUnit4ClassRunner.class)//表示整合JUnit進行測試
@ContextConfiguration(locations ={"classpath:applicationContext.xml"})
public class SpringTest {

    @Test
    public void test1(){
        MemCachedClient memCachedClient=new MemCachedClient();
        memCachedClient.set("username","luck");
        String value= (String) memCachedClient.get("username");
        System.out.println(value);
    }
}

 

四、個人學習中遇到的問題:

              我們通過客戶端添加與獲得數據,那么這個客戶端如何與pool聯系的,通過別人的博客找到答案。客戶端是通過pool的name關聯到某個pool上的。客戶端與Pool都沒有指定名稱的時候,默認是創建名稱為“default”的pool,客戶端與它關聯。如果pool設置了名字,那么客戶也要指定名稱。



ps:參考博客:http://blog.csdn.net/sup_heaven/article/details/32337711 

java_memcached-releasejava_memcached-release常用api:

                       http://blog.csdn.net/qqiabc521/article/details/6438429


菜鳥一枚,如有不對,敬請指正。

                  

     




        

 


免責聲明!

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



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