`
QING____
  • 浏览: 2250646 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Zookeeper-Client端初始化过程.

 
阅读更多

Zookeeper全参数构造函数:

  • public Zookeeper(String connectString,int sessionTimeout,Watcher watcher,long sessionId,byte[] sessionPWD,boolean canBeReadOnly)

 

F1 Zookeeper实例整体过程



 F2 内部原理

 

 

 

  1. 如果server端开启了”readonlymode.enabled”,即允许当前server可以readonly方式运行,
  2. 当server端尚未加入集群(处于LOOING状态),或者集群处于”危险状态”(大多数机器已经失效),那么此时server将会readonly模式,即只能接受read,不能接受write.因为此时write将无法保证在整个集群中是”一致性成功”的.
  3. 处于LOOKING状态的server,会将实例化一个ReadOnlyZookeeper实例来为当前server上的所有请求服务.
  4. 如果client允许连接readonly server(当然也可以连接R/W server),那么在实例化ZK时,传递canReadonly = true即可.在client与server建立链接时(其他请求时也会),将会把此参数交付给server,server会回馈自己的模式是不是readonly.如果client和一个”只读”模式的server建立了链接,那么client在SendThread的处理体中,开启一个pingRW的分支,通过ping的方式查找server列表中是否有server已经处于R/W模式,如果找到,那么将以异常的方式(RWServerFoundException)结束当前socket,并和R/W server建立链接.这些过程,将对Client不可见.
  5. Client通过将请求/响应队列化来确保所有交互的有序性,xid是client维护的唯一性id.server端也会做类似的全序性控制.如果发现交互中次序不符合约定,将会导致异常.
  6. connectString即为客户端可以连接的Server列表,此列表必须和server配置的列表一致。即使不一致,也能工作,比如client交付了server配置列表的一部分;不过如果client交付的列表不在server配置中或许不能工作。


源码参考:
1)    Zookeeper:面向client服务类,通过此类可以创建ZK client实例,以及向server提交请求,此类还间接的负责Watcher的注册和跟踪.
2)    ClientCnxn:client与server交互处理类,负责根据请求类型/数据信号,封装请求内容;负责根据server响应的内容/error信号,封装响应内容或者触发本地事件;根据链接状态或者server响应内容,转换client状态.
3)    ReadOnlyZookeeperServer:只读模式下,Server将会实例化一个临时的此实例,为client服务.
4)    ServerCnxn/NIOServerCnxn:server端处理请求的handle类,通过工厂模式为每个client绑定一个.注意,它只是handle类,仍然会在单线程模式下被使用,被相应的ZookeeperServer实例所调度.

  • 大小: 73.9 KB
  • 大小: 112 KB
分享到:
评论

相关推荐

    apache-zookeeper-3.5.10-bin.tar.gz

    3. **集群初始化**:在每个服务器上创建`dataDir`目录,并在其中创建`myid`文件,文件内容为该服务器的ID,与`zoo.cfg`中的`server.x`对应。 4. **启动与管理**:使用`bin/zkServer.sh`脚本来启动、停止或检查...

    apache-zookeeper-3.6.2-bin.tar.gz

    4. 初始化数据目录:`mkdir -p $ZOOKEEPER_HOME/data`,并创建myid文件,写入该服务器的ID(1-255之间)。 5. 启动Zookeeper:`$ZOOKEEPER_HOME/bin/zkServer.sh start` 标签"zookeeper"进一步强调了主题是关于...

    最新版windows apache-zookeeper-3.6.1-bin.tar.gz

    3. 初始化数据目录,创建一个名为`myid`的文件,其中包含表示当前服务器ID的唯一数字。 4. 启动Zookeeper服务,可以通过运行解压目录下的`bin/zkServer.cmd`脚本来启动服务。 5. 使用`bin/zkCli.cmd`命令行工具与...

    zookeeper-3.4.5-cdh5.15.1.tar.gz

    3. **初始化数据目录**:在dataDir路径下创建myid文件,写入该节点的ID,用于标识不同的Zookeeper节点。 4. **启动Zookeeper**:在Zookeeper目录下,执行`bin/zkServer.sh start`命令启动服务。通过`bin/zkServer....

    apache-zookeeper-3.6.3-bin.zip

    四、初始化数据目录 在`dataDir`目录下创建一个名为`myid`的文件,内容为该Zookeeper实例的唯一ID(1-255之间的数字)。在单机模式下,通常设置为1。 五、启动Zookeeper 在命令行中,进入Zookeeper的bin目录,运行`...

    zookeeper-3.4.10.tar.gz

    - `initLimit`和`syncLimit`:分别设定初始化同步和运行时同步的超时时间。 四、启动与使用 1. 创建数据目录:根据`dataDir`配置创建数据目录,并在其中创建一个myid文件,内容为该服务器的ID(0-255)。 2. ...

    PyPI 官网下载 | cs18-api-client-0.0.2.1484.tar.gz

    具体的使用方式可能会包括初始化客户端对象,设置和获取配置,监控Zookeeper节点状态等。 综上所述,cs18-api-client是一个Python编写的云原生Zookeeper客户端库,它允许开发者在分布式环境中轻松地与Zookeeper服务...

    PyPI 官网下载 | cs18-api-client-0.0.2.2185.tar.gz

    通常,这包括初始化客户端,设置必要的配置,然后调用相应的函数来执行所需的操作。 总结,cs18-api-client-0.0.2.2185.tar.gz是PyPI上一个针对cs18服务的Python库,它整合了Zookeeper的分布式协调能力,并且遵循云...

    apache-zookeeper-3.5.9-bin.rar

    4. **初始化数据目录**:创建 `dataDir` 中的 `myid` 文件,其中写入代表当前服务器的唯一ID(1-255之间),这个ID在 `zoo.cfg` 中的 `server.<id>` 配置段中对应。 5. **启动Zookeeper**:使用 `zkServer.sh` 脚本...

    PyPI 官网下载 | cs18-api-client-0.0.2.2156.tar.gz

    "PyPI 官网下载 | cs18-api-client-0.0....为了更好地利用这个库,需要了解它的API文档,学习如何初始化客户端,调用其提供的方法,以及如何处理返回的数据。同时,阅读源代码和示例可以帮助理解其工作原理和最佳实践。

    PyPI 官网下载 | ory-hydra-client-1.10.5.tar.gz

    对于开发者来说,阅读库的README文件和官方文档至关重要,它们将提供如何初始化客户端、如何调用不同功能的详细指南。 总的来说,ory-hydra-client是一个专为ORY Hydra设计的Python客户端库,适用于分布式和云原生...

    zookeeper-3.4.5安装包.tar.zip

    5. **初始化数据文件**:在`dataDir`下创建一个名为`myid`的文件,该文件只包含一个表示此服务器ID的数字。ID应为集群中的唯一值,通常从1开始。 6. **启动ZooKeeper**:在解压的ZooKeeper目录下,执行以下命令启动...

    apache-zookeeper-3.6.1 (1).tar.gz

    4. **initLimit** 和 **syncLimit**:分别定义了初始化同步和运行时同步的最大时间限制。 安装完成后,可以通过 `zkServer.sh start` 和 `zkServer.sh stop` 脚本来启动和停止 ZooKeeper 服务。为了确保服务正常...

    PyPI 官网下载 | cs18-api-client-0.0.2.2285.tar.gz

    # 初始化客户端 client = cs18_api_client.Client() # 调用API方法 response = client.some_api_method() ``` 具体如何使用取决于库的文档和API设计。 综上所述,`cs18-api-client`是一个用于与cs18 API交互的...

    PyPI 官网下载 | socketIO-client-2-0.7.4.tar.gz

    使用socketIO-client时,我们需要导入模块并初始化客户端。例如: ```python from socketIO_client import SocketIO socketIO = SocketIO('server_address') ``` 然后,我们可以监听服务器的事件,同时发送事件到...

    apache-zookeeper-3.6.0-bin.zip

    3. **初始化数据目录**:在 `dataDir` 指定的目录下创建一个名为 `myid` 的文件,其中包含表示当前服务器ID的数字,用于标识ZooKeeper集群中的节点。 4. **启动ZooKeeper**:使用 `bin/zkServer.sh start` 命令启动...

    ZooKeeper-分布式过程协同技术详解.pdf

    使用 ZooKeeper 类之前,需要初始化一个 ZooKeeper 对象,通常需要指定一组 Server 的地址列表以及超时时间。 ##### 3.3 基本的操作方法 ZooKeeper 提供了一系列基本的操作方法,如创建节点、获取节点数据等。 ###...

    PyPI 官网下载 | recital-client-0.1.0.tar.gz

    为了深入理解和使用`recital-client`,开发者需要查看其官方文档(如果有的话),了解如何安装、初始化和调用库的方法,以及其提供的具体功能。此外,源代码可以帮助开发者理解其内部工作原理,以便进行定制化开发或...

    zookeeper-3.3.4.tar.zip

    4. 初始化数据目录:在`dataDir`目录下创建一个名为`myid`的文件,写入该节点在集群中的唯一ID,用于区分不同节点。 5. 启动Zookeeper:执行`$ZOOKEEPER_HOME/bin/zkServer.sh start`启动服务。 四、Zookeeper的...

    PyPI 官网下载 | modelstatus-client-2.0.0.tar.gz

    例如,可能有初始化客户端、获取模型状态、设置模型状态等操作。为了确保正确使用,开发者应该阅读`README`和`docs`中的内容,了解库的使用方法、最佳实践以及任何需要注意的事项。同时,测试用例可以帮助理解库的...

Global site tag (gtag.js) - Google Analytics