一:介绍
1.方面的体现
spout组件
bolt组件
ack机制
二:Spout组件
1.发送Tuple,给每个tuple设置一个msgId(用来标识、追踪)
重载emit()方法。

2.使用内存缓存已经发射过的tuple
首先新建缓存

在open中初始化缓存

保存到缓存

3.ack方法(成功)
如果消息发送成功后的处理

4.fail的处理
在conf(map类型)中设置最大的重发次数,方面后面的进行获取

在spout类中的初始化中获得次数

新建已经重发的次数的内存(在初始化的时候初始化即可)

fail方法

三:测试spout
1.超时时间的设置

2.测试结果

原文:http://www.cnblogs.com/juncaoit/p/6353792.html