今天介绍用 Flink 读取Kafka生成的数据，并进行汇总的案例 第一步：环境准备，kafka，flink，zookeeper。我这边是用的CDH环境，kafka跟zookeeper 都安装完毕，并测试可以正常使用 第二步：用kafka创建一个生产者进行消息生产 ./kafka-console-p ...
分类：
其他好文 时间：
2020-09-17 18:33:12
阅读次数：
26
环境准备： win10 jdk：jdk1.8.0_121 tomcat：apache-tomcat-8.5.23 zookeeper：zookeeper-3.4.14 idea-2017版 框架：springboot-2.1.8.RELEASE (如果有需要可以联系zhangpba@qq.com) ...
分类：
编程语言 时间：
2020-09-17 17:52:50
阅读次数：
28
微服务系统架构实践 开发语言Java 8 框架使用Spring boot 服务治理框架Dubbo 容器部署Docker 持续集成Gitlab CI 持续部署Piplin 注册中心Zookeeper 服务管理Dubbo-admin 日志采集及分析ELK 链路追踪Zipkin/Tracing Analy ...
分类：
编程语言 时间：
2020-09-17 17:50:16
阅读次数：
37
前言很多框架如mybatis，servlet的filter，dubbo，安全框架诸如Springsecurity、apacheshiro都会用到设计模式中的责任链模式，所以学习责任链模式成为帮助你学习以上这些框架的一个好的手段之一。今天我们就来了解一下责任链模式。定义如果有多个对象（Handler）都有机会处理数据源（RequestSource,这里不是单纯的数据库数据源，可以是一个请求，总之是来
分类：
其他好文 时间：
2020-09-17 15:58:06
阅读次数：
29
kafka是很流行的一款消息队列和流处理组件，其生态非常丰富，今天只简单介绍一下它的安装。 一. Zookeeper安装 kafka高度依赖于Zookeeper做集群协调和分布式存储，当然kafka社区正在逐渐去掉对Zookeeper的依赖，不过至今你还是需要Zookeeper。 下载清华镜像：ht ...
机器为172.25.1.23172.25.1.24172.25.1.28可以在/conf/users.properties中寻找http://172.25.1.28:8161/index.htmladminadminTCP端口61616(主从集群172.25.1.23,172.25.1.24,172.25.1.28)管理端口8161软件下载zookeeper下载地址:https://mirror.
分类：
其他好文 时间：
2020-09-17 13:05:39
阅读次数：
28
微服务架构一般组成由服务中心（或注册中心如Zookeeper等）和开发者提供的消费者微服务和生产者微服务。 服务中心收纳所有的微服务，其他开发者可以上传各自的微服务。需要服务中心是因为可以统一网络地址，方便扩展微服务和机器。 一般调用过程是前端发请求通过网关等到consumer，consumer调p ...
分类：
其他好文 时间：
2020-09-15 21:31:12
阅读次数：
47
1 Zookeeper入门 1.1 概述 Zookeeper是一个开源的分布式的，为分布式应用提供协调服务的Apache项目。 1.2 Zookeeper工作机制 Zookeeper从设计模式角度来理解：是一个基于观察者模式设计的分布式服务管理架构。它负责存储和管理大家都关心的数据，然后接受观察者的 ...
分类：
其他好文 时间：
2020-09-12 21:40:11
阅读次数：
38
一、安装IK分词器 下载ik分词器插件 wget https://github.com/medcl/elasticsearch-analysis-ik/releases/download/v6.4.2/elasticsearch-analysis-ik- 使用linux下载会很慢，于是我自己去git ...
分类：
其他好文 时间：
2020-09-07 19:07:17
阅读次数：
48
Watcher 的基本流程 ZooKeeper 的 Watcher 机制，总的来说可以分为三个过程：客户端注册 Watcher、服务器处理 Watcher 和客户端回调 Watcher客户端注册 watcher 有 3 种方式，getData、exists、getChildren；以如下代码为例来分 ...
分类：
其他好文 时间：
2020-09-04 17:10:50
阅读次数：
51
