[原]Couchbase之环境搭建与Java小试

标签: | 发表时间:2013-03-28 20:55 | 作者:supercrsky
出处:http://blog.csdn.net/supercrsky

Couchbase Server 是一个集群化的、基于文档的数据库系统,网上有MongoDB与Couchbase的对比,请参考:

http://www.javaworld.com/javaworld/jw-03-2013/130321-mongodb-vs-couchbase-nosql.html

Couchbase主页: http://www.couchbase.com/

本文的目标是搭建简单的Couchbase环境并用Java语言进行读写测试。

1.准备工作

1)下载  Couchbase Server ,本文用到的版本是1.8.1 for win32 ,2.0在我的机器上装不上,内核问题。

2)下载  Java相关类库

2.安装Couchbase Server

1)安装详细过程请参考:http://www.couchbase.com/docs/couchbase-manual-2.0/couchbase-getting-started-install-win.html

2)安装完成后Couchbase Console程序会自动打开http://localhost:8091地址,这时候有可能会打不开,最有可能出现的问题就是端口被占用了。

Couchbase默认端口是:8091,运行如下命令排查: 

netstat -ano|findstr "8091"
TCP    127.0.0.1:9050         0.0.0.0:0              LISTENING       1751

端口被进程号为1751的进程占用,继续执行下面命令:

tasklist|findstr "1751"
spool.exe                     1751 Console                 0     16,064 K

打开任务管理器根据进程ID结束掉相应程序。这时打开Couchbase安装目标下的server/bin目录,形如:D:\Program Files\Couchbase\Server\bin执行service_start.bat批处理命令后,在服务里检查CouchbaseServer服务是否启动。


这时再打开http://localhost:8091就能自动CouchServer 的webconsole安装页面了,参考:http://www.couchbase.com/docs/couchbase-manual-2.0/couchbase-getting-started-setup.html进行安装配置。

