——Memcached的安装、使用实例
文:阿蜜果
日期:2011-2-15
版权所有,转载请注明出处:http://www.blogjava.net/amigoxie/archive/2011/02/15/344381.html
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.exe -d install上面这行表示安装Memcached为服务,这样才能正常运行。接着运行如下这样来启动Memcached,还可指定-l参数,表示启动的IP,-m表示缓存大小:
 memcached.exe -d start
memcached.exe -d start若指定了-m,则表示缓存大小为-m后的数字,单位是M,例如:
 memcached.exe –l 127.0.0.1 –m 32 -d start
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 java.util.Date;

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


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

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

 protected static MemcachedTest memCached = new MemcachedTest();
    protected static MemcachedTest memCached = new MemcachedTest();

 // 设置与缓存服务器的连接池
    // 设置与缓存服务器的连接池

 static
    static  {
{
 // 服务器列表和其权重
        // 服务器列表和其权重

 String[] servers =
        String[] servers =  {"127.0.0.1:11211"};
{"127.0.0.1:11211"};

 Integer[] weights =
        Integer[] weights =  {3};
{3};

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

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

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

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

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

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

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


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

 protected MemcachedTest()
    protected MemcachedTest()  {
{

 }
    }


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

 public static MemcachedTest getInstance()
    public static MemcachedTest getInstance()  {
{
 return memCached;
        return memCached;
 }
    }


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

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


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

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


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

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


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

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


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

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

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

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

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

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


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

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

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

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

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

 public static void main(String[] args)
    public static void main(String[] args)  {
{
 MemcachedTest cache = MemcachedTest.getInstance();
        MemcachedTest cache = MemcachedTest.getInstance();
 cache.set("count", 123);
        cache.set("count", 123);
 System.out.println("count=" + cache.get("count"));
        System.out.println("count=" + cache.get("count"));
 boolean flag = cache.add("schedule_2", "0");
        boolean flag = cache.add("schedule_2", "0");
 System.out.println("flag=" + flag);
        System.out.println("flag=" + flag);
 System.out.println("schedule_2=" + cache.get("schedule_2"));
        System.out.println("schedule_2=" + cache.get("schedule_2"));
 }
    }
 }
}      运行结果为:
 count=123
count=123
 flag=true
flag=true
 schedule_2=0
schedule_2=04、附录
         《Memcached Java客户端编程》:
http://sailinglee.javaeye.com/blog/752847
	posted on 2011-02-15 18:06 
阿蜜果 阅读(3038) 
评论(3)  编辑  收藏  所属分类: 
Java 、
解决方案