Jedis Pipeline

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Pipeline

Pipeline 가능하다. 일반 Set에 비해서 처리 속도가 훨신 빠르다. 마지막에 sync()를 꼭 해주어야 한다.

Pipeline SET

public class Pipeline {
	
	Button setBtn = new Button("SET");
	Button pipelineSetBtn = new Button("Pipeline SET");
	
	Pipeline(VBox vbox) {

		GridPane gridpane = new GridPane();
	    gridpane.setPadding(new Insets(5));
	    gridpane.setHgap(5);
	    gridpane.setVgap(5);
	    vbox.getChildren().add(gridpane);
	    Label lbl = new Label("Pipeline");

		gridpane.add(lbl, 0, 1);
		gridpane.add(setBtn, 1, 1);
		gridpane.add(pipelineSetBtn, 2, 1);
		
		setBtn.setOnAction(e->{  set();	});
		pipelineSetBtn.setOnAction(e->{  pipelineSet();	});

	}

	protected void set() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("Set");
		String key = "key-", value = "value-";
		long start = System.currentTimeMillis(); 
		try {
			for (int i=0; i<100000; i++) {
				Redis.cmd.set(key+i, value+i);
			}
		} catch (Exception e) {
			System.out.println(e);
		}
		System.out.println("SET elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
	}

	protected void pipelineSet() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("Pipeline set");
		String key = "key=", value="value=";
		long start = System.currentTimeMillis(); 
		try {
			redis.clients.jedis.Pipeline pipeline = Redis.cmd.pipelined();
			  //start transaction
			  pipeline.multi();
				for (int i=0; i<100000; i++) {
			    pipeline.set(key+i, value+i);
			  }
			  pipeline.exec();
			  pipeline.sync();			  
		} catch (Exception e) {
			System.out.println(e);
		}
		System.out.println("Pipeline SET elapsed time(ms) -> "+(System.currentTimeMillis() - start)); 
	}
}

<< Common Keys	Pipeline	Sentinel >>

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