2020-07-28

5 异步处理,业务链路上有任何时间消耗较长,可以拆分业务,减少阻塞影响,常见的异步处理机制有MQ(消息队列),目前在互联网应用中大量使用。这里了解一下kafka,因为kafKa基于zookeeper的分布式消息平台,他同时也是一款开源的基于发布订阅模式的消息引擎系统,这里了解一下zookeeper,功能非常强大,可以实现诸如分布式应用配置管理,统一命名服务,状态同步服务,集群管理等功能,我们这里拿比较简单的分布式应用配置管理为例来说明,假设我们的程序是分布式部署在多台机器上,如果我们要改变程序的配置文件,需要逐台机器去修改,非常麻烦,现在把这些配置全部放在zk上去,保存在zk的某个目录节点中,然后所有相关应用程序对这个目录节点进行监听,一旦配置信息发生改变,每个应用程序就会收到zk的通知,然后从zk获取新的配置信息应用到系统中。

安装zk:1 .下载并解压zookeeper:wget +URl (镜像网站)  tar -zxvf zookeeper-3.4.12.tar.gz    cd zooKeeper-3.4.12

重命名配置文件 cp conf/zoo_sample.cfg  conf/zoo.cfg

启动zookeeper  bin/zkServer.sh start

检测是否成功启动,用zookeeper客户端连接服务端

bin/zkCli.sh

Zookeeper的使用:

使用客户端命令操作zookeeper

1.使用ls命令来查看当前Zookeeper中所包含的内容2.创建一个新的znode,使用create /zkPro myData 3.再次使用ls命令来查看现在zookeeper中所包含的内容 4.下面我们运行get命令来确认第二步中所创建的znode是否包含我们所创建的字符串5删除  delete  /zkPro

使用java api操作zookeeper

org.apache.zookeeper

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。