JSTORM命令

jps 查看niumbus和supervisor进程

./jstorm list 查看jstorm详细信息

[ducc@saas-billing-server-051 bin]$ ./jstorm list

/opt/jdk1.8.0_162/bin/java

Running: java -client -Xms256m -Xmx256m -Djstorm.home=/app/bss30_bill/tools/env/10.1.0/jstorm -Dstorm.options= -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.root.logger=INFO,stdout -Dlogback.configurationFile=/app/bss30_bill/tools/env/10.1.0/jstorm/conf/client_logback.xml -Dlog4j.configuration=File:/app/bss30_bill/tools/env/10.1.0/jstorm/conf/client_log4j.properties -cp /app/bss30_bill/tools/env/10.1.0/jstorm/conf:/app/bss30_bill/tools/env/10.1.0/jstorm/bin::/app/bss30_bill/tools/env/10.1.0/jstorm/jstorm-core-2.1.1_1.5.3.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/asm-4.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/carbonite-1.4.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/chill-java-0.3.5.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/clojure-1.6.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-cli-1.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-codec-1.6.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-exec-1.1.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-io-2.4.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-lang-2.5.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-lang3-3.4.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/commons-logging-1.1.3.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-api-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-client-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-common-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-remoting-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-srvutil-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/ctg-mq-tools-2.3.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/curator-client-2.5.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/curator-framework-2.5.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/curator-recipes-2.5.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/dcf-client-1.5.3.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/disruptor-3.3.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/fastjson-1.2.40.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/gson-2.3.1.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/guava-16.0.1.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/guava-19.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/httpclient-4.3.3.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/httpcore-4.3.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/jgrapht-core-0.9.0.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/jline-0.9.94.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/json-simple-1.1.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/kryo-2.21.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/libthrift-0.9.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/log4j-over-slf4j-1.6.6.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/logback-classic-1.0.13.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/logback-core-1.0.13.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/metrics-core-3.1.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/metrics-healthchecks-3.1.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/metrics-jvm-3.1.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/netty-3.9.0.Final.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/netty-all-4.0.23.Final.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/netty-tcnative-1.1.33.Fork22.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/objenesis-1.2.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/queue-1.0-SNAPSHOT.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/reflectasm-1.07-shaded.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/rocketmq-client-3.2.6.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/rocketmq-common-3.2.6.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/rocketmq-remoting-3.2.6.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/rocksdbjni-3.10.1.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/servlet-api-2.5.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/slf4j-api-1.7.5.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/slf4j-api-1.7.7.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/snakeyaml-1.11.jar:/app/bss30_bill/tools/env/10.1.0/jstorm/lib/zookeeper-3.4.6.jar backtype.storm.command.list

181 [main] INFO com.alibaba.jstorm.utils.LoadConf - Using defaults.yaml from resources

263 [main] INFO com.alibaba.jstorm.utils.LoadConf - Using storm.yaml from resources

269 [main] INFO com.alibaba.jstorm.utils.LoadConf - Using defaults.yaml from resources

276 [main] INFO com.alibaba.jstorm.utils.LoadConf - Using storm.yaml from resources

289 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry - The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [20]

1438 [main] INFO backtype.storm.security.auth.ThriftClient - masterHost:135.72.42.93:8629

1446 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry - The baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5]

Successfully get cluster info

{

"nimbus": {

"nimbusMaster": {

"host": "135.72.42.93:8629",

"uptimeSecs": "7076"

},

"nimbusSlaves": [

{

"host": "135.72.42.34:8629",

"uptimeSecs": "6994"

},

{

"host": "135.72.42.33:8629",

"uptimeSecs": "6994"

}

],

"supervisorNum": 5,

"totalPortNum": 320,

"usedPortNum": 0,

"freePortNum": 320,

"version": "2.1.1",

"__isset_bitfield": 15

},

"supervisors": [

{

"host": "135.72.42.33",

"supervisorId": "ef2d21dc-58c6-4d1c-ba7e-7a5bca128812",

"uptimeSecs": 6960,

"numWorkers": 64,

"numUsedWorkers": 0,

"__isset_bitfield": 7

},

{

"host": "135.72.42.34",

"supervisorId": "cbc35f16-7c67-4bc3-bf12-fb6712290fa6",

"uptimeSecs": 6960,

"numWorkers": 64,

"numUsedWorkers": 0,

"__isset_bitfield": 7

},

{

"host": "135.72.42.93",

"supervisorId": "c2cd60e1-9c39-45ff-a3a0-df028607fc5c",

"uptimeSecs": 6960,

"numWorkers": 64,

"numUsedWorkers": 0,

"__isset_bitfield": 7

},

{

"host": "135.72.42.94",

"supervisorId": "526eff59-d9b0-4e82-ada0-eb9cc47b8306",

"uptimeSecs": 6960,

"numWorkers": 64,

"numUsedWorkers": 0,

"__isset_bitfield": 7

},

{

"host": "135.72.42.95",

"supervisorId": "3fb55a6e-9d58-4acb-98eb-0e4b38264e86",

"uptimeSecs": 6960,

"numWorkers": 64,

"numUsedWorkers": 0,

"__isset_bitfield": 7

}

],

"topologies": []

}

 

单独启动bolt，查看错误信息:

./cstorm reqblot topologySm_999(图名）

end

！！！必须要输入end才执行。

 

后台杀掉top图。

./jstorm kill topologySm_999

 

jstorm数据存放目录：

/app/bss30_bill/tools/env/10.1.0/jstorm/data

 

查看图的日志：

cd /app/bss30_bill/tools/env/10.1.0/jstorm/logs/topologySm_999-2.4.0.0

more topologySm_999-2.4.0.0-worker-9857.log

 

查看框架日志：

cd /app/bss30_bill/tools/env/10.1.0/jstorm/logs

more nimbus.log

more supervisor.log