该项目是实时监控 PROP 综合业务终端的每笔交易日志，以及监控程序各种信息的监控系统，并且定时查询数据库中交易日志，写入文件中，该项目监控模块分为连接监控，进程监控，交易监控，系统日志，堡垒机连接，堡垒机监控，加密机监控，以及性能监控。其中进程监控需要用到 Jni 调用c++函数实现 该项目架构：SpringBoot+SpringCloud+Mybatis+jQuey+Ajax； 该项目开发环境：win10+tomcat8+jdk8; 上线环境服务器为 Jboss； 技术要点：将不是项目核心的数据存入文本文件，给数据库减少压力，利用 io 流实现千万级数据展示，为了减少 io ，以及不占用内存资源，进行分批次读取数据，为了给前端减少数据量压力，进行分页处理。 在检索业务中，使用了维护成本较为低的Lucene，使用lucene的按需分批次导入方法，使用线程池的方式批量多次导入，减少内存的消耗，如有新的日志产生，定时任务会更新新的日志刀luenne文件中。 为了更快速，高效，节省服务器资源，节省内存，使用二分算法将数据以时间区间进行分段搜索，在将二分所搜索出来的数据，再次进行二分精确查询，实现多条件搜索功能。

该项目是咪咕视频软件的监控平台，针对于软件的流量监控、服务统计告警、监放播控、聊天室监控、静态化管理、Varnish数据监控、健康检查、服务质量监控、App启动监控、数据分析等 聊天室监控主要针对的是节点监控、推送消息、推送监控、推送告警、机房管理、短信告警、云服务监控，涉及到的技术为springboot，springcloud、redis、mongoDB、elasticSearch、zookeeper、websocket、kafka、Prometheus、apollo、grafana等。 技术要点：1、通过读取zookeeper中服务注册信息，获取服务信息、从而监控服务质量，包括：推送服务的接收TPS、推送TPS、客户端连接数量实时监控、延迟消息监控等。生成对应的监控视图，方便运维人员使用。 2、推送告警则是针对异常服务，将异常信息以短信或者邮件的形式通知对应服务负责人，及时做出处理；在异常信息处理方面，将每上一分钟的告警信息从mongo库中查询出来，根据告警信息级别进行分组。因为告警信息数量多，为了减少redis开销，在将告警信息以机房IP地址进行分组，批量使用redis进行存储。在根据告警规则配置表，根据规则算法，最终以规则配置的告警周期将告警信息发送至对应项目负责人的*。

咪咕视频是面向互联网用户推出的高品质综合类视频客户端业务，提供短视频内容、高质量影视、综艺、直播等内容。以2018世界杯为起点，咪咕先后创新推出 4K/8K 超高清、子弹时间、多视角、多屏同看、5G+AR、VR、AI 等系列观赛黑科技。依托中国移动5G领先优势，咪咕通过5G+系列黑科技连接内容，通过*、PC 、电视、VR 等大小屏多终端呈现。 咪咕视频项目服务架构搭建采用多集群，分布式模式，服务支持高可用，高并发。其中上海服务器包括无锡机房和颛桥机房及云机房。 该项目还采用了阿里提供的服务 ID 调度功能，用户使用咪咕视频软件，发起请求，首先会分配所在省市地区就近的IP地址。 咪咕视频门户直播技术框架为 springboot，springcloud 微服务架构，因为是视频直播软件，数据主要以缓存为主，数据存储于redis、mongo及elasticSearch中、服务外部使用varnish及CDN进行一些静态资源存储，消息主要以kafka进行服务消息分发，使用的Prometheus进行服务监控，后台与客户端使用netty建立双通道机制，进行消息传递及心跳检测。 技术要点： 1、 在用户使用咪咕视频的时候，通过调用阿里解析IP接口，获取所有省市区IP地址，予以就近分配，如阿里接口IP调用不通，采取服务调度机制，轮换阿里提供的其他IP进行API调用，通过多线程方式批量校验该地区IP的服务是否正常在线，且筛选出移动、联通、电信，每个运营商所在省市区各一个可用IP地址，即根据用户所在省市区，运营商分配该IP地址。 2、云直播多人同屏场景中，获取直播推流地址采取了 redis的 onMessage 监听结合 redis 的有序集合实现了定时获取推拉流地址存入缓存，解决了高并发时，大量的用户同时使用直播功能拿不到推流地址的问题，用户成功上屏后，可以选择消费一定的 call 值来登上C位，如果用户余额足够，进行上C位操作，如果前面已经有用户申请上C位，启动排队机制，redis 监听排队流程，通知聊天室长连接，获取实时的排队位置信息。直至登上C位成功，扣除相应的费用，最终交易数据落库。 3、送礼作为用户交互功能，支持主播打赏，战队打赏，节目打赏，由于处理的规则及数据量较大，对于这种场景采取了storm大数据框架，来处理用户的贡献值。storm服务采用了KafkaSpout消费用户送礼的信息，Spout作为数据流的源头、从 kafka中消费消息、之后会经过多个Bolt进行数据过滤、分组、入库(redis)一系列操作，使打call榜单数据发生改变。对于用户打call的付费记录、数据会存储到mongo库中、支持异步写入(默认写入本地文件、定时读取文件、写入mongo库)。 4、聊天室的发言场景中，首先为了符合规定，用户发言会调用央视监播平台进行审核，审核分为自动审核，根据配置的违规关键字进行过滤，其次就是人工审核，审核通过的发言会通过kafka发送聊天室服务进行统一打包下发，默认会把最近100条消息存储到redis中，支持客户端默认展示。 5、客户端进入聊天室的时候、会与聊天室建立netty双通道机制、聊天室打包下发的消息会通过推送服务使用websocket下发给客户端。消息支持组推(聊天室指定房间用户接收)、单推(指定用户接收)、群推(所有用户接收)模式。针对高并发的场景、采用多线程加异步队列处理的形式进行消息下发。 6、聊天室和推送作为咪咕直播的核心服务、服务支持高可用、高扩展、多机房多活、聊天室通过监控mongo中的配置表、推送服务采用zookeeper进行节点监控的方式、动态实现了服务上下线及流量高峰时的机器的快速扩展。