Couchbase之环境搭建与基于Java的测试
Couchbase Server (前身是 Membase) 是一个分布式的面向文档的 NoSQL 数据库管理系统,该系统联合了 CouchDB 的简单和可靠以及 Memcached 的高性能。
网上有MongoDB与Couchbase的对比,请参考:
http://www.infoworld.com/d/data-management/nosql-showdown-mongodb-vs-couchbase-214912
Couchbase主页:http://www.couchbase.com/
本文的目标是搭建简单的Couchbase环境并用Java语言进行读写测试。
1.准备工作
1)下载 Couchbase Server ,本文用到的版本是version 2.1.1 for win64 ,2.0在某些机器上装不上,内核问题。
2)下载 Java相关类库
相关下载链接:http://www.couchbase.com/download
2.安装Couchbase Server
1)安装过程很简单,在官网下载并安装即可。
2)安装完成后Couchbase Console程序会自动打开http://localhost:8091地址,这时候有可能会打不开,最有可能出现的问题就是端口被占用了。(占用与否,可以用cmd查一下)
这时再打开http://localhost:8091就能自动CouchServer 的webconsole安装页面了。
(界面图)
3.编写例子进行测试
用eclipse或其它IDE新建Project,导入之前下载的Couchbase-Java-Client-1.1.9.zip中的所有jar包。
新建写入测试类:
- import java.io.IOException;
- import java.net.URI;
- import java.util.LinkedList;
- import java.util.List;
- import java.util.concurrent.ExecutionException;
- import java.util.concurrent.TimeUnit;
- import net.spy.memcached.internal.OperationFuture;
- import com.couchbase.client.CouchbaseClient;
- public class Main {
- //文档key
- public static final String KEY = "testkey1";
- // expiration time of the document (use 0 to persist forever)
- //过期时间(单位毫秒 0 ***)
- public static final int EXP_TIME = 0;
- //文档值
- public static final String VALUE =
- "{\"myname\":\"EugeneQiu\","
- + "\"updated\":\"2013-08-23 13:47:00\","
- + "\"description\":\"Just a simple test\","
- + "\"myblog\":\"http://my.oschina.net/EugeneQiu\"}";
- public static void main(String args[]) {
- List<URI> uris = new LinkedList<URI>();
- //服务器地址(可在Couchbase后台Server NODES中查看)
- uris.add(URI.create("http://127.0.0.1:8091/pools"));
- CouchbaseClient client = null;
- try {
- //在Couchbase后台的Data Buckets中查看
- client = new CouchbaseClient(uris, "default", "");
- } catch (IOException e) {
- System.err.println("IOException connecting to Couchbase: " + e.getMessage());
- System.exit(1);
- }
- OperationFuture<Boolean> setOp = client.set(KEY, EXP_TIME, VALUE);
- //检查是否设置成功
- try {
- if (setOp.get().booleanValue()) {
- System.out.println("Set Succeeded");
- } else {
- System.err.println("Set failed: " + setOp.getStatus().getMessage());
- }
- } catch (InterruptedException e) {
- System.err.println("InterruptedException while doing set: " + e.getMessage());
- } catch (ExecutionException e) {
- System.err.println("ExecutionException while doing set: " + e.getMessage());
- }
- System.out.println();
- //完成操作后3秒后关闭client
- client.shutdown(3, TimeUnit.SECONDS);
- System.exit(0);
- }
- }
运行后看到Set Succeeded字样表示设置成功。
编写测试类进行读取:
- import java.io.IOException;
- import java.net.URI;
- import java.util.LinkedList;
- import java.util.List;
- import java.util.concurrent.TimeUnit;
- import com.couchbase.client.CouchbaseClient;
- public class Client
- {
- public static void main(String[] args)
- {
- List<URI> uris = new LinkedList<URI>();
- uris.add(URI.create("http://127.0.0.1:8091/pools"));
- CouchbaseClient client = null;
- try {
- client = new CouchbaseClient(uris, "default", "");
- } catch (IOException e) {
- System.err.println("IOException connecting to Couchbase: " + e.getMessage());
- System.exit(1);
- }
- Object o = client.get("testkey1");
- System.out.println(o);
- client.shutdown(3, TimeUnit.SECONDS);
- System.exit(0);
- }
- }
由于写入例子中设置的时间是***,所以这里正确的输出应该是:
我们还能在Couchbase webconsole后台的Data buckets中查看到我们刚才设置的key.(图有组件布局错乱是我强制缩小网页的兼容问题)
至此,已经完成一个简单的搭建以及测试。
相关文章
- Java要抛弃祖宗的基业,Java程序员危险了!
- 十大 Java 语言特性
- JVM 三色标记算法,原来是这么回事!
- 聊聊 Spring 事务控制策略以及 @Transactional 失效问题避坑
- 写给 Java 程序员的前端 Promise 教程
- 写给 Java 程序员的前端 Promise 教程,你学会了吗?
- Java 中为什么不全部使用 Static 方法?
- Java 池化技术你了解多少?
- Java 服务 Docker 容器化优秀实践
- Spring Boot + EasyExcel导入导出,简直太好用了!
- 我们一起聊聊 Java 内存泄漏
- CentOS 下安装 Docker 极简教程
- JDK 19 功能集冻结:Java 19 只有七个新特性
- 关于 CMS 垃圾回收器,你真的懂了吗?
- 为什么会有这么多编程语言?
- 改善Java代码的八个建议
- 接口流量突增,如何做好性能优化?
- Java 以编程方式创建JAR文件
- POJO、Java Bean是如何定义的
- Spring 的 Bean 明明设置了 Scope 为 Prototype,为什么还是只能获取到单例对象?