nosql之tokyotyrant以及php接口 nosqltokyotyranttokyocabinettyrant

项目团队采用了tokyocabinet数据库，一个key-value的DBM数据库，是眼下挺热的nosql概念下中的一种数据库，记录和分享下使用的感觉。

 

• 相关网址
  

1. 详细介绍：http://www.162cm.com/p/tokyotyrant.html
2. 项目官网：http://fallabs.com/tokyocabinet/

• 基本介绍

1. tokyocabinet :一个key-value的DBM数据库，但是没有提供网络接口，简称TC
2. tokyotyrant :是为TC写的网络接口，他支持memcache协议，也可以通过HTTP操作，简称TT

• 编译安装

    tokyotyrant所有版本下载地址: http://tokyocabinet.sourceforge.net/tyrantpkg/

    默认安装目录为/usr/local/

wget http://tokyocabinet.sourceforge.net/tokyocabinet-1.4.28.tar.gz
tar zxvf tokyocabinet-1.4.28.tar.gz
cd tokyocabinet-1.4.28/
./configure
make
make install  

wget http://tokyocabinet.sourceforge.net/tyrantpkg/tokyotyrant-1.1.33.tar.gz
tar zxvf cd /usr/local/tokyotyrant -1.1.29.tar.gz
cd tokyocabinet-1.4.28/
./configure
make
make install  

• 测试tc能否连接tt

    进入tc目录下sbin目录，复制启动脚本，修改成自己需要的新的启动脚本

    这里启动脚本使用11311端口，数据库目录使用/var/ttserver11311

mkdir /var/ttserver11311
cp /usr/local/tokyotyrant/sbin/ttservctl /usr/local/tokyotyrant/sbin/ttservctl11311
vi /usr/local/tokyotyrant/sbin/ttservctl11311

 

    ttservctl11311文件修改部分

basedir="/var/ttserver11311"
port="11311"

 

    启动脚本并测试，tc提供了测试工具，tc/bin/tcrmttest

    tcrmttest write 是写入参数

    tcrmttest read 是读取参数

    具体可以参考网址：http://blog.csdn.net/cfw2006/article/details/5649101

/usr/local/tokyotyrant/sbin/ttservctl11311 start
/usr/local/tokyotyrant/bin/tcrmttest write -port 11311 127.0.0.1 100
/usr/local/tokyotyrant/bin/tcrmttest read -port 11311 127.0.0.1

    得到如下结果就表示tt正常启动

[root@DEV sbin]# ../bin/tcrmttest write -port 11311 127.0.0.1 100
<Writing Test>
  host=127.0.0.1  port=11311  tnum=1  rnum=100  nr=0  ext=  rnd=0

record number: 100
size: 4201920
time: 0.175
ok

[root@DEV sbin]# ../bin/tcrmttest read -port 11311 127.0.0.1
<Reading Test>
  host=127.0.0.1  port=11311  tnum=1  mul=0  rnd=0

record number: 100
size: 4201920
time: 0.170
ok

• 结束tt服务器

1. 杀死进程方式
2. 脚本关闭

ps -ef | grep ttserver
kill -9 PID

/usr/local/tokyotyrant/sbin/ttservctl11311 stop

 

• PHP调用tc接口操作tt数据库

1. php扩展方式
2. php代码方式

    扩展方式请参考网址：http://www.php.net/manual/en/book.tokyo-tyrant.php （来源官网）

                                  http://blog.panzhibiao.com/index.php/archives/196 （简单明了）

 

    我们项目组采用代码方式，也就是使用开源的php接口程序，tyrant

    下载地址：http://mamasam.indefero.net/p/tyrant/

 

    仅贴出了我们使用的封装类，由于跟其他部分牵涉比较紧密，所以做了简单修改，时间紧急，也没来得及测试和注释

 

<?php

require_once 'Tyrant.php';

namespace NDBAL;

class NDBAL {
    private $_conn = null;

    public function __construct($host , $port) {
		$this->_conn = Tyrant::connect($host , $port);
	}

	public function set($key , $value = null) {
		$args_num = func_num_args();
		if(is_array($key) && $args_num == 1) {
			$values = $key;
			foreach($values AS $_key => $_val) {
				$this->_conn->put($_key , $_val);
			}
		} else {
			return $this->_conn->put($key , $value);
		}
		return $this;
	}

	public function get($key) {
		if(is_array($key)) {
			$keys = $key;
			$value = array();
			foreach($keys AS $_key) {
				$serialized_value = $this->_conn->get($_key);
				$value[$_key] = $serialized_value;
			}
		} else {
			$value = $this->_conn->get($key);
		}
		return $value;
	}

	public function remove($key) {
		return $this->_conn->out($key);
	}

	public function removeAll() {
		return $this->_conn->vanish();
	}

	public function add($key , $increment) {
		return $this->_conn->addInt($key , $increment);
	}

	public function getIterator() {
		return $this->_conn;
	}

	public function rnum() {
		return $this->_conn->rnum();
	}
}