一、什么是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下做的實(shí)驗(yàn)。
首先下載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)閉正在運(yùn)行的memcached服務(wù)
-d install 安裝memcached服務(wù)
-d uninstall 卸載memcached服務(wù)
-u 以的身份運(yùn)行 (僅在以root運(yùn)行的時(shí)候有效)
-m 最大內(nèi)存使用，單位mb。默認(rèn)64mb
-m 內(nèi)存耗盡時(shí)返回錯(cuò)誤，而不是刪除項(xiàng)
-c 最大同時(shí)連接數(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、基本使用：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
@test public void show(){ memcachedclient client=new memcachedclient(); //使用的服務(wù)器，由于是在本地測試，只有一個(gè)服務(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è)置可用連接的最長等待時(shí)間 pool.setmaxidle(1000*30*30); //設(shè)置連接池維護(hù)線程的睡眠時(shí)間，設(shè)置為0，維護(hù)線程不啟動 pool.setmaintsleep(30); //設(shè)置nagle算法，設(shè)置為false，因?yàn)橥ㄓ崝?shù)據(jù)量比較大要求相應(yīng)及時(shí) pool.setnagle(false); //設(shè)置socket讀取等待超時(shí)時(shí)間 pool.setsocketto(30); //設(shè)置連接等待超時(shí)值 pool.setsocketconnectto(0); //設(shè)置完參數(shù)后，啟動pool pool.initialize(); client.set("value","ok"); string value= (string) client.get("value"); //設(shè)置定時(shí)時(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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
<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配置文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
#服務(wù)器地址memcached.server=127.0.0.1:11211#初始連接數(shù)目memcached.initconn=20#每個(gè)服務(wù)器建立最大連接數(shù)memcached.maxconn=50#自查線程周期工作，其每次休眠時(shí)間memcached.manisleep=3000#是否使用nagle算法（socket參數(shù)，如果是true，寫數(shù)據(jù)不緩沖，直接發(fā)送）memcached.nagle=false#socket阻塞讀取數(shù)據(jù)的超時(shí)時(shí)間memcached.socketto=3000 |
測試：
|
1
2
3
4
5
6
7
8
9
10
11
|
@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); }} |
四、個(gè)人學(xué)習(xí)中遇到的問題：
我們通過客戶端添加與獲得數(shù)據(jù)，那么這個(gè)客戶端如何與pool聯(lián)系的，通過別人的博客找到答案。
客戶端是通過pool的name關(guān)聯(lián)到某個(gè)pool上的。
客戶端與pool都沒有指定名稱的時(shí)候，默認(rèn)是創(chuàng)建名稱為“default”的pool，客戶端與它關(guān)聯(lián)。
如果pool設(shè)置了名字，那么客戶也要指定名稱。
memcached結(jié)合java基本操作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
//創(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,時(shí)間是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(); |
運(yùn)行結(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
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://www.cnblogs.com/GregZQ/p/8365276.html
