碼上快樂

相關內容    簡體    繁體

memcached搭建緩存系統

本文轉載自   查看原文   2014-11-27 05:10   3219    memcached

一、概念

Memcached是danga.com（運營LiveJournal的技術團隊）開發的一套分布式內存對象緩存系統，用於在動態系統中減少數據庫負載，提升性能。

二、適用場合

1.分布式應用。由於memcached本身基於分布式的系統，所以尤其適合大型的分布式系統。

2.數據庫前段緩存。數據庫常常是網站系統的瓶頸。數據庫的大並發量訪問，常常造成網站內存溢出。當然我們也可以使用Hibernate的緩存機制。但memcached是基於分布式的，並可獨立於網站應用本身，所以更適合大型網站進行應用的拆分。

3.服務器間數據共享。舉例來講，我們將網站的登錄系統、查詢系統拆分為兩個應用，放在 不同的服務器上，並進行集群，那這個時候用戶登錄后，登錄信息如何從登錄系統服務器同步到查詢系統服務器呢？這時候，我們便可以使用memcached， 登錄系統將登錄信息緩存起來，查詢系統便可以獲得登錄信息，就像獲取本地信息一樣。

三、不適用場合

那些不需要“分布”的，不需要共享的，或者干脆規模小到只有一台服務器的應用，memcached不會帶來任何好處，相反還會拖慢系統效率，因為網絡連接同樣需要資源

四、安裝

這里介紹windows環境的安裝。

1.下載memcache的windows穩定版，解壓放某個盤下面，比如在c:\memcached

2.在cmd下輸入 'c:\memcached\memcached.exe -d install' 安裝

3.再輸入： 'c:\memcached\memcached.exe -d start' 啟動。

以后memcached將作為windows的一個服務每次開機時自動啟動。這樣服務器端已經安裝完畢了。

五、客戶端

Memcached本身是使用C開發的，客戶端可以是php、C#、或者java。我是做java的，所以這里只介紹基於java的客戶端。

我在網上看到基於java的客戶端有兩個

1.java_memcached-release_2.6.3

1)簡介

這是比較通用的Memcached客戶端框架。具體原創不詳。

2)依賴的jar

A.commons-pool-1.5.6.jar

B.java_memcached-release_2.6.3.jar

C.slf4j-api-1.6.1.jar

D.slf4j-simple-1.6.1.jar

2.alisoft-xplatform-asf-cache-2.5.1

1)簡介

這個東東是阿里軟件的架構師岑文初進行封裝的。里面的注釋都是中文的，比較好。

2)依賴的jar

A.alisoft-xplatform-asf-cache-2.5.1.jar

B.commons-logging-1.0.4.jar

C.hessian-3.0.1.jar

D.log4j-1.2.9.jar

E.stax-api-1.0.1.jar

F.wstx-asl-2.0.2.jar

六、范例

1.基於java_memcached-release_2.6.3

Java代碼  
  1. package com.hl.memcached.cache;  
  2.   
  3. import java.util.Date;  
  4.   
  5. import com.danga.MemCached.MemCachedClient;  
  6. import com.danga.MemCached.SockIOPool;  
  7.   
  8. public class MyCache {  
  9.     public static void main(String[] args) {  
  10.         MemCachedClient client=new MemCachedClient();  
  11.         String [] addr ={"127.0.0.1:11211"};  
  12.         Integer [] weights = {3};  
  13.         SockIOPool pool = SockIOPool.getInstance();  
  14.         pool.setServers(addr);  
  15.         pool.setWeights(weights);  
  16.         pool.setInitConn(5);  
  17.         pool.setMinConn(5);  
  18.         pool.setMaxConn(200);  
  19.         pool.setMaxIdle(1000*30*30);  
  20.         pool.setMaintSleep(30);  
  21.         pool.setNagle(false);  
  22.         pool.setSocketTO(30);  
  23.         pool.setSocketConnectTO(0);  
  24.         pool.initialize();  
  25.           
  26. //      String [] s  =pool.getServers();  
  27.         client.setCompressEnable(true);  
  28.         client.setCompressThreshold(1000*1024);  
  29.           
  30. //      將數據放入緩存  
  31.         client.set("test2","test2");  
  32.           
  33. //      將數據放入緩存,並設置失效時間  
  34.         Date date=new Date(2000000);  
  35.         client.set("test1","test1", date);  
  36.           
  37. //      刪除緩存數據  
  38. //      client.delete("test1");  
  39.           
  40. //      獲取緩存數據  
  41.         String str =(String)client.get("test1");  
  42.         System.out.println(str);  
  43.     }  
  44. }  

 

  1. 基於alisoft-xplatform-asf-cache-2.5.1

