下载Kafka和Zookeeper镜像文件 先运行zk，再运行kafka 创建主题 在项目代码我们可以进行AOP日志处理，将异常信息 发送到Kafaka 然后 Logstash订阅话题，将数据写入到ES中。 Logstash配置: 通过Logstash去订阅主题，主题要保持一致与代码，与创建的主题。 ...
分类：
其他好文 时间：
2019-08-24 22:45:11
阅读次数：
118
问题描述 测试环境ZK集群的三个节点中zk1状态虽然是 ，启动也能正常启动（通过telnet也能telnet 2181端口）; 无法通过zk客户端去连接2181端口，状态一致是 查看zk集群所有节点状态 得到zk2是主节点 查看各个节点的data数据大小 结果： zk1节点的数据落后其它节点太多，查 ...
分类：
其他好文 时间：
2019-08-24 18:52:02
阅读次数：
66
学了zookeeper有一段时间了，写个博客记录一下。。。 一、zookeeper是什么？ zookeeper是一个高效的分布式协调服务，它暴露了一些公共服务，比如起名/配置管理/同步控制/群组控制等。我们可以使用zk来实现达成共识、集群管理、lender选举等。 zookeeper是一个高可用的分 ...
分类：
其他好文 时间：
2019-08-23 19:21:41
阅读次数：
88
1、安装 可参照Ubuntu 搭建Zookeeper服务进行安装并启动。 2、注意 阿里云环境开放2181端口 2.1 查看已开放端口： 2.2 永久的添加该端口。去掉--permanent则表示临时。 2.3 加载配置，使得修改有效 2.4 阿里云安全规则添 3、java来接测试 pom文件依赖引 ...
分类：
编程语言 时间：
2019-08-22 00:48:43
阅读次数：
122
1.1. 客户端源码 1.1.1. 总体流程 启动客户端 zkCli.sh文件里面的配置 实际运行 Main方法流程： 在ZookeeperMain的构造方法里面，重点是 最终在connectToZK方法里面也就是使用原生的Zk客户端进行连接的。 public void start() { send ...
分类：
其他好文 时间：
2019-08-21 23:23:00
阅读次数：
459
分布式锁有几种实现形式 n个线程同时并发－countdown zk配置中心，watch机制底层 zk分布式锁 并发的实践 说说springcloud组件 自己实现一个生产者、消费者 java 基本类型与包装类型 redis底层zset实现 mysql索引底层说一下 B＋树 自平衡 myisam和in ...
分类：
其他好文 时间：
2019-08-19 23:11:43
阅读次数：
98
作为服务注册中心，Eureka比Zookeeper好在哪里 著名的CAP理论指出，一个分布式系统不可能同时满足C(一致性)、A(可用性)和P(分区容错性)。由于分区容错性在是分布式系统中必须要保证的，因此我们只能在A和C之间进行权衡。在此Zookeeper保证的是CP, 而Eureka则是AP。 1 ...
分类：
其他好文 时间：
2019-08-16 22:26:19
阅读次数：
707
1. Zookeeper基础 1.1. 部署 先把ZK安装起来，后面的很多操作，都是的前提都是由ZK的操作环境，先来把ZK安装好， 1.1.1. Zookeeper windows环境安装 环境要求:必须要有jdk环境,本次讲课使用jdk1.8 1.安装jdk 2.安装Zookeeper. 在官网h ...
分类：
其他好文 时间：
2019-08-14 14:57:11
阅读次数：
231
场景说明：当客户端与服务端在不同区域（跨防火墙，地址均做了映射）时，客户端访问kafka时会出现获取不到broker的问题，但是网络之间是互通的。但在跨防火墙下，client请求zookeeper的时候，zookeeper返回给client的brokerIP是kafka的实际地址，而不是映射地址，因此client会访问失败。案例：zk注册的信息解决方式一、
分类：
其他好文 时间：
2019-08-14 12:35:35
阅读次数：
107
1.Zookeeper概念 Zookeeper是一个分布式 协调服务 ,就是为用户的分布式引用程序提供协调服务 A、zookeeper是为别的分布式程序服务的 B、zookeeper 本身就是一个分布式程序 (只要半数以上节点存活，zk就可以提供服务) C、zk提供的服务涵盖：主从协调、服务器节点动 ...
分类：
其他好文 时间：
2019-08-03 14:23:10
阅读次数：
64
