Lettuce Sentinel

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Sentinel

Lettuce Sentinel Commands

info sentinel -> return Bulk String.
role -> 해당 메소드 없음.
sentinelMonitor(masterName, ip, port, quorum) -> return Simple String.
sentinelMasters() -> return List<Map<String, String>>.
sentinelMaster() -> return Map<String, String>.
sentinelSlaves(masterName) -> return List<Map<String, String>>.
sentinelSentinels() -> 해당 메소드 없음.
sentinelGetMasterAddrByName(masterName) -> return List<String>.
sentinel Reset(pattern) -> return long.
sentinelFailover(masterName) -> return Simple String.
sentinelCkquorum() -> 해당 메소드 없음.
sentinelSimulateFailure() -> 해당 메소드 없음.
sentinel Set(masterName, param, value) -> return Simple String.
sentinelFlushConfig() -> 해당 메소드 없음.
sentinelInfoCache() -> 해당 메소드 없음.
sentinelPendingScripts() -> 해당 메소드 없음.
sentinel Remove(String masterName) -> return Simple String.

Connection

public static RedisClient sentinelClient = null;
public static StatefulRedisSentinelConnection<String,String> sentinelConn = null;
public static RedisSentinelCommands<String,String> sentinel = null;

RedisURI sentinelConn = new RedisURI("192.168.56.103", 16000, 5, TimeUnit.SECONDS);
try {
	sentinelClient = RedisClient.create(sentinelConn);
} catch (Exception e) {
	System.out.println(e);
	return;
}
sentinelConn = sentinelClient.connectSentinel();
sentinel = sentinelConn.sync();

Sentinel

package application;

import java.net.SocketAddress;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import com.lambdaworks.redis.RedisClient;
import com.lambdaworks.redis.RedisURI;
import com.lambdaworks.redis.pubsub.RedisPubSubAdapter;
import com.lambdaworks.redis.pubsub.StatefulRedisPubSubConnection;
import com.lambdaworks.redis.pubsub.api.async.RedisPubSubAsyncCommands;
import com.lambdaworks.redis.sentinel.api.StatefulRedisSentinelConnection;
import com.lambdaworks.redis.sentinel.api.sync.RedisSentinelCommands;

import javafx.geometry.Insets;
import javafx.scene.control.Button;
import javafx.scene.control.Label;
import javafx.scene.layout.GridPane;
import javafx.scene.layout.VBox;

public class Sentinel {
	public static RedisClient sentinelClient = null;
	public static StatefulRedisSentinelConnection<String,String> sentinelConn = null;
	public static RedisSentinelCommands<String,String> sentinel = null;

	Button infoBtn = new Button("INFO sentinel");
	Button roleBtn = new Button("ROLE");
	Button monitorBtn = new Button("MONITOR");
	Button mastersBtn = new Button("MASTERS");
	Button masterBtn = new Button("MASTER");
	Button slavesBtn = new Button("SLAVES");
	Button sentinelsBtn = new Button("SENTINELS");
	Button getMasterAddrByNameBtn = new Button("GET-MASTER-ADDR-BY-NAME");
	Button resetBtn = new Button("RESET");
	Button failoverBtn = new Button("FAILOVER");
	Button ckQuorumBtn = new Button("CKQUORUM");
	Button simulateFailureBtn = new Button("SIMULATE-FAILURE");
	Button setBtn = new Button("SET");
	Button flushConfigBtn = new Button("FLUSHCONFIG");
	Button infoCacheBtn = new Button("INFO-CACHE");
	Button pendingScriptsBtn = new Button("PENDING-SCRIPTS");
	Button removeBtn = new Button("REMOVE");
	Button closeBtn = new Button("Close Connection");

