网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

storm记录--6--Storm的HelloWorld

Storm学习的HelloWorld

创新互联建站专注于企业全网整合营销推广、网站重做改版、龙井网站定制设计、自适应品牌网站建设、H5页面制作商城网站建设、集团公司官网建设、外贸网站建设、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为龙井等各大城市提供网站开发制作服务。

1、下载Storm-start(https://github.com/nathanmarz/storm-starter/archive/master.zip)

2、进入下载目录,对zip文件解压

3、进入解压后的文件目录,修改m2-pom.xml(将twitter4j-core和twitter4j-stream替换为下面的部分)

 

      org.twitter4j

      twitter4j-core

      [2.2,)

   

   

      org.twitter4j

      twitter4j-stream

      [2.2,)

   

4、编译项目。转到项目根目录,使用mvn -f m2-pom.xml package 进行编译

5、复制storm-starter目录下的m2_pom.xml为pom.xml,放在与m2_pom.xml同一目录下

6、打jar包mvn jar:jar

如果还需要对工程代码进行修改可以导入eclipse

使用mvn eclipse:eclipse编译成eclipse工程

eclipse import project

7、提交运行

拷贝jar包到Storm所在机器上

编译无误后,在Storm-starter中target目录下

将storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar,拷贝到指定的目录下面

8、执行命令:

./storm jar /usr/soft/stormrun/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology test

不加test参数时,就会运行local形式,会将所有运行信息打印到控制台上,将会看到storm运行的每一步打印信息。

5186 [Thread-26] INFO  backtype.storm.daemon.executor  - Processing received message source: spout:8, stream: default, id: {}, [four score and seven years ago]
four score and seven years ago-------------------
5194 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [four]
5195 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [score]
5196 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [and]
5197 [Thread-22] INFO  backtype.storm.daemon.executor  - Processing received message source: split:6, stream: default, id: {}, [and]
5198 [Thread-22] INFO  backtype.storm.daemon.task  - Emitting: count default [and, 1]
5198 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [seven]
5199 [Thread-20] INFO  backtype.storm.daemon.executor  - Processing received message source: split:6, stream: default, id: {}, [four]
5200 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [years]
5201 [Thread-18] INFO  backtype.storm.daemon.executor  - Processing received message source: split:6, stream: default, id: {}, [seven]
5201 [Thread-26] INFO  backtype.storm.daemon.task  - Emitting: split default [ago]
5201 [Thread-18] INFO  backtype.storm.daemon.task  - Emitting: count default [seven, 1]
5205 [Thread-20] INFO  backtype.storm.daemon.task  - Emitting: count default [four, 1]
5205 [Thread-20] INFO  backtype.storm.daemon.executor  - Processing received message source: split:6, stream: default, id: {}, [score]
5205 [Thread-20] INFO  backtype.storm.daemon.task  - Emitting: count default [score, 1]

9、查看UI http://ip:8080 (端口号默认为8080,可以修改,一般为9090)


本文标题:storm记录--6--Storm的HelloWorld
网站URL:http://bjjierui.cn/article/jescpo.html

其他资讯