主流互联网产品中建立在人工智能技术上的策略系统已深入到产品的方方面面。相应的，策略系统都离不开大量的在线特征。乾升利在线特征系统通过系统上下文，在线获取特征数据，为上游策略系统配置的规则、上游模型算法提供了精确的响应，另外特征计算还需要同步大量数据、接入多种数据源以支持多种多样特征的精确计算。 系统主要功能有正审特征查询、预审特征查询、实时特征监控和报警、特征列表查询、特征结果缓存、用户和系统数据同步到Mysql、HBase、MongoDB、数据源智能路由。 系统利用缓存、数据分层、数据预处理、负载均衡技术使得系统的峰值QPS超过400，响应时间TP95值为15ms。对用户和系统的数据采用AES+RSA 算法 进行加密传输，保证数据安全。

该模块是提供给东航订座人员，以便于管理员可以修改相关工作人员的订座权限。该模块我负责的功能： 1、批量上传订座数据：将相关人员的数据放入excel表中，对excel表中数据进行校验 2、批量修改：excel表中的数据校验成功后会对数据进行修改 3、修改成功后短信通知：修改成功后给该操作人发送短信并且记录跟踪带日志

技术栈 Redis、Ehcache、Canal、GRPC、Xxljob、Hystrix、Docker、k8s、Apollo、Kafka、Mybatis、Netty、 OAuth2、Spring boot、Spring Cloud、APNS、Firebase 该项目由众多微服务组成，我负责以下服务： 发现页服务 发现页服务提供实时财经咨询和用户实时讨论的功能，目前承载日活2w+用户，注册用户100w+ 的访问 首页用户发文列表：定时更新发文用户列表，使用xxljob作为分布式任务调度器，调度GRPC 流式接口批 量返回数据存储在大顶堆中，用户访问时调用用户服务接口将用户信息存储在redis hash中。由于首页并 发量很大，所以使用redis的分布式锁防止缓存击穿 首页文章列表： 查询后台配置的文章展示在首页中，使用Canal 解决redis 和 mysql 数据一致性问题 公司百科和热门榜单列表： 显示后台配置的公司和榜单，这肯定也会使用缓存，这部分数据只会让发现页 使用，放在redis的内存划不来，所以使用Ehcache来缓存。Ehcache 作为一个分布式缓存框架，配置简单 使用容易，就算在其他服务更新缓存也可以调用Ehcahe 提供的接口 首页作者关注： 新用户登录APP时，需要关注后台配置的作者。采用BitMap 存储用户是否完成此任务， 并异步储存到Mysql中(用于缓存重建)，使用13M的内存就可以存储上亿用户。 推送服务 该服务封装了众多推送平台的SDK，承载20WApple用户，80W Android用户 日常推送，例：APNS、 FIREBASE、HUAWEI….., 说到这里肯定疑惑为什么不用极光，WestMoney 面向海外用户 需在GooglePlay上 架，Google那边审核如果使用Huawei会下架。 - 作者发送动态需要推送，使用canal 感知作者是否发文，调 用推送服务的推送接口 推送数据量很大，使用kafka 削峰和解耦、多线程推送。期间出现过消息挤压的问题，增加消费，多线程 解决此问题 要封装的SDK很多，使用策略模式和工厂模式保持代码的可扩展性、易读性 Firebase 的服务器在境外，网路很不稳定不能影响后续推送，使用Hystrix 进行服务熔断和降级， SpringRetry实现指数性重试 用户服务 用户服务提供了100w+ 用户的注册、登录、徽章、封号、注销等功能 封号、注销功能 只是用户的状态枚举值不同，采用责任链模式设计该功能 徽章是用户完成指定任务后发布的奖励，例:点赞狂魔、富豪… 这些用户行为数据分别存储在InfluxDb、 Mysql中，建立多时间维度的任务多线程查询InfluxDb中的用户指标存入统计库，Canal调用用户提供的 GRPC Stream 接口，发布用户徽章 登录、注册，使用OAuth协议 为用户颁发token，该协议是无状态的，所以用户发布不良言论被封号后 服 务不能及时感知，采用减少token的有效期来解决此问题 站内信服务 站内信服务提供关注用户动态消息、审核消息….. 该服务存储消息到Mysql，随着用户量慢慢增加，数据库也慢慢增大，和产品协商只保留30天内的消息， 使用Sharding-Sphare 来分库分表，以自然月为表名存储每月的消息。 视频服务 视频服务提供用户上传视频，将视频上传到火山云实现客户端点播的功能 为增加上传速度优化用户体验，使用Netty 框架基于Socket协议 实现上传的功能，Netty 高性能的异步IO 框架、基于责任链模式提供了JSON、Protol Buffer消息编解码。 使用Socket上传 是因为HTTP请求会有 请求头、请求体 使用不到的报文影响上传速度