第java中Memcached的使用實例(包括與Spring整合)一、什么是Memcached？

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

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

二、安裝Memcached服務端

我是在Win下做的實驗。

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

memcached.exe-dinstall安裝memcached服務

然后通過Memcachedstartmemcached就啟動了。

常用命令：

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

-l連接的IP地址,默認是本機

-dstart啟動memcached服務

-drestart重起memcached服務

-dstop|shutdown關(guān)閉正在運行的memcached服務

-dinstall安裝memcached服務

-duninstall卸載memcached服務

-u以的身份運行(僅在以root運行的時候有效)

-m最大內(nèi)存使用，單位MB。默認64MB

-M內(nèi)存耗盡時返回錯誤，而不是刪除項

-c最大同時連接數(shù)，默認是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

publicvoidshow(){

MemCachedClientclient=newMemCachedClient();

//使用的服務器，由于是在本地測試，只有一個服務器地址。默認端口是11211

//格式為服務器IP:端口號

String[]addr={":11211"};

*設置權(quán)重，與設定的服務器一一對應

Integer[]weight={3};

//建立通信的連接池

SockIOPoolpool=SockIOPool.getInstance();

//設置連接池可用cache服務器列表，服務器構(gòu)成形式：ip地址+端口號

pool.setServers(addr);

//設置連接池可用cache服務器的權(quán)重，和server數(shù)組的位置一一對應

pool.setWeights(weight);

//設置初始連接數(shù)

pool.setInitConn(5);

//設置最小連接數(shù)

pool.setMinConn(5);

//設置最大連接數(shù)

pool.setMaxConn(200);

//設置可用連接的最長等待時間

pool.setMaxIdle(1000*30*30);

//設置連接池維護線程的睡眠時間，設置為0，維護線程不啟動

pool.setMaintSleep(30);

//設置Nagle算法，設置為false，因為通訊數(shù)據(jù)量比較大要求相應及時

pool.setNagle(false);

//設置socket讀取等待超時時間

pool.setSocketTO(30);

//設置連接等待超時值

pool.setSocketConnectTO(0);

//設置完參數(shù)后，啟動pool

pool.initialize();

client.set("value","Ok");

Stringvalue=(String)client.get("value");

//設置定時時間2s后消失

client.set("value1","OK2",newDate(2000));

Stringvalue2=(String)client.get("value1");

System.out.println(value);

System.out.println(value2);

2、spring整合memcached

bean

propertyname="locations"

list

valueclasspath:property/perties/value

/list

/property

/bean

!--spring整合memched--

beanid="memcachedPool"factory-method="getInstance"

init-method="initialize"destroy-method="shutDown"

propertyname="servers"

list

value${memcached.server}/value

/list

/property

propertyname="maxConn"value="${memcached.maxConn}"/property

propertyname="maintSleep"value="${memcached.maniSleep}"/property

propertyname="nagle"value="${memcached.nagle}"/property

propertyname="socketTO"value="${memcached.socketTO}"/property

/bean

properties配置文件：

#服務器地址

memcached.server=:11211

#初始連接數(shù)目

memcached.initConn=20

#每個服務器建立最大連接數(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進行測試

@ContextConfiguration(locations={"classpath:applicationContext.xml"})

publicclassSpringTest{

@Test

publicvoidtest1(){

MemCachedClientmemCachedClient=newMemCachedClient();

memCachedClient.set("username","luck");

Stringvalue=(String)memCachedClient.get("username");

System.out.println(value);

四、個人學習中遇到的問題：

我們通過客戶端添加與獲得數(shù)據(jù)，那么這個客戶端如何與pool聯(lián)系的，通過別人的博客找到答案。

客戶端是通過pool的name關(guān)聯(lián)到某個pool上的。

客戶端與Pool都沒有指定名稱的時候，默認是創(chuàng)建名稱為“default”的pool，客戶端與它關(guān)聯(lián)。

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

Memcached結(jié)合java基本操作

//創(chuàng)建MemcachedClient連接memcached服務器端

MemcachedClientmClient=newMemcachedClient(newInetSocketAddress("",11211));

System.out.println("連接memcached成功..........");

//存儲數(shù)據(jù),key-ruo,value-888,時間是1000秒

Futurefuture=mClient.set("ruo",1000,"888");

System.out.println("查看ruo的存儲狀態(tài)："+future.get()+",存儲的值："+mClient.get("ruo"));

//添加數(shù)據(jù),如果key已經(jīng)存儲，則不會更新之前的value，返回NOT_STORED

Futuref1=mClient.add("ruo",1000,"999");

System.out.println("查看添加ruo的存儲狀態(tài)："+f1.get()+",添加后key：ruo的值是"+mClient.get("ruo"));

//替換replace

Futuref2=mClient.replace("ruo",1000,"999");

System.out.println("查看替換ruo的存儲狀態(tài)："+f2.get()+",替換后key：ruo的值是"+mClient.get("ruo"));

//追加數(shù)據(jù)append，用來向已存在的key，追加數(shù)據(jù)

Futuref3=mClient.append("ruo","666");

System.out.println("查看替換ruo的存儲狀態(tài)："+f3.get()+",替換后key：ruo的值是"+mClient.get("ruo"));

//prepend，用來向已存在的key對應的value前，追加數(shù)據(jù)

Futuref4=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é)果

2025-10-3011:23:07.350INFOnet.spy.memcached.MemcachedConnection:Connectionstatechangedforsun.nio.ch.SelectionKeyImpl@38a22ea7

查看ruo的存儲狀態(tài)：true,存儲的值：888

查看添加ruo的存儲狀態(tài)：false,添加后key：ruo的值是888

查