Memcached使用入门

我不是女神ヾ 2022-08-26 14:17 159阅读 0赞

转：http://www.linuxidc.com/Linux/2011-12/49516.htm

参考：https://code.google.com/p/xmemcached/wiki/User\_Guide\_zh

## Memcached基础及示例程序 ##

1. What is Memcached?

Memcached是一个免费开源、高性能、分布式的内存对象缓存系统。Memcached是在内存中，为特定数据（字符串或对象）构建key-value的小块数据存储。

2. 下载Memcached的服务器端软件

Windows平台版本下载：http://splinedancer.com/memcached-win32/memcached-1.2.4-Win32-Preview-20080309\_bin.zip

Linux平台版本下载：http://memcached.googlecode.com/files/memcached-1.4.10.tar.gz

3. 在服务器上部署Memcached Server

以下以Windows平台为例：

参考：http://www.codeforest.net/how-to-install-memcached-on-windows-machine

下载下来的Windows版本解压到C:/memcached/

在控制台输入命令安装：

c:/memcached/memcached.exe  -d install

启动：

c:/memcached/memcached.exe -d  start

或：

1.  net start "memcached Server"

默认的缓存大小为64M，如果不够用，请打开注册表，找到：

将其内容修改为：

4. 下载Memcached的客户端API包

下载地址：http://spymemcached.googlecode.com/files/memcached-2.5.jar

5. 编写一个Java数据类

package com.sinosuperman.memcached;  
      
    import java.io.Serializable;  
      
      
    public class User implements Serializable{   
      
        private static final long serialVersionUID = -372274003834027815L;  
      
        String userId;  
          
        public User(String userId) {   
            super();   
            this.userId = userId;   
        }  
          
        public String getUserId() {   
            return userId;   
        }   
          
        public void setUserId(String userId) {   
            this.userId = userId;   
        }   
              
        @Override   
        public String toString() {   
            // TODO Auto-generated method stub    
            StringBuffer sb=new StringBuffer();   
            sb.append("userId="+this.userId);   
            return sb.toString();   
        }   
    }

6. 编写一个Memcached的客户端

package com.sinosuperman.memcached;  
      
    import java.io.IOException;  
    import java.net.InetSocketAddress;  
      
    import net.spy.memcached.MemcachedClient;  
      
    public class TestMemcached {  
        public static void main(String[] args) throws IOException {  
            MemcachedClient cache = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));  
            for (int i = 1; i < 10; i++) {  
                cache.set("T0001" + i, 3600, new User(i + ""));   
            }  
            User myObject = (User) cache.get("T00011");  
            System.out.println("Get object from mem :" + myObject);   
        }   
    }

7. 运行测试

运行结果应该如下：

