本发明涉及一种基于Flink的实时计算方法及系统，该方法包括如下步骤：（1）实时数据的获取：获取用于计算的数据源至接入层，触发实时计算；（2）实时数据的清洗和分析处理：采用实时流计算引擎Flink对获取的数据源进行实时的数据清洗和计算，聚合计算结果；（3）实时计算结果持久化：对计算结果进行持久化并完成数据分发。与现有技术相比，本发明方法及系统能够建立高吞吐量、低延迟、高性能的实时计算，满足对业务数据改变的实时地监控和响应，为实时采集客户行为、实时营销计算、实时风险监测等不同场景提供有效服务。