没有合适的资源？快使用搜索试试~ 我知道了~

文库首页安全技术网络安全第三课：zookeeper_典型使用场景实践（预习）1

第三课：zookeeper_典型使用场景实践（预习）1

zookeeper

需积分: 0 0 下载量 86 浏览量 2022-08-03 17:32:56 上传评论收藏 787KB PDF 举报

温馨提示

试读

15页

1. 分布式集群管理 2. 分布式注册中 3. 分布式锁 4. 分布式JOB 1. 主动查看线上服务节点 2. 查看服务节点资源使情况 3. 服务离线通知 4.

资源详情

资源评论

资源推荐

第三课：zookeeper 典型使⽤场景实践

课程概要：

1. 分布式集群管理

2. 分布式注册中⼼

3. 分布式锁

4. 分布式JOB

⼀、分布式集群管理

分布式集群管理的需求：

1. 主动查看线上服务节点

2. 查看服务节点资源使⽤情况

3. 服务离线通知

4. 服务资源（CPU、内存、硬盘）超出阀值通知

架构设计：

节点结构：

1. tuling-manger // 根节点

a. server00001 :<json> //服务节点 1

b. server00002 :<json>//服务节点 2

c. server........n :<json>//服务节点 n

服务状态信息:

a. ip

b. cpu

c. memory

d. disk

功能实现：

数据⽣成与上报：

1. 创建临时节点：

2. 定时变更节点状态信息：

主动查询：

1、实时查询 zookeeper 获取集群节点的状态信息。

被动通知：

1. 监听根节点下⼦节点的变化情况,如果CPU 等硬件资源低于警告位则发出警报。

关键示例代码：

package com.tuling;1

import com.fasterxml.jackson.core.JsonProcessingException;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.tuling.os.CPUMonitorCalc;

import com.tuling.os.OsBean;

import org.I0Itec.zkclient.IZkChildListener;

import org.I0Itec.zkclient.ZkClient;

import java.io.IOException;

import java.lang.instrument.Instrumentation;

import java.lang.management.ManagementFactory;

import java.lang.management.MemoryUsage;

import java.net.InetAddress;

import java.net.UnknownHostException;

import java.util.ArrayList;

import java.util.List;

import java.util.stream.Collectors;

/**

* @author Tommy

* Created by Tommy on 2019/9/22

**/

public class Agent {

private String server = "192.168.0.149:2181";

ZkClient zkClient;

private static Agent instance;

private static final String rootPath = "/tuling-manger";

private static final String servicePath = rootPath + "/service";

private String nodePath;

private Thread stateThread;

List<OsBean> list = new ArrayList<>();

public static void premain(String args, Instrumentation

instrumentation) {

instance = new Agent();

if (args != null) {

instance.server = args;

}

instance.init();

}

// 初始化连接

public void init() {

zkClient = new ZkClient(server, 5000, 10000);

System.out.println("zk连接成功" + server);

buildRoot();

createServerNode();

stateThread = new Thread(() -> {

while (true) {

updateServerNode();

try {

Thread.sleep(5000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}, "zk_stateThread");

stateThread.setDaemon(true);

stateThread.start();

}

// 构建根节点

public void buildRoot() {

if (!zkClient.exists(rootPath)) {

zkClient.createPersistent(rootPath);

}

// 生成服务节点

public void createServerNode() {

nodePath = zkClient.createEphemeralSequential(servicePath,

getOsInfo());

System.out.println("创建节点:" + nodePath);

}

剩余14页未读，继续阅读

内容反馈

SLHJ-Translator

粉丝: 27
资源: 297

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

第三课：zookeeper_典型使用场景实践（预习）1

评论0

最新资源

第三课：zookeeper_典型使用场景实践（预习）1

评论0

第三课：zookeeper 典型使用场景实践1

zookeeper 典型使用场景实践 归档.zip

第二课：zookeeper客户端使用与集群特性.docx

第二课：zookeeper客户端使用与集群特性.md

ZooKeeper典型使用场景

zookeeper_3.4.8-1_arm64.deb 银河麒麟+飞腾

zookeeper_3.4.8-1_arm64.deb UOS+鲲鹏

zookeeper_exporter-master.zip

zookeeper_exporter：用于监视ZooKeeper合奏的Prometheus出口商

ansible-role-zookeeper:Ansible角色，用于管理Apache ZooKeeper的安装和配置

ansible-zookeeper：用于安装和配置Apache ZooKeeper的Ansible角色

ZooKeeper 典型的应用场景详解

netty,redis,zookeeper高-netty_redis_zookeeper_source_code.zip

第一课：zookeeper 特性与节点说明1

第四课：zookeeper ZAB协议实现源码分析1

Paxos到Zookeeper：分布式一致性原理与实践

zookeeper-3.4.6_zookeeper_

笔记_zookeeper_源码.zip

最新版ISO/IEC 27001:2022、ISO 27002:2022中英文合集

Goby红队版-win-x64-2.4.7版本

Chrome Header Editor 插件

ISO SAE 21434-2021 中文版.pdf

OpenVAS GVM 中文翻译补丁

安全认证cisp教材全套

现代永磁同步电机控制原理及MATLAB仿真__袁雷编著1

全面的安全基线核查清单

OpenVAS离线资源

最新资源

zookeeper 典型使用场景实践归档.zip