ZooKeeper 实战与源码剖析
么敬国
新东方集团首席架构师
18975 人已学习
新⼈⾸单¥59
课程目录
已完结/共 47 讲
ZooKeeper 实战与源码剖析
登录|注册
留言
3
收藏
沉浸
阅读
分享
手机端
回顶部
当前播放: 39 | ZooKeeper的客户端网络通信源码解读
00:00 / 00:00
高清
  • 高清
1.0x
  • 2.0x
  • 1.5x
  • 1.25x
  • 1.0x
  • 0.75x
  • 0.5x
网页全屏
全屏
00:00
付费课程,可试看
01 | 课程介绍
02 | 内容综述
03 | 什么是ZooKeeper?
04 | ZooKeeper提供什么服务?
05 | 开始使用ZooKeeper
06 | 使用ZooKeeper实现Master-Worker协同
07 | ZooKeeper架构解析
08 | ZooKeeper API简介
09 | ZooKeeper API:Watch示例
10 | 使用ZooKeeper实现分布式队列
11 | 使用ZooKeeper实现分布式锁
12 | 使用ZooKeeper实现选举
13 | 使用Apache Curator简化ZooKeeper开发
14 | 如何安装配置一个ZooKeeper生产环境?
15 | 如何进行ZooKeeper的监控?
16 | 通过ZooKeeper Observer实现跨区域部署
17 | 通过动态配置实现不中断服务的集群成员变更
18 | ZooKeeper节点是如何存储数据的?
19 | 使用ZooKeeper实现服务发现(1)
20 | 使用ZooKeeper实现服务发现(2)
21 | 使用ZooKeeper实现服务发现(3)
22 | Kafka是如何使用ZooKeeper的?
23 | 什么是Paxos协议?
24 | 对比Chubby和ZooKeeper
25 | Raft协议解析
26 | 什么是etcd?
27 | etcd API: KV部分
28 | etcd API:Watch和Lease部分
29 | 使用etcd实现分布式队列
30 | 使用etcd实现分布式锁
31 | 如何搭建一个etcd生产环境?
32 | 存储数据结构之B+tree
33 | 存储数据结构之LSM
34 | 本地存储技术总结
35 | ZooKeeper本地存储源码解析
36 | 网络编程基础
37 | 事件驱动的网络编程
38 | Java的事件驱动网络编程
39 | ZooKeeper的客户端网络通信源码解读
40 | ZooKeeper的服务器网络通信源码解读
41 | ZooKeeper的Request Processor源码解读
42 | Standalone的ZooKeeper是如何处理客户端请求的?
43 | Quorum模式下ZooKeeper节点的Request Processor Pipeline
44 | ZooKeeper的Leader Election
45 | ZooKeeper的Zab协议
46 | 客户端和服务器端交互:Watch和Session
47 | 结课测试&结束语
登录 后留言

全部留言(3)

  • 最新
  • 精选
李春恒
如何切到netty通信呢, 看到官方文档上写着:NIO continues to be the default, however Netty based communication can be used in place of NIO by setting the environment variable "zookeeper.serverCnxnFactory" to "org.apache.zookeeper.server.NettyServerCnxnFactory". 默认情况下,zkServer.sh start 启动后,查看zk的日志,可以看到: 2019-12-11 00:12:40,842 [myid:] - INFO [main:ServerCnxnFactory@135] - Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory 小弟花了半个小时才实验成功,分享给大家。 【服务端zkServer.sh】 在 $ZK_HOME/conf 目录下创建一个 java.env文件,并配置: JVMFLAGS="-Dzookeeper.serverCnxnFactory=org.apache.zookeeper.server.NettyServerCnxnFactory -Dzookeeper.clientCnxnSocket=org.apache.zookeeper.ClientCnxnSocketNetty " 如果使用zkCli.sh访问时想使用netty,就加上clientCnxnSocket的配置,如上。 通过zkServer.sh start 启动后,查看zk启动日志,检查是否使用Netty通讯: 2019-12-11 00:37:14,230 [myid:] - INFO [main:ServerCnxnFactory@135] - Using org.apache.zookeeper.server.NettyServerCnxnFactory as server connection factory 【客户端使用IDEA】 在VM options中添加下面配置即可: -Dzookeeper.clientCnxnSocket=org.apache.zookeeper.ClientCnxnSocketNetty 如果仅调试netty在zookeeper 客户端执行流程中的使用,只配置客户端为netty即可。 如果使用SSL的话。则必须使用netty通信。 SSL is only supported on top of Netty communication, which means if you want to use SSL you have to enable Netty.

作者回复: 赞

2019-12-11
3
飞翔
老师 也就是eventthread 只在异步调用的时候存在是吧

作者回复: 它除了您说的用处,还有很多其他用处,比方说处理API注册的watch,比如https://zookeeper.apache.org/doc/r3.5.5/api/org/apache/zookeeper/ZooKeeper.html#getData-java.lang.String-boolean-org.apache.zookeeper.AsyncCallback.DataCallback-java.lang.Object-注册的watch。 eventThread一直运行。ClientCnxn的start会启动这个thread,https://github.com/apache/zookeeper/blob/release-3.5.5/zookeeper-server/src/main/java/org/apache/zookeeper/ClientCnxn.java#L408。在创建一个ZooKeeper是会调用cnxn.start()。

2019-11-01
Geek_zhw
感谢老师分享心得
2021-04-29
收起评论