1)  配置memcached.xml

 

Xml代碼  
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <memcached>  
  3.     <!-- name 屬性是程序中使用Cache的唯一標識;socketpool 屬性將會關聯到后面的socketpool配置; -->  
  4.     <client name="mclient_0" compressEnable="true" defaultEncoding="UTF-8"  
  5.         socketpool="pool_0">  
  6.         <!-- 可選，用來處理出錯情況 -->  
  7.         <errorHandler>com.alisoft.xplatform.asf.cache.memcached.MemcachedErrorHandler  
  8.         </errorHandler>  
  9.     </client>  
  10.   
  11.     <!--  
  12.         name 屬性和client 配置中的socketpool 屬性相關聯。  
  13.         maintSleep屬性是后台線程管理SocketIO池的檢查間隔時間，如果設置為0，則表明不需要后台線程維護SocketIO線程池，默認需要管理。  
  14.         socketTO 屬性是Socket操作超時配置，單位ms。 aliveCheck  
  15.         屬性表示在使用Socket以前是否先檢查Socket狀態。  
  16.     -->  
  17.     <socketpool name="pool_0" maintSleep="5000" socketTO="3000"  
  18.         failover="true" aliveCheck="true" initConn="5" minConn="5" maxConn="250"  
  19.         nagle="false">  
  20.         <!-- 設置memcache服務端實例地址.多個地址用","隔開 -->  
  21.         <servers>127.0.0.1:11211</servers>  
  22.         <!--  
  23.             可選配置。表明了上面設置的服務器實例的Load權重. 例如 <weights>3,7</weights> 表示30% load 在  
  24.             10.2.224.36:33001, 70% load 在 10.2.224.46:33001  
  25.           
  26.         <weights>3,7</weights>  
  27.         -->  
  28.     </socketpool>  
  29. </memcached>  

 

 

2) 測試類

 

Java代碼  
  1. package com.hl.memcached.client.test;  
  2.   
  3. import java.util.ArrayList;  
  4. import java.util.List;  
  5.   
  6. import com.alisoft.xplatform.asf.cache.ICacheManager;  
  7. import com.alisoft.xplatform.asf.cache.IMemcachedCache;  
  8. import com.alisoft.xplatform.asf.cache.memcached.CacheUtil;  
  9. import com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager;  
  10. import com.hl.memcached.cache.client.TestBean;  
  11.   
  12. public class ClientTest {  
  13.       
  14.     @SuppressWarnings("unchecked")  
  15.     public static void main(String[] args) {  
  16.         ICacheManager<IMemcachedCache> manager;  
  17.         manager = CacheUtil.getCacheManager(IMemcachedCache.class,  
  18.                 MemcachedCacheManager.class.getName());  
  19.         manager.setConfigFile("memcached.xml");  
  20.         manager.start();  
  21.         try {  
  22.             IMemcachedCache cache = manager.getCache("mclient_0");  
  23.             cache.put("key", "value");  
  24.             System.out.println(cache.get("key"));  
  25.         } finally {  
  26.             manager.stop();  
  27.         }  
  28.     }  
  29.   
  30. }  

 

 

七、使用memcached緩存java bean自定義對象

Memcached可以緩存String，也可以緩存自定義java bean。但必須是可序列化的java bean（implements Serializable即可）

  1. 基於java_memcached-release_2.6.3

測試用java bean

 

Java代碼  
  1. package com.hl.memcached.cache.client;  
  2.   
  3. import java.io.Serializable;  
  4.   
  5. public class TestBean implements Serializable{  
  6.     private static final long serialVersionUID = 5344571864700659321L;  
  7.       
  8.     private String name;  
  9.     private Integer age;  
  10.     //get、set方法略  
  11. }  

 

 MyCache.java 代碼 

 

