这门课的标题里有三个关键词:Flink、实时、风险控制。它们对应的其实是同一件事——当业务要求你在几百毫秒内判断一笔交易该不该拦,而数据又是源源不断涌进来的,用什么技术扛住这个压力。如果你正在做支付风控、信贷反欺诈、或者平台交易监控,这门课讨论的问题大概率就是你手头的问题。

它解决的是什么工作场景

传统做法通常是先把数据落到库里,再跑批处理算规则。账能算清楚,但时间差摆在那里:等结果出来,钱可能已经出去了。实时风控要处理的是另一个节奏——行为发生的同时就给出判断,并且这个判断要能随时调整,因为欺诈手法在变,规则也得跟着变。

课程围绕的正是这类场景:风险数据从哪里来、规则怎么在流上执行、模型或规则命中后如何联动处置、系统在流量高峰时怎么不塌。它不试图讲完 Flink 的所有 API,而是把这些能力放进一个完整的风控链路里去看。

学完之后能独立做什么

比较现实的目标是:你能独立设计并搭起一套实时风控的骨架,包括数据接入、规则匹配、结果输出这几段,并且知道每一段在压力下会先出问题的地方在哪里。具体一点,学完应该能自己完成这几件事:

  • 把风控规则从批处理思路改写成流式作业,理解状态在其中的作用;
  • 为交易、登录、支付这类不同来源的数据设计统一的处理流程;
  • 在流量上涨时定位是反压、状态膨胀还是算子并行度的问题,并做出调整;
  • 为规则和模型结果设计可回溯、可复盘的输出方式,而不只是打一条日志。

需要说明的是,这套内容偏向工程落地,不是算法课。风控模型怎么训练、特征怎么设计,这里不会展开,它假设你已经有规则或模型,需要的是把它们跑在实时链路上。

哪些基础会让你学得顺

如果你写过 Java 或 Scala,理解过多线程和消息队列的基本概念,学起来会比较自然。完全没接触过分布式计算的读者,前期需要额外补一下并行、分区、检查点这些概念,否则容易在调优部分卡住。

另外,对风控业务本身有一点感知会很有帮助。比如知道什么是名单命中、什么是频次限制、什么是处置动作,这些不需要很专业,但能让你明白课程里每个技术选择对应的业务理由。

资料的组织方式与使用建议

资料按主题分块推进,从整体架构讲起,再落到数据接入、规则处理、性能优化几个环节,最后有一部分专门讲系统上线后的问题排查。这个顺序是有意的:先让你看到全貌,再逐个攻破细节。

建议的用法是,第一遍不要纠结某个配置项的具体写法,先把架构那条线走通,搞清楚数据从进入到出去经过了哪些环节、每个环节承担什么职责。第二遍再回头处理优化和异常部分,这时候你已经有整体印象,理解会快很多。项目演示相关的材料可以在第二遍时对照着看,用来验证自己是否真的理解了流程,而不是照着敲。

如果时间有限,优先看架构设计和性能优化两块,这两部分是最难靠零散搜索拼出来的;具体的接口调用细节,用到时再查文档也不迟。

课程目录

