Jedis Pub/Sub

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Pub/Sub

Sentinel 메시지를 받는데는 실패했다. Async가 안되는 것도 좀 문제다. Pub/Sub을 사용할 계획이면 Lettuce를 사용하기를 권합니다.

Pub/Sub

public class Pubsub {
	JedisPubSub jedisPubSub = null;
	BinaryJedisPubSub binaryJedisPubSub = null;
	Button publishBtn = new Button("PUBLISH");
	Button subscribeBtn = new Button("SUBSCRIBE");
	Button sentinelBtn = new Button("SENTINEL");
	String channel = "ch01";
	long idx = 1;
	
	Pubsub(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("Pub/Sub");
		gridpane.add(lbl, 0, 1);
		gridpane.add(publishBtn, 1, 1);
		gridpane.add(subscribeBtn, 2, 1);
		gridpane.add(sentinelBtn, 3, 1);

		jedisPubSub = new JedisPubSub() {
			@Override
			public void onMessage(String channel, String message) {
				System.out.println("channel: "+channel+", message: "+message);
			}
		};

		binaryJedisPubSub = new BinaryJedisPubSub() {
			@Override
			public void onMessage(byte[] channel, byte[] message) {
				System.out.println("channel: "+channel+", message: "+message);
				// redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
			}
		};

		publishBtn.setOnAction(e->{  publish();	});
		subscribeBtn.setOnAction(e->{  subscribe();	});
		sentinelBtn.setOnAction(e->{  subscribeSentinel();	});
	}

	// PUBLISH channel message -> Integer reply: the number of clients that received the message.
	protected void publish() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("PUBLISH channel message");
		try {
			Redis.cmd.publish(channel, "Hello"+idx);
			System.out.println("publish "+channel+" Hello"+idx);
			idx++;
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SUBSCRIBE channel [channel ...]
	// Async를 사용할 수 없기 때문에 subscribe를 실행하면 더이상 화면에 동작을 할 수 없다.
	// Pub/Sub를 사용하려면 Async가 되는 Lettuce를 사용하는게 좋겠다. 2018.02.10(Sat) Gwacheon Lib. Charlie Kwon.
	protected void subscribe() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SUBSCRIBE channel [channel ...]");
		try {
			Redis.cmd.subscribe(jedisPubSub, channel);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// 센티널의 publish 메시지를 받으려고 했으나 아래와 같은 에러가 발생했다.
	// redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
	protected void subscribeSentinel() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("Sentinel SUBSCRIBE channel [channel ...]");
		try {
			Redis.cmd.subscribe(binaryJedisPubSub, "+sdown".getBytes(), "+odown".getBytes(), "+switch-master".getBytes());  
		} catch (Exception e) {
			System.out.println(e);
		}
	}
}

<< Hashes	Pub/Sub	Common Keys >>

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