zookeeper(目前只有安装)

news/2024/7/4 7:47:12 标签: zookeeper, 分布式, 云原生

安装

流程

学kafka的时候安装

Apache ZooKeeper

安装地址:https://archive.apache.org/dist/zookeeper/zookeeper-3.5.7/apache-zookeeper-3.5.7-bin.tar.gz

解压

tar -zxvf kafka_2.12-3.0.0.tgz -C /export/server/

改配置

cd config
cp zoo_sample.cfg zoo.cfg
vim zoo.cfg 

# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=/export/server/zookeeper-3.5.7/zkdata


# 这里和server.几 和下面的myid匹配上
# 2888是正常leader端口,3888是备用端口
server.1=hadoop1:2888:3888
server.2=hadoop2:2888:3888
server.3=hadoop3:2888:3888

:wq

在设置的dataDir目录下创建一个名字叫myid的文件(必须叫myid!!!)

写入一个数(几都行,只要三个集群别一样)

[root@hadoop1 zkdata]# echo 1 > myid

[root@hadoop2 zkdata]# echo 2 > myid

[root@hadoop3 zkdata]# echo 3 > myid

fenfa

zoo.cfg配置解毒

# The number of milliseconds of each tick
# 每个滴答的毫秒数 心跳
tickTime=2000

# The number of ticks that the initial 
# synchronization phase can take 
# 初始同步阶段可以占用的心跳数  到了没连上就失败
initLimit=10

# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
# 在发送请求和获得确认之间可以传递的心跳数
syncLimit=5

# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
# 快照所在的目录。不使用/ tmp为存储、/ tmp这里只是例子的缘故。
dataDir=/export/server/zookeeper-3.5.7/zkdata
# the port at which the clients will connect
clientPort=2181

# the maximum number of client connections.
# increase this if you need to handle more clients
# 客户端连接的最大数量。如果需要处理更多客户端,请增加此值
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
# 在开启自动督促之前,请务必阅读管理员指南的维护部分。
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
# dataDir中要保留的快照数量
#autopurge.snapRetainCount=3

# Purge task interval in hours
# Set to "0" to disable auto purge feature
# 清除任务间隔(小时)  设置为“0”表示禁用自动清除功能
#autopurge.purgeInterval=1

原神启动

hadoop1启动

[root@hadoop1 zookeeper-3.5.7]# bin/zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /export/server/zookeeper-3.5.7/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

[root@hadoop1 zookeeper-3.5.7]# bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /export/server/zookeeper-3.5.7/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Error contacting service. It is probably not running.
一看状态居然失败了?因为另外两个没启动,不过半没法选出来leader

hadoop2/3也启动

bin/zkServer.sh start

现在hadoop1状态

[root@hadoop1 zookeeper-3.5.7]# bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /export/server/zookeeper-3.5.7/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: follower


[root@hadoop2 zookeeper-3.5.7]# bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /export/server/zookeeper-3.5.7/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: leader(hadoop2成leader了)


[root@hadoop3 zookeeper-3.5.7]# bin/zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /export/server/zookeeper-3.5.7/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: follower

批量启动脚本

#!/bin/bash
case $1 in
start)
    for i in hadoop1 hadoop2 hadoop3
    do
        echo ----------------  zookeeper $i start ----------------
        ssh $i "/export/server/zookeeper-3.5.7/bin/zkServer.sh start"
    done
    ;;
stop)
    for i in hadoop1 hadoop2 hadoop3
    do
        echo ----------------  zookeeper $i stop ----------------
        ssh $i "/export/server/zookeeper-3.5.7/bin/zkServer.sh stop"
    done
    ;;
status)
    for i in hadoop1 hadoop2 hadoop3
    do
        echo ----------------  zookeeper $i status ----------------
        ssh $i "/export/server/zookeeper-3.5.7/bin/zkServer.sh status"
    done
    ;;
*)
    echo "Usage: $0 {start|stop|status}"
    ;;
esac

chmod 777 zk


http://www.niftyadmin.cn/n/5105549.html

相关文章

正点原子嵌入式linux驱动开发——Linux按键输入

在前几篇笔记之中都是使用的GPIO输出功能,还没有用过GPIO输入功能,本章就来学习一下如果在Linux下编写GPIO输入驱动程序。正点原子STM32MP1开发板上有三个按键,就使用这些按键来完成GPIO输入驱动程序,同时利用原子操作来对按键值进…

龙芯3A3000源码编译安装deepin-ide

安装环境 系统为统领专业版1050 CPU为龙芯3A3000 安装步骤 1.安装所有依赖库 sudo apt-get install git debhelper cmake qt5-qmake qtbase5-dev qttools5-dev qttools5-dev-tools lxqt-build-tools libssl-dev llvm llvm-dev libclang-dev libutf8proc-dev libmicrohttpd-d…

【AIGC核心技术剖析】改进视频修复的传播和变压器(动态滤除环境中的物体)

基于流的传播和时空变压器是视频修复(VI)中的两种主流机制。尽管这些组件有效,但它们仍然受到一些影响其性能的限制。以前基于传播的方法在图像域或特征域中单独执行。与学习隔离的全局图像传播可能会由于光流不准确而导致空间错位。此外&…

深度学习八股文: 模型训练全过程及各阶段的原因

深度学习模型的训练全过程通常包括以下步骤: 数据准备: 首先,需要准备用于训练的数据集。数据集应包含输入特征(通常是数值或图像数据)和相应的目标标签。数据通常需要被分为训练集、验证集和测试集,以便评…

Polars库的常见用法总结

Polars是一个基于Rust语言的数据操作和分析库,专为大型数据集和高性能计算而设计。它提供了类似于pandas的API,但在性能方面更加强大。 以下是Polars库的一些常见用法: 导入Polars库: import polars as pl读取数据:…

【来点小剧场--项目测试报告】个人博客系统测试报告

一、项目背景 个人博客系统采用前后端分离的方法来实现,使用了MySQL数据库来存储相关的数据,同时对Redis进行配置,将session会话存储在redis中以方便分布式运转,最后通过云服务器将项目部署到网络上。前端主要有六个页面构成&…

深入理解C++中的构造函数和析构函数

引言: 构造函数和析构函数是C中非常重要的概念,它们在对象的创建和销毁过程中起着关键作用。本文将深入探讨C中构造函数和析构函数的技术细节,包括构造函数的作用、构造函数的种类、析构函数的作用、析构函数的调用时机等方面,帮助…

Android AccessibilityService dispatchGesture

Android AccessibilityService dispatchGesture 一、dispatchGesture方法 1.申请权限 <uses-permission android:name"android.permission.BIND_ACCESSIBILITY_SERVICE"tools:ignore"ProtectedPermissions" />2.使用 public class MyAccessibili…