## 第一步： 引入jar <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-core</artifactId> <version>1.2.1</version> <scope>provided</scope> </dependency> ## 第二步：如何編寫組件 首先編寫我們的數據源：spout，可以有兩種方式 繼承 BaseRichSpout類 實現IRichSpout接口 要幾個方法進行重寫或實現、open，nextTuple，declareOutputFields 繼續編寫我們數據處理類：Bolt可以使用兩種方式 繼承BaseBasicBolt類 實現IRichBolt接口 重點需要幾個方法進行重寫或實現 execute、declareOutputFlelds 最后我們編寫主函數（Topolopy）去進行提交一個任務 在使用Topolopy的時候。Storm框架為我們提供兩種模式 本地模式和集群模式 本地模式：（無需Storm集群，直接在java中即可運行，一般用于測試和開發階段） 執行運行main函數即可 集群模式：需要Storm集群，把實現的java程序打包，然后Topolopy進行提交 需要把應用打成jar，使用storm命令把Topology提交到集群中去。 ## 三、storm打成jar包如何啟動 storm jar storm01.jar 指定入口地址 storm list 查看當前工作的程序