文章來源：http://www.cnblogs.com/chengxin1982/p/4001275.html

本地模式下， 基本併發度控制

conf.setMaxTaskParallelism(5);   本地模式下一個元件能夠執行的最大執行緒數

builder.setSpout("spout", new RandomSentenceSpout(), 10);  最後的引數parallelism_hint 表示executor的數目

builder.setSpout("spout", new RandomSentenceSpout(), 5).setNumTasks(2);  ，task的數目，預設和executor是1：1 的關係,就是每個task執行在一個物理執行緒上，

在這裡設定的是taskNum為2，executor 是5，表示RandomSentenceSpout建立2次，實際只有兩個2個executor,  executor不能超過NumTask

builder.setSpout("spout", new RandomSentenceSpout(), 2).setNumTasks(5);   

在這裡設定的是taskNum為5，executor 是2， 表示RandomSentenceSpout建立5次，2個executor在兩個物理執行緒上執行,  每個executor執行1/2的任務

這麼寫感覺意義都不大， 只是個人為了理解storm executor task概念, 在0.8以後，幾個executor有可能是共用一個物理執行緒，由上面測試能看出。

突然想起這個其實還是有好處的，因為在storm中 TaskNum是靜態的， executor是動態的， 比如tasknum是5，exector是2，這時候是在兩個物理執行緒執行， 如果我們將executor改成3,  這時會變成在3個物理執行緒上執行，提高了併發性. 物理執行緒公式應該Min(executor, tasknum),  這個未在任何文件上見過，個人的一個推斷.

動態調整引數

# Reconfigure the topology "mytopology" to use 5 worker processes,
# the spout "blue-spout" to use 3 executors and
# the bolt "yellow-bolt" to use 10 executors.

$ storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10

builder.setBolt("split", new SplitSentence(), 8).setNumTasks(1).shuffleGrouping("spout"); 這裡和上面一樣，會負載均衡地放入一個執行緒中執行

conf.setDebug(true);                         // 
conf.setMaxSpoutPending(2);          //  這個設定一個spout task上面最多有多少個沒有處理(ack/fail)的tuple，防止tuple佇列過大, 只對可靠任務起作用
conf.setMessageTimeoutSecs(1);    //  訊息處理延時, 就是訊息超過延時後， emit發射源會認為是fail , storm預設是30秒，如果實現的為Irichbolt介面，沒有ack和ack延時都會觸發，這個時間過短的話，如果自定義重發，bolt可能會多處理，tuple在發射過程中， 但是還沒有到達bolt, 但是已經延時了，emit發射源會認為已經失敗了，但是bolt還是收到這個tuple, 所以storm引入了事務拓撲，0.8以後叫trident. 如果實現的為IBaseBolt，則只會在延時情況下觸發， 預設會呼叫ack，但是這個ack如果有再次發射， 這個ack就會自動錨定了.

根據具體業務需求選擇合適的Bolt
conf.setNumAckers(2);                     //  訊息處理的acker數量.預設1，可以根據實際處理情況調大

真實環境

conf.setNumWorkers(5); // 設定工作程序 ,  如果不新增埠， 預設會是4個worker程序

需要在storm.yaml下新增埠

supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
- 6704

每個worker使用一個埠. 

 在uI視窗是spout bolt acker幾個的累加.

storm.yaml引數參考  

storm內預設引數