Storm学习日记

标签：

刚开始接触Storm，总体来说是一个订阅发布的功能，中间件

主要由3部分组成，spout bolt topology

1.spout 消息源

有两种实现方式，继承BaseRichSpout类和实现IRichSpout接口

主要用来接收消息，并发射给bolt

有以下几个方法:

1.1 open:初始化参数

1.2 nextTuple :重要方法！！消息接收，发射数据等

1.3 declareOutputFields:简单模式下无卵用，分段模式下据说挺重要，尚未实践，声明输出字段的方法

1.4 ack 传入一个object,主要是id,用来表示唯一的tuple,实现消息保障机制

2.bolt 处理单元

有两种实现方式，继承BaseBasicBolt类和实现IRichBolt接口

主要用来对消息进行处理后再发射

有以下几个方法:

2.1execute:（重要方法+1！！！！）接收一个tuple并执行逻辑处理，发射出去

2.2 declareOutputFields：字段声明

Storm学习日记

标签：

原文地址：http://www.cnblogs.com/pancy/p/5167100.html