Clients

Lettuce Connection Pooling

레디스 개발자 교육 신청	레디스 정기점검/기술지원 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();
	 }
}

<< Reactive	Connection Pooling	Sentinel >>

Email 답글이 올라오면 이메일로 알려드리겠습니다.