最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時間:2021年07月09日 16:55:53   作者:十禾。  
這篇文章主要介紹了java中Memcached的使用實例(包括與Spring整合),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

一、什么是Memcached?

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

但是隨之而來的問題是如果Memcached關閉或者Memcached的服務器關閉那么所保存的內容也就沒有了。

二、安裝Memcached服務端

我是在Win下做的實驗。

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

memcached.exe -d install 安裝memcached服務

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

常用命令:

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

-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,寫數據不緩沖,直接發(fā)送)
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都沒有指定名稱的時候,默認是創(chuàng)建名稱為“default”的pool,客戶端與它關聯。

如果pool設置了名字,那么客戶也要指定名稱。

Memcached結合java基本操作

//創(chuàng)建MemcachedClient    連接memcached服務器端
        MemcachedClient mClient = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
        System.out.println("連接memcached成功..........");
        //存儲數據,key-ruo,value-888,時間是1000秒
        Future future = mClient.set("ruo", 1000, "888");
        System.out.println("查看ruo的存儲狀態(tài):"+future.get()+",存儲的值:"+mClient.get("ruo"));
        //添加數據,如果key已經存儲,則不會更新之前的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"));
        //追加數據append,用來向已存在的key,追加數據
        Future f3 = mClient.append("ruo","666");
        System.out.println("查看替換ruo的存儲狀態(tài):"+f3.get()+",替換后key:ruo的值是"+mClient.get("ruo"));
        //prepend,用來向已存在的key對應的value前,追加數據
        Future f4 = mClient.prepend("ruo", "555");
        System.out.println("查看替換ruo的存儲狀態(tài):"+f4.get()+",替換后key:ruo的值是"+mClient.get("ruo"));
        //清空數據庫
        mClient.flush();
        //關閉連接
        mClient.shutdown();

運行結果

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

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • Springmvc模式上傳和下載與enctype對比

    Springmvc模式上傳和下載與enctype對比

    這篇文章主要介紹了Springmvc模式上傳和下載與enctype對比,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-12-12
  • Spring事務的七種傳播行為

    Spring事務的七種傳播行為

    這篇文章主要介紹了Spring事務的七種傳播行為,文章圍繞主題的相關資料展開詳細的內容解說,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-04-04
  • Spring配置多數據源切換

    Spring配置多數據源切換

    今天小編就為大家分享一篇關于Spring配置多數據源切換,小編覺得內容挺不錯的,現在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2019-01-01
  • SpringBoot中的跨域詳解

    SpringBoot中的跨域詳解

    這篇文章主要介紹了SpringBoot中的跨域詳解,在瀏覽器上當前訪問的網站,向另一個網站發(fā)送請求,用于獲取數據的過程就是跨域請求,跨域是瀏覽器的同源策略決定的,是一個重要的瀏覽器安全策略,需要的朋友可以參考下
    2023-08-08
  • Maven指令打包SpringBoot項目提示沒有主清單文件問題

    Maven指令打包SpringBoot項目提示沒有主清單文件問題

    在Java開發(fā)中,打包Jar時常會遇到“沒有主清單屬性”的錯誤,這通常是因為在pom.xml文件中沒有正確配置maven插件導致的,特別是在使用自定義的<parent/>節(jié)點而非spring-boot-starter-parent時
    2024-09-09
  • Java使用ES?Client?調用滾動查詢及Elasticsearch滾動查詢Scrolling機制

    Java使用ES?Client?調用滾動查詢及Elasticsearch滾動查詢Scrolling機制

    Elasticsearch提供了一種稱為"滾動查詢"(Scrolling)的機制,用于處理大型數據集的分頁查詢,這篇文章給大家介紹滾動查詢的一般步驟及Java使用ESClient調用滾動查詢的方法,感興趣的朋友一起看看吧
    2023-08-08
  • 如何基于LoadingCache實現Java本地緩存

    如何基于LoadingCache實現Java本地緩存

    這篇文章主要介紹了如何基于LoadingCache實現Java本地緩存,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-12-12
  • Java創(chuàng)建對象的六種常用方式總結

    Java創(chuàng)建對象的六種常用方式總結

    作為Java開發(fā)者,經常創(chuàng)建很多對象,你是否知道Java中創(chuàng)建對象有哪些方式呢?下面這篇文章主要給大家介紹了關于Java創(chuàng)建對象的六種常用方式,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-06-06
  • SpringBoot設置編碼UTF-8的兩種方法

    SpringBoot設置編碼UTF-8的兩種方法

    本文通過兩種方式給大家介紹SpringBoot 設置編碼UTF-8 ,每種方式通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-11-11
  • java.lang.StackOverflowError出現的原因及解決

    java.lang.StackOverflowError出現的原因及解決

    這篇文章主要介紹了java.lang.StackOverflowError出現的原因及解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-07-07

最新評論

田阳县| 慈利县| 米易县| 济宁市| 镇江市| 南宁市| 西充县| 射阳县| 嵩明县| 灵丘县| 延寿县| 巫溪县| 称多县| 崇明县| 青浦区| 衡水市| 勐海县| 望城县| 永清县| 临湘市| 湘西| 沧州市| 台东县| 利津县| 盐池县| 浠水县| 长宁县| 乌兰县| 加查县| 汕头市| 睢宁县| 高平市| 达拉特旗| 长宁区| 木里| 潼南县| 沁源县| 昔阳县| 蓬溪县| 集贤县| 永州市|