Java代碼  
  1. package com.hl.memcached.cache;  
  2.   
  3. import java.util.Date;  
  4.   
  5. import com.danga.MemCached.MemCachedClient;  
  6. import com.danga.MemCached.SockIOPool;  
  7.   
  8. public class MyCache {  
  9.     public static void main(String[] args) {  
  10.         MemCachedClient client=new MemCachedClient();  
  11.         String [] addr ={"127.0.0.1:11211"};  
  12.         Integer [] weights = {3};  
  13.         SockIOPool pool = SockIOPool.getInstance();  
  14.         pool.setServers(addr);  
  15.         pool.setWeights(weights);  
  16.         pool.setInitConn(5);  
  17.         pool.setMinConn(5);  
  18.         pool.setMaxConn(200);  
  19.         pool.setMaxIdle(1000*30*30);  
  20.         pool.setMaintSleep(30);  
  21.         pool.setNagle(false);  
  22.         pool.setSocketTO(30);  
  23.         pool.setSocketConnectTO(0);  
  24.         pool.initialize();  
  25.           
  26. //      String [] s  =pool.getServers();  
  27.         client.setCompressEnable(true);  
  28.         client.setCompressThreshold(1000*1024);  
  29.           
  30. //      將數據放入緩存  
  31.         TestBean bean=new TestBean();  
  32.         bean.setName("name1");  
  33.         bean.setAge(25);  
  34.         client.add("bean1", bean);  
  35.           
  36. //      獲取緩存數據  
  37.         TestBean beanClient=(TestBean)client.get("bean1");  
  38.         System.out.println(beanClient.getName());  
  39.     }  
  40. }  
  1. 基於alisoft-xplatform-asf-cache-2.5.1

 

Java代碼  
  1. package com.hl.memcached.client.test;  
  2.   
  3. import java.util.ArrayList;  
  4. import java.util.List;  
  5.   
  6. import com.alisoft.xplatform.asf.cache.ICacheManager;  
  7. import com.alisoft.xplatform.asf.cache.IMemcachedCache;  
  8. import com.alisoft.xplatform.asf.cache.memcached.CacheUtil;  
  9. import com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager;  
  10. import com.hl.memcached.cache.client.TestBean;  
  11.   
  12. public class ClientTest {  
  13.       
  14.     @SuppressWarnings("unchecked")  
  15.     public static void main(String[] args) {  
  16.         ICacheManager<IMemcachedCache> manager;  
  17.         manager = CacheUtil.getCacheManager(IMemcachedCache.class,  
  18.                 MemcachedCacheManager.class.getName());  
  19.         manager.setConfigFile("memcached.xml");  
  20.         manager.start();  
  21.         try {  
  22.             IMemcachedCache cache = manager.getCache("mclient_0");  
  23.   
  24.             TestBean bean=new TestBean();  
  25.             bean.setName("name1");  
  26.             bean.setAge(25);  
  27.             cache.put("bean", bean);  
  28.             TestBean beanClient=(TestBean)cache.get("bean");  
  29.             System.out.println(beanClient.getName());  
  30.               
  31.             List<TestBean> list=new ArrayList<TestBean>();  
  32.             list.add(bean);  
  33.             cache.put("beanList", list);  
  34.             List<TestBean> listClient=(List<TestBean>)cache.get("beanList");  
  35.             if(listClient.size()>0){  
  36.                 TestBean bean4List=listClient.get(0);  
  37.                 System.out.println(bean4List.getName());  
  38.             }  
  39.         } finally {  
  40.             manager.stop();  
  41.         }  
  42.     }  
  43.   
  44. }  

 

八、參考資料：

http://blog.developers.api.sina.com.cn/?p=124

http://www.infoq.com/cn/articles/memcached-java

九、源代碼及資料見附件

  • demo.rar (1006.6 KB)
  • 下載次數: 826


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 Memcached 數據緩存系統 simple-spring-memcached緩存搭建 Python-Flask-Memcached緩存系統 php分布式緩存系統 Memcached 入門 分布式緩存系統Memcached簡介與實踐 MemCached緩存操作 文件緩存與memcached的區別 C# Memcached 緩存 Memcached集群/分布式/高可用 及 Magent緩存代理搭建過程 詳解 Memcached集群原理以及搭建
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM