当前位置: 首页 > 工具软件 > memcachedb > 使用案例 >

Memcachedb环境搭建及访问

东方化
2023-12-01

 

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"));
}
}

 类似资料: