## 第一步： 引入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 查看当前工作的程序