Apache Storm - Cài đặt

Bây giờ chúng ta hãy xem cách cài đặt Apache Storm framework trên máy tính của bạn. Có ba bước chính ở đây -

Cài đặt Java trên hệ thống của bạn, nếu bạn chưa có.
Cài đặt khung công tác ZooKeeper.
Cài đặt khung Apache Storm.

Bước 1 - Xác minh cài đặt Java

Sử dụng lệnh sau để kiểm tra xem bạn đã cài đặt Java trên hệ thống của mình chưa.

$ java -version

Nếu Java đã có, thì bạn sẽ thấy số phiên bản của nó. Nếu không, hãy tải xuống phiên bản mới nhất của JDK.

Bước 1.1 - Tải xuống JDK

Tải xuống phiên bản JDK mới nhất bằng cách sử dụng liên kết sau - www.oracle.com

Phiên bản mới nhất là JDK 8u 60 và tệp là “jdk-8u60-linux-x64.tar.gz”. Tải xuống tệp trên máy của bạn.

Bước 1.2 - Giải nén tệp

Nói chung các tệp đang được tải xuống downloadsthư mục. Giải nén thiết lập tar bằng các lệnh sau.

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

Bước 1.3 - Di chuyển đến thư mục opt

Để cung cấp Java cho tất cả người dùng, hãy di chuyển nội dung java đã giải nén vào thư mục “/ usr / local / java”.

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

Bước 1.4 - Đặt đường dẫn

Để đặt đường dẫn và các biến JAVA_HOME, hãy thêm các lệnh sau vào tệp ~ / .bashrc.

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

Bây giờ áp dụng tất cả các thay đổi cho hệ thống đang chạy hiện tại.

$ source ~/.bashrc

Bước 1.5 - Các lựa chọn thay thế Java

Sử dụng lệnh sau để thay đổi các lựa chọn thay thế Java.

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

Bước 1.6

Bây giờ hãy xác minh cài đặt Java bằng lệnh xác minh (java -version) được giải thích trong Bước 1.

Bước 2 - Cài đặt ZooKeeper Framework

Bước 2.1 - Tải xuống ZooKeeper

Để cài đặt ZooKeeper framework trên máy của bạn, hãy truy cập liên kết sau và tải xuống phiên bản ZooKeeper mới nhất http://zookeeper.apache.org/releases.html

Hiện tại, phiên bản mới nhất của ZooKeeper là 3.4.6 (ZooKeeper-3.4.6.tar.gz).

Bước 2.2 - Giải nén tệp tar

Giải nén tệp tar bằng các lệnh sau:

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

Bước 2.3 - Tạo tệp cấu hình

Mở tệp cấu hình có tên “conf / zoo.cfg” bằng lệnh "vi conf / zoo.cfg" và đặt tất cả các tham số sau làm điểm bắt đầu.

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

Khi tệp cấu hình đã được lưu thành công, bạn có thể khởi động máy chủ ZooKeeper.

Bước 2.4 - Khởi động Máy chủ ZooKeeper

Sử dụng lệnh sau để khởi động máy chủ ZooKeeper.

$ bin/zkServer.sh start

Sau khi thực hiện lệnh này, bạn sẽ nhận được phản hồi như sau:

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

Bước 2.5 - Khởi động CLI

Sử dụng lệnh sau để khởi động CLI.

$ bin/zkCli.sh

Sau khi thực hiện lệnh trên, bạn sẽ được kết nối với máy chủ ZooKeeper và nhận được phản hồi sau.

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

Bước 2.6 - Dừng máy chủ ZooKeeper

Sau khi kết nối máy chủ và thực hiện tất cả các thao tác, bạn có thể dừng máy chủ ZooKeeper bằng cách sử dụng lệnh sau.

bin/zkServer.sh stop

Bạn đã cài đặt thành công Java và ZooKeeper trên máy của mình. Bây giờ chúng ta hãy xem các bước để cài đặt Apache Storm framework.

Bước 3 - Cài đặt Apache Storm Framework

Bước 3.1 Tải xuống Storm

Để cài đặt Storm framework trên máy của bạn, hãy truy cập vào liên kết sau và tải xuống phiên bản Storm mới nhất http://storm.apache.org/downloads.html

Hiện tại, phiên bản mới nhất của Storm là “apache-Storm-0.9.5.tar.gz”.

Bước 3.2 - Giải nén tệp tar

Giải nén tệp tar bằng các lệnh sau:

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

Bước 3.3 - Mở tệp cấu hình

Bản phát hành hiện tại của Storm chứa một tệp tại “conf / Storm.yaml” định cấu hình các daemon Storm. Thêm thông tin sau vào tệp đó.

$ 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

Sau khi áp dụng tất cả các thay đổi, hãy lưu và quay lại thiết bị đầu cuối.

Bước 3.4 - Khởi động Nimbus

$ bin/storm nimbus

Bước 3.5 - Khởi động Trình giám sát

$ bin/storm supervisor

Bước 3.6 Khởi động giao diện người dùng

$ bin/storm ui

Sau khi khởi động ứng dụng giao diện người dùng Storm, hãy nhập URL http://localhost:8080trong trình duyệt yêu thích của bạn và bạn có thể thấy thông tin cụm Storm và cấu trúc liên kết đang chạy của nó. Trang sẽ trông giống như ảnh chụp màn hình sau đây.