3.编写例子进行测试用eclipse或其它IDE新建Project,导入之前下载的Couchbase-Java-Client-1.1.4.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 = "beer_Wrath";
  // expiration time of the document (use 0 to persist forever)
  //过期时间(单位毫秒  0 永久)
  public static final int EXP_TIME = 0;
  //文档值
  public static final String VALUE =
          "{\"name\":\"Wrath\",\"abv\":9.0,"
              + "\"type\":\"beer\",\"brewery_id\":\"110f1a10e7\","
              + "\"updated\":\"2010-07-22 20:00:20\","
              + "\"description\":\"WRATH Belgian-style \","
              + "\"style\":\"Other Belgian-Style Ales\","
              + "\"category\":\"Belgian and French Ale\"}";

  public static void main(String args[]) {
    List<URI> uris = new LinkedList<URI>();
    //服务器地址(可在Couchbase后台Server NODES中查看)
    uris.add(URI.create("http://192.168.10.15: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://192.168.10.15: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("beer_Wrath");
	    System.out.println(o);

	    client.shutdown(3, TimeUnit.SECONDS);
	    System.exit(0);
	}
}

由于写入例子中设置的时间是永久,所以这里正确的输出应该是:

{"name":"Wrath","abv":9.0,"type":"beer","brewery_id":"110f1a10e7","updated":"2010-07-22 20:00:20","description":"WRATH Belgian-style ","style":"Other Belgian-Style Ales","category":"Belgian and French Ale"}

我们还能在Couchbase webconsole后台的Data buckets中查看到我们刚才设置的key.




作者:supercrsky 发表于2013-3-28 20:55:49 原文链接
阅读:81 评论:0 查看评论

相关 [couchbase 环境 java] 推荐:

[原]Couchbase之环境搭建与Java小试

- - 上善若水 厚德载物
Couchbase Server 是一个集群化的、基于文档的数据库系统,网上有MongoDB与Couchbase的对比,请参考:. Couchbase主页: http://www.couchbase.com/. 本文的目标是搭建简单的Couchbase环境并用Java语言进行读写测试. 1)下载  Couchbase Server ,本文用到的版本是1.8.1 for win32 ,2.0在我的机器上装不上,内核问题.

Java环境变量Classpath

- - 译言-电脑/网络/数码科技
Classpath是一个参数,它的值可以通过命令行指定,或者通过环境变量来指定. Classpath这个参数的值,被Java虚拟机或者Java编译器所使用,它告诉Java虚拟机机,Java编译器,去哪里寻找用户定义的类和包. 与传统的动态载入行为类似,当执行一个Java程序的时候,Java虚拟机会寻找和载入类(但是,只有当这个类被用到的时候,Java虚拟机才会载入它.

结合使用 Hadoop 和 Couchbase

- - 博客 - 伯乐在线
来源: IBM Developerworks. 简介: Hadoop 非常适合处理大量数据并将该信息解析为您可查询的较小的信息集. 但是,通过与 Couchbase Server 集成,您可以对信息执行实时查询和报告,同时继续使用 Hadoop 处理大型数据集和数据集的繁重处理工作. Couchbase Server 还使用了一个 MapReduce 查询系统,这使您能够轻松地迁移和集成索引和查询系统,从而有效地提取和操作信息.

Couchbase:更好的Cache系统

- - 博客园_知识库
  在移动互联网时代,我们面对的是更多的客户端,更低的请求延迟,这当然需要对数据做大量的 Cache 以提高读写速度.   现有 Cache 系统的特点.   目前业界使用得最多的 Cache 系统主要是 memcached 和 redis. 这两个 Cache 系统都有都有很大的用户群,可以说是比较成熟的解决方案,也是很多系统当然的选择.

Couchbase Server 2.0 发布,NoSQL 数据库

- - 开源中国社区最新新闻
Couchbase Server 2.0 发布了,主要特性包括:. 增量 Map Reduce. 详细功能描述和下载地址请看:. Couchbase Server (前身是 Membase) 是一个分布式的面向文档的 NoSQL 数据库管理系统,该系统联合了 CouchDB 的简单和可靠以及 Memcached 的高性能以及 Membase 的伸缩性.

使用 Docker 搭建 Java Web 运行环境

- - 码农网
Docker 是 2014 年最为火爆的技术之一,几乎所有的程序员都听说过它. Docker 是一种“轻量级”容器技术,它几乎动摇了传统虚拟化技术的地位,现在国内外已经有越来越多的公司开始逐步使用 Docker 来替换现有的虚拟化平台了. 作为一名 Java 程序员,我们是时候一起把 Docker 学起来了.

Windows7+Eclipse环境下Hbase Java客户端的开发

- - zzm
Centos 下Hbase0.98.10-hadoop2 集群的配置. 在Eclipse中创建Maven的工程. 将集群的hbase-site.xml文件放到工程的classes目录下. C:\windows\system32\drivers\etc文件,将Hbase集群的IP以及域名配置到该文件中.

生产环境下JAVA进程高CPU占用故障排查

- - 开源软件 - ITeye博客
生产环境下的某台tomcat7服务器,在刚发布时的时候一切都很正常,在运行一段时间后就出现CPU占用很高的问题,基本上是负载一天比一天高. 1,程序属于CPU密集型,和开发沟通过,排除此类情况. 2,程序代码有问题,出现死循环,可能性极大. 1,开发那边无法排查代码某个模块有问题,从日志上也无法分析得出.

Java基础:并发环境下指令重排带来的问题

- - CSDN博客推荐文章
JVM内存模型 - 主内存和线程独立的工作内存. Java内存模型规定,对于多个线程共享的变量,存储在主内存当中,每个线程都有自己独立的工作内存,线程只能访问自己的工作内存,不可以访问其它线程的工作内存. 工作内存中保存了主内存共享变量的. 副本,线程要操作这些共享变量,只能通过操作工作内存中的副本来实现,操作完毕之后再同步回到主内存当中.

CouchDB与Couchbase:区别何在,Membase又将如何?

- - InfoQ cn
去年二月, CouchOne与Membase合并了,合并之后的公司叫做Couchbase. Membase公司有一个名为Membase的产品,它是个键/值、持久化、可伸缩的解决方案,使用了 memcached wire协议. CouchOne支持 CouchDB. CouchDB是个文档数据库,提供了端到端的复制方法,这对于移动与分布在不同位置的数据中心来说是很有用的.