项目描述
统计游戏的KPI(用户活跃量,广告的访问量)指标
通过游戏端实时上报数据,经Kafka消息队列,监听Kafka分区获取实时报文进行一个数据统计,
经统计后的数据,根据业务情况存储于对应的数据库(Mysql)或者缓存(Redis)
在通过调度统计对应的数据存入数据库供PHP端展示在后端系统.
调度有小时统计精确到秒,日统计次日触发.相关具体的数据计算实现略.
责任描述
游戏端报文的推送随机发送至Kafka-Topic中的Partition, 再由统计服务监听对应的Partition来进行一个规则计算在写入数据库(Mysql)
调度统计小时实时数据,日活数据,写入对应的数据库(Mysql),其中有用到多线程批次处理.数据库的读写分离等等
游戏用户数据刷新:可自定义某个游戏中的用户体力恢复更新.
自搭的SSM框架, 基于微服务的调度服务,用于腾讯广告,小程序相关数据对接抓取
广告数据接口就一个数据查询接口,根据标识参数先去缓存(Redis)获取对应数据,如果缓存中存在则直接Response,没有则从对应的数据库(Mysql)中查询成功后存入Cache(Redis)在Response