今天介绍用 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
Spring Cloud Bus能管理和传播分布式系统间的消息,就像一个分布式执行器,可用于广播状态更改,时间推送等,也可以当作微服务间的通信通道。 ...
分类:
编程语言 时间:
2020-09-17 16:50:32
阅读次数:
29
Spring Cloud Config为微服务架构中的微服务提供集中化外部配置支持,配置服务器为各个不同微服务应用的所有环境提供了一个中心化的外部配置。 ...
分类:
编程语言 时间:
2020-09-17 16:45:06
阅读次数:
34
面试出题背景 结合项目问 接口 用到数据库资源 技术功能: 限制 某一个接口方法,并发访问数量【限流】 应用场景: Zuul, Spring Cloud网关, Nginx, 普通controller接口 请求:tomcat > 线程池 > 线程 > Spring servlet核心分发器 ...
分类:
编程语言 时间:
2020-09-17 16:12:51
阅读次数:
26
前言在微服务架构中,由于系统和服务的细分,导致系统结构变得非常复杂,为了跨平台,为了统一集中管理api,同时为了不暴露后置服务。甚至有时候需要对请求进行一些安全、负载均衡、限流、熔断、灰度等中间操作,基于此类种种的客观需求一个类似综合前置的系统就产生了,这就是API网关(APIGateway)。API网关作为分散在各个业务系统微服务的API聚合点和统一接入点,外部请求通过访问这个接入点,即可访问内
分类:
编程语言 时间:
2020-09-17 15:58:42
阅读次数:
45
根据CompTIA(美国计算机行业协会)2018年云计算趋势报告,将近一半的公司表示内部31%至60%的IT系统是基于云的。企业正在努力利用云的优势,降低IT成本。如今,云原生(Cloud Native)架构正在彻底改变着行业对开发、部署和管理应用系统的思考方式。企业RPA应用转化成云原生是智能自动 ...
分类:
其他好文 时间:
2020-09-17 15:40:34
阅读次数:
23
一.基本概念 Consul是一套开源的分布式服务发现和配置管理系统,由HashiCorp公司用Go开发。 它提供微服务系统中的服务治理、配置中心、控制总线等功能。 服务发现:提供HTTP和DNS两种发现方式。 健康检测:支持多种方式,http、tcp、Docker、shell等 kv存储:key、v ...
分类:
编程语言 时间:
2020-09-17 13:43:04
阅读次数:
30
kafka是很流行的一款消息队列和流处理组件,其生态非常丰富,今天只简单介绍一下它的安装。 一. Zookeeper安装 kafka高度依赖于Zookeeper做集群协调和分布式存储,当然kafka社区正在逐渐去掉对Zookeeper的依赖,不过至今你还是需要Zookeeper。 下载清华镜像:ht ...