java - 如何在java中检查storm的状态？

Question

现在我已经在我的本地机器上配置了 Storm 集群。现在我知道在启动storm之前你必须先启动nimbus，然后是supervisor，最后通过storm命令启动ui。

现在我正在编写一个 Java 程序，我想检查我的 Storm 集群的状态，它是否正在工作。

喜欢:

if(stormWorking()){
//do this
}
else{
//do this
}

现在如何检查我的 Storm 集群是否成功运行？

Answer 1

您可以使用 monit[1] 守护进程原理并检查 .pid 文件。只需检查每个 Storm 进程是否需要正常工作:

cat /etc/monit.d/storm

check process storm-nimbus with pidfile /var/run/storm/storm-nimbus.pid
start program = "/sbin/service storm-nimbus start"
stop program = "/sbin/service storm-nimbus stop"

check process storm-supervisor with pidfile /var/run/storm/storm-supervisor.pid
start program = "/sbin/service storm-supervisor start"
stop program = "/sbin/service storm-supervisor stop"

check process storm-ui with pidfile /var/run/storm/storm-ui.pid
start program = "/sbin/service storm-ui start"
stop program = "/sbin/service storm-ui stop"

check process storm-logviewer with pidfile /var/run/storm/storm-logviewer.pid
start program = "/sbin/service storm-logviewer start"
stop program = "/sbin/service storm-logviewer stop"

[1] Monit 是一个用于管理和监控 Unix 系统的小型开源实用程序 http://mmonit.com/monit/