1，介绍
Riak服务搭建，可以参考：http://blog.csdn.net/freewebsys/article/details/12609995
Riak的接口访问有两种方式：
HTTP
Protocol Buffers
基于http的和pb的类似。
2，基于PB方式的调用
工程采用 maven，引入依赖：
代码放在github上面了：
https://github.com/freewebsys/riak_demo
<dependencies> <dependency> <groupId>com.basho.riak</groupId> <artifactId>riak-client</artifactId> <version>1.4.0</version> </dependency> <dependency> <groupId>com.basho.riak.protobuf</groupId> <artifactId>riak-pb</artifactId> <version>1.4.0</version> </dependency> </dependencies>
3，简单的做一个表的CRUD
创建一个UserInfo类：
/**
* 用户信息.
*/
public class UserInfo {
private String uid;
private String name;
private String city;
private String nickName;
...get set 方法忽略
使用Riak进行CRUD：只是简单的将uid作为key存储，没有创建索引。
package com.demo;
import java.io.IOException;
import com.basho.riak.client.IRiakClient;
import com.basho.riak.client.RiakException;
import com.basho.riak.client.RiakFactory;
import com.basho.riak.client.RiakRetryFailedException;
import com.basho.riak.client.bucket.Bucket;
public class ClientTest {
public static void main(String[] args) throws IOException {
IRiakClient client = null;
try {// 使用pbc方式连接，而不是http,在/etc/riak/app.config
client = RiakFactory.pbcClient("127.0.0.1", 8087);
} catch (RiakException e) {
e.printStackTrace();
}
// 显示.
System.out.println(client);
Bucket myBucket = null;
String bucketName = "userInfo";
try {
myBucket = client.fetchBucket(bucketName).execute();
if (myBucket == null) {
myBucket = client.createBucket(bucketName).execute();
}
} catch (RiakRetryFailedException e) {
e.printStackTrace();
}
// ################保存数据 .
UserInfo info = new UserInfo();
info.setUid("001");
info.setName("张三");
info.setCity("北京");
try {
myBucket.store(info.getUid(), info).execute();
} catch (Exception e) {
e.printStackTrace();
}
// ################查询数据.
UserInfo fetchedUserInfo = null;
try {
fetchedUserInfo = myBucket.fetch("001", UserInfo.class).execute();
System.out.println(fetchedUserInfo);
} catch (Exception e) {
e.printStackTrace();
}
// ################修改数据.
try {
fetchedUserInfo = myBucket.fetch("001", UserInfo.class).execute();
fetchedUserInfo.setName("李四");
fetchedUserInfo.setNickName("老李");
myBucket.store(info.getUid(), info).execute();
// 保存 新数据
fetchedUserInfo = myBucket.fetch("001", UserInfo.class).execute();
System.out.println("新数据:" + fetchedUserInfo);
} catch (Exception e) {
e.printStackTrace();
}
// ################删除数据.
try {
myBucket.delete("001").execute();
fetchedUserInfo = myBucket.fetch("001", UserInfo.class).execute();
System.out.println("删除收数据." + fetchedUserInfo);
} catch (Exception e) {
e.printStackTrace();
}
// 关闭。
client.shutdown();
}
}
运行结果：
com.basho.riak.client.DefaultRiakClient@145edcf5 UserInfo [uid=001, name=张三, city=北京, nickName=null] 新数据:UserInfo [uid=001, name=张三, city=北京, nickName=null] 删除收数据.null
4，代码分析
在Riak当中，可以简单的把Bucket理解成一个表。首先要创建一个这样的Bucket，然后把数据按照key放进去。
数据类型可以是字符串，基本类型，或是对象（如UserInfo）。
每次操作的时候都是通过执行Bucket的方法执行达到CRUD的操作。
StoreObject<IRiakObject> store(String key, byte[] value);
StoreObject<IRiakObject> store(String key, String value);
<T> StoreObject<T> store(T o);
<T> StoreObject<T> store(String key, T o);
FetchObject<IRiakObject> fetch(String key);
<T> FetchObject<T> fetch(String key, Class<T> type);
<T> FetchObject<T> fetch(T o);
MultiFetchObject<IRiakObject> multiFetch(String[] keys);
<T> MultiFetchObject<T> multiFetch(List<String> keys, Class<T> type);
<T> MultiFetchObject<T> multiFetch(List<T> o);
CounterObject counter(String counter);
<T> DeleteObject delete(T o);
DeleteObject delete(String key);
StreamingOperation<String> keys() throws RiakException;
<T> FetchIndex<T> fetchIndex(RiakIndex<T> index);
5，总结
java通过使用Protocol Buffers方式调用Riak服务，直接操作对象进行CRUD。
有了这些，可以做一个简单的评论系统了。评论系统上面不需要事物，并且数量会随着业务增长，使用Rick可以平稳的进行扩展。
这个只是简单的，对Rick服务进行CRUD。最没有用到其他功能，同时没有关于key的设计。
Rick的其他功能，以后继续研究。
文章参考：
http://docs.basho.com/riak/latest/dev/taste-of-riak/java/