	Sentinel(VBox vbox) {
    	RedisURI sentinelConn1 = new RedisURI("192.168.56.103", 16000, 5, TimeUnit.SECONDS);

		try {
			sentinelClient = RedisClient.create(sentinelConn1);
		} catch (Exception e) {
			System.out.println(e);
			return;
		}
    	
		sentinelConn = sentinelClient.connectSentinel();
		sentinel = sentinelConn.sync();

		try {
			String ret1 = sentinel.ping();
			System.out.println("16000-sentinel] ping -> "+ret1);
		} catch (Exception e) {
			System.out.println(e);
		}
		
		//--------------------------------------------------------------------------------------------------------
		// Subscribing: Sentinel -> check failover
		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));
		        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> pubsubConn = sentinelClient.connectPubSub();
		pubsubConn.addListener(listener);
		RedisPubSubAsyncCommands<String, String> async = pubsubConn.async();
		async.subscribe("+sdown");
		async.subscribe("+odown");
		async.subscribe("+switch-master");
		

	GridPane gridpane = new GridPane();
	gridpane.setPadding(new Insets(5));
	gridpane.setHgap(5);
	gridpane.setVgap(5);
	package application;

import java.net.SocketAddress;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import com.lambdaworks.redis.RedisClient;
import com.lambdaworks.redis.RedisURI;
import com.lambdaworks.redis.pubsub.RedisPubSubAdapter;
import com.lambdaworks.redis.pubsub.StatefulRedisPubSubConnection;
import com.lambdaworks.redis.pubsub.api.async.RedisPubSubAsyncCommands;
import com.lambdaworks.redis.sentinel.api.StatefulRedisSentinelConnection;
import com.lambdaworks.redis.sentinel.api.sync.RedisSentinelCommands;

import javafx.geometry.Insets;
import javafx.scene.control.Button;
import javafx.scene.control.Label;
import javafx.scene.layout.GridPane;
import javafx.scene.layout.VBox;

public class Sentinel {
    public static RedisClient sentinelClient = null;
	public static StatefulRedisSentinelConnection<String,String> sentinelConn = null;
    public static RedisSentinelCommands<String,String> sentinel = null;

	Button infoBtn = new Button("INFO sentinel");
	Button roleBtn = new Button("ROLE");
	Button monitorBtn = new Button("MONITOR");
	Button mastersBtn = new Button("MASTERS");
	Button masterBtn = new Button("MASTER");
	Button slavesBtn = new Button("SLAVES");
	Button sentinelsBtn = new Button("SENTINELS");
	Button getMasterAddrByNameBtn = new Button("GET-MASTER-ADDR-BY-NAME");
	Button resetBtn = new Button("RESET");
	Button failoverBtn = new Button("FAILOVER");
	Button ckQuorumBtn = new Button("CKQUORUM");
	Button simulateFailureBtn = new Button("SIMULATE-FAILURE");
	Button setBtn = new Button("SET");
	Button flushConfigBtn = new Button("FLUSHCONFIG");
	Button infoCacheBtn = new Button("INFO-CACHE");
	Button pendingScriptsBtn = new Button("PENDING-SCRIPTS");
	Button removeBtn = new Button("REMOVE");
	Button closeBtn = new Button("Close Connection");

