nosql之tokyotyrant以及php接口

周奇
2023-12-01

项目团队采用了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();
	}
}
  

 

 类似资料: