storm ISpout

ISpout定义了 7个方法：

1、 open(Map conf, TopologyContext context, SpoutOutputCollector collector);

初始化时被调用，提供spout运行环境

@param conf 对spout的配置

@param context 可以获得任务的信息，如task id,component id输入输出信息等

@param collector 可以发送tuple。Tuples 可以在任何时间被发送，包括 open 和 close 方法，collector 是线程安全的并且会保存    这个spout对象的实例

2、close();

Spout被shutdown时调用，不能保证一定被调用，因为可能会 kill -9 这个worker。

3、activate();

当spout 从未激活状态激活时调用，接下来会调用nextTuple方法。被激活后的 spout 也可以使之失效

4、deactivate();

spout 失效时被调用

5、nextTuple();

当storm 需要 spout 发射 tuple时调用。 方法非阻塞，因此当没有tuple要发射时，方法会直接返回。

而spout任务，又会循环调用 nextTuple, ack, 及 fail 方法，所以为了不浪费CUP，当没有tuple发射时，

尽量让nextTupe停一小会(比如一毫秒)

6、ack(Object msgId);

当 tuple 完全处理结束调用。 典型的应用就是，把消息从队列删除，避免重播

7、
fail(Object msgId);

当 tuple 处理失败时调用，典型应用就是把消息再放回队列稍后重播