	Sentinel(VBox vbox) {
    	RedisURI sentinelConn1 = new RedisURI("192.168.56.103", 16000, 5, TimeUnit.SECONDS);

		try {
			sentinelClient = RedisClient.create(sentinelConn1);
		} catch (Exception e) {
			System.out.println(e);
			return;
		}
    	
		sentinelConn = sentinelClient.connectSentinel();
		sentinel = sentinelConn.sync();

		try {
			String ret1 = sentinel.ping();
			System.out.println("16000-sentinel] ping -> "+ret1);
		} catch (Exception e) {
			System.out.println(e);
		}
		
		//--------------------------------------------------------------------------------------------------------
		// Subscribing: Sentinel -> check failover
		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));
		        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> pubsubConn = sentinelClient.connectPubSub();
		pubsubConn.addListener(listener);
		RedisPubSubAsyncCommands<String, String> async = pubsubConn.async();
		async.subscribe("+sdown");
		async.subscribe("+odown");
		async.subscribe("+switch-master");

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

		Label lbl = new Label("Sentinel");
		gridpane.add(lbl, 0, 1);
		gridpane.add(infoBtn, 1, 1);
		gridpane.add(roleBtn, 2, 1);
		gridpane.add(monitorBtn, 3, 1);
		gridpane.add(mastersBtn, 4, 1);
		gridpane.add(masterBtn, 5, 1);
		
		gridpane.add(slavesBtn, 1, 2);
		gridpane.add(sentinelsBtn, 2, 2);
		gridpane.add(getMasterAddrByNameBtn, 3, 2);
		gridpane.add(resetBtn, 4, 2);
		gridpane.add(failoverBtn, 5, 2);
		
		gridpane.add(ckQuorumBtn, 1, 3);
		gridpane.add(simulateFailureBtn, 2, 3);
		gridpane.add(setBtn, 3, 3);
		gridpane.add(flushConfigBtn, 4, 3);
		gridpane.add(infoCacheBtn, 5, 3);
		
		gridpane.add(pendingScriptsBtn, 1, 4);
		gridpane.add(removeBtn, 2, 4);
		gridpane.add(closeBtn, 2, 4);

		infoBtn.setOnAction(e->{  info();	});
		roleBtn.setOnAction(e->{  role();	});
		monitorBtn.setOnAction(e->{  sentinelMonitor();	});
		mastersBtn.setOnAction(e->{  sentinelMasters();	});
		masterBtn.setOnAction(e->{  sentinelMaster();	});
		
		slavesBtn.setOnAction(e->{  sentinelSlaves();	});
		sentinelsBtn.setOnAction(e->{  sentinelSentinels();	});
		getMasterAddrByNameBtn.setOnAction(e->{  getMasterAddrByName();	});
		resetBtn.setOnAction(e->{  sentinelReset();	});
		failoverBtn.setOnAction(e->{  sentinelFailover();	});
		
		ckQuorumBtn.setOnAction(e->{  sentinelCkquorum();	});		
		simulateFailureBtn.setOnAction(e->{  sentinelSimulateFailure();	});
		setBtn.setOnAction(e->{  sentinelSet();	});
		flushConfigBtn.setOnAction(e->{  sentinelFlushConfig();	});
		infoCacheBtn.setOnAction(e->{  sentinelInfoCache();	});
		
		pendingScriptsBtn.setOnAction(e->{  sentinelPendingScripts();	});
		removeBtn.setOnAction(e->{  sentinelRemove();	});
		closeBtn.setOnAction(e->{  sentinelClose();	});
	}

	// INFO sentinel
	// info 명령으로 master server ip, port를 가져와서 connect해야 한다.
	protected void info() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("INFO sentinel -> return String");
		try {
			String info = sentinel.info("sentinel");
			System.out.println(info);
			/*
			String info[] = ret.split("\r\n");
			for (String s: info) {
				System.out.println(s);
				if (s.startsWith("master")) {
					String items[] = s.split(",");
					String addr[] = items[2].split("=");
					String addr2[] = addr[1].split(":");
					System.out.println("ip -> "+addr2[0]+", port -> "+addr2[1]);
				}
			}
			*/
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// Role -> Nested Array reply.
	protected void role() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("ROLE -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MONITOR  <master-name> <ip> <port> <quorum> -> Simple string reply.
	protected void sentinelMonitor() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MONITOR <master-name> <ip> <port> <quorum> -> return Simple String.");
		String masterName = "mymaster";
		String ip = "192.168.56.103";
		int port = 6000;
		int quorum = 2;
		try {
			String ret = sentinel.monitor(masterName, ip, port, quorum);
			System.out.println("SENTINEL MONITOR "+masterName+" "+ip+" "+port+" "+quorum+" -> "+ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MASTERS -> Nested Array reply.
	protected void sentinelMasters() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MASTERS -> return List<Map<String, String>>");
		try {
			List<Map<String, String>> list = sentinel.masters();
			for(Map<String,String> map:list) {
				System.out.println(map.toString());
			}
			String ip = list.get(0).get("ip");
			String port = list.get(0).get("port");
			System.out.println("ip -> "+ip+", port -> "+port);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MASTER <master name> -> return Map<String, String>
	protected void sentinelMaster() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MASTER <master name> -> return Map<String, String>");
		String master = "mymaster";
		try {
			Map<String, String> map = sentinel.master(master);
			System.out.println("sentinel master mymaster -> "+map.toString());
			String ip = map.get("ip");
			String port = map.get("port");
			System.out.println("ip -> "+ip+", port -> "+port);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL SLAVES <master name> -> Nested Array reply.
	protected void sentinelSlaves() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SLAVES <master name> -> return List<Map<String,String>>");
		String masterName = "mymaster";
		try {
			List<Map<String,String>> list = sentinel.slaves(masterName);
			for(Map<String,String> map:list) {
				System.out.println(map.toString());
			}
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL SENTINELS <master name> -> Nested Array reply.
	protected void sentinelSentinels() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SENTINELS <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL get-master-addr-by-name <master name> -> return SocketAddress
	protected void getMasterAddrByName() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL get-master-addr-by-name <master name> -> return SocketAddress");
		String master = "mymaster";
		try {
			SocketAddress addr = sentinel.getMasterAddrByName(master);
			System.out.println("SENTINEL getMasterAddrByName mymaster -> "+addr.toString());
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL RESET  [<master name>] -> Integer reply.
	protected void sentinelReset() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL RESET [<master name>] -> return long.");
		String masterName = "mymaster";
		try {
			long ret = sentinel.reset(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL FAILOVER   [<master name>] -> Simple string reply.
	protected void sentinelFailover() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL FAILOVER [<master name>] -> return Simple String.");
		String masterName = "mymaster";
		try {
			String ret = sentinel.failover(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL CKQUORUM    [<master name>] -> Bulk string reply.
	protected void sentinelCkquorum() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL CKQUORUM <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL SIMULATE-FAILURE crash-after-election/crash-after-promotion -> Bulk string reply.
	protected void sentinelSimulateFailure() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SIMULATE-FAILURE -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL SET  -> Simple string reply.
	protected void sentinelSet() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SET -> return Simple string.");
		String masterName = "mymaster";
		String param = "down-after-milliseconds";
		String value = "30000";
		try {
			String ret = sentinel.set(masterName, param, value);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL FLUSHCONFIG  -> Simple string reply.
	protected void sentinelFlushConfig() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL FLUSHCONFIG  -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL INFO-CACHE  -> Simple string reply.
	protected void sentinelInfoCache() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL INFO-CACHE <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL PENDING-SCRIPTS  -> 3 Nested Array reply.
	protected void sentinelPendingScripts() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL PENDING-SCRIPTS -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL REMOVE <master name> -> Simple String reply.
	protected void sentinelRemove() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL REMOVE <master name> -> return Simple String.");
		String masterName = "mymaster";
		try {
			String ret = sentinel.remove(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// Close Sentinel Connection 
	protected void sentinelClose() {
		try {
			sentinelConn.close();
			sentinelClient.shutdown();
		} catch (Exception e) {
			System.out.println(e);
		}
	}

}
vbox.getChildren().add(gridpane);

		Label lbl = new Label("Sentinel");
		gridpane.add(lbl, 0, 1);
		gridpane.add(infoBtn, 1, 1);
		gridpane.add(roleBtn, 2, 1);
		gridpane.add(monitorBtn, 3, 1);
		gridpane.add(mastersBtn, 4, 1);
		gridpane.add(masterBtn, 5, 1);
		
		gridpane.add(slavesBtn, 1, 2);
		gridpane.add(sentinelsBtn, 2, 2);
		gridpane.add(getMasterAddrByNameBtn, 3, 2);
		gridpane.add(resetBtn, 4, 2);
		gridpane.add(failoverBtn, 5, 2);
		
		gridpane.add(ckQuorumBtn, 1, 3);
		gridpane.add(simulateFailureBtn, 2, 3);
		gridpane.add(setBtn, 3, 3);
		gridpane.add(flushConfigBtn, 4, 3);
		gridpane.add(infoCacheBtn, 5, 3);
		
		gridpane.add(pendingScriptsBtn, 1, 4);
		gridpane.add(removeBtn, 2, 4);
		gridpane.add(closeBtn, 2, 4);

		infoBtn.setOnAction(e->{  info();	});
		roleBtn.setOnAction(e->{  role();	});
		monitorBtn.setOnAction(e->{  sentinelMonitor();	});
		mastersBtn.setOnAction(e->{  sentinelMasters();	});
		masterBtn.setOnAction(e->{  sentinelMaster();	});
		
		slavesBtn.setOnAction(e->{  sentinelSlaves();	});
		sentinelsBtn.setOnAction(e->{  sentinelSentinels();	});
		getMasterAddrByNameBtn.setOnAction(e->{  getMasterAddrByName();	});
		resetBtn.setOnAction(e->{  sentinelReset();	});
		failoverBtn.setOnAction(e->{  sentinelFailover();	});
		
		ckQuorumBtn.setOnAction(e->{  sentinelCkquorum();	});		
		simulateFailureBtn.setOnAction(e->{  sentinelSimulateFailure();	});
		setBtn.setOnAction(e->{  sentinelSet();	});
		flushConfigBtn.setOnAction(e->{  sentinelFlushConfig();	});
		infoCacheBtn.setOnAction(e->{  sentinelInfoCache();	});
		
		pendingScriptsBtn.setOnAction(e->{  sentinelPendingScripts();	});
		removeBtn.setOnAction(e->{  sentinelRemove();	});
		closeBtn.setOnAction(e->{  sentinelClose();	});
	}

	// INFO sentinel
	// info 명령으로 master server ip, port를 가져와서 connect해야 한다.
	protected void info() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("INFO sentinel -> return String");
		try {
			String info = sentinel.info("sentinel");
			System.out.println(info);
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// Role -> Nested Array reply.
	protected void role() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("ROLE -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MONITOR  <master-name> <ip> <port> <quorum> -> Simple string reply.
	protected void sentinelMonitor() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MONITOR <master-name> <ip> <port> <quorum> -> return Simple String.");
		String masterName = "mymaster";
		String ip = "192.168.56.103";
		int port = 6000;
		int quorum = 2;
		try {
			String ret = sentinel.monitor(masterName, ip, port, quorum);
			System.out.println("SENTINEL MONITOR "+masterName+" "+ip+" "+port+" "+quorum+" -> "+ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MASTERS -> Nested Array reply.
	protected void sentinelMasters() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MASTERS -> return List<Map<String, String>>");
		try {
			List<Map<String, String>> list = sentinel.masters();
			for(Map<String,String> map:list) {
				System.out.println(map.toString());
			}
			String ip = list.get(0).get("ip");
			String port = list.get(0).get("port");
			System.out.println("ip -> "+ip+", port -> "+port);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL MASTER <master name> -> return Map<String, String>
	protected void sentinelMaster() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MASTER <master name> -> return Map<String, String>");
		String master = "mymaster";
		try {
			Map<String, String> map = sentinel.master(master);
			System.out.println("sentinel master mymaster -> "+map.toString());
			String ip = map.get("ip");
			String port = map.get("port");
			System.out.println("ip -> "+ip+", port -> "+port);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL SLAVES <master name> -> Nested Array reply.
	protected void sentinelSlaves() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SLAVES <master name> -> return List<Map<String,String>>");
		String masterName = "mymaster";
		try {
			List<Map<String,String>> list = sentinel.slaves(masterName);
			for(Map<String,String> map:list) {
				System.out.println(map.toString());
			}
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL SENTINELS <master name> -> Nested Array reply.
	protected void sentinelSentinels() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SENTINELS <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL get-master-addr-by-name <master name> -> return SocketAddress
	protected void getMasterAddrByName() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL get-master-addr-by-name <master name> -> return SocketAddress");
		String master = "mymaster";
		try {
			SocketAddress addr = sentinel.getMasterAddrByName(master);
			System.out.println("SENTINEL getMasterAddrByName mymaster -> "+addr.toString());
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL RESET  [<master name>] -> Integer reply.
	protected void sentinelReset() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL RESET [<master name>] -> return long.");
		String masterName = "mymaster";
		try {
			long ret = sentinel.reset(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL FAILOVER   [<master name>] -> Simple string reply.
	protected void sentinelFailover() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL FAILOVER [<master name>] -> return Simple String.");
		String masterName = "mymaster";
		try {
			String ret = sentinel.failover(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL CKQUORUM    [<master name>] -> Bulk string reply.
	protected void sentinelCkquorum() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL CKQUORUM <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL SIMULATE-FAILURE crash-after-election/crash-after-promotion -> Bulk string reply.
	protected void sentinelSimulateFailure() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SIMULATE-FAILURE -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL SET  -> Simple string reply.
	protected void sentinelSet() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL SET -> return Simple string.");
		String masterName = "mymaster";
		String param = "down-after-milliseconds";
		String value = "30000";
		try {
			String ret = sentinel.set(masterName, param, value);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL FLUSHCONFIG  -> Simple string reply.
	protected void sentinelFlushConfig() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL FLUSHCONFIG  -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}

	// SENTINEL INFO-CACHE  -> Simple string reply.
	protected void sentinelInfoCache() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL INFO-CACHE <master name> -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL PENDING-SCRIPTS  -> 3 Nested Array reply.
	protected void sentinelPendingScripts() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL PENDING-SCRIPTS -> No Method.");
		try {
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// SENTINEL REMOVE <master name> -> Simple String reply.
	protected void sentinelRemove() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL REMOVE <master name> -> return Simple String.");
		String masterName = "mymaster";
		try {
			String ret = sentinel.remove(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
	
	// Close Sentinel Connection 
	protected void sentinelClose() {
		try {
			sentinelConn.close();
			sentinelClient.shutdown();
		} catch (Exception e) {
			System.out.println(e);
		}
	}
}

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");

INFO SENTINEL

// INFO sentinel
// info 명령으로 master server ip, port 확인
protected void info() {
	try {
		String info = Redis.sentinel.info("sentinel");
		System.out.println(info);
	} catch (Exception e) {
		System.out.println(e);
	}
}

ROLE -> 해당 메소드 없음

// Role -> Nested Array reply.
protected void role() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("ROLE -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Monitor

// SENTINEL MONITOR  <master-name> <ip> <port> <quorum> -> Simple string reply.
protected void sentinelMonitor() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL MONITOR <master-name> <ip> <port> <quorum> -> return Simple String.");
	String masterName = "mymaster";
	String ip = "192.168.56.103";
	int port = 6000;
	int quorum = 2;
	try {
		String ret = Redis.sentinel.monitor(masterName, ip, port, quorum);
		System.out.println("SENTINEL MONITOR "+masterName+" "+ip+" "+port+" "+quorum+" -> "+ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Masters

// SENTINEL MASTERS -> Nested Array reply.
protected void sentinelMasters() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL MASTERS -> return List<Map<String, String>>");
	try {
		List<Map<String, String>> list = Redis.sentinel.masters();
		for(Map<String,String> map:list) {
			System.out.println(map.toString());
		}
		String ip = list.get(0).get("ip");
		String port = list.get(0).get("port");
		System.out.println("ip -> "+ip+", port -> "+port);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Master

// SENTINEL MASTER <master name> -> return Map<String, String>
protected void sentinelMaster() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL MASTER <master name> -> return Map<String, String>");
	String master = "mymaster";
	try {
		Map<String, String> map = Redis.sentinel.master(master);
		System.out.println("sentinel master mymaster -> "+map.toString());
		String ip = map.get("ip");
		String port = map.get("port");
		System.out.println("ip -> "+ip+", port -> "+port);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Slaves

// SENTINEL SLAVES <master name> -> Nested Array reply.
protected void sentinelSlaves() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL SLAVES <master name> -> return List<Map<String,String>>");
	String masterName = "mymaster";
	try {
		List<Map<String,String>> list = Redis.sentinel.slaves(masterName);
		for(Map<String,String> map:list) {
			System.out.println(map.toString());
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Sentinels -> 해당 메소드 없음

// SENTINEL SENTINELS <master name> -> Nested Array reply.
protected void sentinelSentinels() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL SENTINELS <master name> -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel getMasterAddrByName

// SENTINEL get-master-addr-by-name <master name> -> return SocketAddress
protected void getMasterAddrByName() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL get-master-addr-by-name <master name> -> return SocketAddress");
	String master = "mymaster";
	try {
		SocketAddress addr = Redis.sentinel.getMasterAddrByName(master);
		System.out.println("SENTINEL getMasterAddrByName mymaster -> "+addr.toString());
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Reset

// SENTINEL RESET  [<master name>] -> Integer reply.
protected void sentinelReset() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL RESET [<master name>] -> return long.");
	String masterName = "mymaster";
	try {
		long ret = Redis.sentinel.reset(masterName);
		System.out.println(ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Failover

// SENTINEL FAILOVER   [<master name>] -> Simple string reply.
protected void sentinelFailover() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL FAILOVER [<master name>] -> return Simple String.");
	String masterName = "mymaster";
	try {
		String ret = Redis.sentinel.failover(masterName);
		System.out.println(ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Ckquorum -> 해당 메소드 없음

// SENTINEL CKQUORUM    [<master name>] -> Bulk string reply.
protected void sentinelCkquorum() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL CKQUORUM <master name> -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Simulate-Failure -> 해당 메소드 없음

// SENTINEL SIMULATE-FAILURE crash-after-election/crash-after-promotion -> Bulk string reply.
protected void sentinelSimulateFailure() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL SIMULATE-FAILURE -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Set

// SENTINEL SET  -> Simple string reply.
protected void sentinelSet() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL SET -> return Simple string.");
	String masterName = "mymaster";
	String param = "down-after-milliseconds";
	String value = "30000";
	try {
		String ret = Redis.sentinel.set(masterName, param, value);
		System.out.println(ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel FlushConfig -> 해당 메소드 없음

// SENTINEL FLUSHCONFIG  -> Simple string reply.
protected void sentinelFlushConfig() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL FLUSHCONFIG  -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Info-Cache -> 해당 메소드 없음

// SENTINEL INFO-CACHE  -> Simple string reply.
protected void sentinelInfoCache() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL INFO-CACHE <master name> -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Pending-Scripts -> 해당 메소드 없음

// SENTINEL PENDING-SCRIPTS  -> 3 Nested Array reply.
protected void sentinelPendingScripts() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL PENDING-SCRIPTS -> No Method.");
	try {
	} catch (Exception e) {
		System.out.println(e);
	}
}

Sentinel Remove

// SENTINEL REMOVE <master name> -> Simple String reply.
protected void sentinelRemove() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL REMOVE <master name> -> return Simple String.");
	String masterName = "mymaster";
	try {
		String ret = Redis.sentinel.remove(masterName);
		System.out.println(ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

<< Connection Pooling	Sentinel	Sentinel Failover >>

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