Couchbase之环境搭建 与 基于Java的测试

01

import

java.io.IOException;

02

import

java.net.URI;

03

import

java.util.LinkedList;

04

import

java.util.List;

05

import

java.util.concurrent.ExecutionException;

06

import

java.util.concurrent.TimeUnit;

07

import

net.spy.memcached.internal.OperationFuture;

08

import

com.couchbase.client.CouchbaseClient;

09

10

public

class

Main {

11

12

//文档key

13

public

static

final

String KEY =

"testkey1"

;

14

// expiration time of the document (use 0 to persist forever)

15

//过期时间(单位毫秒  0 永久)

16

public

static

final

int

EXP_TIME =

0

;

17

//文档值

18

public

static

final

String VALUE =

19

"{\"myname\":\"EugeneQiu\","

20

+

"\"updated\":\"2013-08-23 13:47:00\","

21

+

"\"description\":\"Just a simple test\","

22

+

"\"myblog\":\"http://my.oschina.net/EugeneQiu\"}"

;

23

24

public

static

void

main(String args[]) {

25

List<URI> uris =

new

LinkedList<URI>();

26

//服务器地址(可在Couchbase后台Server NODES中查看)

27

uris.add(URI.create(

"http://127.0.0.1:8091/pools"

));

28

CouchbaseClient client =

null

;

29

try

{

30

//在Couchbase后台的Data Buckets中查看

31

client =

new

CouchbaseClient(uris,

"default"

,

""

);

32

}

catch

(IOException e) {

33

System.err.println(

"IOException connecting to Couchbase: "

+ e.getMessage());

34

System.exit(

1

);

35

}

36

37

OperationFuture<Boolean> setOp = client.set(KEY,EXP_TIME,VALUE);

38

//检查是否设置成功

39

try

{

40

if

(setOp.get().booleanValue()) {

41

System.out.println(

"Set Succeeded"

);

42

}

else

{

43

System.err.println(

"Set failed: "

+ setOp.getStatus().getMessage());

44

}

45

}

catch

(InterruptedException e) {

46

System.err.println(

"InterruptedException while doing set: "

+ e.getMessage());

47

}

catch

(ExecutionException e) {

48

System.err.println(

"ExecutionException while doing set: "

+ e.getMessage());

49

}

50

System.out.println();

51

//完成操作后3秒后关闭client

52

client.shutdown(

3

,TimeUnit.SECONDS);

53

System.exit(

0

);

54

}

55

}

01

import

java.io.IOException;

02

import

java.net.URI;

03

import

java.util.LinkedList;

04

import

java.util.List;

05

import

java.util.concurrent.TimeUnit;

06

07

import

com.couchbase.client.CouchbaseClient;

08

09

10

public

class

Client

11

{

12

public

static

void

main(String[] args)

13

{

14

15

List<URI> uris =

new

LinkedList<URI>();

16

17

uris.add(URI.create(

"http://127.0.0.1:8091/pools"

));

18

CouchbaseClient client =

null

;

19

try

{

20

client =

new

CouchbaseClient(uris,

"default"

,

""

);

21

}

catch

(IOException e) {

22

System.err.println(

"IOException connecting to Couchbase: "

+ e.getMessage());

23

System.exit(

1

);

24

}

25

Object o  = client.get(

"testkey1"

);

26

System.out.println(o);

27

28

client.shutdown(

3

,TimeUnit.SECONDS);

29

System.exit(

0

);

30

}

31

}