1、1.1SSMP数据库OMC4数据库PMC数据库H2内存数据库请求客户端交换机Linux服务器1.2 系统部署图. 服务启动模块子系统的结构模型图:服务启动模块子系统模块管理器模块加载标注模块扫描启动模块程序入口子模块扫描优先级排序M-2-1 客户端消息处理器消息处理器(Adapter)子系统消息Handler线程startSocket开启协议解析器会话配置异步监听处理消息返回处理请求增加监控任务增加告警任务会话关闭或异常处理结束实时监控模块Service启动SSMP数据抽取抽取Task统计TaskH2数据保存H2数据读取查询结果返回线程sleep统计Task结束M-3 实时监控模块M-3-1
2、数据抽取模块数据抽取模块线程interrupted线程sleep抽取模块线程结束查询原始区域数据更改对应的标志位时间粒度&监控类型SSMP日志信息线程集合获取线程阻塞循环获取任务线程start模块初始化数据保存到H2中移除中断线程不存在则新增M-3-2 数据统计模块数据统计模块线程interruptedKPI翻译统计模块线程结束线程集合获取线程阻塞式循环获取任务开启start模块初始化移除中断线程不存在则新增启动翻译工厂设置查询参数H2处理查询返回结束信息更改标志位线程sleepM-4 实时告警模块实时告警模块Service启动GetterCheckPusherOMCSaverM-4-1 告警
3、抽取模块Getter模块线程interrupted线程sleep抽取模块线程结束AlarmType线程集合获取线程阻塞式循环获取任务线程startGetter初始化查询导入数据到H2移除中断线程不存在则新增M-4-2 告警核对模块Checker模块阻塞式循环获取任务Checker初始化循环更新报警缓存配置核对告警配置OMC报警线程Start推送数据线程集合获取线程PMC报警线程StartdoAlarm建立添加PushTaskdoCheck获取KPI阀值报警波动报警建立添加SaveTask不存在则新增不存在则新增M-4-3 告警入库保存模块Saver模块阻塞式循环获取任务一般告警Saver初始化
4、初始化报警记录doSave设置报警记录实体恢复告警更新PMC记录更新Cache记录建立并添加PushTask清除告警记录M-4-4 告警推送模块Pusher模块阻塞式循环获取任务Pusher初始化doPush封装报警实体查找请求用户推送报警数据循环列表超详细流程图1、 ExtracterOrcLogData data = new OrcLogData(); data:private Date date;private Map map;List dateCpmpare = new ArrayList();dateCpmpare:获取(selectCgiMaxTime和selectXcgiMaxTime)中的最大时间。dateDateMapOrcCgiParameter:private String tableName;private String beginTime;private String endTime;包名及其意义:一、 Adapter:1、 rtmp/codecStrategy:编码策略。2、 rtmp/protocol:接口协议(即是客户端传输过来的对象)3、 rtmp/respStrategy:各种子Handler二、