`

tokyotyrant-java客户端

 
阅读更多

目录：

  1. 概述
  2. 演示

[一]、概述

java实现了对ttserver服务端的连接和访问。相关的源代码和jar包可以到其官网下载。

官网地址：http://code.google.com/p/tokyotyrant-java/

如果是maven构建项目的，在pom.xml 的<dependencies>节点中增加如下依赖配置即可：

1 <dependency>
2             <groupId>tokyotyrant</groupId>
3             <artifactId>tokyotyrant</artifactId>
4             <version>0.11</version>
5         </dependency>
6         <dependency>
7             <groupId>org.jboss.netty</groupId>
8             <artifactId>netty</artifactId>
9             <version>3.1.5.GA</version>
10         </dependency>
11         <dependency>
12             <groupId>org.slf4j</groupId>
13             <artifactId>slf4j-api</artifactId>
14             <version>1.5.6</version>
15         </dependency>
16         <dependency>
17             <groupId>org.slf4j</groupId>
18             <artifactId>slf4j-log4j12</artifactId>
19             <version>1.5.6</version>
20             <scope>runtime</scope>
21             <optional>true</optional>
22         </dependency>

[二]、演示

1.RDB ：官方Tokyo Tyrant API的实现

演示代码：RDBExample.java

1 package com.micmiu.nosql.ttserver;
2  
3 import java.io.IOException;
4 import java.net.InetSocketAddress;
5  
6 import tokyotyrant.RDB;
7 import tokyotyrant.transcoder.DoubleTranscoder;
8 import tokyotyrant.transcoder.IntegerTranscoder;
9  
10 /**
11  *
12  * blog http://www.micmiu.com
13  *
14  * @author Michael
15  *
16  */
17 public class RDBExample {
18  
19     public static void main(String[] args) throws IOException {
20  
21         RDB db = new RDB();
22         try {
23             // connect to the server
24             // db.open(new NodeAddress("tcp://192.168.126.134:1978"));
25             db.open(new InetSocketAddress("192.168.126.134", 1978));
26  
27             Object key;
28             Object value;
29             // store records
30             if (db.put("my_firstname", "Sun")) {
31                 System.out.println("db put my_firstname successful.");
32             } else {
33                 System.out.println("db put my_firstname error.");
34             }
35  
36             if (db.put("my_lastname", "Michael")) {
37                 System.out.println("db put my_lastname successful.");
38             } else {
39                 System.out.println("db put my_lastname error.");
40             }
41  
42             if (db.put("my_blogurl", "www.micmiu.com")) {
43                 System.out.println("db put my_blogurl successful.");
44             } else {
45                 System.out.println("db put my_blogurl error.");
46             }
47  
48             if (db.put("my_weibo", "www.sina.com/ctosun")) {
49                 System.out.println("db put my_weibo successful.");
50             } else {
51                 System.out.println("db put my_weibo error.");
52             }
53  
54             // retrieve records
55             value = db.get("my_blogurl");
56             System.out.println("test_blogurl =: " + value);
57  
58             value = db.get("test_noexit");
59             System.out.println("test_noexit =: " + value);
60  
61             System.out.println("===== test repeat put ");
62             db.put("test_desc", "hello world");
63             System.out.println("test_desc =: " + db.get("test_desc"));
64             db.put("test_desc", "repeat put value is hello Michael");
65             System.out.println("test_desc =: " + db.get("test_desc"));
66  
67             // Initialize the iterator
68             System.out.println("===== access all key ");
69             db.iterinit();
70             while ((key = db.iternext()) != null) {
71                 value = db.get(key);
72                 System.out.println(key + " =: " + value);
73             }
74             System.out.println("===== test int double ");
75             // add int
76             db.put("int_i", 3, new IntegerTranscoder());
77             int i = db.addint("int_i", 4);
78             System.out.println(" i =: " + i);
79             System.out.println("int_i =: "
80                     + db.get("int_i", new IntegerTranscoder()));
81  
82             // add double
83             db.put("dou_d", 3.0D, new DoubleTranscoder());
84             double d = db.adddouble("dou_d", 4.0D);
85             System.out.println(" d =: " + d);
86             System.out.println("dou_d =: "
87                     + db.get("dou_d", new DoubleTranscoder()));
88  
89         } catch (Exception e) {
90             e.printStackTrace();
91         } finally {
92             // close the connection
93             db.close();
94         }
95     }
96 }

运行日志如下：

db put my_firstname successful.
db put my_lastname successful.
db put my_blogurl successful.
db put my_weibo successful.
test_blogurl =: www.micmiu.com
test_noexit =: null
===== test repeat put
test_desc =: hello world
test_desc =: repeat put value is hello Michael
===== access all key
my_firstname =: Sun
my_lastname =: Michael
my_blogurl =: www.micmiu.com
my_weibo =: www.sina.com/ctosun
test_desc =: repeat put value is hello Michael
===== test int double
 i =: 7
int_i =: 7
 d =: 7.0
dou_d =: 7.0

2.MRDB ：用于多数据源，可复制、可靠性高、响应快等特点

演示代码：MRDBExample.java

1 package com.micmiu.nosql.ttserver;
2  
3 import tokyotyrant.MRDB;
4 import tokyotyrant.networking.NodeAddress;
5  
6 /**
7  *
8  * blog http://www.micmiu.com
9  *
10  * @author Michael
11  *
12  */
13 public class MRDBExample {
14  
15     /**
16      * @param args
17      * @throws Exception
18      */
19     public static void main(String[] args) throws Exception {
20  
21         MRDB db = null;
22         try {
23             db = new MRDB();
24             // connect to the server
25             db.open(NodeAddress.addresses("tcp://192.168.126.134:1978"));
26             Object value;
27             // store records
28             if (db.await(db.put("my_firstname", "Sun"))) {
29                 System.out.println("MRDB put my_firstname successful.");
30             } else {
31                 System.out.println("MRDB put my_firstname error.");
32             }
33  
34             if (db.await(db.put("my_lastname", "Michael"))) {
35                 System.out.println("MRDB put my_lastname successful.");
36             } else {
37                 System.out.println("MRDB put my_lastname error.");
38             }
39  
40             if (db.await(db.put("my_blogurl", "www.micmiu.com"))) {
41                 System.out.println("MRDB put my_blogurl successful.");
42             } else {
43                 System.out.println("MRDB put my_blogurl error.");
44             }
45  
46             if (db.await(db.put("my_weibo", "www.sina.com/ctosun"))) {
47                 System.out.println("MRDB put my_weibo successful.");
48             } else {
49                 System.out.println("MRDB put my_weibo error.");
50             }
51  
52             // retrieve records
53             value = db.await(db.get("my_blogurl"));
54             System.out.println("test_blogurl =: " + value);
55  
56             value = db.await(db.get("test_noexit"));
57             System.out.println("test_noexit =: " + value);
58  
59             System.out.println("===== test repeat put ");
60             db.put("test_desc", "hello world");
61             System.out.println("test_desc =: " + db.await(db.get("test_desc")));
62             db.put("test_desc", "repeat put value is hello Michael");
63             System.out.println("test_desc =: " + db.await(db.get("test_desc")));
64  
65             // add int
66             db.put("int_i", 4);
67             // add double
68             db.put("dou_d", 8.8D);
69  
70             // Initialize the iterator
71             System.out.println("===== access all key ");
72             Object[] keys = db
73                     .await(db.fwmkeys("", db.size().get().intValue()));
74             for (Object keyObj : keys) {
75                 System.out.println(keyObj + " =: " + db.await(db.get(keyObj)));
76             }
77  
78         } catch (Exception e) {
79             e.printStackTrace();
80         } finally {
81             // close the connection
82             db.close();
83         }
84     }
85 }

运行结果：

[16:42:42] INFO [tokyotyrant.networking.nio.NioNode] - Connect tcp://192.168.126.134:1978
MRDB put my_firstname successful.
MRDB put my_lastname successful.
MRDB put my_blogurl successful.
MRDB put my_weibo successful.
test_blogurl =: www.micmiu.com
test_noexit =: null
===== test repeat put
test_desc =: hello world
test_desc =: repeat put value is hello Michael
===== access all key
my_firstname =: Sun
my_lastname =: Michael
my_blogurl =: www.micmiu.com
my_weibo =: www.sina.com/ctosun
int_i =: 4
test_desc =: repeat put value is hello Michael
dou_d =: 8.8
[16:42:42] INFO [tokyotyrant.networking.nio.NioNode] - Disconnect tcp://192.168.126.134:1978
[16:42:42] INFO [tokyotyrant.networking.nio.NioNetworking] - Stopped. So will not handle IO. 0 keys will be ignored

————————

原创文章，转载请注明： 转载自micmiu – 软件开发+生活点滴[ http://www.micmiu.com/ ]

本文链接地址: http://www.micmiu.com/nosql/tokyotyrant-java-client/

分享到：
| 高性能NoSQL数据库Redis结合谷歌开源tcma ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    tokyotyrant-1.1.40.tar.gz

    tokyotyrant-1.1.40.tar.gz centos 7 x64系统应用 配合 tokyocabinet-1.4.45.tar

    tokyotyrant/tokyocabinet/gpac

    对数据库的使用方式进行了修改，使得开源软件能够支持分布式的访问。

    ttserver-lib包

    tokyocabinet-1.4.45.tar.gz tokyotyrant-1.1.41.tar.gz tokyotyrant-0.11.jar ch-tokyocabinet-java-1.24.0.jar

    tokyotyrant

    媲美memcached的缓存服务器软件包，tokyocabinet-1.4.45.tar.gz+tokyotyrant-1.1.40.tar.gz

    发布一个基于TokyoTyrant的C#客户端开源项目

    目前在网上关于TokyoCabinet（以下简称TC）和TokyoTyrant（以下简称TT）的资料已相对丰富了，但在.NET平台上的客户端软件却相对匮乏，因为做Discuz!NT企业版的关系，两个月前开始接触TC和TT，开始写相关的客户端代码...

    Tokyocabinet-Tokyotyrant文档大合集

    Tokyo Cabinet 是一个DBM的实现。这里的数据库由一系列key-value对的记录构成。key和value都可以是任意长度的字节序列,既可以是二进制也可以是字符串。这里没有数据类型和数据表的概念。 当做为Hash表数据库使用时，...

    tokyoCabint及tokyoTyrant简介

    NULL 博文链接：https://alvin871111.iteye.com/blog/680677

    tokyo tyrant文档

    一个小型快速数据库的安装使用及原理介绍。

    django-kvstore:Django 的键值存储框架

    tokyotyrant（东京暴君） Redis (Redis) 还有一些非持久化存储，主要用于测试目的： locmem 内存缓存 store和parameters因一个后端而异。 有关更多详细信息，请参阅每个后端实现中包含的文档。 您可以以类似于...

    NoSQL数据库入门(当今最炙手可热的NoSQL新型数据库技术)

    《nosql数据库入门 中文版》详细地介绍了nosql数据库(非关系型数据库)的种类、用途以及使用方法，并对memcached、tokyotyrant、redis、mongodb这4种代表性的nosql数据库的特征、适用范围、实现代码进行了深入探讨，...

    tokyotytrant

    日本开发的nosql数据库，据说吞吐量很牛逼，最近开始研究这玩意的内部实现

Magicbox
Global site tag (gtag.js) - Google Analytics