Storm

Nimbus

Spout A 

Storm集群的组件

Supervisor

 public  void setCofig(){        //配置        Config config = new Config();        config.setNumWorkers(2);        TopologyBuilder topologyBuilder = new TopologyBuilder();       topologyBuilder.setSpout(\"wordReader\

Excutor

Worker

Bolt B

task

SpoutA 

worldCount

Spout C

并发度

wordReader

WordSplit

线程数

2

6

任务数

4

Streams 抽象

Spout D 

SpoutB 

 Zookeeper

并发度：2+2+6=10最大并发度：4+2+6=12