0
자바 클라이언트를 사용하여 Riak Kv 클러스터 설정을 설정하는 중 어려움을 겪고 있습니다.클러스터에서의 리크 보안
아무에게도 어떻게 할 수 있습니까 ??
어쨌든 내가 클러스터에서 riak 보안을 사용하려면 아래 코드를 시도했지만 SSLEngine 오류가 발생했습니다. 아무도이 문제를 해결하는 방법을 말할 수 있습니까?
다음은 우리가 보안을 원격으로 Riak KV 수 있도록 액세스하는 방법
InputStream inputStream = null; KeyStore ks = null; try { // inputStream = new FileInputStream("/ssl_dir/cacertfile.pem"); inputStream = new FileInputStream("/home/shahzad/Desktop/amit/rootCA.pem"); // Generate an X509Certificate from the InputStream CertificateFactory certFactory = CertificateFactory.getInstance("X.509"); X509Certificate caCert = (X509Certificate) certFactory.generateCertificate(inputStream); inputStream.close(); // Generate a KeyStore object ks = KeyStore.getInstance(KeyStore.getDefaultType()); ks.load(null, "password".toCharArray()); ks.setCertificateEntry("cacert", caCert); } catch (Exception e) { e.printStackTrace(); } synchronized (RiakConfig.class) { List<RiakNode> riakNodeList = new ArrayList<RiakNode>(); for (final String riakServer : riakServerArray) { RiakNode node = new RiakNode.Builder() .withMinConnections(10) .withMinConnections(50) .withRemoteAddress(riakServer.split(":")[0]) .withRemotePort( Integer.parseInt(riakServer.split(":")[1])) .withAuth("shahzad", "shahzad", ks) .build(); riakNodeList.add(node); } // This cluster object takes our one node as an argument cluster = new RiakCluster.Builder(riakNodeList).build(); // The cluster must be started to work, otherwise you will see // errors cluster.start(); } 가 ..... 한 가지를 말해 Refference
을위한 자바 코드입니다.