CN113905044B 一种对讲服务集群的业务级联拓展方法及其执行单元 （石家庄市善理通益科技有限公司）

一种对讲服务集群的业务级联拓展方法及本发明公开了一种对讲服务集群的业务级集群系统内注册有用于提供基础功能服务的已端所发起数据交互请求由集群系统分配至已有服务实例和/或新增服务实例实现对应的功能服2集群系统内注册有用于提供基础功能服务的所述终端所发起数据交互请求由集群系统分配至已有服务实例和/或新增服务实例实其中，所述的已有服务实例通过持续链接与终端通信，所述的已有服务实例和新增服务实例服务类集群系统包含服务网关，新增服务实例向服务网关发起注册服务网关接受新增服务实例服务地址并将服务地址更新至数据库，服务网关的起数据交互请求由集群系统分配至已有服务实例和/或新增服务实例实现对应的功能服重定向服务查询并下发健康服务实例库登录地址至对应终端，对所述已有服务实例的登录终端信息上传至数据库服务，数据库服务所对讲服务以目标终端所建立的UDP信道发送所述3所述已有服务实例分别与对应的某一终端建立单独对应的所述的所有的新增服务实例查找每一个通信链接并与每一个述的新增服务实例通过支链路查找所述的通信链接与所对应的某一理器适于实现权利要求1-6任一项所述的对讲服务集群的级联4针对小型化企业提供服务时仅需提供小型化的服务器进行轻量化服务时，如40-60人的集过云服务器或者IDC的硬件服务器作为载体进行安装部署。对讲系统软件通常包含的功能5少解决所述的服务器集群中并不能实现针对单独服务而进行单独的内存分配以实现模块[0014]所述终端所发起数据交互请求由集群系统分配至已有服务实例和/或新增服务实[0024]进一步的，所述终端发起数据交互请求由集群系统分配至已有服务实例和/或新[0026]调度服务根据数据交互请求的服务类型将该数据交互请求分配至对应的新增服[0027]进一步的，所述终端发起数据交互请求由集群系统分配至已有服务实例和/或新6[0031]监测服务定时与已有服务实例和新增服务实例通信交互，交互时长超出预设时括[0036]已有服务实例至少提供语音对讲服务，语音对讲服务获语音对讲服务以目标终端所建立的UDP信道发送所[0042]所述的所有的新增服务实例查找每一个通信连接并与每一个通信连接建立支链现以上所述的集成有对讲服务集群的业务级联拓展方法由处理[0048]图2为本发明中重定向服务及数据库服务与共享缓存的服务集群结构及信号流示7员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本发明保护的范[0055]一种对讲服务集群的业务级联拓展方法包括扩容级联方法和扩展新服务实例级201，所述的已有服务实例101及新增服务实例201可以是部署有服务实例的服务集群或者8[0066]设定已有服务实例101上线状态且与多个终端300通信交互以实现一个或多个基[0067]在实施过程中，已有服务实例101已纳入整体集群系统内，所述的已有服务实例101收到该数据包由已有服务实例101进行解析并根据另一终端300为地址转发至该终端300，所述的终端300和实现收发接收的另一个终端300形成群组，群组信息被数据库服务所述的基础功能的扩展功能服务或者新增服务实例201201通信，已有服务实例101和新增服务实例201通过交换机实现硬件联通，已有服务实例101会调用并开放对应的防火墙端口，新增服务实例201访问所述的已有服务实例101的防实例101的无线模块互相识别，识别完成后，以局域网wifi传播协议或者UWB传输协议、交换机而实现无线互联，其交互过程中，已有服务实例101会调用并开放对应的防火墙端201内预设已有服务实例101的IP信息，通过已有服务实例101的IP信息查找到已有服务实9请求包含新增服务实例201的登录地址，所述的新增服务实例201与已有服务实例101同时也通信互联，所述的新增服务实例201依据配置清单对自身环境进行配置以无线形式在协[0080]已有服务实例101也可接受网络上线请求并将网络上线请求转发至服务网关进行群系统，检索集群系统的数据库所获得的扩展服务类型的终端300目录进行汇总并下发上线通知，下发后所述的终端300接收到封装数据包以预先设置好的读取格式进行读取并对自身的登录模块进行更新，注册完成后更新新增服务实例201为上线状态，已有服务实例101将所述的新增服务实例201的地址更新至所述的基础服务所对应的终端300的登录地[0081]所述终端300所发起数据交互请求由集群系统分配至已有服务实例101和/或新增的新增服务实例201并与新增服务实例201建立通信连接以实现扩展功能服务和基础功能[0084]①新增服务实例201检索由集群系统的数据库所共享出的共享缓存202查找该终进行鉴权，所述的扩展服务类型的终端300根据配置文件更新配置列表时于此同时，终端300同时将自身登录信息发送至已有服务实例101的且由已有服务实例101查询集群系统数[0089]所述终端所发起数据交互请求由集群系统分配至已有服务实例和/或新增服务实业务模块对应的已有服务实例101，视频业务则调度视频业务模块对应新增服务实例201，首先由调度服务判断其属于已有服务实例101所提供的基础服务或新服务实例201都由调度服务进行调度以分别实现不同服务类型，当该数据交互请求对应类基础功能服务实例对数据交互请求中包含数据内容进行[0092]其中终端300与服务器之间TCP信道所收发的控制信令，新增服务实例201所发出的控制信令经由已有服务实例101进行转发下发给对应终端300，或者新增服务实例201所[0093]其中终端300与已有服务实例101建立用于传输基础功能对应消息的UDP信道与新增服务实例201建立起用于传输扩展功能群组的所有终端300，已有服务实例101或新增服务实例201将数据交互请求所包含数据内[0098]服务网关接受新增服务实例201服务地址并将服务地址更新至数据库，服务网关[0100]所述的新增服务实例201连接互联网并向服务网关发起注册请求，注册请求包含[0101]如图5和图6所示，已有服务实例101已注册至集群系统内，集群系统包括消息总增服务实例201的登录地址以接受新增服务实例201的注册请求，新增服务实例201与服务[0105]新增服务实例201向已有服务实例101发送网络上线请求，新增服务实例201以预有服务实例101根据新增服务实例201的配置信息注册识别新增服务实例201，已有服务实例101根据所述的配置信息更新自身的配置清单将自身的配置清单更新至集群系统的数据[0106]新增服务实例201注册至集群系统中以提供扩展功能服务，所述的新增服务实例201依据配置清单对自身环境进行配置以无线形式在协议规定频段收发数据或有线形式登录至互联网，其中已有服务实例101和新增服务实例201都并发有父进程以监听连接请求，已有服务实例101随后将所述的配置信息下发至所有终端300，终端300更新自身的登录配[0109]所述终端300发起数据交互请求由集群系统分配至已有服务实例101和/或新增服[0110]所述的集群系统搭载有调度服务，所述的终端300所发起数据交互请求优先访问[0111]调度服务根据数据交互请求的服务类型将该数据交互请求分配至对应的新增服对应终端300的信息至共享缓存202，共享缓存202用于写入和存储所述的扩展功能所对应和存储，公共数据库即为集群系统数据库服务102，公共数据库其内信息共享至共享缓存令消息的TCP信道或者对应终端300的与新增服务实例201建立用于传输信令消息的TCP信[0117]登录后终端300发送数据根据其业务类型，如POC业务则调度服务调度POC业务模调度服务判断其属于已有服务实例101所提供的基础服务或新增服务实例201都由调度服务进行调度以分别实现不同服务类型，当该数据交互请求对应类基础功能服务实例对数据交互请求中包含数据内容进行[0119]其中终端300与服务器之间TCP信道所收发的控制信令，新增服务实例201所发出的控制信令经由已有服务实例101进行转发下发给对应终端300，或者新增服务实例201所[0120]其中终端300与已有服务实例101建立用于传输基础功能对应消息的UDP信道与新增服务实例201建立起用于传输扩展功能群组的所有终端300，已有服务实例101或新增服务实例201将数据交互请求所包含数据内询服务网关，服务网关查询已有服务实例101的存活状态，并将健康存活的已有服务实例询服务网关，服务网关查询新增服务实例201的存活状态，并将健康存活的新增服务实例[0127]新增服务实例201的服务类型包括视频服务、多媒体离线服务，录音服务离线服务，终端300向已有服务实例101和/或新增服务实例201发起服务请求时访问重定向服务，重定向服务对比已有服务实例101和/或新增服务实例201负载，并将负载最低的服务器且[0129]可选的，包括集群系统搭载有用于为终端300重新分配服务实例的重定向服务和[0131]重定向服务查询并下发健康服务实例501库登录地址至对应终端300，对应终端300根据所述的健康服务实例501的地监控服务通知调度服务将数据流转故障所对应终端300分配至数据流转正常服务器的服务[0140]所述的所有的新增服务实例201查找每一个通信连接并与每一个通信连接建立支[0142]各个终端300发送链接请求前分配唯一的随机数组，该随机数组为该链接请求的服务实例将各个随机数组确定唯一对应的随机编号，以每个随机数组所对应终端300为目的地返回返回携带有随机编号的预定类型的长存活或不限期存活应答链接至终[0146]服务实例的循环自检以携带该随机数组的预先定义的格式的数据包，终端300循[0147]同时，新增服务实例201向已有服务实例101发送链接请求前分配唯一的随机字[0149]终端300请求扩展功能服务时经由与调度器所对应链接收发，调度器通过查询服务网关中存活的新增服务实例201，新增服务实例201获取到所述的终端300所对应的随机[0151]新增服务实例201查找所述的随机数组所对应的随机字码，确定目标已有服务实的接收地址信息变更为对应随机编号所对应的终端3[0152]①返回数据经由目标已有服务实例101通过持续链路发送至随机数组所对应的目[0154]②目标发送地址由已有服务实例101的接收地址信息变更为对应随机编号所对应[0160]通过确定当地网络波动和与上级节点的波动健康情况判定服务实例宕机问题或[0163]数据库服务102所分享出的缓存数据库内存储有随机编号、随机数组和随机字码存在缓存语音帧链包则将缓存的语音帧链包的上传次序按照由上传次序较早到上传次序服务实例的登录地址重新申请登录并建立持续链接，登录成功后数据库服务102通知缓存数据库准备依照所述的键值表向对应的终端300同步语音流转数据，同时通知该键值表该语音流转数据包含语音帧链包，语音帧链包所对应语音信息在终端300被重新组合后标红及述实现权利要求所述的集成有对讲服务集群的业务级联拓展方