绘制类图

安装插件 PlantUML Integration PlantUML Parser 下载在 IDEA -> Settings -> Plugins -> Marketplace 搜索即可 配件 graphviz-dot PlantUML Parser 依赖 PlantUML 插件 (PlantUML 不仅仅是一个插件，官网还提供了一个独立的 Java 程序（jar 包），我们

软件设计

前言参考文章：https://blog.csdn.net/Q1410136042/article/details/83108121 接口语法1<|.. 示例1工厂 <|.. Class4 继承语法1<|-- 示例1动物 <|-- 野兽 组合语法1*-- 示例1野兽 *-- 四肢 聚合语法1-- 或 o-- 示例1雄狮 -- 雌狮 课程 o-- 学生

Kafka 消费者

消费方式 工作流程总体流程 消费者组流程消费者组：由多个 consumer （允许1个）组成，其条件是所有消费者的 groupid 相同，因为默认情况下定义消费者时都需要输入 groupid，即便不输入 kafka 内部也会分配一个 groupid 消费者组内的每个消费者负责消费不同分区的数据，一个分区只能由一个组内的一个消费者消费 消费者之间互不影响。所有的消费者都属于某个消费者组，即消费者

Kafka Broker

工作流程 副本基本信息（1）Kafka 副本作用：提高数据可靠性。 （2）Kafka 默认副本 1 个，生产环境一般配置为 2 个，保证数据可靠性；太多副本会 增加磁盘存储空间，增加网络上数据传输，降低效率。 （3）Kafka 中副本分为：Leader 和 Follower。Kafka 生产者只会把数据发往 Leader， 然后 Follower 找 Leader 进行同步数据。 （4）Kafk

快速开始

Kafka生产者

一、消息发送1. 发送原理在消息发送的过程中，涉及两个线程 main 线程 ​ 创建双端队列 RecordAccumulator（默认大小 32 M），并将消息发送到 RecordAccumulator sender线程 ​ 不断地从 RecordAccumulator 中拉取消息发送到 Kafka Broker ISR = 与 leader 保持正常通讯的节点 也就是为和

网关

前言本文将介绍什么是微服务网关，为什么要用网关并以 Spring Cloud Gateway 为例介绍网关的作用和用途 什么是网关是出现在系统边界上的一个面向 API 的、串行集中式的强管理服务，这里面的边界是企业 IT 系统的边界，可以理解为企业级应用防火墙 作用是将外部访问与内部系统隔离 API 网关是一个服务器，是系统对外的唯一入口。API 网关封装了系统内部架构，为每个客户端提供定制的 A

DataStream API

介绍DataStream（数据流）本身是 Flink 中一个用来表示数据集合的类（Class），我们编写的 Flink 代码其实就是基于这种数据类型的处理，所以这套核心 API 就以 DataStream 命名。 对于批处理和流处理，我们都可以用这同一套 API 来实现。 其用法上，有些类似于常规的 Java 集合，但又有所不同。 我们在代码中往往并 不关心集合中具体的数据，而只是用 API 定义

运行时架构

系统架构 运行时组件 作业管理器 任务管理器 资源管理器 分发器 任务提交流程抽象概念 单机模式 Yarn 环境会话模式 单作业模式 重要概念程序与数据流Flink 是流式计算框架。它的程序结构，其实就是定义了一连串的处理操作，每一个数据 输入之后都会依次调用每一步计算。在 Flink 代码中，我们定义的每一个处理转换操作都叫作 “算子”（Operator），所以我们的程序可以看作是一串算子构成的

行为型模式

一、概述行为型模式（Behavioral Pattern）关注系统中对象之间的交互，研究系统在运行时对象之间的相互通信与协作，进一步明确对象的职责 行为型模式不仅仅关注类和对象本身，还重点关注它们之间的相互作用和职责划分 行为型模式可以分为类行为型模式和对象行为型模式两种 类行为型模式通过继承关系在几个类之间分配行为，主要通过多态等方式来分配父类与子类的职责 对象行为型模式通过对象的关联关系来分