Riak Client Libraries(Erlang)

一Riak Erlang Client接口(Protocol Buffer)

 

   github地址: https://github.com/basho/riak-erlang-client

 

   下面来看看它的使用

 

   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地址: https://github.com/basho/riak-erlang-httpc-client

   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的可以看看它的代码风格