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

一、什么是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、基本使用：

@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);//設置完參數后，啟動poolpool.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

<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配置文件：

#服務器地址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

測試：

@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基本操作

//創建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_STOREDFuture f1 = mClient.add('ruo', 1000, '999');System.out.println('查看添加ruo的存儲狀態：'+f1.get()+',添加后key：ruo的值是'+mClient.get('ruo'));//替換replaceFuture 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的值是5559996662018-10-30 11:23:07.368 INFO net.spy.memcached.MemcachedConnection: Shut down memcached client

以上為個人經驗，希望能給大家一個參考，也希望大家多多支持好吧啦網。