Lettuce Pub/Sub

Redis 開発者教育 Redis Developer Course	Redis 定期点検/技術支援 Redis Technical Support	Redis エンタープライズサーバ Redis Enterprise Server

Pub/Sub

Class 변수로 선언

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

PUBLISH

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

// Subscribe channel 
RedisPubSubAdapter<String, String> listener = new RedisPubSubAdapter<String, String>() {
		@Override
		public void message(String channel, String message) {
				System.out.println(String.format("subscribe -> Channel: %s, Message: %s", channel, message));
		}
};
StatefulRedisPubSubConnection<String, String> pubsubConn = Redis.redisClient.connectPubSub();
pubsubConn.addListener(listener);
RedisPubSubAsyncCommands<String, String> async = pubsubConn.async();
async.subscribe(channel);

Subscribe for Sentinel failover

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

// Subscribe: Sentinel -> check failover
RedisPubSubAdapter<String, String> listener2 = new RedisPubSubAdapter<String, String>() {
		@Override
		public void message(String channel, String message) {
				System.out.println(String.format("subscribe -> Channel: %s, Message: %s", channel, message));
				if (channel.equals("+switch-master")) {
					String items[] = message.split(" ");
					int len = items.length;
					String ip = items[len-2];
					int port = Integer.parseInt(items[len-1]);
					System.out.println(ip+":"+port);
					Redis.conn2(ip, port);
				}
		}
};
StatefulRedisPubSubConnection<String, String> pubsubConn2 = Redis.sentinelClient.connectPubSub();
pubsubConn2.addListener(listener2);
RedisPubSubAsyncCommands<String, String> async2 = pubsubConn2.async();
async2.subscribe("+sdown");
async2.subscribe("+odown");
async2.subscribe("+switch-master");

<< Hashes	Pub/Sub	Common Keys >>

조회수 :

Email 返事がかかってなれば、メールでお知らせします。

Lettuce Pub/Sub

Pub/Sub

PUBLISH

SUBSCRIBE

Subscribe for Sentinel failover