一种多域信令快速调度方法
技术领域
本发明涉及通信领域，尤其涉及一种多域信令快速调度方法。
背景技术
随着雪亮工程建设不断地提速，为安防行业发展带来了众多发展机遇，也为提升公安机关各项警务战斗工作提供了坚实基础。物联网、云计算、大数据等新技术逐渐兴起并应用到安防行业，公共安全视频监控建设联网应用将为更多基于视频深度应用提供基础信息，不断推进社会管理创新，具有重要的战略意义。雪亮工程既是打造“互联网+”环境下加强和创新社会治安防控体系建设的重要途径，也是对天网工程、平安城市等视频监控全覆盖工程的巩固和延伸。
实现视频的互联互通，通常将远端视频流，经过网络传输给乡镇级视频联网平台，再转发至县级视频联网平台，最终将视频流传输给客户端播放。用户实现对视频码流的实时点播、控制、历史视频的检索和回放等调度信令，都是逐级下发进行控制。以乡镇为域单位进行视频汇聚，然后统一汇聚到上级平台。由于各地方基础网络建设时期不同，网络带宽负载能力、复杂度都有所不同，特别是多个域的情况下，个别域网络不好，造成整个联网平台调度信令的延迟，甚至阻塞，用户体验效果非常差。
单域网络环境不好时，导致其他域信令延迟、阻塞；多信令并发时执行时间耗时长；由于前一个信令同步反馈结果有延迟导致下一个信令超时或者无效。因此一种多域信令快速调度方法就显得尤为重要。
因此，本领域的技术人员致力于开发一种多域信令快速调度方法，有效地解决多域、网络环境复杂导致调度延迟、阻塞的情况，算法简单易懂且应用范围较广。
发明内容
有鉴于现有技术的上述缺陷，本发明所要解决的技术问题是解决信令传输不受限于某一个域的网络环境；降低多信令并发时执行时间；降低因信令超时引起无效信令的概率。
为实现上述目的，本发明提供了一种多域信令快速调度方法，包括以下步骤：
步骤1、初始化：对接入的所有下级域绑定对应的消息处理入口，设置所有所述下级域的消息处理模式为从模式，设置上级域的消息处理模式为主模式，设置所述下级域的域ID后开始消息的轮转，开启所述下级域接收消息线程；
步骤2、消息轮转：所述上级域在接收到消息后对消息进行预分析后根据消息的类型进行不同的消息处理，根据信令携带的参数查找当前信令所需要的环境并根据环境进行匹配域信息，根据域绑定的消息处理入口判断主从模式，然后进行对应的消息处理；
步骤3、资源释放，结束。
进一步地，所述步骤1包括以下步骤：
步骤1.1、获取联网平台相关服务的信息；
步骤1.2、相关服务初始化成功后插入对应的列表中；
步骤1.3、从数据库中获取上下级域信息；
步骤1.4、根据域信息创建所述下级域队形，设置IP、端口、域ID等信息，初始化所述下级域；
步骤1.5、将所述下级域插入到域管理队列中；
步骤1.6、遍历所有域，设置心跳回调，链接下级域，创建信令通路；
步骤1.7、创建所述下级域的消息处理模块；
步骤1.8、获取sip服务信息，sip服务初始化，参数设置。
进一步地，所述步骤1.7包括以下步骤：
步骤1.7.1、创建消息处理对象；
步骤1.7.2、所述下级域绑定对应的消息处理对象；
步骤1.7.3、设置所述下级域的工作模式为从模式；
步骤1.7.4、开始消息轮转，开启所述下级域的消息接收。
进一步地，所述步骤2包括以下步骤：
步骤2.1、查看消息接收队列；
步骤2.2、延时等待填充消息队列；
步骤2.3、信令接收，创建接收缓冲；
步骤2.4、从信令接收缓冲中获取信令；
步骤2.5、信令解析，查看是否是停止消息，如果是，执行所述步骤3；
步骤2.6、保存当前消息指针，数据拷贝，方便后续的消息传递；
步骤2.7、信令分发处理；
步骤2.8、查看是否播放信令；
步骤2.9、查看是否其他信令；
步骤2.10、其他信令处理。
进一步地，所述步骤2.1查看消息接收队列是否为空，如果为空执行所述步骤2.2，否则执行所述步骤2.3。
进一步地，所述步骤2.8查看信令是否播放信令，如果是执行播放处理流程，否则执行所述信令步骤2.9。
进一步地，所述播放处理流程包括以下步骤：
步骤2.8.1、参数合法性检测；
步骤2.8.2、系统时钟校验，检查客户端是否存在，当前设备是否可操作；
步骤2.8.3、根据摄像头ID获取摄像头信息，获取所述摄像头对应的设备ID及通道信息；
步骤2.8.4、获取设备所在的域ID；
步骤2.8.5、查看当前的工作模式；
步骤2.8.6、获取设备所在域的域对象；
步骤2.8.7、向对应下级域消息队列插入当前消息的深拷贝，消息分发；
步骤2.8.8、建立当前设备通路获取转发地址，创建转发通路；
步骤2.8.9、更新错误状态并返回结果，资源释放。
进一步地，所述步骤2.8.1参数合法性检测，如果合法执行所述步骤2.8.2，否则执行所述步骤2.8.9。
进一步地，所述步骤2.8.5查看当前的工作模式是否是主模式，如果是则执行所述步骤2.8.6，否则执行所述步骤2.8.8。
进一步地，所述步骤2.9查看是否其他信令，如果是执行所述步骤2.10，否则执行所述步骤3。
在本发明的较佳实施方式中，通过主从消息队列设计模式，通过信令类型实现消息队列的入和出。
在本发明的另一较佳实施方式中，使用线程池方式，将信令送入线程池快速执行也可实现。
本发明与现有技术相比较，具有如下显而易见的实质性特点和显著优点：
1、直观改善了信令执行慢导致视频播放不流畅的问题。
2、提升了多域并行信令并发访问的效率。
3、在多域且网络情况不好的情况下，有效降低了无效信令的出现概率。
以下将结合附图对本发明的构思、具体结构及产生的技术效果作进一步说明，以充分地了解本发明的目的、特征和效果。
附图说明
图1是本发明的一个较佳实施例的初始化流程图；
图2是本发明的一个较佳实施例的创建下级域消息处理图；
图3是本发明的一个较佳实施例的消息轮转流程图；
图4是本发明的一个较佳实施例的播放处理流程图。
具体实施方式
以下参考说明书附图介绍本发明的多个优选实施例，使其技术内容更加清楚和便于理解。本发明可以通过许多不同形式的实施例来得以体现，本发明的保护范围并非仅限于文中提到的实施例。
在附图中，结构相同的部件以相同数字标号表示，各处结构或功能相似的组件以相似数字标号表示。附图所示的每一组件的尺寸和厚度是任意示出的，本发明并没有限定每个组件的尺寸和厚度。为了使图示更清晰，附图中有些地方适当夸大了部件的厚度。
本发明提供一种多域信令快速调度的方法。主要提供一种多域信令快速调度的方法，同时也为后续的信令处理奠定了一定的基础。
采用主-从模式消息队列方式，接收到信令后，对信令类型分析判断，如果是本域信令，直接执行该信令。如果非本域信令，将信令快速路由到下级域，实现了一种多域信令快速调度方法。
步骤1、初始化。
如图1所示为初始化的流程图。
1.1)获取联网平台相关服务的信息；
1.2)相关服务初始化成功后插入对应的列表中；
1.3)从数据库中获取上下级域信息；
1.4)根据域信息创建下级域队形，设置IP、端口、域ID等信息，初始化下级域；
1.5)将下级域插入到域管理队列中；
1.6)遍历所有域，设置心跳回调，链接下级域，创建信令通路；
1.7)创建下级域的消息处理模块；
如图2所示创建下级域消息处理模块的主要流程如下：
1.7.1)创建消息处理对象；
1.7.2)下级域绑定对应的消息处理对象；
1.7.3)设置下级域的工作模式为从模式；
1.7.4)消息轮转，开启下级域的消息接收。
1.8)获取sip服务信息，sip服务初始化，参数设置。
步骤2、消息轮转。
如图3所示消息轮转的流程如下：
2.1)查看消息接收队列是否为空，如果为空，执行步骤2.2，否则执行步骤2.3；
2.2)延时等待填充消息队列；
2.3)信令接收，创建接收缓冲；
2.4)从信令接收缓冲中获取信令；
2.5)信令解析，查看是否是停止消息，如果是，执行步骤3，否则执行步骤2.6；
2.6)保存当前消息指针，数据拷贝，方便后续的消息传递；
2.7)信令分发处理；
2.8)查看是否播放信令，如果是，执行步骤2.8.1，否则执行步骤2.9；
如图4所示播放处理的流程如下：
2.8.1)参数合法性检测，如果合法执行步骤2.8.2，否则执行步骤2.8.9；
2.8.2)系统时钟校验，检查客户端是否存在，当前设备是否可操作；
2.8.3)根据摄像头ID获取摄像头信息，获取摄像头对应的设备ID及通道信息；
2.8.4)获取该设备所在的域ID；
2.8.5)查看当前的工作模式是否是主模式，如果则执行步骤2.8.6，否则执行步骤2.8.8；
2.8.6)获取设备所在域的域对象；
2.8.7)向对应下级域消息队列插入当前消息的深拷贝(消息分发)；
2.8.8)建立当前设备通路获取转发地址，创建转发通路；
2.8.9)更新错误状态并返回结果，资源释放。
2.9)查看是否其他信令，如果是，执行步骤2.10，否则执行步骤3；
2.10)其他信令处理。
步骤3、资源释放，结束。
本方案是通过主从消息队列设计模式，通过信令类型实现消息队列的入和出。使用线程池方式，将信令送入线程池快速执行也可以实现。
以上详细描述了本发明的较佳具体实施例。应当理解，本领域的普通技术无需创造性劳动就可以根据本发明的构思作出诸多修改和变化。因此，凡本技术领域中技术人员依本发明的构思在现有技术的基础上通过逻辑分析、推理或者有限的实验可以得到的技术方案，皆应在由权利要求书所确定的保护范围内。
