redis clients redisson redisson_connection

Redisson Connection

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Redis Client for Java

필요한 Jar 파일들

• redisson-3.5.7.jar
• netty-all-4.1.19.Final.jar
• jackson, slf4j 파일들을 Libraries에 추가하세요.

Connection

Redis class를 만들어 아래 source code를 넣는다.   이후에는 Redis.syncCmd.set() 이렇게 사용한다.

• Redisson client object 선언
  // SET, GET 같은 DB 명령은 안된다. info 같은 server 명령만 실행된다. public static RedissonClient redissonSingle = null; public static RedissonClient redissonMasterSlave = null; // DB명령 됨. public static RedissonClient redissonReplicate = null; // DB명령 됨. public static RedissonClient redissonSentinel = null; // For Sentinel public static RedissonClient redissonCluster = null; // For Cluster, DB명령 됨. public static RedisConnection connLowLevel = null; // For Low Level Commands
• useSingleServer 특정 노드에 접속해서 명령을 실행할 때 사용한다.
  // useSingleServer // SingleServer라고 해서 Standalone mode의 master만을 위한 것은 아니다. // 클러스터 노드, 클론 노드를 포함한 모든 노드에 접속 가능하다. // 즉, 특정 노드에 접속해 명령을 실행하고자 할 경우에 사용한다. // 다만, Standalone 노드에 접속해서 cluster info 명령을 실행하면 에러가 발생한다. String connStringSingle = "redis://127.0.0.1:6010"; Config configSingle = new Config(); configSingle.useSingleServer().setAddress(connStringSingle); RedissonClient redissonSingle = Redisson.create(configSingle); // pingAll() Boolean retSinglePing1 = redissonSingle.getNodesGroup().pingAll(); System.out.println("redisson Single getNodesGroup()] pingAll -> "+retSinglePing1); // ping() Boolean retSinglePing2 = redissonSingle.getNodesGroup().getNode(connStringSingle).ping(); System.out.println("redisson Single getNode("+connStringSingle+")] ping -> "+retSinglePing2); System.out.println(); System.out.println("Info all -----------------------------------------------------------"); // info all -> 각 section 별 구분이 되지 않는다. 원래 순서대로 오지 않는다. Map<String, String> retSingleInfo = redissonSingle.getNodesGroup().getNode(connStringSingle).info(InfoSection.ALL); for( Map.Entry<String, String> elem : retSingleInfo.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } System.out.println(); System.out.println("Info server ------------------------------------------------------"); Map<String, String> retSingleInfoServer = redissonSingle.getNodesGroup().getNode(connStringSingle).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : retSingleInfoServer.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } // config get, set 명령을 사용할 수 없다. // slaveof 명령을 사용할 수 없다. // cluster mode이면 cluster info 명령을 실행한다. if (retSingleInfoServer.get("redis_mode").equals("cluster")) { System.out.println(); System.out.println("cluster info ------------------------------------------------------"); // cluster info RFuture<Map<String, String>> clusterInfo = redissonSingle.getNodesGroup().getNode(connStringSingle).clusterInfoAsync(); try { for( Map.Entry<String, String> elem : clusterInfo.get().entrySet()) { System.out.println( elem.getKey()+" -> "+elem.getValue() ); } } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } }
• useMasterSlaveServers
  // useMasterSlaveServers String connStringMaster = "redis://127.0.0.1:6000"; String connStringSlave = "redis://127.0.0.1:6001"; Config configMasterSlave = new Config(); configMasterSlave.useMasterSlaveServers().setMasterAddress(connStringMaster) .addSlaveAddress(connStringSlave) .setReadMode(ReadMode.SLAVE); try { // slave가 다운된 상태이면 여기서 에러 발생 -> Unable to connect to Redis server: /127.0.0.1:6001 redissonMasterSlave = Redisson.create(configMasterSlave); } catch (Exception e) { System.out.println("MasterSalve connection Error -> "+e); e.printStackTrace(); } // pingAll() // slave가 다운 상태이면 pingAll()에서도 에러 발생 Boolean retMasterSlavePing1 = redissonMasterSlave.getNodesGroup().pingAll(); System.out.println("redisson MasterSlave getNodesGroup()] pingAll -> "+retMasterSlavePing1); // ping() Boolean retMasterSlavePing2 = redissonMasterSlave.getNodesGroup().getNode(connStringMaster).ping(); System.out.println("redisson MasterSlave getNode("+connStringMaster+")] ping -> "+retMasterSlavePing2); // ping() Boolean retMasterSlavePing3 = redissonMasterSlave.getNodesGroup().getNode(connStringSlave).ping(); System.out.println("redisson MasterSlave getNode("+connStringSlave+")] ping -> "+retMasterSlavePing3); System.out.println(); // master를 지정했음에도 불구하고 slave 노드 정보를 가져온다. 버그로 생각됨. Map<String, String> infoMaster = redissonMasterSlave.getNodesGroup().getNode(connStringMaster).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : infoMaster.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } System.out.println(); // master를 지정했음에도 불구하고 slave 노드 정보를 가져온다. 버그로 생각됨. Map<String, String> infoMasterRepl = redissonMasterSlave.getNodesGroup().getNode(connStringMaster).info(InfoSection.REPLICATION); for( Map.Entry<String, String> elem : infoMasterRepl.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } System.out.println(); Map<String, String> infoSlave = redissonMasterSlave.getNodesGroup().getNode(connStringSlave).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : infoSlave.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } // 주소는 제대로 가져온다. System.out.println(); InetSocketAddress addr = redissonMasterSlave.getNodesGroup().getNode(connStringMaster).getAddr(); System.out.println(addr.getHostName()+", "+addr.getHostString()+", "+addr.getAddress()+", "+addr.getPort()); System.out.println(); InetSocketAddress addrSlave = redissonMasterSlave.getNodesGroup().getNode(connStringSlave).getAddr(); System.out.println(addrSlave.getHostName()+", "+addrSlave.getHostString()+", "+addrSlave.getAddress()+", "+addrSlave.getPort());