Flink���㵽һ��ʵսʵʱ���տ���ϵͳ ʵսFlink������ʵʱ���տ�����ϵ �༭���� ��Ƚ���Flink�ڷ�������Ӧ�ã��Ӽܹ���Ƶ������Ż���ȫ������ʵʱ���տ��ơ� ? �༭�Ƽ� ���γ�����dz���ؽ���Flink��ʵʱ���տ���ϵͳ��Ӧ�ã����Ǽܹ���ơ��������桢�����Ż��ȹؼ����ڣ������Ϊ��������ר�ҡ� �γ����� ? FlinkʵսӦ�� ? ���ϵͳ�ܹ���� ? ʵʱ���ݴ����Ż� �γ�Ŀ¼ ? ��10�� ���ϵͳ����--�������� ��10�� ���ϵͳ����--������������.zip
 [1.8 MB] 10-9 Aviator����Ӧ���ڷ�ع����������ж�.mp4
 [237.8 MB] 10-7 ��ع���������жϱ���ʽ�����ķ���.mp4
 [72.9 MB] 10-15 �����ܽ�.mp4
 [39.4 MB] 10-6 ��ع����Mysql�����˼·����Ӫ��̨����.mp4
 [125.6 MB] 10-3 ����ָ��ۺϼ���Ĺ�����������ۺϼ���.mp4
 [474.5 MB] 10-5 Kafka������ֱ�ӷ����¼����Լ����ô�������������Ϣ.mp4
 [347.3 MB] 10-10 Flink�Զ������ɹ����¼���.mp4
 [181.6 MB] 10-4 aggregate���Ӹ���ָ��ۺϼ���Ĺ�����н�����.mp4
 [365.0 MB] 10-1 �����ص���ѵ�.mp4
 [5.7 MB] 10-13 ?????????????????????????????2??.mp4
 [231.5 MB] 10-14 ����Ϊ�¼�ʹ�ö�Ӧ�Ĺ�����з���ж�.mp4
 [184.2 MB] 10-8 Aviator����ı���ʽ���㼰�Զ��庯��.mp4
 [364.9 MB] 10-2 window���Ӹ���ָ��ۺϼ�������¼����䵽��Ӧ����.mp4
 [294.5 MB] 10-12 ?????????????????????????????1??.mp4
 [257.7 MB] 10-11 Flink�������¼����㲥����Ϊ�¼���.mp4
 [192.1 MB] ? ��3�� �������ܹ���Ƽ���Ŀ��ʾ ��3�� �������ܹ���Ƽ���Ŀ��ʾ����.zip
 [1.8 MB] 3-1 �������ܹ������˼·.mp4
 [132.7 MB] 3-4 ����������弼��ջ�Լ��汾.mp4
 [159.0 MB] 3-2 ������������ϵͳ�ܹ�ͼ.mp4
 [143.9 MB] 3-5 �ڼ���Ϊ���ݼ��ṩ�IJ�ͬ���͵���ë�������ֲ�.mp4
 [18.6 MB] 3-3 ��ع�������ѡ��Groovy��ԭ��.mp4
 [69.3 MB] ? ��14�� ������沿��--ѹ���Ż� ��14�� ������沿��--ѹ���Ż�����.zip
 [1.8 MB] 14-4 Flink��ѹ�������.mp4
 [12.8 MB] 14-2 Flink����ѹ�ⷽ��.mp4
 [18.1 MB] 14-3 Flink��ѹ�澯�Լ���ɵ�Ӱ��.mp4
 [53.6 MB] 14-1 Flink��ѹ�ı���.mp4
 [15.1 MB] ? ��7�� ������ʩ�--flink�������װ ��7�� ������ʩ�--flink�������װ�ĵ�.png [493.5 KB] 7-10 Flinkʹ��JDBC-Connector+Ԥ��������д��ClickHouse���£�.mp4
 [241.5 MB] 7-6 Flink�Զ���Source��ȡRedis��Ⱥ���ϣ�.mp4
 [247.3 MB] 7-8 Flink�Զ���Source��ȡClickHouse.mp4
 [294.3 MB] 7-9 Flinkʹ��JDBC-Connector+Ԥ��������д��ClickHouse���ϣ�.mp4
 [215.0 MB] 7-12 �����ܽ�.mp4
 [63.9 MB] 7-

