AI 助理
备案控制台
开发者社区 云原生 文章 正文

k8s学习--k8s群集部署zookeeper应用及详细解释

2024-10-07 83
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
容器服务 Serverless 版 ACK Serverless，952元额度 多规格
云原生网关 MSE Higress，422元/月
简介： k8s学习--k8s群集部署zookeeper应用及详细解释

@TOC

zookeeper

什么是zookeeper

ZooKeeper 是一个开源的分布式协调服务，主要用于分布式应用程序中，管理数据、同步服务以及维护配置信息。它是由 Apache Software Foundation 管理和维护的。

基本概念

ZNode: ZooKeeper 的数据存储单元，类似于文件系统中的文件和目录。ZNode 可以存储数据和子节点。

Zookeeper Ensemble: 一个 ZooKeeper 服务通常由多个 ZooKeeper 服务器（节点）组成，称为一个 ensemble。通常会有一个主节点（Leader）和若干个跟随节点（Follower）。

Session: 客户端与 ZooKeeper 服务器之间的会话。每个客户端会话都有一个唯一的会话 ID。

主要功能

命名服务（Naming Service）: 类似于 DNS，允许分布式应用程序使用路径来访问资源和服务。

配置管理（Configuration Management）: 存储和更新配置信息，使得分布式应用程序的各个部分能够同步读取最新的配置。

分布式同步（Distributed Synchronization）: 支持分布式锁和队列，帮助多个进程协调对共享资源的访问。

组服务（Group Services）: 用于维护分布式系统中群组成员的列表，监控集群中节点的状态。

工作原理

ZooKeeper 采用了一个简单的、基于全局数据一致性的模型：

Leader Election: 当 ZooKeeper 集群启动时，节点之间通过投票选举出一个 Leader。Leader 负责处理所有写请求，而读请求可以由任何节点处理。

Watches: 客户端可以在 ZNode 上设置 watch，当 ZNode 的数据或子节点变化时，ZooKeeper 会通知客户端。

Atomic Broadcast (Zab): ZooKeeper 使用一种叫做 Zab 协议的原子广播协议，确保所有服务器上的数据一致性。所有的写操作都会被记录为事务日志，并通过 Zab 协议广播给其他节点。

使用场景

分布式锁: 使用临时 ZNode 实现分布式锁，确保多个进程不会同时访问共享资源。

集群管理: 在分布式系统中，使用 ZooKeeper 监控集群中的节点，处理节点的动态增加和减少。

配置管理: 存储和分发分布式应用程序的配置参数，确保所有节点使用相同的配置。

命名服务: 管理分布式系统中服务的命名和查找。

优点

高可用性: ZooKeeper 采用分布式架构，保证了高可用性和容错能力。

高性能: ZooKeeper 的读性能非常高，适合高读负载的场景。

一致性: 提供严格的数据一致性，确保分布式系统中各个节点的数据一致。

缺点

单点瓶颈: Leader 处理所有写请求，可能成为性能瓶颈。

复杂性: 部署和管理 ZooKeeper 集群需要一定的技术门槛。

k8s集群部署zookeeper

环境

虚拟机

Ip 主机名 cpu 内存 硬盘
192.168.10.11 master01 2cpu双核 4G 100G
192.168.10.12 worker01 2cpu双核 4G 100G
192.168.10.13 worker02 2cpu双核 4G 100G
192.168.10.18 nfs 1cpu一核 2G 40G

版本 centos7.9
已部署k8s-1.27

需要做的前置配置
storageclass
详情请看
链接: k8s练习--StorageClass详细解释与应用
区别仅有ip不一致，按本次ip来

Ingress（本章使用nodeport方式访问）
详情请看
链接: k8s学习--ingress详细解释与应用(nginx ingress controller))

本章不再过多叙述

一、zookeeper部署YAML资源清单准备

master节点配置

vim zookeeper.yaml

---
apiVersion: v1
kind: Namespace
metadata:
  name: smart

---
apiVersion: v1
kind: Service
metadata:
  name: zk-headless 
  namespace: smart
  labels:
    app: zk
spec:
  ports:
  - port: 2888 
    name: server
  - port: 3888 
    name: leader-election
  clusterIP: None  #无头服务集群内访问
  selector:
    app: zk
---
apiVersion: v1
kind: Service
metadata:
  name: zk-np 
  namespace: smart
  labels:
    app: zk
spec:
  type: NodePort    #对外发布访问
  ports:
  - port: 2181
    targetPort: 2181
    name: client
    nodePort: 32181
  selector:
    app: zk
