1.storm优点

    2.核心概念

    3.Storm架构

    4.storm工作流程

    编程流程：

    Spout
    那么首先开始编写Spout类。一般是实现 IRichSpout 或继承BaseRichSpout该类，然后实现该方法。
    这里我们继承BaseRichSpout这个类,该类需要实现这几个主要的方法:

    1. 代码示例:

    @Override
    public void open(Map map, TopologyContext arg1, SpoutOutputCollector collector) {
    System.out.println(“open:”+map.get(“test”));
    this.collector = collector;
    }

    1. 二、nextTuple
    2. nextTuple()方法是Spout实现的核心。
    3. 也就是主要执行方法，用于输出信息,通过collector.emit方法发射。
    5. @Override
    6. public void nextTuple() {
    7.     if(count<=2){
    8.         System.out.println("第"+count+"次开始发送数据...");
    9.         this.collector.emit(new Values(message));
    10.     }
    11.     count++;
    12. }
    14. 三、declareOutputFields
    15. declareOutputFields是在IComponent接口中定义，用于声明数据格式。
    16. 即输出的一个Tuple中，包含几个字段
    18. @Override
    19. public void declareOutputFields(OutputFieldsDeclarer declarer) {
    20.     System.out.println("定义格式...");
    21.     declarer.declare(new Fields(field));
    22. }
    25. 四、ack
    26. ack是在ISpout接口中定义，用于表示Tuple处理成功。
    30. 五、fail
    31. fail是在ISpout接口中定义，用于表示Tuple处理失败。
    35. 六、close
    36. close是在ISpout接口中定义，用于表示Topology停止。
    37. 代码示例:
    38. @Override
    39. public void close() {
    40.     System.out.println("关闭...");
    41. }
    44. Bolt
    46. Bolt是用于处理数据的组件，主要是由execute方法来进行实现。
    47. 一般来说需要实现 IRichBolt 或继承BaseRichBolt该类，然后实现其方法。
    48. 需要实现方法如下:
    50. 一、prepare
    51. 在Bolt启动前执行，提供Bolt启动环境配置的入口。
    52. 参数基本和Sqout一样。
    53. 一般对于不可序列化的对象进行实例化。
    54. 这里的我们就简单的打印下
    56. @Override
    57. public void prepare(Map map, TopologyContext arg1, OutputCollector collector) {
    58.     System.out.println("prepare:"+map.get("test"));
    59.     this.collector=collector;
    60. }
    61. 注:如果是可以序列化的对象，那么最好是使用构造函数。
    64. 二、execute
    65. execute()方法是Bolt实现的核心。
    66. 也就是执行方法，每次Bolt从流接收一个订阅的tuple，都会调用这个方法。
    67. 从tuple中获取消息可以使用 tuple.getString()和tuple.getStringByField();这两个方法。
    68. 个人推荐第二种，可以通过field来指定接收的消息。
    69. 注:如果继承的是IRichBolt，则需要手动ack。这里就不用了,BaseRichBolt会自动帮我们应答
    71. 代码示例:
    73. @Override
    74. public void execute(Tuple tuple) {
    75.     //String msg=tuple.getString(0);
    76.     String msg=tuple.getStringByField("test");
    77.     //这里我们就不做消息的处理，只打印
    78.     System.out.println("Bolt第"+count+"接受的消息:"+msg); 
    79.     count++;
    80.     /**
    81.      * 
    82.      * 没次调用处理一个输入的tuple，所有的tuple都必须在一定时间内应答。
    83.      * 可以是ack或者fail。否则，spout就会重发tuple。
    84.      */
    85.     //collector.ack(tuple);
    86. }
    88. 三、declareOutputFields
    90. 和Spout的一样。
    91. 因为到了这里就不再输出了，所以就什么都没写。
    93. @Override
    94. public void declareOutputFields(OutputFieldsDeclarer arg0) {        
    95. }
    98. cleanup
    99. cleanup是IBolt接口中定义,用于释放bolt占用的资源。
    100. Storm在终止一个bolt之前会调用这个方法。
    101. 因为这里没有什么资源需要释放，所以就简单的打印一句就行了。
    102. @Override
    103. public void cleanup() {
    104.     System.out.println("资源释放");
    105. }