Jedis Sentinel

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

Sentinel

Jedis Sentinel Commands

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

Sentinel

package application;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

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

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

		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();	});

	}

	// INFO sentinel
	// info 명령으로 master server ip, port를 가져와서 connect해야 한다.
	protected void info() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("INFO sentinel -> return Bulk String");
		try {
			String info = Redis.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 = Redis.sentinel.sentinelMonitor(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 = Redis.sentinel.sentinelMasters();
			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> -> Array reply.
	protected void sentinelMaster() {
		System.out.println("-------------------------------------------------------------------------");
		System.out.println("SENTINEL MASTER <master name> -> No method.");
		try {
		} 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 = Redis.sentinel.sentinelSlaves(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 {
			List<String> addr = Redis.sentinel.sentinelGetMasterAddrByName(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 = Redis.sentinel.sentinelReset(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 = Redis.sentinel.sentinelFailover(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";
		Map<String, String> param = new HashMap<String, String>();
		param.put("down-after-milliseconds", "30000");		
		try {
			String ret = Redis.sentinel.sentinelSet(masterName, param);
			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 = Redis.sentinel.sentinelRemove(masterName);
			System.out.println(ret);
		} catch (Exception e) {
			System.out.println(e);
		}
	}
}

INFO Sentinel

protected void info() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("INFO sentinel -> return Bulk String");
	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.sentinelMonitor(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.sentinelMasters();
		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> -> Array reply.
protected void sentinelMaster() {
	System.out.println("-------------------------------------------------------------------------");
	System.out.println("SENTINEL MASTER <master name> -> No method.");
	try {
	} 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.sentinelSlaves(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 {
		List<String> addr = Redis.sentinel.sentinelGetMasterAddrByName(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.sentinelReset(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.sentinelFailover(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";
	Map<String, String> param = new HashMap<String, String>();
	param.put("down-after-milliseconds", "30000");		
	try {
		String ret = Redis.sentinel.sentinelSet(masterName, param);
		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.sentinelRemove(masterName);
		System.out.println(ret);
	} catch (Exception e) {
		System.out.println(e);
	}
}

<< Pipeline	Sentinel	Cluster >>

조회수 :

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