189 8069 5689
本篇内容主要讲解“Spout的相关知识点有哪些”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Spout的相关知识点有哪些”吧!
创新互联公司主要业务有网站营销策划、网站设计、做网站、微信公众号开发、小程序制作、H5页面制作、程序开发等业务。一次合作终身朋友，是我们奉行的宗旨；我们不仅仅把客户当客户，还把客户视为我们的合作伙伴，在开展业务的过程中，公司还积累了丰富的行业经验、全网整合营销推广资源和合作伙伴关系资源，并逐渐建立起规范的客户服务和保障体系。
在Storm 之中，Spout 和Bolt 都是其Compnent， 所以在Storm之中定义了一个名叫 IComponent
的总接口
Spout
在前面的基本例子中，我们实现了一个RandomSout，来看看其类图
Spout的最顶级的抽象是ISpout接口
有关如下的API
1：oepn 方法是初始化动作： 允许你在该spout 初始化时做一些动作，传入了上写文，也方便娶上下文的一些数据
2 ：close 方法在该Spout 关闭前执行，但是并不能得到保证其一定会执行，spout是作为task 运行，在worker内的，在
clouster 集群之下，我们的 supervisor 会直接kill掉 ，这样它就有可能不会允许， 而在本地的模式之下，只要不是kill -9，如果是发送停止命令，是可以保证close的执行的。
3 : Activate
4 :deactivate
5: nextTuple : nextTuple 用来发送数据
6 ack ( Object ) : Ack 传入的Object其实是一个id. 表示唯一一个tuple
7 fail ( Object )
由于继承了BaseRichSpout， 所以不用实现 close，activate，deactivate，ack，fail
等方法。
结论：
在通常的情况之下，(Shel 和事物型的除外)，实现一个Spout，可以直接的去实现IRichSpout
如果不想写IRIchSpout代码，可以继承自BaseRichSpout
Bolt
ExclaimBasicBolt的类图
Ibolt 继承了java.io.Serializable 我们在nimbus上提交了topology
execute 接受一个tuple进行处理，并在prepare 方法传入的 ACK方法，或者fail方法表示来反馈处理的结果
通常情况之下，他实际上相当于自动做掉prepare方法和collector.emit.ack(inputTupe)
到此，相信大家对“Spout的相关知识点有哪些”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！