---
apiVersion: policy/v1
kind: PodDisruptionBudget
metadata:
  name: zk-pdb
  namespace: smart
spec:
  selector:
    matchLabels:
      app: zk
  maxUnavailable: 1  #允许失效pod的数量
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: zookeeper
  namespace: smart
spec:
  serviceName: zk-headless
  replicas: 3
  updateStrategy:
    type: RollingUpdate
  selector:
    matchLabels:
      app: zk
  template:
    metadata:
      labels:
        app: zk
    spec:
      affinity:  #pod粘滞
        podAntiAffinity:
          requiredDuringSchedulingIgnoredDuringExecution:
            - labelSelector:
                matchExpressions:
                  - key: "app"
                    operator: In
                    values:
                    - zk
              topologyKey: "kubernetes.io/hostname"
      containers:
      - name: kubernetes-zookeeper
        image: k8s.gcr.io/kubernetes-zookeeper:1.0-3.4.10
        imagePullPolicy: Always
        resources:
          requests:
            memory: "1Gi"
            cpu: "0.5"
        ports:
        - containerPort: 2181
          name: client
        - containerPort: 2888
          name: server
        - containerPort: 3888
          name: leader-election
        command:
        - sh
        - -c
        - "start-zookeeper \
          --servers=3 \
          --data_dir=/var/lib/zookeeper/data \
          --data_log_dir=/var/lib/zookeeper/data/log \
          --conf_dir=/opt/zookeeper/conf \
          --client_port=2181 \
          --election_port=3888 \
          --server_port=2888 \
          --tick_time=2000 \
          --init_limit=10 \
          --sync_limit=5 \
          --heap=512M \
          --max_client_cnxns=60 \
          --snap_retain_count=3 \
          --purge_interval=12 \
          --max_session_timeout=40000 \
          --min_session_timeout=4000 \
          --log_level=INFO"
        readinessProbe:
          exec:
            command:
            - sh
            - -c
            - "zookeeper-ready 2181"
          initialDelaySeconds: 10
          timeoutSeconds: 5
        livenessProbe:
          exec:
            command:
            - sh
            - -c
            - "zookeeper-ready 2181"
          initialDelaySeconds: 10
          timeoutSeconds: 5
        volumeMounts:
        - name: datadir
          mountPath: /var/lib/zookeeper
        - name: localtime
          mountPath: /etc/localtime
      volumes:
      - name: localtime
        hostPath:
          path: /etc/localtime  #pod时间同步于宿主机时间
          type: ''

  volumeClaimTemplates:
  - metadata:
      name: datadir
      annotations:
        volume.alpha.kubernetes.io/storage-class: anything
    spec:
      accessModes: [ "ReadWriteOnce" ]
      storageClassName: "nfs-client"
      resources:
        requests:
          storage: 1Gi

用于创建一个zookeeper群集
简单来说就是创建一个命令空间存放相关资源，两个service一个对内一个对外发布服务，还有一个statefulset控制器创建pod，特点是在每个节点至少部署一个，适用于有状态服务，比如说数据库之类

二、zookeeper部署及部署验证

应用yaml文件

kubectl apply -f zookeeper.yaml

Zookeeper运行pod数量一般为奇数，每节点上会运行一个pod，k8sworker节点如果不够，可能会出现如下现象

kubectl get pod -n smart -o wide

在这里插入图片描述
出于安全考虑，默认配置下Kubernetes不会将Pod调度到Master节点。
如果希望将k8s-master也当作Node使用，可以执行如下命令：
查看master01调度控制（Taints污点设置，NoSchedule不被调度）

kubectl describe node master01 | grep Taints

可以看到是noscheduler
禁止调用
在这里插入图片描述

取消污点设置：

kubectl taint node master01 node-role.kubernetes.io/control-plane-

在这里插入图片描述
再查看就好了

 kubectl get pod -n smart -o wide

在这里插入图片描述

注
如果发现pod只有一个且一直pending,那就是storageclass没有做好，nfs的pod没有或无法起来，pv无法调度存储设备的资源，请详细查看
链接: k8s练习--StorageClass详细解释与应用

查看statefulset应用\

kubectl get sts -n smart

在这里插入图片描述

查看service

kubectl get svc -n smart

在这里插入图片描述
如果想取消被调度，执行如下命令即可，不会影响已经被调度的pod

kubectl taint node master01 node-role.kubernetes.io/control-plane:NoSchedule

三、zookeeper应用验证

zookeeper访问连接信息验证

dig -t a zk-headless.smart.svc.cluster.local @10.96.0.10
dig -t a zk-np.smart.svc.cluster.local @10.96.0.10

