redis clients lettuce lettuce_connection_pool

Lettuce Connection Pooling

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Lettuce Connection Pooling

• Lettuce-6.1.7, Redis-7.0.2 Example
• Lettuce-4.4.2, Redis-4.0.6 Example

Lettuce-6.1.7, Redis-7.0.2 Example

LettuceAsyncCmd.java
import java.util.Scanner; import org.apache.commons.pool2.impl.GenericObjectPool; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import io.lettuce.core.RedisClient; import io.lettuce.core.api.StatefulRedisConnection; import io.lettuce.core.api.async.RedisAsyncCommands; import io.lettuce.core.api.sync.RedisCommands; import io.lettuce.core.support.ConnectionPoolSupport; public class LettuceConnPool { Scanner scanner = new Scanner(System.in); Util util = new Util(); protected RedisClient redisClient = null; protected StatefulRedisConnection<String, String> connection = null; protected RedisCommands<String, String> commands = null; protected RedisAsyncCommands<String, String> cmdsAsync = null; protected GenericObjectPool<StatefulRedisConnection<String, String>> pool = null; protected int idx = 0; public LettuceConnPool() { connPoolSync(); while(true) { System.out.println("1:SET 2:GET 3:SET-loop\n"); System.out.println("선택(exit:99)> "); int i = scanner.nextInt(); scanner.nextLine(); switch (i) { case 1: set(); break; case 2: get(); break; case 3: setLoop(); break; case 99: break; default: System.out.println("잘못 선택했습니다. 다시 선택하세요. "); } if (i==99) break; } closePool(); } /* ----------------------------------------------- * 레디스 서버에 실제로 connect하지 않는다. * 처음 명령을 실행할 때 connect한다. * 이후로 이미 연결된 connection을 사용하고 부족하면 추가로 연결한다. */ @SuppressWarnings({ "rawtypes", "unchecked" }) public void connPoolSync() { GenericObjectPoolConfig conConf = new GenericObjectPoolConfig(); pool = ConnectionPoolSupport.createGenericObjectPool(() -> redisConnectSync(), conConf); System.out.println("Create Connection Pool: getMaxTotal -> "+pool.getMaxTotal()); } public StatefulRedisConnection<String, String> redisConnectSync() { System.out.println("Redis Connection -> Start"); try { redisClient = RedisClient.create(Main.conn); connection = redisClient.connect(); System.out.println("Redis Connection -> OK"); return connection; } catch (Exception e) { System.out.println(e.getMessage()); return null; } } public void set() { try (StatefulRedisConnection<String, String> connection = pool.borrowObject()) { RedisCommands<String, String> commands = connection.sync(); idx++; String ret = commands.set("keyPool-"+idx, "valuePool-"+idx); System.out.println("SET -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void get() { try (StatefulRedisConnection<String, String> connection = pool.borrowObject()) { RedisCommands<String, String> commands = connection.sync(); String ret = commands.get("keyPool-"+idx); System.out.println("GET -> "+ret); } catch (Exception e) { System.out.println(e.getMessage()); return; } } public void setLoop() { for (int i=0; i<1000; i++) { set(); } } public void closePool() { pool.close(); redisClient.shutdown(); } }

Lettuce-4.4.2, Redis-4.0.6 Example

Lettuce Connection Pooling은 commons-pool2를 필요로 합니다. 여거서는 commons-pool2-2.4.2를 사용했습니다.

Connection Pooling

public class ConnectionPool { StatefulRedisConnection<String, String> connection = null; RedisCommands<String, String> commands = null; RedisAsyncCommands<String, String> cmdsAsync = null; GenericObjectPool<StatefulRedisConnection<String, String>> pool = null; HBox hbox = new HBox(); Button setGetBtn = new Button("setGet"); ConnectionPool(VBox vbox) { Label lbl = new Label("Connection Pooling"); GridPane gridpane = new GridPane(); gridpane.setPadding(new Insets(5)); gridpane.setHgap(5); gridpane.setVgap(5); vbox.getChildren().add(gridpane); gridpane.add(lbl, 0, 1); gridpane.add(setGetBtn, 1, 1); setGetBtn.setOnAction(e->{ setGet(); }); GenericObjectPoolConfig conConf = new GenericObjectPoolConfig(); pool = ConnectionPoolSupport.createGenericObjectPool(() -> Redis.redisClient.connect(), conConf); System.out.println("Create Connection Pool: getMaxTotal -> "+pool.getMaxTotal()); try { connection = pool.borrowObject(); commands = connection.sync(); cmdsAsync = connection.async(); } catch (Exception e) { e.printStackTrace(); } System.out.println("pool.borrowObject() -> OK"); } public void setGet() { String ret = commands.set("key", "value"); System.out.println("Connect pool: Sync Cmd: SET -> "+ret); RedisFuture<String> future = cmdsAsync.get("key"); future.thenAccept(v -> System.out.println("Connect pool: Async Cmd: GET -> "+v)); } public void finalize() { System.out.println("Connection을 리턴하고 Connection Pool을 닫는다. "); pool.returnObject(connection); pool.close(); } }