一、什么是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、基本使用:
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(); //使用的服務器,由于是在本地測試,只有一個服務器地址。默認端口是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
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
|
#服務器地址 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 |
測試:
1
2
3
4
5
6
7
8
9
10
11
|
@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設置了名字,那么客戶也要指定名稱。
memcached結合java基本操作
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
//創建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的存儲狀態:" +future.get()+ ",存儲的值:" +mclient.get( "ruo" )); //添加數據,如果key已經存儲,則不會更新之前的value,返回not_stored future f1 = mclient.add( "ruo" , 1000 , "999" ); system.out.println( "查看添加ruo的存儲狀態:" +f1.get()+ ",添加后key:ruo的值是" +mclient.get( "ruo" )); //替換replace future f2 = mclient.replace( "ruo" , 1000 , "999" ); system.out.println( "查看替換ruo的存儲狀態:" +f2.get()+ ",替換后key:ruo的值是" +mclient.get( "ruo" )); //追加數據append,用來向已存在的key,追加數據 future f3 = mclient.append( "ruo" , "666" ); system.out.println( "查看替換ruo的存儲狀態:" +f3.get()+ ",替換后key:ruo的值是" +mclient.get( "ruo" )); //prepend,用來向已存在的key對應的value前,追加數據 future f4 = mclient.prepend( "ruo" , "555" ); system.out.println( "查看替換ruo的存儲狀態:" +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的存儲狀態:true,存儲的值:888
查看添加ruo的存儲狀態:false,添加后key:ruo的值是888
查看替換ruo的存儲狀態:true,替換后key:ruo的值是999
查看替換ruo的存儲狀態:true,替換后key:ruo的值是999666
查看替換ruo的存儲狀態:true,替換后key:ruo的值是555999666
2018-10-30 11:23:07.368 info net.spy.memcached.memcachedconnection: shut down memcached client
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持服務器之家。
原文鏈接:https://www.cnblogs.com/GregZQ/p/8365276.html