11 Flink TableSQL Api + ��ת����ȡMysql.mp4
 [297.3 MB] 7-2 Flinkʹ��ParameterTool��ȡ����.mp4
 [269.8 MB] 7-5 Flinkͨ����������ʵ���Զ���Source.mp4
 [333.0 MB] 7-1 �����ص���ѵ�.mp4
 [8.4 MB] 7-4 ���ڰ�ϣ��(Bahire)-Flinkд��Redis��Ⱥ���£�.mp4
 [188.7 MB] 7-7 Flink�Զ���Source��ȡRedis��Ⱥ���£�.mp4
 [248.8 MB] 7-3 ���ڰ�ϣ��(Bahire)-Flinkд��Redis��Ⱥ���ϣ�.mp4
 [318.6 MB] ? ��12�� ������沿��--��Ԫ���� ��12�� ������沿��--��Ԫ��������.png [493.5 KB] 12-8 ʹ��ͨ�������MybatisPlus3.5+ �Զ�����CRUD.mp4
 [325.8 MB] 12-3 �ܽ�Flink-Cep��DataStream Api���з�صIJ�ͬʹ�ó���.mp4
 [31.9 MB] 12-7 ͨ����Ӫ��̨��̬�޸�Flink-Cep Pattern����.mp4
 [121.1 MB] 12-5 ����Flink-Cep��������¼����е��û�.mp4
 [328.1 MB] 12-4 ����Flink-Cep����¼ʧ�ܳ�����ֵ���û�.mp4
 [308.4 MB] 12-2 �����Ӫ��̨���ն����.mp4
 [96.5 MB] 12-1 �ܽ��������漰��Flink����.mp4
 [51.5 MB] 12-6 ����Flink-Cep����Groovy�ű�����Pattern-.mp4
 [123.2 MB] ? ��6�� ������ʩ�--springboot�������װ ��6�� ������ʩ�--springboot�������װ�ؿ�.png [493.5 KB] 6-8 Springboot����slf4j+log4j2���£�.mp4
 [220.4 MB] 6-3 Springboot��װ����FastJson2��json�����ࣨ�У�.mp4
 [171.8 MB] 6-6 ����LocalDate��װʱ�乤����+�Զ����ɲ����ࣨ�£�.mp4
 [151.9 MB] 6-4 Springboot��װ����FastJson2��json�����ࣨ�£�.mp4
 [182.4 MB] 6-9 Springboot��װ�Զ����쳣+ȫ���쳣�Ĺ�����.mp4
 [231.6 MB] 6-10 ��װLettuce+RedisTemplate��дRedis��Ⱥ���ϣ�.mp4
 [271.5 MB] 6-1 �����ص���ѵ�.mp4
 [12.7 MB] 6-7 Springboot����slf4j+log4j2���ϣ�.mp4
 [227.9 MB] 6-5 ����LocalDate��װʱ�乤����+�Զ����ɲ����ࣨ�ϣ�.mp4
 [222.8 MB] 6-14 �����ܽ�.mp4
 [58.7 MB] 6-12 ��װLettuce+RedisTemplate��дRedis��Ⱥ���£�.mp4
 [182.0 MB] 6-2 Springboot��װ����FastJson2��json�����ࣨ�ϣ�.mp4
 [149.4 MB] 6-13 Springboot��װHbase������.mp4
 [303.7 MB] 6-11 ��װLettuce+RedisTemplate��дRedis��Ⱥ���У�.mp4
 [288.4 MB] ? ��1�� �γ̽�����ѧϰָ�� ��1�� �γ̽�����ѧϰָ������.png [493.5 KB] 1-3 �γ���Ƶ�˼·�Լ������ǵ�֪ʶ��.mp4
 [60.4 MB] 1-1 ����һ�Ű�����׵ĺÿ�.mp4
 [166.0 MB] 1-4 �Ƽ������γ���Ŀʹ�õĿ�������.mp4
 [42.6 MB] 1-2 �����Ŀ���ڸ���ְҵ����������.mp4
 [35.7 MB] ? ��13�� ������沿��--������� ��13�� ������沿��--��������ĵ�.zip
 [1.8 MB] 13-

12 ����̬cep �޸�cepԴ��ע�붯̬��ȡPattern�ķ���.mp4
 [256.1 MB] 13-6 ????????? Flink-CDC?????????.mp4
 [202.1 MB] 13-

