本地模式運行
   本地模式類似storm集群是一個進程，用來編寫和測試topology。在本地模式上運行topology類似在一個集群上運行topology。創建一個本地集群：
   import backtype.storm.LocalCluster;
   LocalCluster cluster = new LocalCluster();
提交集群使用submitTopology，
殺死集群使用killTopology
關閉一個本地集群使用cluster.shutdown();
   本地模式下的公共配置：
   Config.TOPOLOGY_MAX_TASK_PARALLELISM
   Config.TOPOLOGY_DEBUG:

創新互聯公司專注于企業全網營銷推廣、網站重做改版、辰溪網站定制設計、自適應品牌網站建設、H5高端網站建設、商城網站建設、集團公司官網建設、成都外貿網站建設公司、高端網站制作、響應式網頁設計等建站業務，價格優惠性價比高，為辰溪等各大城市提供網站開發制作服務。

---

生產集群運行

一、步驟
1、定義topology，若用java語言，使用TopologyBuilder來定義
2、使用StormSubmitter來提交topology到集群中，所需參數需要topology名字，topology的參數配置，topology本身
例：
Config conf = new Config();
conf.setNumWorkers(20);
conf.setMaxSpoutPending(5000);
StormSubmitter.submitTopology("mytopology", conf, topology);
3、創建jar包使用storm 客戶端命令，jar包包含你的所有的代碼
4、提交topology，為jar包指定參數
storm jar path/to/allmycode.jar org.me.MyTopology arg1 arg2 arg3
實例：

1 public static void main(String[] args) throws Exception {

2 TopologyBuilder builder = new TopologyBuilder();

3 builder.setSpout("random", new RandomWordSpout(), 2);

4 builder.setBolt("transfer", new TransferBolt(), 4).shuffleGrouping("random");

5 builder.setBolt("writer", new WriterBolt(), 4).fieldsGrouping("transfer", new Fields("word"));

6 Config conf = new Config();

7 conf.setNumWorkers(4);// 設置啟動4個Worker

8 conf.setNumAckers(1); // 設置一個ack線程

9 conf.setDebug(true); // 設置打印所有發送的消息及系統消息

10 StormSubmitter.submitTopology("test", conf, builder.createTopology());

11 }

二、公共配置
Config.TOPOLOGY_WORKERS ：設置執行topology的worker的數量
Config.TOPOLOGY_ACKER_EXECUTORS：
Config.TOPOLOGY_MAX_SPOUT_PENDING
Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS:默認是30s
Config.TOPOLOGY_SERIALIZATIONS

三、殺死topology
storm kill stormname

四、更新一個正在運行的topology
 殺死一個正在運行的topology，提交一個新的topology，計劃使用storm swap命令

五、監控topology使用Storm UI或者集群上的工作日志

另外有需要云服務器可以了解下創新互聯scvps.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業上云的綜合解決方案，具有“安全穩定、簡單易用、服務可用性高、性價比高”等特點與優勢，專為企業上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

新聞標題：Storm的2種運行模式-創新互聯
新聞來源：http://www.yijiale78.com/article14/docdde.html

成都網站建設公司_創新互聯，為您提供微信小程序、Google、網站建設、網站設計公司、網站改版、網站內鏈

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