Lettuce Connection Pooling

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Lettuce Connection Pooling

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 답글이 올라오면 이메일로 알려드리겠습니다.