• useReplicatedServers
  // useReplicatedServers System.out.println(); String connStringNode1 = "redis://127.0.0.1:6000"; String connStringNode2 = "redis://127.0.0.1:6001"; Config configReplicate = new Config(); configReplicate.useReplicatedServers().addNodeAddress(connStringNode1, connStringNode2) .setReadMode(ReadMode.SLAVE); try { redissonReplicate = Redisson.create(configReplicate); } catch (Exception e) { System.out.println("Replicate connection Error -> "+e); e.printStackTrace(); } // pingAll() Boolean retReplicatePing = redissonReplicate.getNodesGroup().pingAll(); System.out.println("redisson Replicate getNodesGroup()] pingAll -> "+retReplicatePing); System.out.println(); // Node1을 지정했는데 Node2의 정보를 가져온다. 버그로 생각됨. Map<String, String> infoNode1 = redissonReplicate.getNodesGroup().getNode(connStringNode1).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : infoNode1.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } System.out.println(); Map<String, String> infoNode2 = redissonReplicate.getNodesGroup().getNode(connStringNode2).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : infoNode2.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); }
• useSentinelServers
  // useSentinelServers Config configSentinel = new Config(); String connSentinel1 = "redis://192.168.56.103:16000"; String connSentinel2 = "redis://192.168.56.103:16001"; String connSentinel3 = "redis://192.168.56.103:16002"; configSentinel.useSentinelServers() .setMasterName("mymaster") .addSentinelAddress(connSentinel1, connSentinel2, connSentinel3); try { redissonSentinel = Redisson.create(configSentinel); } catch (Exception e) { System.out.println("Sentinel connection Error -> "+e); e.printStackTrace(); } Boolean ret = redissonSentinel.getNodesGroup().pingAll(); System.out.println("Sentinel Ping -> "+ret);
• useClusterServers
  // useClusterServers System.out.println(); String connStringClusterNode1 = "redis://127.0.0.1:7000"; String connStringClusterNode2 = "redis://127.0.0.1:7001"; String connStringClusterNode3 = "redis://127.0.0.1:7002"; String connStringClusterNode4 = "redis://127.0.0.1:7003"; String connStringClusterNode5 = "redis://127.0.0.1:7004"; String connStringClusterNode6 = "redis://127.0.0.1:7005"; Config configCluster = new Config(); configCluster.setUseLinuxNativeEpoll(false); configCluster.useClusterServers().addNodeAddress(connStringClusterNode1, connStringClusterNode2, connStringClusterNode3) .addNodeAddress(connStringClusterNode4, connStringClusterNode5, connStringClusterNode6) .setReadMode(ReadMode.SLAVE); // 첫 번째 노드가 다운되었으면 두 번째 노드에서 클러스터 정보를 가져온다. try { redissonCluster = Redisson.create(configCluster); } catch (Exception e) { System.out.println("Cluster connection Error -> "+e); e.printStackTrace(); } // pingAll() -> 클러스터내 모든 노드에서 응답이 오면 true, 하나라도 응답이 오지 않으면 false이다. Boolean retClusterPing = redissonCluster.getNodesGroup().pingAll(); System.out.println("redisson Cluster getNodesGroup()] pingAll -> "+retClusterPing); System.out.println(); // 마지막 노드이 정보가 온다. 버그로 생각됨. Map<String, String> infoClusterNode3 = redissonCluster.getNodesGroup().getNode(connStringClusterNode3).info(InfoSection.SERVER); for( Map.Entry<String, String> elem : infoClusterNode3.entrySet() ){ System.out.println( elem.getKey()+" -> "+elem.getValue() ); } // cluster mode이면 cluster info 명령을 실행한다. if (infoClusterNode3.get("redis_mode").equals("cluster")) { System.out.println(); System.out.println("cluster info ------------------------------------------------------"); // cluster info RFuture<Map<String, String>> clusterInfo = redissonCluster.getNodesGroup().getNode(connStringClusterNode3).clusterInfoAsync(); try { for( Map.Entry<String, String> elem : clusterInfo.get().entrySet()) { System.out.println( elem.getKey()+" -> "+elem.getValue() ); } } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } }
• Low level Redis client
  // Low level Redis client RedisClientConfig config = new RedisClientConfig(); config.setAddress(connStringMaster); RedisClient client = RedisClient.create(config); connLowLevel = client.connect(); // Sync commands try { String s = connLowLevel.sync(StringCodec.INSTANCE, RedisCommands.SET, "testKey", "value"); System.out.println("Low level Redis client: set -> "+s); } catch (Exception e) { System.out.println("Low level Redis client: set Error-> "+e); e.printStackTrace(); } try { Long s2 = connLowLevel.sync(StringCodec.INSTANCE, RedisCommands.APPEND, "testKey", "addValue"); System.out.println("Low level Redis client: append -> "+s2); } catch (Exception e) { System.out.println("Low level Redis client: append Error-> "+e); e.printStackTrace(); } // Async commands try { RFuture<String> s3 = connLowLevel.async(StringCodec.INSTANCE, RedisCommands.SET, "testKey-1", "value-1"); System.out.println("Low level Redis client: Async set -> "+s3.get()); } catch (Exception e) { System.out.println("Low level Redis client: Async set Error-> "+e); e.printStackTrace(); }