Memcached 高性能的分布式内存对象缓存系统 Memcached的安装、使用实例

??????? Memcached 是一个高性能的分布式内存对象缓存系统，用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数，从而提供动态、数据库驱动网站的速度。Memcached基于一个存储键/值对的hashmap。其守护进程（daemon ）是用C写的，但是客户端可以用任何语言来编写，并通过memcached协议与守护进程通信。但是它并不提供冗余（例如，复制其hashmap条目）；当某个服务器S停止运行或崩溃了，所有存放在S上的键/值对都将丢失。

　　Memcached由Danga Interactive开发，其最新版本发布于2010年，作者为Anatoly Vorobey和Brad Fitzpatrick。用于提升LiveJournal . com访问速度的。LJ每秒动态页面访问量几千次，用户700万。Memcached将数据库负载大幅度降低，更好的分配资源，更快速访问。\

?

?

源地址：http://baike.baidu.com/view/794242.htm

?

?

阿蜜果

源地址: http://www.blogjava.net/amigoxie/archive/2011/02/15/344381.html

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=04、附录

???????? 《Memcached Java客户端编程》：

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

?

?

?