21_尚硅谷_Zookeeper_服务器节点动态上下线案例注册代码.avi原创

好，刚才呢，我们对这个案例呢，进行一个综合的分析，那下面呢，我们开始写这个具体服务器动态上下线的一个案例啊代码。呃，这个主机标集群里面的代码用不用写。想一想用不用写这个主页基金代码。不需要啊，只需要把它启动起来就OK了吧，是不是需要一个启动啊，而且目前我们这个基金起没起来。是已经起来了。是已经启动起来了，哎，那就说这里面，呃，其中的主K边集群我们已经搞定了，那剩下的就是有两个角色，一个是服务器，一个是狗的。对吧，啊，而且呢，他们相对于这个主K集群来说都是够的。好，那我们先写谁呢？先写这个数据的来源，注册他是负责什么？像这个目录下是不是写数据啊。

那就写呗，OK，写不气啊。把服务器先写了。创建一个类。那么在这个类当中定一个没方法。在没方法中，我们要做什么事呢？第一件事儿。你要不要连接到这个主页集群呢？你想想你这是客户端对吧，客户端你是不是要访问这个server，哎，那你是不是要连接啊。那就是连接服务器。集群啊，连接它连接完了之后，你是不是要向这个集群上进行一个注册操作。注册是什么意思？

注册是不是就是向这个集群上进行写呀，啊创建一个server。啊，然后下面有一堆一堆server啊，是不是往往这个去写这个数据啊啊。去创建它啊，相当于创建节点，那这个呢，就是注册。注册节点注册节点。注册完了，正常你这个客户端有这个这个客户端他还有自己的业务代码吧。是他自己的业务代码。处理。基本上呢，分这么三大步啊。那么第一个获取这个连接，那么需要创建一个方法。那这个方法呢，我们可以。一个对象啊，就用这个类自己啊，然后自己呢，调查自己的一个方法，不知道你们玩没玩过哈。比如说又一个。地表的时候。获取到这个对象。那那就是一个so。

拿到这个server，我们创建一个对象。第二。Get seven city。也说我要在这个类里面定义一个get connect方法。创建一下。那你要想连接这个。曹姐呢？又一个主对个对象不就完了吗？对吧，又一个这对象，那这对象里面呢，有三个。参数需要我们写一下。这个还记得吗，行吗？嗨豆1022181，嗨豆吧，1032181。嗨，豆1042181。那下面呢，是超出时间设置一下。多少了，记得不？

啊，2000也就两秒是吧，好。那这个呢，需要创建一个又一个。抛出异常。那这个呢，也得往外跑。呃，抛一个大的抛个。好，拿到这个对象。JK。这样就拿到了它啊。那剩下的事下边，哎，这个相当于你已经跟这个主力包集群建立了网络连接，那剩下的事就需要你注册，那注册的话有注册的方法d re SD。写代码都是这么写的。不撤。那你注册的话，相当于向这个服务器上是不是写数据啊。

现在创建，那就是拿到这个JKCLA来。来的。是获取链接的时候拿到的啊，他拿到的，拿到它之后点。放架子。那这次就是不陌生，刚才呢，已经把这个API练过了。啊，中间。那创建你看这张图哈，啥意思。是不是将这个服务器的信息写入到这个节点上。首先前面是。没问题，后面是不是写的这个。主机名称啊。我要往serve serve1下面。然后里面这个一里面填的就是还101，那我再写二，那就是102。43103。回来回来。那第一个是路径，那这个路径就是。下面加一个。

不写了。那不写了，那你看啊，我这是当前这个客户端，我运行一次。他能创建一个节点。这个。那么再执行一遍呢？那这节点是不是就相当于已经存在了？那什么样的节点允许这么无限的覆盖呢？是不是带序号的啊，带序号的同时这个节点如果说他下线了。是要挂掉啊，那这个属于什么性质。出杠一啊，哎，杠一离暂时的节点啊，那这也是带编号的。所以说那最终就决定了我们这个位置设置的类型是不是只能有一种啊。啊，那这种是什么呢。点。临时的临时的，临时的带序号的说。那在这个数据里面，我是不是要传下当前的主机的名称啊？

当前这个服务器，它是哪一个服务器？这个能是一个固定的值吗？啊，你运行一下，那你这个船谁呀？写驶是写驶成101，那我下次再运行呢，还是101吗。不行，那怎么办呢？动态获取是吧。Host。那这个值从哪来传进来？那你在里面传进来，那它又是从哪来呢？是从外边来啊。那外边能从哪呢？比如说在运行的参运行的时候，我就把你这台服务器，我给你设置一个主题名称是谁，那就通过它传进来。传来之后，那就会进入到这儿啊。进入到这点get get啊，别忘了找上它。OK，那这个呢。

Ids点第二个就行。发生异常。那这个呢，有个返回值，返回值。这就创业成功了。相当于拿到了这个客户端对象，哎，在这个路径上。创建了一个节点，那这个节点上的数据就是post，那这个名称是通过二传进来的。你说看你执行几遍这个server啊，运行一遍开几个客户端，运行一遍开几个客户端。那后面这个就是常规操作，只不过这个它只能是这种暂时的带句号的。暂时的是因为这个服务器一下线，那这个节点是不是要取消啊哎。杠S呢，是因为你这块写死的路径，那它不能重复。要想让它不重复，那就加上编号，它自动的给你维护，保证它不重。

这么。那相当于当前host name这台主机。怎么的呢？Is on one。是上线了。小时他上线了啊。那这个呢，就是注册，注册完了之后，他自己正常的代码，还会有他自己的业务逻辑。第2B。自己的业务处理。那处理一下吧，哎，往这里面干什么呢。不着要就会。睡觉啊。Sleep。长长的那。一张。

其实睡觉是为了干啥呀？为了长身体。睡觉呢，是为了是不是这个进程不结束啊，啊，为了这个进程不结束啊，OK。让他活着，对，还证明他活着。那好，那这呢，就是整个这个distribute server，它的业务逻辑啊，看一下啊，回顾一下，创建了一个自己的对象，那在这里面呢，定义了一个get方法。然后一个注册节点的方法啊，一个业务国际。正常情况下，一个架构师他只负责写这些。写完剩下的每一块分给不同的网。那这是connect connect。等待呢，就是创建一个客户端对象啊，没啥说的啊。引用一个主配本就行，只不过呢，这里三个参数相信大家不陌生啊，连接主推本集群用的。那连接的过程中呢，超时时间设置。最后呢，是一个包啊，这里面没有用啊，先放在这儿OK。

那这个客户端对象准备好之后，那剩下的就是具体的去如何注册，注册说的比较高大上，呃，比较接地气一点呢，就是。就是创建一个节点啊，这个节点呢，在这个路径下。里面存放的就是主机的名称，这个主机名称呢，不能写时需要呢，你从外界传进来啊。啊，每运行一次更新一个。那另一个呢，这个后面这个模式呢，只能是杠一和杠S刚才解释过了。然后他启动。最后这个B呢，其实就是这样的啊，一直睡，保证这个进程不结束。就OK了啊。好，一会儿我们综合来调试。