13 ����̬cep �޸�cepԴ�빹���µ�NFA�����¼�ƥ��.mp4
 [306.5 MB] 13-3 ���� Flink-CDC�ĵײ�ԭ��.mp4
 [95.7 MB] 13-9 ????????? ?????????????????????????.mp4
 [179.7 MB] 13-1 ����ʱ���� ģ��ԴԴ���ϵ���Ϊ�¼���.mp4
 [27.6 MB] 13-

10 ????????? ?????????????????????????????????.mp4
 [110.1 MB] 13-5 ���� Flink-CDC�Զ��巴���л�.mp4
 [312.7 MB] 13-4 ���� Flink-CDCʵʱ����Mysql���ݱ��.mp4
 [341.1 MB] 13-7 ���� Flink ˫��Join.mp4
 [193.2 MB] 13-8 ????????? ???Join????????????????????.mp4
 [120.5 MB] 13-2 ����ʱ���� ClickHouse���û�ÿСʱ����Ϊ�¼��鵵.mp4
 [87.9 MB] 13-

11 ����̬cep Flink��ͣ����̬���� cep ��ع���ķ���.mp4
 [265.8 MB] ? ��5�� ������ʩ�--���������Ԫ���� ��5�� ������ʩ�--���������Ԫ��������.zip
 [1.8 MB] 5-10 ����maven-helper������������ͻ�쳣.mp4
 [69.6 MB] 5-

12 ����ҵ��������ҵ.pdf
 [20.3 KB] 5-4 ����������Ŀ���������.pdf
 [72.6 KB] 5-13 �����ܽ�.mp4
 [75.9 MB] 5-2 ������Ŀ�ṹͼ.mp4
 [165.7 MB] 5-6 ����Junit5+MockMvc�ĵ�Ԫ����������д���ϣ�.mp4
 [252.5 MB] 5-5 Springboot����Maven��ģ�鹹����Ŀ.mp4
 [273.7 MB] 5-1 �����ص���ѵ�.mp4
 [14.7 MB] 5-11 ����չ������ֲ���ص㼰�����漰����֪ʶ��.pdf
 [10.8 KB] 5-8 Flink������ĵ�Ԫ����������д���ϣ�.mp4
 [224.5 MB] 5-3 ����docker��һ��ʽ���Ŀ����.mp4
 [128.6 MB] 5-7 ����Junit5+MockMvc�ĵ�Ԫ����������д���£�.mp4
 [275.0 MB] 5-9 Flink������ĵ�Ԫ����������д���£�.mp4
 [250.9 MB] ? ��8�� ������������--�¼��������� ��8�� ������������--�¼����������ĵ�.zip
 [1.8 MB] 8-7 ClickHouse�洢�û���Ϊ·�����еı����˼·.mp4
 [92.9 MB] 8-

18 Flink aggregateͳ���û����1Сʱ��¼Ƶ�ʵľۺϲ���.mp4
 [186.2 MB] 8-3 �¼����ĵ����ݸ�ʽ.mp4
 [29.8 MB] 8-

13 Flink Job��Checkpoint, State�����Լ����жȵĺ����������ϣ�.mp4
 [147.1 MB] 8-2 ����¼��������ļܹ��˼·.mp4
 [32.0 MB] 8-15 Flink��Kafka������ϴ��ת��ΪPOJO����.mp4
 [184.0 MB] 8-10 ClickHouse���û���Ϊ���н���·���ھ��ҳ���ë�ͣ��ϣ�.mp4
 [136.1 MB] 8-1 �����ص���ѵ�.mp4
 [23.3 MB] 8-16 Flink���¼�����������ˮӡ��֤�¼���Ϊ��������.mp4
 [178.6 MB] 8-17 Flink���ڻ�������ÿ5����ͳ���û����1Сʱ�ĵ�¼Ƶ��.mp4
 [247.5 MB] 8-11 ClickHouse���û���Ϊ���н���·���ھ��ҳ���ë�ͣ��£�.mp4
 [143.8 MB] 8-9 ClickHouse���û���Ϊ�ۺ�Ϊ��Ϊ·������.mp4
 [149.9 MB] 8-8 ClickHouse��ȡKafka Json��ʽ���û���Ϊ����.mp4
 [82.5 MB] 8-

