addmasternodeを追加
trunk/src/okuyama/imdst/client/UtilClient.java (diff)| @@ -100,6 +100,16 @@ | ||
| 100 | 100 | } |
| 101 | 101 | addDataNode(args[1], addNodeList); |
| 102 | 102 | } |
| 103 | + | |
| 104 | + if (args[0].equals("addmasternode")) { | |
| 105 | + if (args.length < 3) { | |
| 106 | + System.out.println("Argument Error! args[0]=Command, args[1]=MasterNodeIp:Port, args[2]=AddMasterNodeIP:Port"); | |
| 107 | + System.exit(1); | |
| 108 | + } | |
| 109 | + | |
| 110 | + addMasterNode(args[1], args[2]); | |
| 111 | + } | |
| 112 | + | |
| 103 | 113 | } |
| 104 | 114 | |
| 105 | 115 |
| @@ -292,4 +302,37 @@ | ||
| 292 | 302 | } |
| 293 | 303 | } |
| 294 | 304 | |
| 305 | + | |
| 306 | + public static void addMasterNode(String masterNodeIpPort, String addNode) { | |
| 307 | + OkuyamaClient client = null; | |
| 308 | + | |
| 309 | + try { | |
| 310 | + client = new OkuyamaClient(); | |
| 311 | + client.setConnectionInfos(masterNodeIpPort.split(",")); | |
| 312 | + client.autoConnect(); | |
| 313 | + | |
| 314 | + | |
| 315 | + String[] masterNodeRet = client.getValue(ImdstDefine.ConfigSaveNodePrefix + ImdstDefine.Prop_AllMasterNodeInfo); | |
| 316 | + | |
| 317 | + if (masterNodeRet[0].equals("true")) { | |
| 318 | + String updateMasterNodeInfo = masterNodeRet[1] + "," + addNode; | |
| 319 | + if(client.setValue(ImdstDefine.ConfigSaveNodePrefix + ImdstDefine.Prop_AllMasterNodeInfo, updateMasterNodeInfo)) { | |
| 320 | + System.out.println("MasterNode add success"); | |
| 321 | + } else { | |
| 322 | + System.out.println("MasterNode add error"); | |
| 323 | + } | |
| 324 | + } else { | |
| 325 | + System.out.println("MasterNode add error"); | |
| 326 | + } | |
| 327 | + | |
| 328 | + } catch (Exception e) { | |
| 329 | + e.printStackTrace(); | |
| 330 | + } finally { | |
| 331 | + try { | |
| 332 | + if (client != null) client.close(); | |
| 333 | + } catch (Exception e2) { | |
| 334 | + } | |
| 335 | + } | |
| 336 | + } | |
| 337 | + | |
| 295 | 338 | } |
Fork