Riak学习(2):java连接Riak服务,使用Protocol Buffers连接
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
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);
java通过使用Protocol Buffers方式调用Riak服务,直接操作对象进行CRUD。
有了这些,可以做一个简单的评论系统了。评论系统上面不需要事物,并且数量会随着业务增长,使用Rick可以平稳的进行扩展。
这个只是简单的,对Rick服务进行CRUD。最没有用到其他功能,同时没有关于key的设计。
Rick的其他功能,以后继续研究。