Riak Client Libraries(Erlang)

一 Riak Erlang Client接口(Protocol Buffer)
 
  github地址:
 

下面来看看它的使用

1.与Riak建立连接

{ok,Pid}=riakc_pb_socket:start_link("127.0.0.1", 8087)

2.update与insert操作

Object = riakc_obj:new(Bucket, Key, Value),
  ok = riakc_pb_socket:put(Pid, Object)

(Bucket、Key和Value都是二进制格式)

3.delete操作

riakc_pb_socket:delete(Pid, Bucket, Key)

(Bucket和Key都是二进制格式)

 4.get操作

{ok, Object} = riakc_pb_socket:get(Pid, Bucket, Key),
  riakc_obj:get_value(Object)

(Bucket和Key都是二进制格式)

想了解更多的方法看看src下面的riakc_pb_socket.erl和riakc_obj.erl

其实这个Client Library的结构很简单,首先定义了riakclient.proto文件,然后riakc_pb.erl使用protobuffs进行encode发送给Riak处理

二 Riak Erlang Http Client(Http方式)

github地址:

1. 设置连接信息

C = rhc:create("127.0.0.1", 8098, "riak", [])

2.update与insert操作

Object = riakc_obj:new(Bucket, Key, Value),
  rhc:put(C, Object, <<"text/plain">>)

 3.delete操作

rhc:delete(C, Bucket, Key)

4.get操作

{ok, Object} = rhc:get(C, Bucket, Key),
   riakc_obj:get_value(Object)

Http Client用ibrowse把对Riak的http请求都封装好,学习erlang的可以看看它的代码风格

原始出处