资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划,从策略到执行的一站式服务

storm记录--6--Storm的HelloWorld-创新互联

Storm学习的HelloWorld

成都创新互联为企业级客户提高一站式互联网+设计服务,主要包括网站制作、成都网站制作、重庆APP开发小程序制作、宣传片制作、LOGO设计等,帮助客户快速提升营销能力和企业形象,创新互联各部门都有经验丰富的经验,可以确保每一个作品的质量和创作周期,同时每年都有很多新员工加入,为我们带来大量新的创意。 

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)

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


本文标题:storm记录--6--Storm的HelloWorld-创新互联
网页URL:http://cdkjz.cn/article/djgdgi.html
多年建站经验

多一份参考,总有益处

联系快上网,免费获得专属《策划方案》及报价

咨询相关问题或预约面谈,可以通过以下方式与我们联系

大客户专线   成都:13518219792   座机:028-86922220