java中Memcached的使用實(shí)例(包括與Spring整合)
一、什么是Memcached?
Memcached是danga.com開發(fā)的分布式內(nèi)存對(duì)象緩存系統(tǒng),所謂分布式,意味著它不是本地的,而是基于網(wǎng)絡(luò)連接完成服務(wù)。Memcached把一些數(shù)據(jù)通過key=value數(shù)據(jù)存儲(chǔ)到內(nèi)存中,這樣訪問更加方便快捷。
但是隨之而來(lái)的問題是如果Memcached關(guān)閉或者M(jìn)emcached的服務(wù)器關(guān)閉那么所保存的內(nèi)容也就沒有了。
二、安裝Memcached服務(wù)端
我是在Win下做的實(shí)驗(yàn)。
首先下載Win下的Memcached,解壓到指定目錄。
memcached.exe -d install 安裝memcached服務(wù)
然后通過Memcached start memcached就啟動(dòng)了。
常用命令:
-p 監(jiān)聽的端口
-l 連接的IP地址, 默認(rèn)是本機(jī)
-d start 啟動(dòng)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 塊大小增長(zhǎng)因子,默認(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ù)器,由于是在本地測(cè)試,只有一個(gè)服務(wù)器地址。默認(rèn)端口是11211
//格式為 服務(wù)器IP:端口號(hào)
String [] addr={"127.0.0.1:11211"};
/**
* 設(shè)置權(quán)重,與設(shè)定的服務(wù)器一一對(duì)應(yīng)
*/
Integer[] weight={3};
//建立通信的連接池
SockIOPool pool=SockIOPool.getInstance();
//設(shè)置連接池可用cache服務(wù)器列表,服務(wù)器構(gòu)成形式:ip地址+端口號(hào)
pool.setServers(addr);
//設(shè)置連接池可用cache服務(wù)器的權(quán)重,和server數(shù)組的位置一一對(duì)應(yīng)
pool.setWeights(weight);
//設(shè)置初始連接數(shù)
pool.setInitConn(5);
//設(shè)置最小連接數(shù)
pool.setMinConn(5);
//設(shè)置最大連接數(shù)
pool.setMaxConn(200);
//設(shè)置可用連接的最長(zhǎng)等待時(shí)間
pool.setMaxIdle(1000*30*30);
//設(shè)置連接池維護(hù)線程的睡眠時(shí)間,設(shè)置為0,維護(hù)線程不啟動(dòng)
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ù)后,啟動(dòng)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
<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 #每個(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
測(cè)試:
@RunWith(SpringJUnit4ClassRunner.class)//表示整合JUnit進(jìn)行測(cè)試
@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基本操作
//創(chuàng)建MemcachedClient 連接memcached服務(wù)器端
MemcachedClient mClient = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
System.out.println("連接memcached成功..........");
//存儲(chǔ)數(shù)據(jù),key-ruo,value-888,時(shí)間是1000秒
Future future = mClient.set("ruo", 1000, "888");
System.out.println("查看ruo的存儲(chǔ)狀態(tài):"+future.get()+",存儲(chǔ)的值:"+mClient.get("ruo"));
//添加數(shù)據(jù),如果key已經(jīng)存儲(chǔ),則不會(huì)更新之前的value,返回NOT_STORED
Future f1 = mClient.add("ruo", 1000, "999");
System.out.println("查看添加ruo的存儲(chǔ)狀態(tài):"+f1.get()+",添加后key:ruo的值是"+mClient.get("ruo"));
//替換replace
Future f2 = mClient.replace("ruo", 1000, "999");
System.out.println("查看替換ruo的存儲(chǔ)狀態(tài):"+f2.get()+",替換后key:ruo的值是"+mClient.get("ruo"));
//追加數(shù)據(jù)append,用來(lái)向已存在的key,追加數(shù)據(jù)
Future f3 = mClient.append("ruo","666");
System.out.println("查看替換ruo的存儲(chǔ)狀態(tài):"+f3.get()+",替換后key:ruo的值是"+mClient.get("ruo"));
//prepend,用來(lái)向已存在的key對(duì)應(yīng)的value前,追加數(shù)據(jù)
Future f4 = mClient.prepend("ruo", "555");
System.out.println("查看替換ruo的存儲(chǔ)狀態(tài):"+f4.get()+",替換后key:ruo的值是"+mClient.get("ruo"));
//清空數(shù)據(jù)庫(kù)
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的存儲(chǔ)狀態(tài):true,存儲(chǔ)的值:888
查看添加ruo的存儲(chǔ)狀態(tài):false,添加后key:ruo的值是888
查看替換ruo的存儲(chǔ)狀態(tài):true,替換后key:ruo的值是999
查看替換ruo的存儲(chǔ)狀態(tài):true,替換后key:ruo的值是999666
查看替換ruo的存儲(chǔ)狀態(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è)參考,也希望大家多多支持腳本之家。
相關(guān)文章
使用Spring MVC攔截器實(shí)現(xiàn)日志記錄的方法
本篇文章主要介紹了使用Spring MVC攔截器實(shí)現(xiàn)日志記錄的方法,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來(lái)看看吧2017-04-04
Java 使用Calendar計(jì)算時(shí)間的示例代碼
這篇文章主要介紹了Java 使用Calendar計(jì)算時(shí)間的示例代碼,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-10-10
springboot利用@Aspect實(shí)現(xiàn)日志工具類的詳細(xì)代碼
這篇文章主要介紹了springboot利用@Aspect實(shí)現(xiàn)日志工具類,通過實(shí)例代碼介紹了導(dǎo)包及在啟動(dòng)類上進(jìn)行注解自動(dòng)掃描的方法,需要的朋友可以參考下2022-03-03
JDBC獲取數(shù)據(jù)庫(kù)連接的5種方式實(shí)例
JDBC是一種用于執(zhí)行SQL語(yǔ)句的JavaAPI,為多種關(guān)系數(shù)據(jù)庫(kù)提供統(tǒng)一訪問,它由一組用Java語(yǔ)言編寫的類和接口組成,提供了諸如查詢和更新數(shù)據(jù)庫(kù)中數(shù)據(jù)的方法,這篇文章主要給大家介紹了關(guān)于JDBC獲取數(shù)據(jù)庫(kù)連接的5種方式,需要的朋友可以參考下2022-06-06
加速spring/springboot應(yīng)用啟動(dòng)速度詳解
這篇文章主要介紹了加速spring/springboot應(yīng)用啟動(dòng)速度詳解,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-07-07