1.  2011\-12\-15 17:25:30.276 INFO net.spy.memcached.MemcachedConnection:  Added \{QA sa=/127.0.0.1:11211, \#Rops=0, \#Wops=0, \#iq=0, topRop=**null**, topWop=**null**, toWrite=0, interested=0\} to connect queue  
2.  2011\-12\-15 17:25:30.292 INFO net.spy.memcached.MemcachedConnection:  Connection state changed **for** sun.nio.ch.SelectionKeyImpl@c62080  
3.  Get object from mem :userId=1

## Memcached Java API基础之MemcachedClient ##

1. 构造函数

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;MemcachedClient(InetSocketAddress[]&nbsp;ia)&nbsp;</span><span><strong><span style="color:#66ccff">throws</span></strong></span><span style="color:#ffffff">&nbsp;IOException; &nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;MemcachedClient(List&lt;InetSocketAddress&gt;&nbsp;addrs)&nbsp;</span><span><strong><span style="color:#66ccff">throws</span></strong></span><span style="color:#ffffff">&nbsp;IOException; &nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;MemcachedClient(ConnectionFactory&nbsp;cf,&nbsp;List&lt;InetSocketAddress&gt;&nbsp;addrs)&nbsp;</span><span><strong><span style="color:#66ccff">throws</span></strong></span><span style="color:#ffffff">&nbsp;IOException;</span></td> 
  </tr> 
 </tbody> 
</table>

其中最简单的构造函数就是第一个，可以直接传递一个InetSocketAddress，也可以是InetSocketAddress的数组。其实InetSocketAddress也是被转换成数组的。

比如：

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span style="color:#ffffff">MemcachedClient&nbsp;cache&nbsp;=&nbsp;</span><span><strong><span style="color:#66ccff">new</span></strong></span><span style="color:#ffffff">&nbsp;MemcachedClient(</span><span><strong><span style="color:#66ccff">new</span></strong></span><span style="color:#ffffff">&nbsp;InetSocketAddress(</span><span><span style="color:#ff9900">"127.0.0.1"</span></span><span style="color:#ffffff">,&nbsp;</span><span><span style="color:#c00000">11211</span></span><span style="color:#ffffff">)); &nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

2. 常用方法

一般缓存数据的常用操作有：set(add+replace)、get、replace、add

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;Future&lt;Boolean&gt;&nbsp;set(String&nbsp;key,&nbsp;</span><span><strong><span style="color:#66ccff">int</span></strong></span><span style="color:#ffffff">&nbsp;exp,&nbsp;Object&nbsp;o) &nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

第一个参数：键（key）

第二个参数：过期时间（单位是秒）

第三个参数：要设置缓存中的对象（value），如果没有则插入，如果有则修改。

第一个参数：键（key）

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;Future&lt;Boolean&gt;&nbsp;replace(String&nbsp;key,&nbsp;</span><span><strong><span style="color:#66ccff">int</span></strong></span><span style="color:#ffffff">&nbsp;exp,&nbsp;Object&nbsp;o) &nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

第一个参数：键（key）

第二个参数：过期时间（单位是秒）

第三个参数：该键的新值（new value），如果有则修改。

<table style="color:rgb(51,51,51); font-family:tahoma,宋体; font-size:14px; line-height:22.399999618530273px; table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span><strong><span style="color:#66ccff">public</span></strong></span><span style="color:#ffffff">&nbsp;Future&lt;Boolean&gt;&nbsp;add(String&nbsp;key,&nbsp;</span><span><strong><span style="color:#66ccff">int</span></strong></span><span style="color:#ffffff">&nbsp;exp,&nbsp;Object&nbsp;o)&nbsp;&nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

第一个参数：键（key）

第二个参数：过期时间（单位是秒）

第三个参数：该键的值（value），如果没有则插入。

## Memcached配置参数初解 ##

**一、基本参数**

在我们第一次安装Memcached时，一般都是用过这个命令：

<table style="table-layout:fixed; border-collapse:collapse"> 
 <tbody> 
  <tr> 
   <td style="font-size:14px; word-wrap:break-word; font-family:tahoma,宋体; line-height:1.6"> &nbsp;<span style="color:#ffffff">memcached&nbsp;-m&nbsp;512&nbsp;-u&nbsp;root&nbsp;-d&nbsp;-l&nbsp;127.0.0.1&nbsp;-p&nbsp;11211&nbsp;&nbsp;</span></td> 
  </tr> 
 </tbody> 
</table>

我们先来解释这几个参数的含义吧。

\-m 指定缓存所使用的最大内存容量，单位是Megabytes，默认是64MB

\-u 只有以root身份运行时才指定该参数

\-d 以daemon的形式运行

\-l 指定监听的地址

\-p 指定监听的TCP端口号，默认是11211

**二、其他常用的参数**

\-t 指定线程数，默认是4个

\-h 打印帮助信息

\-c 最大同时连接数，默认是1024.

\-U 指定监听的UDP端口号，默认是11211

\-M 内存耗尽时显示错误，而不是删除项

一开始说的“-d”参数需要进行进一步的解释

\-d install 安装memcached

\-d uninstall 卸载memcached

\-d start 启动memcached服务

\-d restart 重启memcached服务

\-d stop 停止memcached服务

\-d shutdown 停止memcached服务

**三、更多参数**

使用"-h"去了解吧～

**四、使用服务软件的经验**

写到这里，最后说一句。在使用任何软件的时候，首先要去关注这样几点：

1. 打印帮助信息：

这个一般都是“-h”，当然也有需要“-help”才可以的。

2. 启动、停止、重启/重载配置的命令：

要注意，是同一个命令的不同参数来标识的，还是用不同的命令或脚本。

3. 配置

首先，启动是否需要配置文件。

其次，如果是比较大型的软件，一般都需要配置文件，那么默认的配置文件在哪里要清楚。

再次，指定加载配置文件的命令格式如何。

4. 指定使用内存容量、线程数、硬盘容量等

是否有这方面的配置参数需要指定，以及如何设置。

5. 日志文件

首先，是否有日志文件需要存储。

其次，如果有日志文件，默认的存储目录是什么。

最后，手动指定日志文件的命令格式如何。

6. 最大连接数

首先，是否提供监听的连接服务。

其次，如果提供，默认的最大连接数是多少。

最后，手动指定最大连接数的命令格式如何。

## Memcached的CAS协议 ##

1. 什么是CAS协议

很多中文的资料都不会告诉大家CAS的全称是什么，不过一定不要把CAS当作中国科学院（China Academy of Sciences）的缩写。Google.com一下，CAS是什么？CAS是Check And Set的缩写。

2. CAS协议原文

[http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt][http_code.sixapart.com_svn_memcached_trunk_server_doc_protocol.txt]

3. CAS的基本原理

基本原理非常简单，一言以蔽之，就是“版本号”。每个存储的数据对象，多有一个版本号。我们可以从下面的例子来理解：

如果不采用CAS，则有如下的情景：

第一步，A取出数据对象X；

第二步，B取出数据对象X；

第三步，B修改数据对象X，并将其放入缓存；

第四步，A修改数据对象X，并将其放入缓存。

我们可以发现，第四步中会产生数据写入冲突。

如果采用CAS协议，则是如下的情景。

第一步，A取出数据对象X，并获取到CAS-ID1；

第二步，B取出数据对象X，并获取到CAS-ID2；

第三步，B修改数据对象X，在写入缓存前，检查CAS-ID与缓存空间中该数据的CAS-ID是否一致。结果是“一致”，就将修改后的带有CAS-ID2的X写入到缓存。

第四步，A修改数据对象Y，在写入缓存前，检查CAS-ID与缓存空间中该数据的CAS-ID是否一致。结果是“不一致”，则拒绝写入，返回存储失败。

这样CAS协议就用了“版本号”的思想，解决了冲突问题。

## Memcached的CAS程序实例 ##

1. 非CAS

首先看一个不是CAS的Memcached程序实例。实例的问题原型，见上一篇博文。

程序实例：

package com.sinosuperman.memcached;  
      
    import java.io.IOException;  
    import java.net.InetSocketAddress;  
      
    import net.spy.memcached.MemcachedClient;  
      
    public class Test {  
        public static void main(String[] args) throws IOException {  
            MemcachedClient cache = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));  
              
            cache.set("x", 1800, "Love");  
      
            String obj1 = (String) cache.get("x");  
            String obj2 = (String) cache.get("x");  
            obj2 = "Michael";  
              
            cache.set("x", 1800, obj2);  
            System.out.println("Non-CAS 2:\t" + obj2);  
            System.out.println("Non-CAS 1:\t" + obj1);  
        }  
    }

