memcached magent

1、环境:vitualbox centos6（192.168.56.101） centos7（192.168.56.102） minimal version

yum install wget

yun install gcc

yum install glibc glibc-devel

在centos6 和 centos7中均执行2、3、4

2、手动安装libevent，否则后面安装magent的时候会有麻烦

wget http://www.monkey.org/~provos/libevent-2.0.10-stable.tar.gz

tar -zxvf libevent-2.0.10-stable.tar.gz

cd 进入解压目录

./configure –prefix=/usr

make

make install

3、安装 memcached

wget http://memcached.org/latest

tar -zxvf latest

cd 进入解压目录

./configure --prefix=/usr --with-libevent=/usr

make && make install

/usr/bin/memcached -m 100 -u root -d -l 127.0.0.1 -p 11211

-m max memory to use for items in megabytes, default is 64 MB

-d run as a daemon

-l interface to listen on, default is INDRR_ANY

-p TCP port number to listen on (default: 11211)

可以多启动几个，以备后面的magent使用

/usr/bin/memcached -m 100 -u root -d -l 127.0.0.1 -p 11212

4、安装magent 0.6

下载magent，在google上，可以从其他地方下载，比如csdn上

tar -zxvf magent.tar.gz

cd 进入解压目录

/sbin/ldconfig

sed -i "s#LIBS = -levent#LIBS = -levent -lm#g" Makefile    

make

各种错误，网上有总结

vi ketama.h 
#在开头加入
#ifndef SSIZE_MAX
#define SSIZE_MAX      32767
#endif

ln -s /usr/lib/libevent*  /usr/lib64/

cp /usr/lib64/libm.so /usr/lib64/libm.a

vi Makefile
CFLAGS = -Wall -g -O2 -I/usr/local/include $(M64)
改为：    
CFLAGS = -lrt -Wall -g -O2 -I/usr/local/include $(M64)

继续make

启动magent

magent -u root -n 4096 -l 192.168.56.101 -p 11210 -s192.168.56.101:11211 -s 192.168.56.101:11212 -b 192.168.56.101:11213

magent -u root -n 4096 -l 192.168.56.102 -p 11210 -s 192.168.56.102:11211 -s 192.168.56.102:11212 -b 192.168.56.102:11213

5、client 使用java，使用xmemcached

import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeoutException;


import net.rubyeye.xmemcached.MemcachedClient;
import net.rubyeye.xmemcached.MemcachedClientBuilder;
import net.rubyeye.xmemcached.XMemcachedClientBuilder;
import net.rubyeye.xmemcached.exception.MemcachedException;
import net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator;
import net.rubyeye.xmemcached.utils.AddrUtil;
public class MemcacheManage {
    private static MemcachedClientBuilder builder = null;
    private static MemcachedClient mcc = null;
    private static List<InetSocketAddress> address = new ArrayList<InetSocketAddress>();
    private static String memcachedServerAddress = "192.168.56.101:11210,192.168.56.102:11210";//"10.32.177.19:11211";
    private static int poolSize = 5;
    private static List<String> servers = new ArrayList<String>();
    
    static{
    if(memcachedServerAddress.indexOf(",")!=-1){
    String[] tmp = memcachedServerAddress.split(",");
    for(String server:tmp){
    servers.add(server);
    address.add(AddrUtil.getOneAddress(server));
    }
    }else{
    address.add(AddrUtil.getOneAddress(memcachedServerAddress));
    }
   
    builder = new XMemcachedClientBuilder(address);
    builder.setConnectionPoolSize(poolSize);
    builder.setSessionLocator(new KetamaMemcachedSessionLocator(true));
        try{
        mcc = builder.build();


        }catch(Exception ex){
        ex.printStackTrace();
        }
    }
    public static Object get(String keyName){
    Object obj = null;
    try{
    obj = mcc.get(keyName);
    }catch(Exception ex){
    ex.printStackTrace();
    }
    return obj;
    }
    public static boolean set(String keyName,Object keyValue,int expire){
    boolean ret = false;
    try{
    ret = mcc.set(keyName, expire, keyValue);
    }catch(MemcachedException ex){
    ex.printStackTrace();
    } catch (TimeoutException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
    return ret;
    }
    
}

7、实验junit

public class MemcacheTest {


@Test
public void _00(){
for(int i=0;i<30;i++){
boolean success = MemcacheManage.set("k"+i, "key"+i+"value", 0);
if(success){
Object v = MemcacheManage.get("k"+i);
assertEquals("key"+i+"value",v);
}else{
fail("");
}
}
}
@Test
public void _01(){

for(int i=0;i<30;i++){
Object v = MemcacheManage.get("k"+i);
System.out.println("k"+i+":"+v);
}

}
}

8、问题

1、magent增加 -b192.168.56.102:11213 不知道为什么，添加备份的memcached，测试timeout，测试不成功

2、在101中关掉一个memcached，会有异常net.rubyeye.xmemcached.exception.MemcachedServerException: CAN NOT CONNECT TO BACKEND SERVER,key=k*

可见当一个magent中的memcached宕机了，是无法获取到全部数据的，而关掉101的magent，数据可以全部取出来，数据应该来源于102，

这个问题应该是xmemcached的问题

3、以上只是个人实验结果

10、参考

http://www.php-note.com/article/detail/800

http://www.iyunv.com/thread-59460-1-1.html