Storm學(xué)習(xí)的HelloWorld

創(chuàng)新互聯(lián)建站專注于企業(yè)全網(wǎng)整合營(yíng)銷推廣、網(wǎng)站重做改版、龍井網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5頁(yè)面制作、商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為龍井等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

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

2、進(jìn)入下載目錄，對(duì)zip文件解壓

3、進(jìn)入解壓后的文件目錄，修改m2-pom.xml（將twitter4j-core和twitter4j-stream替換為下面的部分）

 <dependency>

      <groupId>org.twitter4j</groupId>

      <artifactId>twitter4j-core</artifactId>

      <version>[2.2,)</version>

    </dependency>

    <dependency>

      <groupId>org.twitter4j</groupId>

      <artifactId>twitter4j-stream</artifactId>

      <version>[2.2,)</version>

    </dependency>

4、編譯項(xiàng)目。轉(zhuǎn)到項(xiàng)目根目錄，使用mvn -f m2-pom.xml package 進(jìn)行編譯

5、復(fù)制storm-starter目錄下的m2_pom.xml為pom.xml，放在與m2_pom.xml同一目錄下

6、打jar包mvn jar:jar

如果還需要對(duì)工程代碼進(jìn)行修改可以導(dǎo)入eclipse

使用mvn eclipse:eclipse編譯成eclipse工程

eclipse import project

7、提交運(yùn)行

拷貝jar包到Storm所在機(jī)器上

編譯無(wú)誤后，在Storm-starter中target目錄下

將storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar，拷貝到指定的目錄下面

8、執(zhí)行命令：

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

不加test參數(shù)時(shí)，就會(huì)運(yùn)行l(wèi)ocal形式，會(huì)將所有運(yùn)行信息打印到控制臺(tái)上，將會(huì)看到storm運(yùn)行的每一步打印信息。

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 (端口號(hào)默認(rèn)為8080，可以修改，一般為9090)

當(dāng)前名稱：storm記錄--6--Storm的HelloWorld
本文URL：http://aaarwkj.com/article30/jescpo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、用戶體驗(yàn)、App開發(fā)、外貿(mào)網(wǎng)站建設(shè)、小程序開發(fā)、商城網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)