Apache Storm - การติดตั้ง

ตอนนี้ให้เราดูวิธีการติดตั้ง Apache Storm framework บนเครื่องของคุณ มีบันไดสามขั้นที่นี่ -

  • ติดตั้ง Java บนระบบของคุณหากคุณยังไม่มี
  • ติดตั้ง ZooKeeper framework
  • ติดตั้ง Apache Storm framework

ขั้นตอนที่ 1 - ตรวจสอบการติดตั้ง Java

ใช้คำสั่งต่อไปนี้เพื่อตรวจสอบว่าคุณได้ติดตั้ง Java บนระบบของคุณแล้วหรือไม่

$ java -version

หากมี Java อยู่แล้วคุณจะเห็นหมายเลขเวอร์ชัน มิฉะนั้นให้ดาวน์โหลด JDK เวอร์ชันล่าสุด

ขั้นตอนที่ 1.1 - ดาวน์โหลด JDK

ดาวน์โหลด JDK เวอร์ชันล่าสุดโดยใช้ลิงค์ต่อไปนี้ - www.oracle.com

เวอร์ชันล่าสุดคือ JDK 8u 60 และไฟล์คือ “jdk-8u60-linux-x64.tar.gz”. ดาวน์โหลดไฟล์บนเครื่องของคุณ

ขั้นตอนที่ 1.2 - แตกไฟล์

โดยทั่วไปไฟล์จะถูกดาวน์โหลดลงในไฟล์ downloadsโฟลเดอร์ แยกการตั้งค่า tar โดยใช้คำสั่งต่อไปนี้

$ cd /go/to/download/path
$ tar -zxf jdk-8u60-linux-x64.gz

ขั้นตอนที่ 1.3 - ย้ายไปที่ไดเรกทอรีที่เลือก

ในการทำให้ Java พร้อมใช้งานสำหรับผู้ใช้ทั้งหมดให้ย้ายเนื้อหา java ที่แยกแล้วไปยังโฟลเดอร์“ / usr / local / java”

$ su
password: (type password of root user)
$ mkdir /opt/jdk
$ mv jdk-1.8.0_60 /opt/jdk/

ขั้นตอนที่ 1.4 - กำหนดเส้นทาง

ในการกำหนดเส้นทางและตัวแปร JAVA_HOME ให้เพิ่มคำสั่งต่อไปนี้ในไฟล์ ~ / .bashrc

export JAVA_HOME =/usr/jdk/jdk-1.8.0_60
export PATH=$PATH:$JAVA_HOME/bin

ตอนนี้ใช้การเปลี่ยนแปลงทั้งหมดในระบบที่กำลังทำงานอยู่

$ source ~/.bashrc

ขั้นตอนที่ 1.5 - ทางเลือก Java

ใช้คำสั่งต่อไปนี้เพื่อเปลี่ยนทางเลือกของ Java

update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100

ขั้นตอนที่ 1.6

ตอนนี้ตรวจสอบการติดตั้ง Java โดยใช้คำสั่งตรวจสอบ (java -version) อธิบายไว้ในขั้นตอนที่ 1

ขั้นตอนที่ 2 - การติดตั้ง ZooKeeper Framework

ขั้นตอนที่ 2.1 - ดาวน์โหลด ZooKeeper

ในการติดตั้ง ZooKeeper framework บนเครื่องของคุณให้ไปที่ลิงค์ต่อไปนี้และดาวน์โหลด ZooKeeper เวอร์ชันล่าสุด http://zookeeper.apache.org/releases.html

ณ ตอนนี้ ZooKeeper เวอร์ชันล่าสุดคือ 3.4.6 (ZooKeeper-3.4.6.tar.gz)

ขั้นตอนที่ 2.2 - แตกไฟล์ tar

แตกไฟล์ tar โดยใช้คำสั่งต่อไปนี้ -

$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data

ขั้นตอนที่ 2.3 - สร้างไฟล์กำหนดค่า

เปิดไฟล์คอนฟิกูเรชันชื่อ“ conf / zoo.cfg” โดยใช้คำสั่ง "vi conf / zoo.cfg" และตั้งค่าพารามิเตอร์ต่อไปนี้ทั้งหมดเป็นจุดเริ่มต้น

