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