这篇文章给大家介绍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.(图有组件布局错乱是我强制缩小网页的兼容问题)
至此,已经完成一个简单的搭建以及测试。
关于Couchbase中环境搭建与Java的测试是怎样的就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。