void open (java,util.Map conf,TopologyContext context,SpoutOutputCollector collector)
用于实例化Spout的一个运行时任务，被急群众的某一进程调用 (conf对象维护Storm中针对该Spout的配置信息，context是一个上下文对象，可用于获取该组件运行时任务的信息,collector用于从该Spout发送数据项)void close()
用于停止一个Spoutvoid activate()
在Spout从非激活状态转换为激活状态时被调用void deactivate()
在Spout的非激活状态被调用

void ack(java.lang.Object msgId)Storm用于确认该Spout发送的这个数据项已经被完整处理void fail(java.lang.Object msgId)
Storm用于确认该Spout发送的这个数据项已经失败void nextTuple()
当这个方法被调用时，Storm要求Spout发送一个数据项至output collector

(nextTuple是Spout向Topology中发送一个数据项，是Spout需要实现的最重要的方法。在可靠的Spout的一个任务中，nextTuple()、ack()、fail()三个方法的调用在一个单独线程中循环。当不存在数据项需要发送时，nextTuple()将会休眠一小段间隔，确保不会浪费过多的CPU资源）

void declareOutputFields(OutputFieldsDeclarer declarer)
声明指定输出流的数据项结构。(这里指定了输出流的数据项结构(schema)。参数declarer被用来声明输出流(stream)的id,域。java.util.Map  getComponentConfiguration()
获取组件的配置信息

public class WordCount extends BaseRichSpout
{public static Logger log = logger.getLogger(backtype/storm/testing/WordCount);boolean_isDistributed;SpoutOutputCollector_collector;public WordCount(){this(true);}public WordCount(boolean isDistributed){_isDistributed = isDistributed;}public void open(Map conf,TopologyContext context,SpoutOutputCollector collector){_collector = collector;}public void close(){}public void nextTuple(){Utils.sleep(100L);String words[] = {"nathan","mike","jackson","golda","bertels"};public void ack(Object obj){}public void fail(Object obj){}public void declareOutputFields(OutputFieldsDeclarer declarer){declarer.declarer(new Fields(new String[] {"word"}));}public Map getComponentConfiguration(){if(!_isDistributed_){Map ret = new HashMap();ret.put(Config.TOPOLOGY_MAX_TASK_PARALLELISM,Integer.valueOf(1));
}else{return null;}}
}

TopologyBuilder builder = new TopologyBuilder();builder.setSpout("sentenceGenSpout",new WordCount());