日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Storm教程2安装部署

發布時間:2023/11/30 编程问答 25 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Storm教程2安装部署 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.


Storm 安裝部署

部署Storm集群需要依次完成的安裝步驟:
? ? ? ? 1.安裝jdk6及以上版本;
  2. 搭建Zookeeper集群;
  3. 安裝Storm依賴庫;
  4. 下載并解壓Storm發布版本;
  5. 修改storm.yaml配置文件;
  6. 啟動Storm各個后臺進程。

——————————————————————————————————————


Storm包的安裝配置

需要在Nimbus和Supervisor機器上安裝Storm發行版本。
1. 下載Storm發行版本:
wget https://github.com/downloads/nathanmarz/storm/storm-0.9.2.zip?
2. 解壓到安裝目錄下:
unzip storm-0.9.2.zip?
修改storm.yaml配置文件conf/storm.yaml
conf/storm.yaml中的配置選項將覆蓋defaults.yaml中的默認配置。


1) storm.zookeeper.servers: Storm集群使用的Zookeeper集群地址,其格式如下:
storm.zookeeper.servers:?
- “111.222.333.444″?
- “555.666.777.888″?
如果Zookeeper集群使用的不是默認端口,那么還需要storm.zookeeper.port選項。
2) storm.local.dir: Nimbus和Supervisor進程用于存儲少量狀態,如jars、confs等的本地磁盤目錄,需要提前創建該目錄并給以足夠的訪問權限。然后在storm.yaml中配置該目錄,如:
storm.local.dir: "/home/admin/storm/workdir"?


注意事項:
啟動Storm后臺進程時,需要對conf/storm.yaml配置文件中設置的storm.local.dir目錄具有寫權限。
storm后臺進程被啟動后,將在Storm安裝部署目錄下的logs/子目錄下生成各個進程的日志文件。
經測試,Storm UI必須和Storm Nimbus部署在同一臺機器上,否則UI無法正常工作,因為UI進程會檢查本機是否存在Nimbus鏈接。
為了方便使用,可以將bin/storm加入到系統環境變量中。
至此,Storm集群已經部署、配置完畢,可以向集群提交拓撲運行了。

——————————————————————————————————————


Storm 相關配置項

storm.zookeeper.root
Storm在zookeeper集群中的根目錄,默認是“/”

topology.workers
每個Topology運行時的worker的默認數目,若在代碼中設置,則此選項值被覆蓋

storm.zookeeper.servers
zookeeper集群的節點列表

storm.local.dir
Storm用于存儲jar包和臨時文件的本地存儲目錄

ui.port ??
Storm集群的UI地址端口號,默認是8080

nimbus.host:
Nimbus節點的host

supervisor.slots.ports
Supervisor節點的worker占位槽,集群中的所有Topology公用這些槽位數,即使提交時設置了較大數值的槽位數,系統也會按照當前集群中實際剩余的槽位數來進行分配,當所有的槽位數都分配完時,新提交的Topology只能等待,系統會一直監測是否有空余的槽位空出來,如果有,就再次給新提交的Topology分配。

——————————————————————————————————————


Storm 常用命令

1、啟動nimbus后臺程序 命令格式:storm nimbus

2、啟動supervisor后臺程序 命令格式:storm supervisor

3、啟動ui服務 命令格式:storm ui

4、提交Topologies

命令格式:storm jar 【jar路徑】 【拓撲包名.拓撲類名】【stormIP地址】【storm端口】【拓撲名稱】【參數】

eg: storm jar /home/storm/storm-starter.jar storm.starter.WordCountTopology wordcountTop;

#提交storm-starter.jar到遠程集群,并啟動wordcountTop拓撲。

5、停止Topologies

查看當前運行的topo: storm list

命令格式:storm kill 【拓撲名稱】

樣例:storm kill wordcountTop #殺掉wordcountTop拓撲。



總結

以上是生活随笔為你收集整理的Storm教程2安装部署的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。