14 Flink Job��Checkpoint, State�����Լ����жȵĺ����������£�.mp4
 [159.0 MB] 8-6 Flink1.14�Զ��巴���л�����Kafka Json��ʽ����.mp4
 [289.7 MB] 8-12 ClickHouse���û���Ϊά��ָ��洢�ı����˼·.mp4
 [118.1 MB] 8-4 Flume����Ŀ¼����Ϊ�¼�����д��Kafka.mp4
 [103.1 MB] 8-5 Flink1.14ʹ��ȫ�µ�Kafka Connector��ȡKafka.mp4
 [283.9 MB] ? ��2�� �����Ŀ���� ��2�� �����Ŀ����˵��.zip
 [1.8 MB] 2-1 ��ë������Ⱥ�غͽ���ƽ̨޶����ë.mp4
 [52.1 MB] 2-5 �Ż�ȯ�����µķ�ع������ֵȷ��.mp4
 [96.9 MB] 2-3 �����������������Ż�ȯ�����·�صļܹ����.mp4
 [100.5 MB] 2-4 ��������������ƵĴ���Ŀ¼�ֲ�ܹ�˼·.mp4
 [286.5 MB] 2-2 �Ż�ȯ�����±�޶��ë��ҵ���߼�©������.mp4
 [47.1 MB] ? ��11�� ʵʱ���--��̬����ʵ�� ��11�� ʵʱ���--��̬����ʵ�ֱؿ�.png [493.5 KB] 11-9 Flink-Cep��ʯ NFA״̬ת������.mp4
 [39.8 MB] 11-1 �����ص���ѵ�.mp4
 [14.9 MB] 11-10 Ϊʲôѡ��Groovy����Flink-Cep Pattern����.mp4
 [38.7 MB] 11-11 Java����Groovyִ֮��Groovy�ű�.mp4
 [104.1 MB] 11-4 Flink-Cep������1���ӵ�¼ʧ�ܳ�����ֵ���û�2.mp4
 [33.4 MB] 11-5 Flink-Cep���ϸ���ڵ�ģʽ���������¼ʧ�ܵ��û�.mp4
 [233.3 MB] 11-2 �������͵ķ�ع����ʺ�ʵʱ�����Լ�ʵʱ�ж�.mp4
 [53.7 MB] 11-12 Java����Groovy֮��ָ��λ�ü���Groovy�ű�.mp4
 [187.0 MB] 11-6 Flink-Cep���ڵ�������������15����IPƵ���仯���û�.mp4
 [321.9 MB] 11-16 Groovy��̬���ؽű�Ƶ������Full GC �Ľ������.mp4
 [128.9 MB] 11-13 Java����Groovy֮����Groovy�ű����Զ�����1.mp4
 [83.2 MB] 11-13 Java����Groovy֮����Groovy�ű����Զ�����2.mp4
 [107.3 MB] 11-4 Flink-Cep������1���ӵ�¼ʧ�ܳ�����ֵ���û�1.mp4
 [352.3 MB] 11-8 Flink-Cep��ƥ���¼�����ȡ����������¼���.mp4
 [287.8 MB] 11-14 Groovy�ܶ�̬���ؽű��ĵײ�ԭ��.mp4
 [223.6 MB] 11-3 Flink-Cep�������̼�ģʽƥ��.mp4
 [265.7 MB] 11-7 Flink-Cep����������޶��ë������Ϊ·�����û�.mp4
 [108.7 MB] 11-15 Flink-Cep����Groovy�ű���̬����Pattern.mp4
 [313.9 MB] ? ��4�� ��������������֪ʶ׼�� ��4�� ��������������֪ʶ׼��˵��.png [493.5 KB] 4-7 ������ʾFlink����״̬����ʵ��wordcount���ϣ�.mp4
 [230.2 MB] 4-9 ����Flink4���ʯ֮���ڻ���.mp4
 [109.0 MB] 4-15 ����Flink4���ʯ֮checkpoint���ƣ��У�.mp4
 [49.7 MB] 4-16 ����Flink4���ʯ֮checkpoint���ƣ��£�.mp4
 [66.5 MB] 4-10 ͨ����׻�ͨ�׵�ȥ����Flink4���ʯ֮ʱ������ϣ�.mp4
 [70.6 MB] 4-5 ͨ���н������޽�����������Flink����һ��ܹ�.mp4
 [131.0 MB] 4-1 �����ص���ѵ�.mp4
 [36.6 MB] 4-13 ������ʶFlink��Cepģʽƥ��.mp4
 [59.1 MB] 4-12 ͨ����׻�ͨ�׵�ȥ����Flink4���ʯ֮ʱ������£�.mp4
 [67.4 MB] 4-8 ������ʾFlink����״̬����ʵ��wordcount���£�.mp4
 [314.2 MB] 4-14 ����Flink4���ʯ֮checkpoint���ƣ��ϣ�.mp4
 [97.4 MB] 4-6 ����Flink4���ʯ֮״̬����.mp4
 [120.7 MB] 4-4 ������ʾFlink���������ַ�ʽʵ��wordcount���£�.mp4
 [188.5 MB] 4-3 ������ʾFlink���������ַ�ʽʵ��wordcount���ϣ�.mp4
 [285.9 MB] 4-11 ͨ����׻�ͨ�׵�ȥ����Flink4���ʯ֮ʱ������У�.mp4
 [37.0 MB] 4-17 �����ܽ�.mp4
 [107.0 MB] 4-2 ����Flink����������.mp4
 [118.7 MB] ? ��9�� ��ع����ж�����--ָ�����ģ�� ��9�� ��ع����ж�����--ָ�����ģ��˵��.png [493.5 KB] 9-6 Flink��POJO����֮��Ĺ�ϵ.mp4
 [116.1 MB] 9-1 �����ص���ѵ�.mp4
 [12.6 MB] 9-3 ���ڻ�������˼��ķ��ָ�����˼·.mp4
 [32.2 MB] 9-11 ��ָ��ۺϼ������д�뵽�¼�����������������˼·.mp4
 [249.9 MB] 9-4 ����Redis���ٻ�ȡ���ָ�������˼·.mp4
 [103.9 MB] 9-2 ���ָ��Ĺ����Լ�ָ��洢�����˼·.mp4
 [30.6 MB] 9-13 ͨ��������ƽ�ָ��ۺϼ������д�뵽�¼���.mp4
 [309.3 MB] 9-5 ���ָ����RedisΨһid�����˼·.mp4
 [24.9 MB] 9-8 ����Flinkʵ�ֵ�ָ��ͨ�þۺϼ����ܳ����ṹ.mp4
 [356.5 MB] 9-12 ��һ��ϸ����Ӫ��̨��ָ��ۺϼ�������Զ���.mp4
 [60.0 MB] 9-14 keyBy���Ӹ���ָ��ۺϼ��������з���.mp4
 [275.5 MB] 9-10 Flinkͨ�������̶߳�ȡָ��ۺϼ������.mp4
 [173.9 MB] 9-7 ����Flinkʵ�ֵ�ָ��ͨ�þۺϼ�����˼·.mp4
 [84.0 MB] 9-9 ��Ӫ��̨�Զ���ָ��ۺϼ������.mp4
 [22.3 MB] �ʺ���Ⱥ �����ݹ���ʦ ��ع���ʦ ���ݷ���ʦ ѧϰ�ջ� ����Flink�ڷ�������Ӧ�� ����ʵʱ���տ���ϵͳ �������ݴ������� ף��ѧϰ��죡 ѧ�����ɣ�ǰ���ƽ���