Couchbase中环境搭建与Java的测试是怎样的

2023-06-17 08:06:25 722人浏览独家记忆

摘要

这篇文章给大家介绍CoucHBase中环境搭建与Java的测试是怎样的，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。Couchbase Server （前身是 Membase）是一个分布式的面向文档的 No

这篇文章给大家介绍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安装页面了。

Couchbase中环境搭建与Java的测试是怎样的

(界面图)

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中环境搭建与Java的测试是怎样的