深入 Flink 数据源：RichSourceFunction 的设计与最佳实践
Flink DataStream API 实战：从 SourceFunction 到 RichSourceFunction 的进阶与优化
本文详细讲解了 Apache Flink 中源函数（Source Function）的演进，从最基础的
SourceFunction到功能更强大的RichSourceFunction，并结合数据库、Kafka 仿真及可配置化场景提供实战示例，同时涵盖状态管理、资源管理和最佳实践。
1. 源函数演进概述
在 Flink 中，源函数是数据流处理的起点。Flink 提供两类主要接口：
- SourceFunction: 基础源函数接口，适合简单数据源。
- RichSourceFunction: 增强版接口，提供生命周期管理、运行时上下文和状态管理能力。
RichSourceFunction是构建复杂生产环境数据源的首选接口。
2. SourceFunction 基础用法
2.1 SourceFunction 接口定义
public interface SourceFunction<T> extends Function, Serializable { void run(SourceContext<T> ctx) throws Exception; void cancel(); }2.2 基础 SourceFunction 示例
public class BasicSourceFunction implements SourceFunction<String> { private volatile boolean isRunning = true; private long count = 0; @Override public void run(SourceContext<String> ctx) throws Exception { while (isRunning && count < 100) { ctx.collect("Event-" + count + "-" + System.currentTimeMillis()); count++; Thread.sleep(100); } } @Override public void cancel() { isRunning = false; } }2.3 使用基础 SourceFunction
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStream<String> dataStr