Redisson Pub/Sub

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Pub/Sub

Pub/Sub에는 getTopic()을 사용한다.

Class 변수로 선언

String channel = "ch01";
long idx = 1;

PUBLISH

// PUBLISH channel message
protected void publish() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("PUBLISH channel message");
	try {
		Redis.redissonMasterSlave.getTopic(channel).publish("Hello"+idx);
		System.out.println("publish "+channel+" Hello"+idx);
		idx++;
	} catch (Exception e) {
		System.out.println(e);
	}
}

// Subscribe
RTopic<Object> topic = Redis.redissonMasterSlave.getTopic(channel);
topic.addListener(new MessageListener<Object>() {
		@Override
		public void onMessage(String channel, Object message) {
				System.out.println(String.format("subscribe -> Channel: %s, Message: %s", channel, message));
		}
});

Subscribe for Sentinel failover

마스터 서버 다운이 발생하면 센티널은 Failover를 진행한다. Failover를 진행하면서 각 단계마다 로그에 기록하고 단계명을 channel명으로 해서 관련 정보를 publish한다. Client는 "+switch-master" 메시지를 받으면 기존 connection을 버리고 새 마스터에 connect한다. Redisson에서는 Sentinel의 Publish를 받을 수 없었다. Sentinel 관련 자세한 내용은 여기를 보세요.

// Subscribing: Sentinel -> check failover
// Sentinel로 부터 메시지를 받지 못함.
RTopic<Object> topic2 = Redis.redissonSentinel.getTopic("+switch-master");
topic2.addListener(new MessageListener<Object>() {
	@Override
		public void onMessage(String channel, Object message) {
			System.out.println(String.format("subscribe -> Channel: %s, Message: %s", channel, message));
	}
});

<< Hashes	Pub/Sub	Common Keys >>

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

Redisson Pub/Sub

Pub/Sub

PUBLISH

SUBSCRIBE

Subscribe for Sentinel failover