如何将java代码连接到RIAK数据库并获取记录

Question

public class TasteOfRiak {              
public static void main(String[] args) throws UnknownHostException, ExecutionException, InterruptedException 
  {          
     RiakClient client = RiakClient.newClient(port, "IP");      
     Location location = new Location(new Namespace("Bucket"), "bucketType");   
     FetchValue fv = new FetchValue.Builder(location).build();  
     FetchValue.Response response = client.execute(fv);                     
     String value = response.getValue(String.class);    
     System.out.println(value);              
     client.shutdown();         
  }
}

Answer 1

检查riak节点正在运行（正如Craig所说），您可以在etc/vm.args中看到节点名称。

确保erlang节点cookie正确。Erlang VM将检查来自其他VM的cookie是否匹配，如果不匹配，它将拒绝ping或连接请求。本地cookie位于~/.erlang.cookie中，建议在连接前尝试将VM cookie设置为本地cookie。

另一种方式：

$ bin/riak console
%% set cookie
erlang:set_cookie(your_riak_node_name, your_cookie)