riak KV 是一个分布式的键值存储数据库.

这里我使用的操作系统为 ubuntu 16.04.

配置riak

安装好riakKV之后, 我们需要将 riak.conf 文件中的 nodename修改为本机的 IP 地址.

nodename = kv@192.168.10.83
listener.http.internal = 192.168.10.83:8098
listener.protobuf.internal = 192.168.10.83:8087

删除 ring 文件

rm -rf /var/lib/riak/ring/*

启动 riak

riak start

使用 riak elixir 客户端

新建 elixir 项目

mix new riak_app

在mix.exs文件中添加依赖

  defp deps do
    [ {:riak, "~> 1.0"} ]
  end

运行mix.deps.get安装依赖.

配置config.exs文件

config :pooler, pools:
  [
    [
      name: :riaklocal,
      group: :riak,
      max_count: 10,
      init_count: 5,
      start_mfa: { Riak.Connection, :start_link, ['192.168.10.83', 8087] }
    ]
  ]

使用Riak

启动 elixir 项目

iex -S mix

一切正常的话, 我们就可以使用 riak 数据库了

增

o = Riak.Object.create(bucket: "user", key: "my_key", data: "Han Solo")
Riak.put(pid, o)

查

o = Riak.find("user", "my_key")

改

o = %{o | data: "Something Else"}
Riak.put(o)

删

Riak.delete(o)