$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2

เมื่อบันทึกไฟล์การกำหนดค่าเรียบร้อยแล้วคุณสามารถเริ่มเซิร์ฟเวอร์ ZooKeeper ได้

ขั้นตอนที่ 2.4 - เริ่มเซิร์ฟเวอร์ ZooKeeper

ใช้คำสั่งต่อไปนี้เพื่อเริ่มเซิร์ฟเวอร์ ZooKeeper

$ bin/zkServer.sh start

หลังจากดำเนินการคำสั่งนี้คุณจะได้รับคำตอบดังนี้ -

$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED

ขั้นตอนที่ 2.5 - เริ่ม CLI

ใช้คำสั่งต่อไปนี้เพื่อเริ่ม CLI

$ bin/zkCli.sh

หลังจากดำเนินการคำสั่งข้างต้นคุณจะเชื่อมต่อกับเซิร์ฟเวอร์ ZooKeeper และรับคำตอบต่อไปนี้

Connecting to localhost:2181
................
................
................
Welcome to ZooKeeper!
................
................
WATCHER::
WatchedEvent state:SyncConnected type: None path:null
[zk: localhost:2181(CONNECTED) 0]

ขั้นตอนที่ 2.6 - หยุดเซิร์ฟเวอร์ ZooKeeper

หลังจากเชื่อมต่อเซิร์ฟเวอร์และดำเนินการทั้งหมดแล้วคุณสามารถหยุดเซิร์ฟเวอร์ ZooKeeper ได้โดยใช้คำสั่งต่อไปนี้

bin/zkServer.sh stop

คุณติดตั้ง Java และ ZooKeeper บนเครื่องของคุณสำเร็จแล้ว ให้เราดูขั้นตอนในการติดตั้ง Apache Storm framework

ขั้นตอนที่ 3 - การติดตั้ง Apache Storm Framework

ขั้นตอนที่ 3.1 ดาวน์โหลด Storm

ในการติดตั้ง Storm framework บนเครื่องของคุณให้ไปที่ลิงค์ต่อไปนี้และดาวน์โหลด Storm เวอร์ชันล่าสุด http://storm.apache.org/downloads.html

ณ ตอนนี้ Storm เวอร์ชันล่าสุดคือ“ apache-storm-0.9.5.tar.gz”

ขั้นตอนที่ 3.2 - แตกไฟล์ tar

แตกไฟล์ tar โดยใช้คำสั่งต่อไปนี้ -

$ cd opt/
$ tar -zxf apache-storm-0.9.5.tar.gz
$ cd apache-storm-0.9.5
$ mkdir data

ขั้นตอนที่ 3.3 - เปิดไฟล์กำหนดค่า

Storm รุ่นปัจจุบันมีไฟล์ที่“ conf / storm.yaml” ที่กำหนดค่า Storm daemons เพิ่มข้อมูลต่อไปนี้ลงในไฟล์นั้น

$ vi conf/storm.yaml
storm.zookeeper.servers:
 - "localhost"
storm.local.dir: “/path/to/storm/data(any path)”
nimbus.host: "localhost"
supervisor.slots.ports:
 - 6700
 - 6701
 - 6702
 - 6703

หลังจากใช้การเปลี่ยนแปลงทั้งหมดแล้วให้บันทึกและกลับไปที่เทอร์มินัล

ขั้นตอนที่ 3.4 - เริ่ม Nimbus

$ bin/storm nimbus

ขั้นตอนที่ 3.5 - เริ่มหัวหน้างาน

$ bin/storm supervisor

ขั้นตอนที่ 3.6 เริ่ม UI

$ bin/storm ui

หลังจากเริ่มแอปพลิเคชันส่วนต่อประสานผู้ใช้ Storm ให้พิมพ์ URL http://localhost:8080ในเบราว์เซอร์ที่คุณชื่นชอบและคุณจะเห็นข้อมูลคลัสเตอร์ Storm และโทโพโลยีที่ทำงานอยู่ หน้าควรมีลักษณะคล้ายกับภาพหน้าจอต่อไปนี้