什么是状态？状态有什么作用？如果你来设计，对于一个流式服务，如何根据不断输入的数据计算呢？又如何做故障恢复呢？一、为什么要管理状态流计算不像批计算，数据是持续流入的，而不是一个确定的数据集。在进行计算的时候，不可能把之前已经输入的数据全都保存下来，然后再和新数据合并计算。

文章目录Flink系列文章一、maven依赖二、KeyedState1、KeyedState介绍及示例2、KeyedState状态有效期(TTL)1）、过期数据的清理2）、全量快照时进行清理3）、增量数据清理4）、在RocksDB压缩时清理3、keyedstate示例：实现地铁站哪个进站口人数最多1）、javabean2）、实现3）、验证本文

什么是KeyedserviceKeyedservice是指，为一个需要注入的服务定义一个KeyName，并使用使用KeyName检索依赖项注入(DI)服务的机制。使用方法通过调用AddKeyedSingleton（或AddKeyedScoped或AddKeyedTransient）来注册服务，与KeyName相关联。或使用[FromKeyedServices]属性指

背景在做elasticsearch集群从原来的2.x版本升级到更新版本如6.x过程中，由于需要在原来的应用中，同时连接2.x的集群以及6.x的集群来做在线动态灰度切流量，保证流量平滑切换，有问题可随时回切；一般在应用侧比较常规的做法是使用elasticsearch提供rest的sdk:JavaHighLevelRESTClient，