1. 简介:
Memcachedb是基于memcached Socket层和berkeley-db存储层结构的实现, 是新浪互动社区技术团队2007年的一项重大的技术成果,现在应用于新浪互动社区多个产品线中,其中包括新浪博客等重头产品。能够实现任意memcache api的调用、数据实时落地以及主辅实时备份。
Memcachedb的安装包括三个部分:Libevent、BerkeleyDB、Memcachedb。
2. 安装过程:
1)安装libevent,
$tar xvzf libevent-2.0.20-stable.tar.gz
$cd libevent-2.0.20-stable
$./configure
$make
$sudo make install
2)安装BerkeleyDB
这里需要说明的是:berkeley-db 必须是4.7或更高的版本,否则在编译时会出错
$tar xvzf db-4.7.25.tar.gz
$cd db-4.7.25/
$cd build_unix/
$../dist/configure
$make
$sudo make install
然后,BerkeleyDB会被默认安装在/usr/local/BerkeleyDB.4.7路径下。
编辑 /etc/ld.so.conf 添加
/usr/local/BerkeleyDB.4.7/lib
然后运行 ldconfig
3)安装Memcachdb
$tar xvzf <span style="text-decoration: underline;"><span style="color: #810081;">memcachedb-1.2.0.tar.gz</span></span>
$cd memcachedb-1.2.0
$./configure --enable-threads
$make
$sudo make install
4)启动 memcachedb
第一种,读写合并模式,即不做辅拷贝,即读又写,不做冗余备份
memcachedb -p21211 -d -r -u root -H /server/mdb_11211 –N
-H 参数是制定DB数据文件存放的位置
第二种,读写分离/备份模式
#主服务器 192.168.0.1 读写监听 11211 ,同步通过31211的端口完成,不占用繁忙的主服务端口
memcachedb -p21211 -d -r -u root -H /data/mdb_11211_m -N -R 127.0.0.1:31211 -M
# 辅服务器 192.168.0.2 只读监听 21212,从192.168.0.1 的 31211端口同步数据,同时再开一个31212端口对外提供数据同步服务
memcachedb -p21212 -d -r -u root -H /data/mdb_11211_from_16801_s -O 192.168.0.1:31211 -R 192.168.0.2:31212 -S
5)采用主从方式,可以实现读写分离和备份,能有更好的性能和可靠性。由于本实验测试时以读为主且基本可以不考虑宕机的情况,采用第一种方式。
3. Memcachedb的访问
使用http://danga.com/memcached/提供的windows版本和java客户端jar包。
采用java接口访问方法如下:
//初始化连接池
pool.initialize();
//压缩设置,超过指定大小(单位为K)的数据都会被压缩
mcc.setCompressEnable( true);
mcc.setCompressThreshold( 64*1024);
}
/**
* 保护型构造方法,不允许实例化!
*
*/
protectedMemCached()
{
}
/**
* 获取唯一实例.
* @return
*/
publicstaticMemCached getInstance()
{
returnmemCached;
}
/**
* 添加一个指定的值到缓存中.
* @paramkey
* @paramvalue
* @return
*/
publicbooleanadd(String key, Object value)
{
returnmcc.add(key, value);
}
publicbooleanadd(String key, Object value, Date expiry)
{
returnmcc.add(key, value, expiry);
}
publicbooleanreplace(String key, Object value)
{
returnmcc.replace(key, value);
}
publicbooleanreplace(String key, Object value, Date expiry)
{
returnmcc.replace(key, value, expiry);
}
/**
* 根据指定的关键字获取对象.
* @paramkey
* @return
*/
publicObject get(String key)
{
returnmcc.get(key);
}
publicstaticvoidmain(String[] args)
{
MemCached cache =MemCached.getInstance();
cache.add( "hello", 234 );
System.out.print("get value : "+cache.get("hello"));
}
}