首页 > 其他 > 详细

Storm消息可靠机制

时间:2017-01-27 12:52:49      阅读:311      评论:0      收藏:0      [点我收藏+]

一:介绍

1.方面的体现

  spout组件

  bolt组件

  ack机制

 

二:Spout组件

1.发送Tuple,给每个tuple设置一个msgId(用来标识、追踪)

  重载emit()方法。

  技术分享

 

2.使用内存缓存已经发射过的tuple

  首先新建缓存

  技术分享

  在open中初始化缓存

  技术分享

  保存到缓存

  技术分享

 

3.ack方法(成功)

  如果消息发送成功后的处理

  技术分享

 

4.fail的处理

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

  技术分享

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

  技术分享

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

  技术分享

  fail方法

  技术分享

 

三:测试spout

1.超时时间的设置

  技术分享

2.测试结果

  技术分享

 

  

 

Storm消息可靠机制

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!