目录前言一、安装 sentinel-dashboard二、接入客户端前言    Sentinel 是面向分布式服务架构的高可用流量防护组件，主要以流量为切入点，从限流、流量整形、熔断降级、系统负载保护、热点防护等多个维度来帮助开发者保障微服务的稳定性。Sentinel 的主要工作机制如下：    对主流框架提供适配或者

目录前言二、消费者三、测试前言使用kafka来实现基于生产者消费者的模型。# 一、生产者@Slf4jpublic class KafkaProducerTest implements Runnable {//生产者private final Producer<Integer, String> producer;//主题private final String topic;//服务列表p

目录一 、引入依赖二 、配置三 、生产者四 、消费者一 、引入依赖<!-- https://mvnrepository.com/artifact/org.springframework.kafka/spring-kafka --><dependency><groupId>org.springframework.kafka</groupId><a

目录前言1.map2.flatMap3.filter4.keyBy5.max6.reduce7.connect8.union9.process前言Transform 数据转换算子，可以将一个或多个 DataStream 转换成新的 DataStream，可以将多个数据转换算子合并成一个复杂的数据流拓扑。1.map数据转换@Testpublic void mapTest() throws Excep

目录前言1、连接ftp2、连接sftp3、获取ftp文件流4、在sftp连接服务器上创建目录5、上传到sftp所在服务器前言通过ftp连接ftp服务器，通过sftp连接另外一台服务器，实现文件拷贝。1、连接ftp/*** 连接FTP*/public void connect(String host, int port, String user, String pwd) {FTPClient cli

目录前言一、流、批处理二、hello world1.环境2.流处理3.批处理4.自动处理三、文件数据源1.从文件中读取2.从目录中读取前言        Apache Flink 是一个框架和分布式处理引擎，用于在无边界和有边界数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行，并能以内存速度和任意规模进

目录前言一、安装步骤1.下载2.环境3.安装4.启停5.测试前言安装一主一从两个节点：172.16.10.225 master172.16.10.226 slave一、安装步骤1.下载下载地址：https://archive.apache.org/dist/hadoop/common/我这里下载的是3.2.0版本，hadoop-3.2.0.tar.gz2.环境（1）设置 hostname，并设置到

目录前言一、参数列表二、使用示例前言docker run 命令用于创建一个新的容器，启动一个新的进程，并为这个进程分配其独占的文件系统、网络资源等。通过参数设置可以覆盖镜像和容器的一些默认配置。一、参数列表-a: 指定标准输入输出内容类型，可选 STDIN/STDOUT/STDERR 三项；-d: 后台运行容器；-i: 以交互模式运行容器，通常与 -t 同时使用，写作 -it；-P: 随机端口映射

目录一、NacosServiceRegistryAutoConfiguration注册流程一、NacosServiceRegistryAutoConfiguration@Configuration(proxyBeanMethods = false)@EnableConfigurationProperties@ConditionalOnNacosDiscoveryEnabled# 默认开启服务自动注

前言一、通过@MapperScan1、进入@MapperScan可以看到，通过@Import导入了MapperScannerRegistrar.class@Import(MapperScannerRegistrar.class)@Repeatable(MapperScans.class)public @interface MapperScan {2、MapperScannerRegistrar实现