av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

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

瀏覽:2日期:2022-08-09 10:15:25
一、什么是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)閉或者M(jìn)emcached的服務(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)是本機(jī)

-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è)置連接池維護(hù)線程的睡眠時間,設(shè)置為0,維護(hù)線程不啟動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ù)后,啟動poolpool.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 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進(jìn)行測試@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_STOREDFuture f1 = mClient.add('ruo', 1000, '999');System.out.println('查看添加ruo的存儲狀態(tài):'+f1.get()+',添加后key:ruo的值是'+mClient.get('ruo'));//替換replaceFuture 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的值是5559996662018-10-30 11:23:07.368 INFO net.spy.memcached.MemcachedConnection: Shut down memcached client

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Java
相關(guān)文章:
主站蜘蛛池模板: 狠狠做深爱婷婷综合一区 | 久久av网| 欧美 视频 | 久久久久久久一区 | 在线观看国产视频 | 欧美日韩一区二区三区在线观看 | 久久综合一区 | 欧美日韩久久久 | h视频网站在线观看 | 99热最新网址| 国产精品99一区二区 | 自拍偷拍中文字幕 | 日本在线视频中文字幕 | 韩日av在线 | 男女网站视频 | 91国内视频在线 | 国产成人精品区一区二区不卡 | 亚洲精品1区 | 色男人的天堂 | 亚洲精品视频一区二区三区 | 成人午夜在线 | 91久久精品国产91久久性色tv | 国产电影一区二区三区爱妃记 | 伊人艹 | 在线看片网站 | 羞羞色网站 | av网站在线看 | 国产精品污www在线观看 | 一级看片免费视频 | 成人在线视频免费观看 | 婷婷综合五月天 | 国产亚洲人成a在线v网站 | 男人天堂av网站 | 99久久免费精品 | 成人在线视频网 | 日韩国产精品一区二区三区 | 国产特一级黄色片 | 91一区二区三区在线观看 | 91啪影院 | 五月天婷婷丁香 | 91麻豆精品国产91久久久更新资源速度超快 |