文档章节

zk中ServerCnxn

writeademo
 writeademo
发布于 10/16 17:43
字数 127
阅读 9
收藏 0

实现接口Stats, Watcher

内部类

DisconnectReason

CloseRequestException

EndOfStreamException(流关闭)

属性

 

方法

getSessionTimeout

获取session失效时间

sendResponse

发送回复数据

serializeRecord

序列化record

process(WatchedEvent event)

 

getSessionId()

 

packetReceived(long bytes)

 

getLastZxid()

获取最新事务id

getConnectionInfo(boolean brief)

 
   
protected void packetReceived(long bytes) {
    incrPacketsReceived();
    ServerStats serverStats = serverStats();
    if (serverStats != null) {
        serverStats().incrementPacketsReceived();
    }
    ServerMetrics.getMetrics().BYTES_RECEIVED_COUNT.add(bytes);
}


protected void packetSent() {
    incrPacketsSent();
    ServerStats serverStats = serverStats();
    if (serverStats != null) {
        serverStats.incrementPacketsSent();
    }
}

© 著作权归作者所有

writeademo
粉丝 25
博文 700
码字总数 267560
作品 0
东城
私信 提问
zk中ServerCnxnFactory连接管理工厂

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

writeademo
10/17
12
0
zookeeper watcher机制

客户端ClientWatchManager,管理由ClientXncn产生的watchers和handle events。在zookeeper的exists、getChildren、getData等这些API中可以注册watcher对象到ClientWatchManager中,create、s...

jeff_han
2015/11/27
759
0
ZooKeeper源码研究系列(3)单机版服务器介绍

1 系列目录 - ZooKeeper源码研究系列(1)源码环境搭建- ZooKeeper源码研究系列(2)客户端创建连接过程分析- ZooKeeper源码研究系列(3)单机版服务器介绍- ZooKeeper源码研究系列(4)集群...

乒乓狂魔
2015/08/13
2.7K
0
ZooKeeper源码研究系列(5)集群版建立连接过程

1 系列目录 - ZooKeeper源码研究系列(1)源码环境搭建- ZooKeeper源码研究系列(2)客户端创建连接过程分析- ZooKeeper源码研究系列(3)单机版服务器介绍- ZooKeeper源码研究系列(4)集群...

乒乓狂魔
2015/08/24
6.7K
2
Zookeeper-watcher机制源码分析(二)

服务端有一个NettyServerCnxn类,用来处理客户端发送过来的请求 NettyServerCnxn public void receiveMessage(ChannelBuffer message) { try { while(message.readable() && !throttled) { ......

Java架构
2018/08/07
0
0

没有更多内容

加载失败,请刷新页面

加载更多

006-Docker中导出单个或多个tar包

docker中导出单个镜像和多个镜像的tar包 docker save [images] > [name.tar] docker save [images] [images] > [name.tar]...

伟大源于勇敢的开始
今天
8
0
Kotlin基础语法学习

安装好安卓studio,以及插件支持Kotlin 就可以在创建项目的时候选择 Kotlin语言了。 https://www.jianshu.com/p/4ab13691d681 参考手册: https://www.runoob.com/kotlin/otlin-android-setu...

T型人才追梦者
今天
6
0
java实现简单计算器

1.概述 之前作者写过一篇文章,也是关于计算器的,用的是C++与Qt,链接在这里 这次用java的swing写的(这差距好像有点大,好吧是qt太强了). 先上图: 2.UI 总体布局使用流布局. (1)文本框 文本框就...

Blueeeeeee
今天
9
0
纯CSS实现DIV悬浮(固定位置)

纯CSS实现的DIV悬浮效果(固定位置),兼容常用的浏览器:IE8、360、FireFox、Chrome、Safari、Opera、傲游、搜狗、世界之窗等。效果如下: 实现代码: <!DOCTYPE html> <html> <head> <meta ...

独钓渔
今天
6
0
OSChina 周二乱弹 —— 给我来个女菩萨

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @这次装个文艺青年吧 :#今日歌曲推荐#分享XXXTENTACION/Travis Barker的单曲《Pain = BESTFRIEND》: 《Pain = BESTFRIEND》- XXXTENTACION/...

小小编辑
今天
137
4

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部