Storm学习日记
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了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学习日记的主要内容，如果未能解决你的问题，请参考以下文章