现在的位置: 首页 > 数据库 > 正文

怎样用Kyoto Tycoon挂载LevelDB存储

2020年07月01日 数据库 ⁄ 共 2138字 ⁄ 字号 评论关闭

  KyotoTycoon(以下简称KT)是TokyoTyrant的作者MikioHirabayashi的系列作品之一,KT是一个数据库网络层服务,它提供一个插件机制,可以挂载几乎所有的数据库存储设备。下面学步园小编来讲解下怎样用KyotoTycoon挂载LevelDB存储?

  怎样用KyotoTycoon挂载LevelDB存储

  1.安装LevelDB

  先获取源代码

  $svncheckouthttp://leveldb.googlecode.com/svn/trunk/leveldb-read-only

  修改Makefile,加上-fPIC选项

  +CFLAGS=-c-I.-I./include$(PLATFORM_CFLAGS)$(OPT)

  -CFLAGS=-c-I.-I./include$(PLATFORM_CFLAGS)$(OPT)-fPIC

  如果你用的是Ubuntu,那么再修改port/port_posix.h文件:

  +#include

  -#include

  上面几处修改完后,开始安装

  $make

  $sudocplibleveldb.a/usr/local/lib

  $sudocp-rinclude/leveldb/usr/local/include

  这样LevelDB就安装完了

  2.在KC上挂载式安装LevelDB

  下载最新的KC源代码,运行下面命令进行安装

  $cdkyototycoon-x.y.z

  $./configure

  $make

  $sudomakeinstall

  $cdlab/leveldb

  $make

  $sudocpktplugdblevel.so/usr/local/lib

  安装完成后就可以运行了

  $ktserver-pldb/usr/local/lib/ktplugdblevel.socasket.ldb

  你可以直接挂靠一些Set操作

  $ktremotemgrsetjapantokyo

  $ktremotemgrsetkoreaseoul

  $ktremotemgrsetchinabeijing

  查看刚刚Set进去的数据:

  $ktremotemgrlist-pv

  怎样用KyotoTycoon挂载LevelDB存储

  3.插件实现

  下面附上一份挂接LevelDB的源码,其逻辑也非常简单:

  classLevelDB:publickt::PluggableDB{

  ...

  boolaccept_impl(constchar*kbuf,size_tksiz,Visitor*visitor,boolwritable){

  size_tlidx=kc::hashmurmur(kbuf,ksiz)%RLOCKSLOT;

  if(writable){

  rlock_.lock_writer(lidx);

  }else{

  rlock_.lock_reader(lidx);

  }

  std::stringkey(kbuf,ksiz);

  std::stringvalue;

  lv::Statusstatus=db_->Get(lv::ReadOptions(),key,&value);

  constchar*rbuf;

  size_trsiz;

  if(status.ok()){

  rbuf=visitor->visit_full(kbuf,ksiz,value.data(),value.size(),&rsiz);

  }else{

  rbuf=visitor->visit_empty(kbuf,ksiz,&rsiz);

  }

  boolerr=false;

  if(rbuf==kc::BasicDB::Visitor::REMOVE){

  lv::WriteOptionswopts;

  if(autosync_)wopts.sync=true;

  status=db_->Delete(wopts,key);

  if(!status.ok()){

  set_error(_KCCODELINE_,Error::SYSTEM,"DB::Deletefailed");

  err=true;

  }

  }elseif(rbuf!=kc::BasicDB::Visitor::NOP){

  lv::WriteOptionswopts;

  if(autosync_)wopts.sync=true;

  std::stringrvalue(rbuf,rsiz);

  status=db_->Put(wopts,key,rvalue);

  if(!status.ok()){

  set_error(_KCCODELINE_,Error::SYSTEM,"DB::Putfailed");

  err=true;

  }

  }

  rlock_.unlock(lidx);

  return!err;

  }

  ...

  };

  以上就是关于“怎样用KyotoTycoon挂载LevelDB存储”的内容,希望对大家有用。更多资讯请关注学步园。学步园,您学习IT技术的优质平台!

抱歉!评论已关闭.