java中Memcached的使用方法

這篇文章主要講解了“java中Memcached的使用方法”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“java中Memcached的使用方法”吧！

一、什么是Memcached？

Memcached是danga.com開發(fā)的分布式內(nèi)存對象緩存系統(tǒng)，所謂分布式，意味著它不是本地的，而是基于網(wǎng)絡(luò)連接完成服務(wù)。Memcached把一些數(shù)據(jù)通過key=value數(shù)據(jù)存儲到內(nèi)存中，這樣訪問更加方便快捷。

但是隨之而來的問題是如果Memcached關(guān)閉或者Memcached的服務(wù)器關(guān)閉那么所保存的內(nèi)容也就沒有了。

二、安裝Memcached服務(wù)端

我是在Win下做的實驗。

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

memcached.exe -d install 安裝memcached服務(wù)

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

常用命令：

-p 監(jiān)聽的端口

-l 連接的IP地址, 默認(rèn)是本機

-d start 啟動memcached服務(wù)

-d restart 重起memcached服務(wù)

-d stop|shutdown 關(guān)閉正在運行的memcached服務(wù)

-d install 安裝memcached服務(wù)

-d uninstall 卸載memcached服務(wù)

-u 以的身份運行 (僅在以root運行的時候有效)

-m 最大內(nèi)存使用，單位MB。默認(rèn)64MB

-M 內(nèi)存耗盡時返回錯誤，而不是刪除項

-c 最大同時連接數(shù)，默認(rèn)是1024

-f 塊大小增長因子，默認(rèn)是1.25

-n 最小分配空間，key+value+flags默認(rèn)是48

-h 顯示幫助

三、java下使用Memcached（java客戶端程序）

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

所需全部的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();
        //使用的服務(wù)器，由于是在本地測試，只有一個服務(wù)器地址。默認(rèn)端口是11211
        //格式為 服務(wù)器IP:端口號
        String [] addr={"127.0.0.1:11211"};
        /**
         * 設(shè)置權(quán)重，與設(shè)定的服務(wù)器一一對應(yīng)
         */
        Integer[] weight={3};
        //建立通信的連接池
        SockIOPool pool=SockIOPool.getInstance();
        //設(shè)置連接池可用cache服務(wù)器列表，服務(wù)器構(gòu)成形式：ip地址+端口號
        pool.setServers(addr);
        //設(shè)置連接池可用cache服務(wù)器的權(quán)重，和server數(shù)組的位置一一對應(yīng)
        pool.setWeights(weight);
        //設(shè)置初始連接數(shù)
        pool.setInitConn(5);
        //設(shè)置最小連接數(shù)
        pool.setMinConn(5);
        //設(shè)置最大連接數(shù)
        pool.setMaxConn(200);
        //設(shè)置可用連接的最長等待時間
        pool.setMaxIdle(1000*30*30);
        //設(shè)置連接池維護線程的睡眠時間，設(shè)置為0，維護線程不啟動
        pool.setMaintSleep(30);
        //設(shè)置Nagle算法，設(shè)置為false，因為通訊數(shù)據(jù)量比較大要求相應(yīng)及時
        pool.setNagle(false);
        //設(shè)置socket讀取等待超時時間
        pool.setSocketTO(30);
        //設(shè)置連接等待超時值
        pool.setSocketConnectTO(0);
        //設(shè)置完參數(shù)后，啟動pool
        pool.initialize();
        client.set("value","Ok");
        String value= (String) client.get("value");
         //設(shè)置定時時間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配置文件：

#服務(wù)器地址
memcached.server=127.0.0.1:11211
#初始連接數(shù)目
memcached.initConn=20
#每個服務(wù)器建立最大連接數(shù)
memcached.maxConn=50
#自查線程周期工作，其每次休眠時間
memcached.maniSleep=3000
#是否使用nagle算法（Socket參數(shù)，如果是true，寫數(shù)據(jù)不緩沖，直接發(fā)送）
memcached.nagle=false
#Socket阻塞讀取數(shù)據(jù)的超時時間
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);
    }
}

四、個人學(xué)習(xí)中遇到的問題：

我們通過客戶端添加與獲得數(shù)據(jù)，那么這個客戶端如何與pool聯(lián)系的，通過別人的博客找到答案。

客戶端是通過pool的name關(guān)聯(lián)到某個pool上的。

客戶端與Pool都沒有指定名稱的時候，默認(rèn)是創(chuàng)建名稱為“default”的pool，客戶端與它關(guān)聯(lián)。

如果pool設(shè)置了名字，那么客戶也要指定名稱。

Memcached結(jié)合java基本操作

//創(chuàng)建MemcachedClient    連接memcached服務(wù)器端
        MemcachedClient mClient = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
        System.out.println("連接memcached成功..........");
        //存儲數(shù)據(jù),key-ruo,value-888,時間是1000秒
        Future future = mClient.set("ruo", 1000, "888");
        System.out.println("查看ruo的存儲狀態(tài)："+future.get()+",存儲的值："+mClient.get("ruo"));
        //添加數(shù)據(jù),如果key已經(jīng)存儲，則不會更新之前的value，返回NOT_STORED
        Future f1 = mClient.add("ruo", 1000, "999");
        System.out.println("查看添加ruo的存儲狀態(tài)："+f1.get()+",添加后key：ruo的值是"+mClient.get("ruo"));
        //替換replace
        Future f2 = mClient.replace("ruo", 1000, "999");
        System.out.println("查看替換ruo的存儲狀態(tài)："+f2.get()+",替換后key：ruo的值是"+mClient.get("ruo"));
        //追加數(shù)據(jù)append，用來向已存在的key，追加數(shù)據(jù)
        Future f3 = mClient.append("ruo","666");
        System.out.println("查看替換ruo的存儲狀態(tài)："+f3.get()+",替換后key：ruo的值是"+mClient.get("ruo"));
        //prepend，用來向已存在的key對應(yīng)的value前，追加數(shù)據(jù)
        Future f4 = mClient.prepend("ruo", "555");
        System.out.println("查看替換ruo的存儲狀態(tài)："+f4.get()+",替換后key：ruo的值是"+mClient.get("ruo"));
        //清空數(shù)據(jù)庫
        mClient.flush();
        //關(guān)閉連接
        mClient.shutdown();

運行結(jié)果

2018-10-30 11:23:07.350 INFO net.spy.memcached.MemcachedConnection: Connection state changed for sun.nio.ch.SelectionKeyImpl@38a22ea7
查看ruo的存儲狀態(tài)：true,存儲的值：888
查看添加ruo的存儲狀態(tài)：false,添加后key：ruo的值是888
查看替換ruo的存儲狀態(tài)：true,替換后key：ruo的值是999
查看替換ruo的存儲狀態(tài)：true,替換后key：ruo的值是999666
查看替換ruo的存儲狀態(tài)：true,替換后key：ruo的值是555999666
2018-10-30 11:23:07.368 INFO net.spy.memcached.MemcachedConnection: Shut down memcached client

感謝各位的閱讀，以上就是“java中Memcached的使用方法”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對java中Memcached的使用方法這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！