zk中ServerCnxn的用法
这篇文章主要讲解了“zk中ServerCnxn的用法”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“zk中ServerCnxn的用法”吧!
实现接口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(); } }
感谢各位的阅读,以上就是“zk中ServerCnxn的用法”的内容了,经过本文的学习后,相信大家对zk中ServerCnxn的用法这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!