我已经在 Ubuntu 机器上设置了 Riak,如果我这样做了,它就可以工作了riak ping
。
现在我想使用Riak Java 客户端来存储一个对象,但是它不起作用。com.basho.riak.client.response.RiakIORuntimeException
当我尝试存储一个对象时,我得到了。我究竟做错了什么?有没有办法测试我是否可以从我的 java 客户端访问 riak?我必须先创建一个存储桶吗?如何?
import com.basho.riak.client.RiakClient;
import com.basho.riak.client.RiakObject;
import com.basho.riak.client.response.FetchResponse;
public class RiakTest {
public static void main(String[] args) {
// connect
RiakClient riak = new RiakClient("http://192.168.1.107:8098/riak");
// create object
RiakObject o = new RiakObject("mybucket", "mykey", "myvalue");
// store
riak.store(o);
}
}