![在这里插入图片描述](https://i-blog.csdnimg.cn/blog_migrate/b93bde5c32c0d2d03d5b5c03ecca4b2c.png)
![在这里插入图片描述](https://i-blog.csdnimg.cn/blog_migrate/434b817407d96c93313c1841081af05d.png)

**在kubernetes集群内访问验证**

kubectl exec -it zookeeper-0 -n smart -- bash
root@zookeeper-0:/# zkCli.sh
[zk: localhost:2181(CONNECTED) 0] create /key1 111
[zk: localhost:2181(CONNECTED) 1] get /key1
[zk: localhost:2181(CONNECTED) 2] quit
root@zookeeper-0:/# exit

![在这里插入图片描述](https://i-blog.csdnimg.cn/blog_migrate/e40699926cb69fd7abc7ad845045fa92.png)
**在kubernetes集群外访问验证：**
**下载客户端软件**

wget https://dlcdn.apache.org/zookeeper/zookeeper-3.8.4/apache-zookeeper-3.8.4-bin.tar.gz

会提示，由于是虚拟机环境且只是查看能不能用，所以使用不安全的方式链接也无伤大雅
![在这里插入图片描述](https://i-blog.csdnimg.cn/blog_migrate/837e3393eb311c1da32def83d9b28499.png)

wget https://dlcdn.apache.org/zookeeper/zookeeper-3.8.4/apache-zookeeper-3.8.4-bin.tar.gz --no-check-certificate
tar xf apache-zookeeper-3.8.4-bin.tar.gz
cd apache-zookeeper-3.8.4-bin/
cd bin/
./zkCli.sh -server 192.168.10.11:32181

出现以下提示说明需要jdk包
![在这里插入图片描述](https://i-blog.csdnimg.cn/blog_migrate/603d7e4ba5ad804f0e15620df68b2f8b.png)

安装jdk
呃呃呃，路径忘了，但包名是
jdk-8u191-linux-x64.tar.gz
可以自己试着找找，我上传的时候显示资源已存在，可以找一找
传到虚拟机内

tar xf jdk-8u191-linux-x64.tar.gz
mv jdk1.8.0_191/ /usr/local/jdk
echo "export JAVA_HOME=/usr/local/jdk" >> /etc/profile
source /etc/profile
cd /root/apache-zookeeper-3.8.4-bin/bin
./zkCli.sh -server 192.168.10.11:32181

[zk: 192.168.10.11:32181(CONNECTED) 2] create /key2 123
[zk: 192.168.10.11:32181(CONNECTED) 3] get /key2
[zk: 192.168.10.11:32181(CONNECTED) 4] quit
```
在这里插入图片描述
完成

文章标签：
容器服务Kubernetes版
微服务引擎
容器
Kubernetes
Perl
调度
存储
关键词：
容器服务Kubernetes版应用
学习微服务引擎
容器服务Kubernetes版学习
容器服务Kubernetes版学习应用
k8s微服务引擎
相关实践学习
通过Ingress进行灰度发布
本场景您将运行一个简单的应用，部署一个新的应用用于新的发布，并通过Ingress能力实现灰度发布。
容器应用与集群管理
欢迎来到《容器应用与集群管理》课程，本课程是“云原生容器Clouder认证“系列中的第二阶段。课程将向您介绍与容器集群相关的概念和技术，这些概念和技术可以帮助您了解阿里云容器服务ACK/ACK Serverless的使用。同时，本课程也会向您介绍可以采取的工具、方法和可操作步骤，以帮助您了解如何基于容器服务ACK Serverless构建和管理企业级应用。 学习完本课程后，您将能够： 掌握容器集群、容器编排的基本概念 掌握Kubernetes的基础概念及核心思想 掌握阿里云容器服务ACK/ACK Serverless概念及使用方法 基于容器服务ACK Serverless搭建和管理企业级网站应用
爱吃龙利鱼
目录
相关文章
跃@sir
|
23天前
|
存储 Kubernetes 持续交付
介绍一下Kubernetes的应用场景
【10月更文挑战第18天】介绍一下Kubernetes的应用场景。
跃@sir
100 3
听风de歌
|
1月前
|
存储 Kubernetes 持续交付
k8s学习
【10月更文挑战第1天】
听风de歌
80 4
光明顶阳顶天
|
4天前
|
监控 持续交付 Docker
Docker 容器化部署在微服务架构中的应用有哪些？
Docker 容器化部署在微服务架构中的应用有哪些？
光明顶阳顶天
18 2
光明顶阳顶天
|
4天前
|
监控 持续交付 Docker
Docker容器化部署在微服务架构中的应用
Docker容器化部署在微服务架构中的应用
光明顶阳顶天
20 3
土木林森
|
12天前
|
JavaScript 持续交付 Docker
解锁新技能：Docker容器化部署在微服务架构中的应用
【10月更文挑战第29天】在数字化转型中，微服务架构因灵活性和可扩展性成为企业首选。Docker容器化技术为微服务的部署和管理带来革命性变化。本文探讨Docker在微服务架构中的应用，包括隔离性、可移植性、扩展性、版本控制等方面，并提供代码示例。
土木林森
49 1
java冯坚持
|
1月前
|
存储 负载均衡 监控
dubbo学习一：zookeeper与dubbo的关系，下载安装启动zookeeper（解决启动中报错）
这篇文章是关于Apache Dubbo框架与Zookeeper的关系，以及如何下载、安装和启动Zookeeper的教程，包括解决启动过程中可能遇到的报错问题。
java冯坚持
48 3
dubbo学习一：zookeeper与dubbo的关系，下载安装启动zookeeper（解决启动中报错）
阿里云基础设施.
|
21天前
|
JSON Kubernetes 容灾
ACK One应用分发上线：高效管理多集群应用
ACK One应用分发上线，主要介绍了新能力的使用场景
阿里云基础设施.
40 9
mzlogin
|
20天前
|
Dubbo 应用服务中间件 Apache
Dubbo 应用切换 ZooKeeper 注册中心实例，流量无损迁移
如果 Dubbo 应用使用 ZooKeeper 作为注册中心，现在需要切换到新的 ZooKeeper 实例，如何做到流量无损？
mzlogin
17 4
java冯坚持
|
1月前
|
监控 Dubbo Java
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
这篇文章详细介绍了如何将Spring Boot与Dubbo和Zookeeper整合，并通过Dubbo管理界面监控服务注册情况。
java冯坚持
76 0
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
听风de歌
|
1月前
|
存储 Kubernetes 调度
Kubernetes 基础学习之Pods介绍和深入学习
【10月更文挑战第1天】
听风de歌
47 4

热门文章

最新文章

  • 1
    Dubbo的Zookeeper单机配置和Zookeeper集群配置
  • 2
    Spring Cloud Zookeeper 中心化配置文件
  • 3
    ZooKeeper 未授权访问漏洞
  • 4
    zookeeper集群搭建
  • 5
    阿里云微服务引擎 MSE 12 月产品动态
  • 6
    Dubbo与Zookeeper、SpringMVC整合和使用（负载均衡、容错）（转）
  • 7
    zookeeper源码分析之leader选举
  • 8
    阿里云微服务引擎 MSE 2023 年 10 月产品动态
  • 9
    【ZooKeeper Notes 7】使用super身份对有权限的节点进行操作
  • 10
    zookeeper实现分布式锁
  • 1
    有了k8s还需要gateway网关，nacos配置中心吗
    221
  • 2
    自动化运维的新篇章：容器编排与微服务架构
    52
  • 3
    容器服务Kubernetes版（ACK）上快速部署应用
    199
  • 4
    使用 Scapy 库编写 TCP SYN-ACK 反射脚本
    40
  • 5
    使用 Scapy 库编写 TCP ACK 洪水脚本
    51
  • 6
    Kubernetes 集群的持续性能优化策略
    106
  • 7
    里云容器服务Kubernetes版（ACK）上快速部署应用
    167
  • 8
    容器服务Kubernetes版（ACK）上快速部署应用
    133
  • 9
    Java中的容器编排工具比较与选择
    63
  • 10
    docker、docker compose、k8s有什么区别？
    220

    • 相关课程

    更多
  • 阿里云 EMR on ACK 实战
  • 阿里云K8S微服务部署案例
  • Kubernetes极速入门
  • Serverless 容器从入门到精通: - Serverless Kubernetes
  • Kubernetes云原生管理实践
  • Kubernetes入门

    • 相关电子书

    更多
  • ACK 云原生弹性方案—云原生时代的加速器
  • ACK集群类型选择最佳实践
  • 企业运维之云原生和Kubernetes 实战

    • 相关实验场景

    更多
  • 搭建Hadoop环境
  • 通过FastMR自动拉起大数据集群并运行TPCDS任务
  • 容器服务Serverless版ACK Serverless 快速入门：在线魔方应用部署和监控
  • 容器管理命令

    • 推荐镜像

    更多
  • kubernetes
  • pouch
  • CloudFoundry
    • 下一篇
    阿里云OSS设置跨域访问