一.单节点 1.上传Kafka安装包到Linux系统【当前为Centos7】。 2.解压,配置conf/server.property。 2.1配置broker.id 2.2配置log.dirs 2.3配置zookeeper.connect 3.启动Zookeeper集群 备注:zookeeper集 ...
分类:
其他好文 时间:
2019-04-07 13:11:03
阅读次数:
159
/**前台传过来一个文件名*/ @RequestMapping("/download") public ResponseEntity export(@RequestParam("strZipPath") String strZipPath) throws IOException { //filepa... ...
分类:
编程语言 时间:
2019-03-27 11:11:45
阅读次数:
151
一、带版本控制的注册中心RPC框架 server端 客户端 二、模拟集群 新增发布类: 修改示例2类的注解 运行发布类1,2 linux 下查看节点显示: [zk: localhost:2181(CONNECTED) 13] ls /registrys/zoorpc.IHelloWorld[127. ...
分类:
其他好文 时间:
2019-03-19 01:27:02
阅读次数:
117
在使用zookeper的时候一般不使用原生的API,Curator,解决了很多Zookeeper客户端非常底层的细节开发工作,包括连接重连、反复注册Watcher和NodeExistsException异常等等。 Curator包含了几个包: curator-framework:对zookeeper ...
一 .概述 在zk之中,对于每一个节点都有一个监听器,我们称这个对象为watcher对象. 当一个节点发生变化的时候,都会触发不同的事件,我们可以捕获这些事件,完成特定的功能. 在zk之中,节点可能存在子节点,当子节点发生变化的时候,父节点会受到对应的事件. 二 .设置watch 在zk之中,我们可 ...
分类:
其他好文 时间:
2019-03-05 21:37:07
阅读次数:
155
redis的分布式锁,基于while循环不停的尝试,可以回导致占用cpu,能减缓的方法就是通过sleep一段时间 再去尝试,其实并不ok zookeeper做分布式锁, 是通过在zk上新建一个根node 通过client下面新建临时的node 把这些Node的id的序号设置成有序的,当前client ...
分类:
其他好文 时间:
2019-02-22 00:43:39
阅读次数:
180
搞懂分布式技术3:初探分布式协调服务zookeeper 1.Zookeepr是什么 Zookeeper是一个典型的分布式数据一致性的解决方案,分布式应用程序可以基于它实现诸如数据发布/订阅,负载均衡,命名服务,分布式协调/通知。集群管理,Master选举,分布式锁和分布式队列等功能。 2.zooke ...
分类:
其他好文 时间:
2019-02-08 21:57:02
阅读次数:
199
vue的依赖收集是定义在defineReactive方法中,通过Object.defineProperty来设置getter,红字部分主要做依赖收集,先判断了Dep.target如果有的情况会执行红字逻辑进行依赖收集过程 Dep是一个类,target是Dep的一个静态属性,是一个Watcher,上面 ...
分类:
其他好文 时间:
2019-02-08 14:33:26
阅读次数:
134
欢迎来到分布式管中窥豹之zookeeper小白学习系列,本系列会记录zookeeper以及分布式系统学习过程中的一些操作和细节,大饼果子非科班出身,如有错误,欢迎指出 在了解节点结构之后,我们深入探究一下节点的一些属性 1. 临时与持久 znode按照生命周期划分属性可分为临时节点(ephemera ...
分类:
其他好文 时间:
2019-01-28 13:50:34
阅读次数:
182
分布式锁现在用的越来越多,通常用来协调多个并发任务。在一般的应用场景中存在一定的不安全用法,不安全用法会带来多个master在并行执行,业务或数据可能存在重复计算带来的副作用,在没有拿到lock的情况下扮演者master等诸如此类。
要想准确的拿到分布式锁,并且准确的捕获在分布式情况下锁的动态转... ...
分类:
其他好文 时间:
2019-01-26 13:21:07
阅读次数:
211