信用卡实时数据计算中心

信用卡实时数据中心是一个集成系统，主要由六个核心模块构成：控制中心、客群中心、事件中心、达标中心、奖品中心和触达中心。控制中心负责与营销系统对接，同步营销活动相关数据。客群中心通过分析用户行为，加工出各种标签客群数据。事件中心对实时数据计算中心接收的各个消息流进行加工，形成模型，触发后续流程。达标中心根据事件中心加工后的消息，执行规则判断是否达标。奖品中心在客户的行为数据触达达标条件后，对客户进行奖品派发。触达中心则负责对客户的各个阶段行为达标或派奖进行通知。

信用卡实时数据中心是一个集成系统，主要由六个核心模块构成：控制中心、客群中心、事件中心、达标中心、奖品中心和触达中心。控制中心负责与营销系统对接，同步营销活动相关数据。客群中心通过分析用户行为，加工出各种标签客群数据。事件中心对实时数据计算中心接收的各个消息流进行加工，形成模型，触发后续流程。达标中心根据事件中心加工后的消息，执行规则判断是否达标。奖品中心在客户的行为数据触达达标条件后，对客户进行奖品派发。触达中心则负责对客户的各个阶段行为达标或派奖进行通知。

该实时数据中心与信用卡中心的多个系统进行对接，通过消息传递的方式，将数据发送到信用卡实时数据计算中心。对上游系统的消息字段进行提取、转换、清洗，加工成指标原子，这些原子作为规则引擎中的变量，执行相应的规则来判断是否达标。根据一定的路由规则进行派奖、触达相应的流程操作。

2. 开发环境：
该项目使用IntelliJ IDEA作为开发工具，采用Maven进行项目管理，JDK 8为运行环境，使用Git进行版本控制。

3. 所用技术：
在技术方面，该项目采用了Springcloud + Mybatis作为后端开发框架，使用RocketMQ进行消息传递，Elasticsearch作为搜索引擎，Redis作为缓存数据库。
4.本人参与负责模块：
事件中心：
事件中心使用RocketMQ作为消息队列，将MQ的配置存储在数据库中。项目启动时会启动consumer和producer，实现MQ的配置可以通过脚本修改，而不是通过配置文件的方式。

触达中心：
触达中心使用消息表的方式实现了分布式事务，使用Redis分布式锁保证每个客户只能报名参加一次活动，避免重复报名。