本文主要是介绍dolphinscheduler集群部署教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
文章目录
- 前言
- 一、架构规划
- 二、配置集群免密登录
- 1. 配置root用户集群免密登录
- 1.1 hadoop101节点操作
- 1.2 hadoop102节点操作
- 1.3 hadoop103节点操作
- 2. 创建用户
- 2.1 hadoop101节点操作
- 2.2 hadoop102节点操作
- 2.3 hadoop103节点操作
- 三、安装准备
- 1. 安装条件
- 2. 安装jdk
- 3. 安装MySQL
- 4. zookeeper集群搭建
- 4.1 部署zookeeper集群
- 4.1.1 hadoop101节点操作
- 4.1.2 hadoop102节点操作
- 4.1.3 hadoop103节点操作
- 4.2 启动zookeeper集群
- 4.2.1 hadoop101节点操作
- 4.2.2 hadoop102节点操作
- 4.2.3 hadoop103节点操作
- 4.3 zookeeper命令
- 4.3.1 启动zookeeper
- 4.3.2 停止zookeeper
- 4.3.3 重启zookeeper
- 4.3.4 查看zookeeper状态
- 4.3.5 进入zookeeper客户端
- 四、安装dolphinscheduler
- 1. 下载并解压dolphinscheduler
- 2. 修改安装配置文件
- 2.1 修改 install_env.sh 文件
- 2.2 修改 dolphinscheduler_env.sh 文件
- 3. 配置mysql数据源
- 3.1 修改MySQL安全策略
- 3.2 查看数据库
- 3.3 创建数据库
- 3.4 创建MySQL用户
- 3.5 配置MySQL驱动
- 4. 初始化数据库
- 5. 修改目录权限
- 6. 安装部署dolphinscheduler
- 7. 登录 DolphinScheduler
- 8. dolphinscheduler命令
- 8.1 一键停止集群所有服务
- 8.2 一键开启集群所有服务
- 8.3 启停 Master
- 8.4 启停 Worker
- 8.5 启停 Api
- 8.6 启停 Alert
- 总结
前言
本文将介绍如何安装和配置 DolphinScheduler,一个分布式任务调度系统。首先,我们将讨论架构规划,包括主机IP、主机名和安装的服务。然后,我们将配置集群之间的免密登录,创建用户并设置密码。接下来,我们将安装所需的软件和库,如JDK、MySQL和ZooKeeper。最后,我们将下载和部署 DolphinScheduler,并演示如何登录和使用该系统。
一、架构规划
主机ip | 主机名 | 安装服务 |
---|---|---|
192.168.198.101 | hadoop101 | master、worker、apiServers、mysql、zookeeper |
192.168.198.102 | hadoop102 | master、worker、zookeeper |
192.168.198.103 | hadoop103 | worker、alertServer、zookeeper |
二、配置集群免密登录
1. 配置root用户集群免密登录
分别在hadoop101、hadoop102和hadoop103节点执行下面命令,用于配置集群之间互相免密登录。
执行ssh-copy-id命令过程中需要根据提示输入yes和root用户密码。
1.1 hadoop101节点操作
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
1.2 hadoop102节点操作
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
1.3 hadoop103节点操作
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
2. 创建用户
分别在hadoop101、hadoop102和hadoop103节点创建dolphinscheduler用户并设置密码。
分别在hadoop101、hadoop102和hadoop103节点切换到dolphinscheduler用户,然后配置集群之间互相免密登录。
dolphinscheduler用户的密码:dolphinscheduler
2.1 hadoop101节点操作
useradd dolphinscheduler
echo "dolphinscheduler" | passwd --stdin dolphinscheduler
sed -i '$adolphinscheduler ALL=(ALL) NOPASSWD: NOPASSWD: ALL' /etc/sudoers
sed -i 's/Defaults requirett/#Defaults requirett/g' /etc/sudoers
su dolphinscheduler
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
退出dolphinscheduler用户。
exit
2.2 hadoop102节点操作
useradd dolphinscheduler
echo "dolphinscheduler" | passwd --stdin dolphinscheduler
sed -i '$adolphinscheduler ALL=(ALL) NOPASSWD: NOPASSWD: ALL' /etc/sudoers
sed -i 's/Defaults requirett/#Defaults requirett/g' /etc/sudoers
su dolphinscheduler
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
退出dolphinscheduler用户。
exit
2.3 hadoop103节点操作
useradd dolphinscheduler
echo "dolphinscheduler" | passwd --stdin dolphinscheduler
sed -i '$adolphinscheduler ALL=(ALL) NOPASSWD: NOPASSWD: ALL' /etc/sudoers
sed -i 's/Defaults requirett/#Defaults requirett/g' /etc/sudoers
su dolphinscheduler
ssh-keygen -t rsa -P '' -f ~/.ssh/id_rsa
ssh-copy-id hadoop101
ssh-copy-id hadoop102
ssh-copy-id hadoop103
退出dolphinscheduler用户。
exit
三、安装准备
1. 安装条件
- jdk版本:1.8+
- MySQL版本:5.7+
- MySQL驱动版本:8.0.16+
- zookeeper版本:3.4.6+
2. 安装jdk
下载地址:https://www.oracle.com/java/technologies/downloads/#java8
下载后上传到hadoop101、hadoop102和hadoop103节点的/tmp目录下。
然后分别在hadoop101、hadoop102和hadoop103节点执行下面命令,用于创建目录、解压,并设置系统级环境变量。
mkdir -p /opt/module
tar -zxvf /tmp/jdk-8u401-linux-x64.tar.gz -C /opt/module/
echo >> /etc/profile
echo '#JAVA_HOME' >> /etc/profile
echo "export JAVA_HOME=/opt/module/jdk1.8.0_401" >> /etc/profile
echo 'export PATH=$PATH:$JAVA_HOME/bin' >> /etc/profile
source /etc/profile
3. 安装MySQL
在hadoop101安装MySQL。
- mysql5.7.44自动化安装教程
- mysql5.7.37自动化安装教程
4. zookeeper集群搭建
4.1 部署zookeeper集群
4.1.1 hadoop101节点操作
wget --no-check-certificate https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz -P /tmp
tar -zxvf /tmp/zookeeper-3.4.14.tar.gz -C /opt/module
echo >> /etc/profile
echo '#ZOOKEEPER_HOME' >> /etc/profile
echo 'export ZOOKEEPER_HOME=/opt/module/zookeeper-3.4.14' >> /etc/profile
echo 'export PATH=$PATH:$ZOOKEEPER_HOME/bin' >> /etc/profile
source /etc/profile
cd /opt/module/zookeeper-3.4.14
cp ./conf/zoo_sample.cfg ./conf/zoo.cfg
sed -i "s|^dataDir=.*|dataDir=./tmp/zookeeper|" ./conf/zoo.cfg
echo >> ./conf/zoo.cfg
echo "server.1=hadoop101:2888:3888" >> ./conf/zoo.cfg
echo "server.2=hadoop102:2888:3888" >> ./conf/zoo.cfg
echo "server.3=hadoop103:2888:3888" >> ./conf/zoo.cfg
./bin/zkServer.sh start
echo 1 > ./tmp/zookeeper/myid
4.1.2 hadoop102节点操作
wget --no-check-certificate https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz -P /tmp
tar -zxvf /tmp/zookeeper-3.4.14.tar.gz -C /opt/module
echo >> /etc/profile
echo '#ZOOKEEPER_HOME' >> /etc/profile
echo 'export ZOOKEEPER_HOME=/opt/module/zookeeper-3.4.14' >> /etc/profile
echo 'export PATH=$PATH:$ZOOKEEPER_HOME/bin' >> /etc/profile
source /etc/profile
cd /opt/module/zookeeper-3.4.14
cp ./conf/zoo_sample.cfg ./conf/zoo.cfg
sed -i "s|^dataDir=.*|dataDir=./tmp/zookeeper|" ./conf/zoo.cfg
echo >> ./conf/zoo.cfg
echo "server.1=hadoop101:2888:3888" >> ./conf/zoo.cfg
echo "server.2=hadoop102:2888:3888" >> ./conf/zoo.cfg
echo "server.3=hadoop103:2888:3888" >> ./conf/zoo.cfg
./bin/zkServer.sh start
echo 2 > ./tmp/zookeeper/myid
4.1.3 hadoop103节点操作
wget --no-check-certificate https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz -P /tmp
tar -zxvf /tmp/zookeeper-3.4.14.tar.gz -C /opt/module
echo >> /etc/profile
echo '#ZOOKEEPER_HOME' >> /etc/profile
echo 'export ZOOKEEPER_HOME=/opt/module/zookeeper-3.4.14' >> /etc/profile
echo 'export PATH=$PATH:$ZOOKEEPER_HOME/bin' >> /etc/profile
source /etc/profile
cd /opt/module/zookeeper-3.4.14
cp ./conf/zoo_sample.cfg ./conf/zoo.cfg
sed -i "s|^dataDir=.*|dataDir=./tmp/zookeeper|" ./conf/zoo.cfg
echo >> ./conf/zoo.cfg
echo "server.1=hadoop101:2888:3888" >> ./conf/zoo.cfg
echo "server.2=hadoop102:2888:3888" >> ./conf/zoo.cfg
echo "server.3=hadoop103:2888:3888" >> ./conf/zoo.cfg
./bin/zkServer.sh start
echo 3 > ./tmp/zookeeper/myid
4.2 启动zookeeper集群
4.2.1 hadoop101节点操作
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh start
4.2.2 hadoop102节点操作
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh start
4.2.3 hadoop103节点操作
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh start
4.3 zookeeper命令
4.3.1 启动zookeeper
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh start
4.3.2 停止zookeeper
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh stop
4.3.3 重启zookeeper
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh restart
4.3.4 查看zookeeper状态
cd /opt/module/zookeeper-3.4.14
./bin/zkServer.sh status
4.3.5 进入zookeeper客户端
cd /opt/module/zookeeper-3.4.14
./bin/zkCli.sh -server hadoop101:2181
四、安装dolphinscheduler
在hadoop101
节点下载并解压dolphinscheduler。
以下操作都在hadoop101节点进行。
1. 下载并解压dolphinscheduler
wget --no-check-certificate https://archive.apache.org/dist/dolphinscheduler/3.1.4/apache-dolphinscheduler-3.1.4-bin.tar.gz -P /tmp
mkdir -p /opt/soft/dolphinscheduler
tar -zxvf /tmp/apache-dolphinscheduler-3.1.4-bin.tar.gz -C /opt/soft/dolphinscheduler
2. 修改安装配置文件
2.1 修改 install_env.sh 文件
根据架构规划修改 /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/bin/env/install_env.sh
文件。内容如下所示。
# 需要安装DolphinScheduler相关组件的主机
ips=${ips:-"hadoop101,hadoop102,hadoop103"}# SSH协议端口号,默认为22。
sshPort=${sshPort:-"22"}# 需要安装master节点的主机
masters=${masters:-"hadoop101,hadoop102"}# 需要安装worker节点的主机
workers=${workers:-"hadoop101:default,hadoop102:default,hadoop103:default"}# 需要安装警报服务的主机
alertServer=${alertServer:-"hadoop103"}# 需要安装api服务的主机
apiServers=${apiServers:-"hadoop101"}# 安装dolphinscheduler的目录。如果不存在,将由install.sh脚本创建。
installPath=${installPath:-"/opt/module/dolphinscheduler/dolphinscheduler"}# 部署dolphinscheduler的用户
deployUser=${deployUser:-"dolphinscheduler"}# zookeeper的根目录,目前DolphinScheduler默认的注册服务器是zookeeper。
zkRoot=${zkRoot:-"/dolphinscheduler"}
2.2 修改 dolphinscheduler_env.sh 文件
修改 /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/bin/env/dolphinscheduler_env.sh
文件。内容如下所示。
# 修改为自己的jdk安装目录
export JAVA_HOME=${JAVA_HOME:-/opt/module/jdk1.8.0_391}# 修改MySQL配置
export DATABASE=${DATABASE:-mysql}
export SPRING_PROFILES_ACTIVE=${DATABASE}
export SPRING_DATASOURCE_URL="jdbc:mysql://hadoop101:3306/dolphinscheduler?useUnicode=true&characterEncoding=UTF-8&useSSL=false"
export SPRING_DATASOURCE_USERNAME="dolphinscheduler"
export SPRING_DATASOURCE_PASSWORD="dolphinscheduler"# DolphinScheduler服务相关配置
export SPRING_CACHE_TYPE=${SPRING_CACHE_TYPE:-none}
export SPRING_JACKSON_TIME_ZONE=${SPRING_JACKSON_TIME_ZONE:-UTC}
export MASTER_FETCH_COMMAND_NUM=${MASTER_FETCH_COMMAND_NUM:-10}# 注册中心配置,修改为自己的zookeeper监听地址
export REGISTRY_TYPE=${REGISTRY_TYPE:-zookeeper}
export REGISTRY_ZOOKEEPER_CONNECT_STRING=${REGISTRY_ZOOKEEPER_CONNECT_STRING:-hadoop101:2181,hadoop102:2181,hadoop103:2181}# 这些环境变量根据自己的需要更改,没有保持默认即口
export HADOOP_HOME=${HADOOP_HOME:-/opt/soft/hadoop}
export HADOOP_CONF_DIR=${HADOOP_CONF_DIR:-/opt/soft/hadoop/etc/hadoop}
export SPARK_HOME1=${SPARK_HOME1:-/opt/soft/spark1}
export SPARK_HOME2=${SPARK_HOME2:-/opt/soft/spark2}
export PYTHON_HOME=${PYTHON_HOME:-/opt/soft/python}
export HIVE_HOME=${HIVE_HOME:-/opt/soft/hive}
export FLINK_HOME=${FLINK_HOME:-/opt/soft/flink}
export DATAX_HOME=${DATAX_HOME:-/opt/soft/datax}
export SEATUNNEL_HOME=${SEATUNNEL_HOME:-/opt/soft/seatunnel}
export CHUNJUN_HOME=${CHUNJUN_HOME:-/opt/soft/chunjun}export PATH=$HADOOP_HOME/bin:$SPARK_HOME1/bin:$SPARK_HOME2/bin:$PYTHON_HOME/bin:$JAVA_HOME/bin:$HIVE_HOME/bin:$FLINK_HOME/bin:$DATAX_HOME/bin:$SEATUNNEL_HOME/bin:$CHUNJUN_HOME/bin:$PATH
3. 配置mysql数据源
3.1 修改MySQL安全策略
修改安全策略为LOW,使其可以设置简单密码,根据自己的需要更改。
mysql -h hadoop101 -P 3306 -uroot -proot -e "set global validate_password_length=4;"
mysql -h hadoop101 -P 3306 -uroot -proot -e "set global validate_password_policy=LOW;"
3.2 查看数据库
查看dolphinscheduler数据库是否存在。
mysql -h hadoop101 -P 3306 -uroot -proot -e "SHOW DATABASES;" | grep dolphinscheduler
若存在则删除。
mysql -h hadoop101 -P 3306 -uroot -proot -e "DROP DATABASE dolphinscheduler;"
3.3 创建数据库
创建dolphinscheduler数据库
mysql -h hadoop101 -P 3306 -uroot -proot -e "CREATE DATABASE dolphinscheduler DEFAULT CHARACTER SET utf8 DEFAULT COLLATE utf8_general_ci;"
3.4 创建MySQL用户
创建 dolphinscheduler 用户并授予操作 dolphinscheduler 数据库的权限。
此处创建dolphinscheduler用户并设置密码为dolphinscheduler。
mysql -h hadoop101 -P 3306 -uroot -proot -e "CREATE USER 'dolphinscheduler'@'%' IDENTIFIED BY 'dolphinscheduler';"
授予操作 dolphinscheduler 数据库的权限并刷新权限。
mysql -h hadoop101 -P 3306 -uroot -proot -e "GRANT ALL PRIVILEGES ON dolphinscheduler.* TO 'dolphinscheduler'@'%' IDENTIFIED BY 'dolphinscheduler';"
mysql -h hadoop101 -P 3306 -uroot -proot -e "flush privileges;"
3.5 配置MySQL驱动
下载并配置MySQL驱动。
wget https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.16/mysql-connector-java-8.0.16.jar -P /tmp
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/worker-server/libs
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/api-server/libs
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/alert-server/libs
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/master-server/libs
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/tools/libs
cp /tmp/mysql-connector-java-8.0.16.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/standalone-server/libs/standalone-server
wget https://repo1.maven.org/maven2/commons-cli/commons-cli/1.5.0/commons-cli-1.5.0.jar -P /tmp
cp /tmp/commons-cli-1.5.0.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/worker-server/libs
cp /tmp/commons-cli-1.5.0.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/api-server/libs
cp /tmp/commons-cli-1.5.0.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/alert-server/libs
cp /tmp/commons-cli-1.5.0.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/master-server/libs
cp /tmp/commons-cli-1.5.0.jar /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin/tools/libs
4. 初始化数据库
初始化dolphinscheduler数据库。
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash tools/bin/upgrade-schema.sh
初始化成功如下图所示。
5. 修改目录权限
修改apache-dolphinscheduler-3.1.4-bin目录权限到dolphinscheduler用户。
cd /opt/module/dolphinscheduler
chown -R dolphinscheduler:dolphinscheduler apache-dolphinscheduler-3.1.4-bin
6. 安装部署dolphinscheduler
使用5.4.1指定的部署用户运行以下命令完成部署。
su dolphinscheduler
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/install.sh
7. 登录 DolphinScheduler
浏览器访问地址 http://localhost:12345/dolphinscheduler/ui 即可登录系统UI。默认的用户名和密码是 admin/dolphinscheduler123
如下图所示。
8. dolphinscheduler命令
8.1 一键停止集群所有服务
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/stop-all.sh
8.2 一键开启集群所有服务
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/start-all.sh
8.3 启停 Master
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/dolphinscheduler-daemon.sh stop master-server
bash ./bin/dolphinscheduler-daemon.sh start master-server
8.4 启停 Worker
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/dolphinscheduler-daemon.sh start worker-server
bash ./bin/dolphinscheduler-daemon.sh stop worker-server
8.5 启停 Api
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/dolphinscheduler-daemon.sh start api-server
bash ./bin/dolphinscheduler-daemon.sh stop api-server
8.6 启停 Alert
cd /opt/module/dolphinscheduler/apache-dolphinscheduler-3.1.4-bin
bash ./bin/dolphinscheduler-daemon.sh start alert-server
bash ./bin/dolphinscheduler-daemon.sh stop alert-server
总结
本文详细介绍了安装和配置 DolphinScheduler 的步骤。我们首先进行了架构规划,确定了主机IP、主机名和安装的服务。然后,我们配置了集群之间的免密登录,并创建了用户并设置了密码。接下来,我们安装了所需的软件和库,如JDK、MySQL和ZooKeeper。最后,我们下载并部署了 DolphinScheduler,并演示了登录和使用该系统的过程。
希望本教程对您有所帮助!如有任何疑问或问题,请随时在评论区留言。感谢阅读!
这篇关于dolphinscheduler集群部署教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!