加载中
docker中搭建zookeeper

拉取镜像 docker pull zookeeper 启动容器并添加映射 docker run --privileged=true -d --name zookeeper --publish 2181:2181 -d zookeeper:latest 查看是否启动 docker ps 使用过程 在开发...

02/18 14:24
8
zk中的节点配额,配额管理树,状态信息

Qutas 主要完成配额目录的定义: 限制信息包含某个路径的要求大小 在zk中目录结构为/zookeeper/quota/xxx/zookeeper_limits 状态信息包含对某个路径实际大小 /zookeeper/quota/xxx/zookeeper...

09/25 17:20
13
zk client会话过程

client会话过程 zk客户端的主要核心组件 zk客户端会话过程 初始化阶段 创建阶段 响应阶段 UML图 zk客户端主要组件 zookeeper 客户端入口 ClientWatchManager:客户端Watch管理器 HostProvider...

10/09 18:43
22
zookeeper 3

zookeeper更专注于任务协同 保障一致性,有序性和持久性 实现通用的同步原语的能力 在实际分布式系统中,并发往往导致不正确的行为,zookeeper提供了简单的并发处理机制 真实环境中我们应该考...

02/19 17:24
7
zk工厂方法实现NIOServerCnxnFactory

NIOServerCnxnFactory类 内部类 AbstractSelectThread AcceptThread SelectorThread 属性 ZOOKEEPER_NIO_SESSIONLESS_CNXN_TIMEOUT 10s session过期时间 ZOOKEEPER_NIO_NUM_SELECTOR_THREADS...

zk的树形数据模型

zookeeper的数据模型是树结构 在内存数据库中存储了整颗树内容,包含所有节点路径,节点数据,状态信息 会定时将数据刷到磁盘上 数据模型表示主要有DataTree DataNode ZKDatabase datatree是...

09/26 14:45
18
curator zookeeper的高级封装库

curator zookeeper的高级封装库 是为了将zookeeper中的复杂操作隐藏起来,使得操作简单化,提供了操作的菜谱,并且结合了开发过程的最佳实践和常见的边际情况的处理; curator实现了锁,屏障...

zk服务器的构成,一个请求是如何处理的

请求处理器是对处理流水线上不同阶段的抽象, 每一个服务器实现了一个请求处理器的序列,一个请求经过服务器上所有处理器的处理后得到了完全处理 RequestProcessor的接口,这个接口的主要方法...

02/26 17:31
35
zookeeper中请求顺序性问题的考虑

顺序性保障 连接丢失时的顺序性 zookeeper会取消等待的请求,同步方法会抛出异常,对于异步请求调用,回调函数会返回结果码来标示连接丢失,这种情况下依赖客户端解决后续的操作,而不能依赖...

02/25 17:15
42
zk服务预启动和启动选举过程

QuorumPeerMain类 public static void main(String[] args) { QuorumPeerMain main = new QuorumPeerMain(); try { main.initializeAndRun(args); } catch (IllegalArgumentException e......

前天 15:11
8
zk中的事务日志

zk事务日志文件用来标记事务操作,每一个事务操作如添加,删除节点等等 都会在事务日志中记录一条记录,用来在zookeeper异常情况下恢复数据 public interface TxnLog extends Closeable { /*...

ZK
09/25 10:44
10
zk会话,快照,序列化,本地存储

FolloewerRequestProcessor类 追随者 输入会有不同的形式,客户端请求,提议,提交事务 通过箭头来标示追随者处理的不同路径 本地存储 事务日志和快照 SyncRequestProcessor在处理提议写入这...

02/27 11:12
19
zk中的会话管理SessionTrackerImpl

SessionTrackerImpl中包含实现SessionImpl继承Session(在SessionTracker中) SessionTracker接口 SessionImpl是session属性集合类 属性 sessionsById sessionid和会话的对应map sessionExpi...

10/11 14:50
12
zk集群版服务启动,Leader和Follower之间数据交互

集群版服务启动过程 LeaderElection算法 完成自己投票和投票算法的获取 集群特有,zookeeper首先会根据自身服务器id(sid) 最新的zxid(lastloggedZxid)和当前的服务器epoch(currentEpoch) 来生...

10/12 17:35
15
zk中ServerCnxnFactory连接管理工厂

作为ServerCnxn的工厂抽象类 属性 ZOOKEEPER_SERVER_CNXN_FACTORY zookeeper.serverCnxnFactory secure 在ServerCnxnFactory中SSL是否启用 sessionMap session管理配置中信息(sessionId,Ser...

前天 11:08
11
深入了解zookeeper中的角色,和角色之间的关系

zookeeper中的角色 :群主,群员,观察者 exists,getData getChildren 会直接处理,在以请求为主要负载时,性能很高 create ,delete setData 会转发给群主处理,并形成事务 如 设置某个节点的...

02/26 17:24
80
zk服务器异常报警,线程服务关闭机制

主要查看ZooKeeperServer 监听与服务器关系类图 疑问:重要线程关闭或中断的时候?这个监听器在什么时候被调用呢? 接口 ZooKeeperServerListener void notifyStopping(String threadName, i...

10/12 11:09
13
hadoop集群中一些默认的端口和配置大全

Hadoop集群的各部分一般都会使用到多个端口,有些是daemon之间进行交互之用,有些是用于RPC访问以及HTTP访问。而随着Hadoop周边组件的增多,完全记不住哪个端口对应哪个应用,特收集记录如此...

2016/11/14 17:37
2.6K
kafaka了解

kafaka是一个消息系统,linkedIn被用作活动流和数据处理管道,它要作为一个队列平台,既能支持离线又能支持在线 消息,话题,队列,生产者,代理,使用者,使用者小组,消息集 Btree O(log N)...

2016/12/22 20:03
102
storm的使用笔记

storm的使用笔记 1. 关于log 用storm jar ...将项目提交给storm集群后,想查看本项目的log信息,要到supervisor机器的:storm安装路径/logs/worker-number.log(其中的number视实际情况而定)...

2016/12/16 17:05
18

没有更多内容

加载失败,请刷新页面

返回顶部
顶部