当前位置: 首页 > 网络应用技术

Zookeeper的Watcher界面如何意识到?

时间:2023-03-06 17:52:01 网络应用技术

  早些时候,我们看到了观察者的基本概念以及Zookeeper的一些使用场景,它是如何做到的;

  下面我们说出它是如何通过其监视或接收通知来完成的。首先,我们必须了解官方动物园管理员课程的解释。

  我们查看先前分布式锁定的代码逻辑的GetChildren方法,它将返回给定方式节点的子节点列表。如果观看是真实的,并且成功呼叫(没有异常),则将离开在给定路径节点上的手表。特定方法是,当您将手表设置为True时,它将为特定路径注册一个观察者,将其提供给观察者,将其送达特定路径。观察者Fuzi节点监视注册表,

  请求头的类型在这里是8,如果创建为1(其他值在zoodefs.opcode接口中),然后通过cnxn.submitrequest(H,请求,响应,WCB);在Queuepacket对象中打包,并打包然后存储在LinkedBlockingdeque列表的链接镇流器中以发送。我们可以看到添加队列的方式;

  同步代码块的官方说明是:同步块此处具有两个目的:1。与sendthread.run()中的Final clearron()同步以避免竞争2.每个数据包的同步。因此,如果Clossession Packet为补充说,稍后将通知数据包;

  对于这种状态,我学会了另一个名词和守护线。在这里,它将设置一个监护线:当JVM退出时,线程可以自动关闭;

  我们将沿SendThread搜索找到SendPacket方法,并继续找到CreateBB方法;

  它具有序列化,Baidu具有序列化定义:序列化是将对象状态转换为形式或可传输形式的过程。序列化补充是备份,后者将转换为对象。这些过程确保了两个过程。数据易于存储和传输。

  

  result.Addlistener(OnSendPktDonelistener);这是为了聆听,什么是OnSendPktDonelistenerer。此处写的是使用单个监视器实例来减少GC。如果成功,发送计数将累积;

  观看状态后,继续观看WaitforPacketFinish;

  让我们看看注册方法;

  翻译是将观察者注册到一组观察者。参数:RC-尝试在路径上添加监视操作的结果代码;让我们下次谈论它,这么长时间,后来的监视处理被分为下一部分。好的!