码迷，mamicode.com
首页 > 系统相关 > 详细

memcached搭建缓存系统

时间：2014-11-27 06:47:23      阅读：442      评论：0      收藏：0      [点我收藏+]

标签：blog   http   io   ar   使用   sp   java   for   文件   

一、概念

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

memcached搭建缓存系统

标签：blog   http   io   ar   使用   sp   java   for   文件   

原文地址：http://www.cnblogs.com/han1982/p/4125527.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！