posts - 297,  comments - 1618,  trackbacks - 0

 

——Memcached的安装、使用实例

文:阿蜜果

日期:2011-2-15
版权所有,转载请注明出处:http://www.blogjava.net/amigoxie/archive/2011/02/15/344381.html

1、Memcached介绍

Memcached是高性能的,分布式的内存对象缓存系统,用于在动态应用中减少数据库负载,提升访问速度。MemcachedDanga Interactive开发,用于提升LiveJournal.com访问速度的。LJ每秒动态页面访问量几千次,用户700万。Memcached将数据库负载大幅度降低,更好的分配资源,更快速访问。

Memcached的最新版是采用c语言进行开发和设计的,它是一个应用软件,是作为缓存服务器的服务器端运行在服务器上的,需要使用特定的语言编写客户端与其进行通信来进行数据的缓存和获取。

在系统中,通常将Memcached安装运行在服务器上,然后通过对需要的数据进行缓存,所有数据的缓存设置和存取操作,以及数据的更新后替换操作全部需要程序来进行。

2、Memcached的安装

2.1 主程序的安装

一般的服务器都是采用Linux,笔者只是讲述在Windows上如何安装Memcached,在Linux上的安装请参考网上其它资料。

Windows版本的下载地址为:http://code.jellycan.com/memcached/

当前win32的最新版本是1.2.6,下载页面参考如下:
   

在上图中点击“memcached-1.2.6-win32-bin.zip”进入下载页面,下载后,将其解压到D盘下,解压后的D:"memcached-1.2.6-win32-bin目录下有一个memcached.exe

Windows的命令行(cmd命令进入命令行)窗口进入该目录,首先运行:

memcached.exe -d install

上面这行表示安装Memcached为服务,这样才能正常运行。接着运行如下这样来启动Memcached,还可指定-l参数,表示启动的IP-m表示缓存大小:

memcached.exe -d start

若指定了-m,则表示缓存大小为-m后的数字,单位是M,例如:

memcached.exe –l 127.0.0.1 –m 32 -d start

运行参考如下图所示:
  

2.2 Java客户端的安装

下载地址为:https://github.com/gwhalin/Memcached-Java-Client

下载页面参考如下:
  

         在上图中点击右侧区域的“Downloads”,弹出的下载小窗口如下图:
   

         当前最新的版本是2.5.2,点击“java_memcached-release_2.5.2.zip”下载。下载后解压,目录结构如下图所示:
   

         在应用中,需要将“java_memcached-release_2.5.2.jar”包拷贝到Java项目中。

3Memcached的使用

3.1 创建项目

MyEclipse中创建一个名为memcacheddemo的测试项目,src放源代码,binclasses文件,libjar包,并将java_memcached-release_2.5.2.jar拷贝到lib目录中,目录结构如下:
  

3.2 SockIOPool类及其常用方法

         SockIOPoolsocket连接池类,常用方法如下:

setServers(String[] servers):设置服务器信息数组;

setWeights(String[] weights):设置服务器权重数组;

setInitConn(int count):设置初始连接数;

setMinConn(int minConn):设置最小连接数;

setMaxConn(int maxConn):设置最大连接数;

setMaxIdle(long arg0):设置最大处理时间;

setMaintSleep(long arg0):主线程的睡眠时间;

initialize():初始化连接池。

3.3 MemCachedClient类及其常用方法

         MemCachedClient类用于对Memcached内存对象缓存系统进行操作,常用方法如下:

add(String key, Object value):添加一个键值对到缓存中;

add(String key, Object value,Date expires):添加一个键值对到缓存中,并设置其超时时间;

set(String key, Object value):在缓存中设置一个键的值;

set(String key, Object value, Date expires):在缓存中设置一个键的值,并设置其超时时间;

get(String key):获得某个键的值。

incr(String key):为某个键上的值执行+1操作;

decr(String key):为某个键上的值执行-1操作;

replace(String key, String value):将某个键的值替换成新的值;

replace(String key, String value, Date expires):将某个键的值替换成新的值,并设置其超时时间。

3.4 使用实例

         memcacheddemo工程的源码目录创建测试的JavaMemcachedTest,该类的代码参考如下:

import java.util.Date;

import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;

/**
 * 使用memcached的缓存测试类.
 * 
@author 阿蜜果
 
*/

public class MemcachedTest {
    
// 创建全局的唯一实例
    protected static MemCachedClient mcc = new MemCachedClient();

    
protected static MemcachedTest memCached = new MemcachedTest();

    
// 设置与缓存服务器的连接池
    static {
        
// 服务器列表和其权重
        String[] servers = {"127.0.0.1:11211"};
        Integer[] weights 
= {3};

        
// 获取socket连接池的实例对象
        SockIOPool pool = SockIOPool.getInstance();

        
// 设置服务器信息
        pool.setServers(servers);
        pool.setWeights(weights);

        
// 设置初始连接数、最小和最大连接数以及最大处理时间
        pool.setInitConn(5);
        pool.setMinConn(
5);
        pool.setMaxConn(
250);
        pool.setMaxIdle(
1000 * 60 * 60 * 6);

        
// 设置主线程的睡眠时间
        pool.setMaintSleep(30);

        
// 设置TCP的参数,连接超时等
        pool.setNagle(false);
        pool.setSocketTO(
3000);
        pool.setSocketConnectTO(
0);

        
// 初始化连接池
        pool.initialize();

        
// 压缩设置,超过指定大小(单位为K)的数据都会被压缩
        mcc.setCompressEnable(true);
        mcc.setCompressThreshold(
64 * 1024);
    }


    
/**
     * 保护型构造方法,不允许实例化
     
*/

    
protected MemcachedTest() {

    }


    
/**
     * 获取唯一实例.
     * 
@return
     
*/

    
public static MemcachedTest getInstance() {
        
return memCached;
    }


    
/**
     * 添加一个指定的值到缓存中.
     * 
@param key 键
     * 
@param value 值
     * 
@return 在缓存中若该key不存在,并成功添加返回true,否则将返回false
     
*/

    
public boolean add(String key, Object value) {
        
return mcc.add(key, value);
    }


    
/**
     * 添加一个键值对到缓存中.
     * 
@param key 键
     * 
@param value 值
     * 
@param expires 超时时间
     * 
@return 在缓存中若该key不存在,并成功添加返回true,否则将返回false
     
*/

    
public boolean add(String key, Object value, Date expires) {
        
return mcc.add(key, value, expires);
    }


    
/**
     * 将某个键的值改变成新值,首先需要保证该键存在.
     * 
@param key 键
     * 
@param value 值
     * 
@return 成功返回true,失败返回false
     
*/

    
public boolean replace(String key, Object value) {
        
return mcc.replace(key, value);
    }


    
/**
     * 将某个键的值改变成新值,首先需要保证该键存在.
     * 
@param key 键
     * 
@param value 值
     * 
@param expires 超时时间
     * 
@return 成功返回true,失败返回false
     
*/

    
public boolean replace(String key, Object value, Date expires) {
        
return mcc.replace(key, value, expires);
    }


    
/**
     * 添加一个指定的值到缓存中.
     * 
@param key
     * 
@param value
     * 
@return 成功返回true,否则返回false
     
*/

    
public boolean set(String key, Object value) {
        
return mcc.set(key, value);
    }

    
    
/**
     * 添加一个指定的值到缓存中,并设置其超时时间.
     * 
@param key 键
     * 
@param value 值
     * 
@param expires 超时时间
     * 
@return 成功返回true,否则返回false
     
*/

    
public boolean set(String key, Object value, int expires) {
        
return mcc.set(key, value, expires);
    }

    
    
/**
     * 根据指定的关键字获取对象.
     * 
@param key
     * 
@return 返回value
     
*/

    
public Object get(String key) {
        
return mcc.get(key);
    }


    
/**
     * 将指定key的value值+1,将返回最后的value值
     * 
@param key 
     * 
@return 返回最后的value值
     
*/

    
public long incr(String key) {
        
return mcc.incr(key);
    }

    
    
/**
     * 将指定key的value值-1,将返回最后的value值
     * 
@param key 
     * 
@return 返回最后的value值
     
*/

    
public long decr(String key) {
        
return mcc.decr(key);
    }

    
    
/**
     * 测试方法
     * 
@param args
     
*/

    
public static void main(String[] args) {
        MemcachedTest cache 
= MemcachedTest.getInstance();
        cache.set(
"count"123);
        System.out.println(
"count=" + cache.get("count"));
        
boolean flag = cache.add("schedule_2""0");
        System.out.println(
"flag=" + flag);
        System.out.println(
"schedule_2=" + cache.get("schedule_2"));
    }

}

      运行结果为:

count=123
flag
=true
schedule_2
=0

4、附录

         Memcached Java客户端编程》:

http://sailinglee.javaeye.com/blog/752847

posted on 2011-02-15 18:06 阿蜜果 阅读(2966) 评论(3)  编辑  收藏 所属分类: Java解决方案


FeedBack:
# re: 在系统中使用内存对象缓存系统(下篇)[未登录]
2011-02-16 09:33 | roywong
虽然以前在IBM 论坛看过类似帖子 ,但没有楼主这么详细的。感谢下,学习了  回复  更多评论
  
# re: 在系统中使用内存对象缓存系统(下篇)
2011-02-16 12:35 | 陈于喆
memcached确实已经得到了广泛的应用,不过始终在java的应用不如php简便,前面我也记录过一点memcached在java应用中碰到的一些问题和应用http://www.blogjava.net/dongbule/archive/2010/12/08/340066.html  回复  更多评论
  
# re: 在系统中使用内存对象缓存系统(下篇)
2011-02-20 17:19 | 淘宝网女装2011春装
确实,博主这篇帖子写得非常详细,很受教!!  回复  更多评论
  

只有注册用户登录后才能发表评论。


网站导航:
 
<2011年2月>
303112345
6789101112
13141516171819
20212223242526
272812345
6789101112

      生活将我们磨圆,是为了让我们滚得更远——“圆”来如此。
      我的作品:
      玩转Axure RP  (2015年12月出版)
      

      Power Designer系统分析与建模实战  (2015年7月出版)
      
     Struts2+Hibernate3+Spring2   (2010年5月出版)
     

留言簿(262)

随笔分类

随笔档案

文章分类

相册

关注blog

积分与排名

  • 积分 - 2279820
  • 排名 - 3

最新评论

阅读排行榜

评论排行榜