Memcached的安装、使用实例

1、 Memcached 介绍

Memcached是高性能的，分布式的内存对象缓存系统，用于在动态应用中减少数据库负载，提升访问速度。 Memcached由 Danga 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项目中。

3 、 Memcached 的使用

3.1 创建项目

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

3.2 SockIOPool 类及其常用方法

         SockIOPool是 socket连接池类，常用方法如下：

l  setServers(String[] servers)：设置服务器信息数组；

l  setWeights(String[] weights)：设置服务器权重数组；

l  setInitConn(int count)：设置初始连接数；

l  setMinConn(int minConn)：设置最小连接数；

l  setMaxConn(int maxConn)：设置最大连接数；

l  setMaxIdle(long arg0)：设置最大处理时间；

l  setMaintSleep(long arg0)：主线程的睡眠时间；

l  initialize()：初始化连接池。

3.3 MemCachedClient 类及其常用方法

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

l  add(String key, Object value)：添加一个键值对到缓存中；

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

l  set(String key, Object value)：在缓存中设置一个键的值；

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

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

l  incr(String key)：为某个键上的值执行 +1操作；

l  decr(String key)：为某个键上的值执行 -1操作；

l  replace(String key, String value)：将某个键的值替换成新的值；

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

3.4 使用实例

         在 memcacheddemo工程的源码目录创建测试的 Java类 MemcachedTest，该类的代码参考如下：

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