| | |
| | | } |
| | | |
| | | //启动服务 |
| | | func StartServer(binPath string, ip string) bool { |
| | | resultMsg := CMDSC("sh " + binPath + "/elasticsearch -d") |
| | | func StartServer(binPath string, ip string, port string) bool { |
| | | resultMsg := CMDSC("sh " + binPath + "/es_start.sh") |
| | | if resultMsg == "运行失败" { |
| | | return false |
| | | } |
| | | bool := VerifyNodeServer(ip, "9200") |
| | | return bool |
| | | b := VerifyNodeServer(ip, port) |
| | | return b |
| | | } |
| | | |
| | | //关闭服务 |
| | | func StopServer(pidPath string, ip string, port string) bool { |
| | | bool := VerifyShortNodeServer(ip, port) |
| | | if bool == true { |
| | | resultMsg := CMDSC("kill `cat " + pidPath + "pid`") |
| | | func StopServer(binPath string, ip string, port string) bool { |
| | | b := VerifyShortNodeServer(ip, port) |
| | | if b == true { |
| | | resultMsg := CMDSC("sh " + binPath + "/es_stop.sh") |
| | | if resultMsg == "运行失败" { |
| | | return false |
| | | } |
| | | } |
| | | return true |
| | | return b |
| | | } |
| | | |
| | | //更换节点角色 |