运行结果：

1.  2011-12-18 23:12:39.836 INFO net.spy.memcached.MemcachedConnection:  Added \{QA sa=/127.0.0.1:11211, \#Rops=0, \#Wops=0, \#iq=0, topRop=null, topWop=null, toWrite=0, interested=0\} to connect queue  
2.  2011-12-18 23:12:39.843 INFO net.spy.memcached.MemcachedConnection:  Connection state changed for sun.nio.ch.SelectionKeyImpl@b09e89  
3.  Non-CAS 2:  Michael  
4.  Non-CAS 1:  Love

可见在多个Client操作时，一定会引起写不一致性的问题。

2. CAS

程序实例：

package com.sinosuperman.memcached;  
      
    import java.io.IOException;  
    import java.net.InetSocketAddress;  
      
    import net.spy.memcached.CASValue;  
    import net.spy.memcached.MemcachedClient;  
      
    public class Test {  
        @SuppressWarnings("unchecked")  
        public static void main(String[] args) throws IOException {  
            MemcachedClient cache = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));  
              
            cache.set("y", 1800, "Love");  
      
            CASValue casValue1 = cache.gets("y");  
            CASValue casValue2 = cache.gets("y");  
            cache.cas("y", casValue2.getCas(), casValue2.getValue());  
              
            System.out.println("CAS 2:\t" + casValue2.getCas());  
            System.out.println("Value 2:\t" + casValue2.getValue());  
              
            System.out.println("CAS 1:\t" + casValue1.getCas());  
            System.out.println("Value 1:\t" + casValue1.getValue());  
        }  
    }

运行结果：

1.  2011-12-18 23:07:14.528 INFO net.spy.memcached.MemcachedConnection:  Added \{QA sa=/127.0.0.1:11211, \#Rops=0, \#Wops=0, \#iq=0, topRop=null, topWop=null, toWrite=0, interested=0\} to connect queue  
2.  2011-12-18 23:07:14.541 INFO net.spy.memcached.MemcachedConnection:  Connection state changed for sun.nio.ch.SelectionKeyImpl@1621e42  
3.  CAS 2:  11  
4.  Value 2:    Love  
5.  CAS 1:  11  
6.  Value 1:    Love

[http_code.sixapart.com_svn_memcached_trunk_server_doc_protocol.txt]: http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt