应急广播平台的消息播发方法和设备与流程

1.本发明涉及通信技术领域，尤其涉及一种应急广播平台的消息播发方法和设备。


背景技术：

2.应急广播，是指一种利用广播系统向公众发布突发事件相关信息的方式。通常应急广播系统由应急广播平台、消息接收设备、传输覆盖网络和客户端设备等组成。应急广播消息，是指各级调度控制平台之间，以及调度控制平台到播发平台，播发平台到客户端之间传递的数据。
3.应急广播平台消息播发通常是在b端（服务端，例如转发平台、播发平台等）之间通过超文本传输协议（hypertext transfer protocol，http）按照时间戳主动拉取广播消息，并传输至c端（客户端）。其中，b端拿到数据后优先解析，解析后的数据以一定的数据结构入库或刷入缓存，这种操作需要在b端的多个系统之间逐层传递下发。上述方案中，在b端之间的消息传递由于依赖下游主动获取，很容易出现下游自主配置时间粒度过大导致消息延迟从而不可靠。


技术实现要素：

4.本发明提供一种应急广播平台的消息播发方法和设备，用以解决现有技术中消息延迟较大的缺陷，实现一种延迟较小的消息播发方法。
5.本发明提供一种应急广播平台的消息播发方法，包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中。
6.根据本发明提供的一种应急广播平台的消息播发方法，在所述服务器为与所述客户端设备建立连接的服务器的情况下，所述方法还包括：接收客户端设备发送的请求消息，所述请求消息为所述客户端设备接收所述广播消息后发送的，用于请求所述广播消息中附件信息对应的附件数据；若所述服务器的本地未存储所述附件数据，则基于所述请求消息中附件信息对应的源地址，获取所述附件数据；所述源地址为所述服务器的上级应急广播平台的本地代理地址。
7.根据本发明提供的一种应急广播平台的消息播发方法，所述方法还包括：从上级应急广播平台的服务器获取消息队列中的广播消息，基于所述广播消息对应的区域范围，确定多个下级应急广播平台对应的消息队列；
将所述广播消息，以组播形式传输至所述多个下级应急广播平台对应的消息队列。
8.根据本发明提供的一种应急广播平台的消息播发方法，所述方法还包括以下至少一项：利用消息补齐模型对所述广播消息进行内容补充；在广播消息的播发策略出现冲突时，对所述广播消息的播发策略进行调整处理，所述播发策略为基于播发手段、播发次数、播发条件、消息适用范围中至少一项确定的。
9.根据本发明提供的一种应急广播平台的消息播发方法，所述对所述广播消息进行调整处理，包括：基于优先级顺序，对所述广播消息的播发策略进行调整处理；所述优先级顺序为播发手段的优先级大于播发次数的优先级。
10.根据本发明提供的一种应急广播平台的消息播发方法，所述利用消息补齐模型对所述广播消息进行内容补充，包括：利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息；基于所述历史消息对所述广播消息进行内容补充；所述相似度为基于消息的属性信息确定的，所述属性信息包括以下至少一项：消息类型、消息等级、影响范围。
11.根据本发明提供的一种应急广播平台的消息播发方法，所述利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息之前，还包括：利用预先建立的分类模型对训练集中的历史消息进行分类，得到多个分类集合；利用所述消息补齐模型确定所述多个分类集合中与所述广播消息匹配的目标分类集合；基于所述目标分类集合中的历史消息，对所述广播消息进行内容补充；基于补充后的广播消息的播发完成度，对所述分类模型和所述消息补齐模型的参数进行更新，得到训练后的消息补齐模型。
12.本发明还提供一种应急广播平台的消息播发方法，包括：接收目标应急广播平台基于消息队列发送的广播消息；若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
13.本发明还提供一种应急广播平台的消息播发装置，包括：获取模块，用于获取上级应急广播平台的服务器发送的广播消息；处理模块，用于若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息；传输模块，用于将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；所述传输模块，还用于若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中。
14.本发明还提供一种应急广播平台的消息播发装置，包括：接收模块，用于接收目标应急广播平台基于消息队列发送的广播消息；发送模块，用于若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；所述接收模块，还用于接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
15.本发明还提供一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述程序时实现如上述任一种所述应急广播平台的消息播发方法。
16.本发明还提供一种非暂态计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现如上述任一种所述应急广播平台的消息播发方法。
17.本发明还提供一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现如上述任一种所述应急广播平台的消息播发方法。
18.本发明提供的应急广播平台的消息播发方法和设备，若广播消息具有附件信息，则将广播消息中的附件信息对应的源地址替换为服务器的本地代理地址，得到预处理后的广播消息，并将预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中，上述方案中，服务器对于接收到的广播消息中附件不进行下载或解析，只是将广播消息中附件的源地址进行替换后转发至下级应急广播平台，而对于不带附件信息的广播消息直接进行转发，能够减小消息播发的延迟。
附图说明
19.为了更清楚地说明本发明或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
20.图1是本发明提供的应急广播平台的消息播发方法的流程示意图之一；图2是本发明提供的应急广播平台的消息播发方法的系统架构示意图；图3是本发明提供的应急广播平台的消息播发方法的消息播发示意图；图4是本发明提供的应急广播平台的消息播发方法的消息播发策略示意图；图5是本发明提供的应急广播平台的消息播发方法的消息传递示意图；图6是本发明提供的应急广播平台的消息播发方法的流程示意图之二；图7是本发明提供的应急广播平台的消息播发装置的结构示意图之一；图8是本发明提供的应急广播平台的消息播发装置的结构示意图之二；图9是本发明提供的电子设备的结构示意图。
具体实施方式
21.为使本发明的目的、技术方案和优点更加清楚，下面将结合本发明中的附图，对本发明中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
22.首先，对本发明实施例涉及的应用场景进行介绍：应急广播平台消息播发主要有两种手段：一种是在b端（服务端，例如转发平台、播发平台等）之间通过超文本传输协议（hypertext transfer protocol，http）按照时间戳主动拉取广播消息的手段，另一种是c端（客户端）通过http按照广播码主动请求b端获取消息的手段。其中，b端之间实现较为简单，只需要下游平台按照某个时间戳以一个约定的时间粒度轮询拉取数据即可，b端拿到数据后优先解析，解析后的数据以一定的数据结构入库或刷入缓存，这种操作需要在b端的多个系统之间逐层传递下发。c端获取数据则需要c端以某个频率定期主动获取结果。
23.上述方案中，在b端之间的消息传递由于依赖下游主动获取，很容易出现下游自主配置时间粒度过大导致消息延迟从而不可靠。
24.另外该方案中很容易造成上下游平台大量播发资源闲置或浪费；而且，上述c端主动请求b端获取消息的方案中，在b端到c端的消息传递除会出现上述问题外，还有个致命的问题就是c端由于受到网络和系统的不可靠性制约，会一定概率造成某些终端反复重试或反复请求，从而加剧形成数据洪峰，容易引起服务性能雪崩。
25.下面结合图1-图9以具体的实施例对本发明实施例的技术方案进行详细说明。下面这几个具体的实施例可以相互结合，对于相同或相似的概念或过程可能在某些实施例不再赘述。
26.图1是本发明提供的应急广播平台的消息播发方法的流程示意图之一。如图1所示，本实施例提供的方法包括：步骤101、获取上级应急广播平台的服务器发送的广播消息；具体的，在应急广播场景下，需要利用广播消息系统向公众发布突发事件相关信息，具有突发、实时、紧急的特点。目的是将应急广播平台的消息数据尽快播发下达到各端，广播消息的内容包括以下至少一项文本、图片和音视频信息。
27.如图2所示，可选地，上级应急广播平台向广播转发平台实时传递播发手段、播发条件及适用范围。
28.例如，播发手段采取上游主动通知调用下游接口实现，双方以简单对象访问协议（simple object access protocol，soap）为基础，提前约定字段保证数据一致性。
29.应急广播平台在满足一定的播发条件下播发应急广播消息，播发条件例如可以是消息队列中的消息数量不超过一定的数量阈值，服务器的负载小于预设阈值等，各级应急广播平台之间的链路情况等。
30.适用范围，例如指广播消息播发的地理区域范围，播发的用户的范围（例如某运营商的用户）等。
31.步骤102、若广播消息具有附件信息，则将广播消息中的附件信息对应的源地址替换为服务器的本地代理地址，得到预处理后的广播消息，并将预处理后的广播消息传输至
下级应急广播平台对应的消息队列中，消息队列用于下级应急广播平台向客户端设备发送广播消息；可选地，生产应急广播消息的应急广播平台至广播转发平台的播发整体延时最大不超过1秒。上级应急广播平台向广播转发平台的播发条件需要保证通过专网专线交互保证链路可靠性。其中，专线建设需要充分考虑文本、图片、音视频等流媒体文件的最大带宽要求，例如可以建立主备边界网关协议（border gateway protocol，bgp）链路，最大程度保证系统高可用性。
32.如图2所示，广播转发平台实时向广播播发平台传递播发手段、播发条件及适用范围等。
33.由于广播转发平台从上级应急广播平台以soap协议为基础被动接收消息通知，为了保证上下游应急广播平台的消息数据和附件的最小延迟性，广播消息在跨平台传输过程中始终采取先传递再解析的策略，广播消息向下游平台传递和本平台消息处理同步进行；对于其中包含的附件在跨平台传递过程中可以采取直接代理的原则，牺牲了一部分资源空间来换取消息同步时间。
34.广播转发平台消息向下游播发消息为通过将被动接收的广播消息首先进行预处理。对于消息（例如电子节目指南（electronic program guide，epg）信息）的内容不做任何处理，直接按照原始样例封装。但对于消息附件的信息则进行代理地址替换，将附件的源地址替换为本地代理地址，然后将预处理后的消息传输至消息队列。即对于接收到的广播消息先不对消息进行解析，优先进行转发，如果具有附件信息，只将广播消息中的附件信息对应的源地址替换为服务器的本地代理地址，即无需下载附件，可以减少消息延迟。
35.对于客户端设备来说，在接收到消息队列中的广播消息后，解析发现具有附件，则向与客户端设备连接的应急广播平台发送请求消息，用于请求附件数据，该应急广播平台可以先从缓存中获取，若没有则基于附件信息中本地代理地址，向上级应急广播平台获取，若上级应急广播平台的缓存中没有，则基于源地址从之前下发该广播消息的应急广播平台的服务器获取。
36.上述方案中，替换本地代理地址其实是一套具备合并回源能力的cdn服务，当首次请求时，代理服务会去源地址对附件数据进行拉取并缓存在缓存（cache）中，后续其他请求优先判定从cache中寻找，若找到则由cache直接返回，若没有则合并回源再次拉取，以低成本回源带宽代价承载高质量服务。
37.步骤103、若广播消息不具有附件信息，则直接将广播消息传输至下级应急广播平台对应的消息队列中。
38.具体的，若广播消息不具有附件信息，则无需对该广播消息进行预处理，直接将广播消息传输至下级应急广播平台对应的消息队列中。
39.本实施例的方法，若广播消息具有附件信息，则将广播消息中的附件信息对应的源地址替换为服务器的本地代理地址，得到预处理后的广播消息，并将预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中，上述方案中，服务器对于接收到的广播消息中附件不进行下载或解析，只是将广播消息中附件的源地址进行替换后转发至下级应急广播
平台，而对于不带附件信息的广播消息直接进行转发，能够减小消息播发的延迟。
40.可选地，在所述服务器为与所述客户端设备建立连接的服务器的情况下，所述方法还包括：接收客户端设备发送的请求消息，所述请求消息为所述客户端设备接收所述广播消息后发送的，用于请求所述广播消息中附件信息对应的附件数据；若所述服务器的本地未存储所述附件数据，则基于所述请求消息中附件信息对应的源地址，获取所述附件数据；所述源地址为所述服务器的上级应急广播平台的本地代理地址。
41.可选地，从上级应急广播平台的服务器获取消息队列中的广播消息，基于所述广播消息对应的区域范围，确定多个下级应急广播平台对应的消息队列；将所述广播消息，以组播形式传输至所述多个下级应急广播平台对应的消息队列。
42.可选地，如图2、图3所示，当前应急广播平台例如为广播转发平台，下级应急广播平台例如为广播播发平台，广播播发平台从长连接队列获取到消息后，不对消息进行完整解析，只将解析范围框定到区域码范围，然后根据区域码匹配省级队列范围，以组播形式进行发送，期间保证对应省侧每一个队列都能收到消息。
43.同理，省级播发队列也不对消息进行完整解析，只将解析范围框定到区域码范围，然后匹配市县级队列范围，以组播形式进行发送，期间保证对应市县侧每一个队列都能收到消息。
44.例如，广播播发平台进行区域码初选后向省级队列以长连接手段实施播发；省级队列接收到上游队列广播消息后，再根据区域码进行筛选、将符合条件的广播按照市县以长连接手段进行传递，由于需要保证整体播发时效性，播发平台向下游播发的队列层级不宜过多，以不超过三层为宜，整体播发时间控制在2秒以内；市县级队列会对播发报文进行初步校验，对于紧急播发缺少播发信息的内容会利用ai模型进行内容补全；市县级队列会根据本队列建立长连接的终端按照播发策略进行消息播发，并收集每个终端的播发数据，然后逐级上传反馈。
45.图2中，最上级的应急广播平台，即广播生产平台，用于进行消息生产，播发同步，播发统计等。
46.广播转发平台，用于进行广播接收，推送策略，附件代理，数据管理，队列管理，播发统计和统计上报等。
47.广播播发平台，用于进行播发管理，区域管理，附件管理，队列管理，队列监控，回调管理和广播推送等。
48.播发sdk为内嵌在客户端设备的应用程序，客户端设备例如包括移动端设备（如手机、平板电脑、智能手表等）和电视端等。
49.在一实施例中，该方法还包括以下至少一项：利用消息补齐模型对所述广播消息进行内容补充；在广播消息的播发策略出现冲突时，对所述广播消息的播发策略进行调整处理，所述播发策略为基于播发手段、播发次数、播发条件、消息适用范围中至少一项确定的。
50.具体的，应急广播消息由于具有突发、实时、紧急的特点。一些重大紧急预警报文
发布的第一时间往往信息不全面，为了使得消息内容更准确和全面，需要二次干预。这种场景下可以利用消息补齐模型根据历史相似度较高消息的类型、等级、影响范围等进行自适应匹配并减少人工干预，满足不断增长的人工需求。
51.在播发策略冲突的场景下，例如同一时间有两条广播消息都需要弹窗播发，但只能播发一条，此时即出现冲突，可以对播发策略进行调整处理，播发策略为基于播发手段、播发次数、播发条件、消息适用范围中至少一项确定的，例如播发策略中指示了播发手段具体采用哪种手段、播发次数为几次、播发条件包括哪些条件、消息适用范围为哪些区域。如图4所示，例如，消息类型包括全屏广播消息和弹窗广播消息等，消息等级又分为：特别紧急消息、紧急消息和普通消息。
52.消息推送，涉及播发策略管理、播发加密、消息剔除、播发结果跟踪、播发入队、播发上报等环节。其中，播发加密是指例如对于部分用户的广播消息可以进行加密处理。消息剔除例如指将不符合规范，或者优先级低的消息剔除，以保证播发效果。
53.可选地，该步骤也可以通过训练的ai模型实现。
54.可选地，基于优先级顺序，对所述广播消息的播发策略进行调整处理；所述优先级顺序为播发手段的优先级大于播发次数的优先级。
55.具体的，当播发消息的播发策略中的信息出现冲突时，可以以播发手段作为第一优先级，播发次数次之，以此类推将播发消息的播发策略重新调整。
56.上述实施方式中，利用消息补齐模型对所述广播消息进行内容补充；在广播消息的播发策略出现冲突时，对所述广播消息的播发策略进行调整处理，提高了播发成功率以及广播消息的质量。
57.进一步地，“利用消息补齐模型对所述广播消息进行内容补充”具体可以通过如下方式实现：利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息；基于所述历史消息对所述广播消息进行内容补充；所述相似度为基于消息的属性信息确定的，所述属性信息包括以下至少一项：消息类型、消息等级、影响范围。
58.具体的，利用相似度较高的历史消息，对广播消息进行内容补充，例如广播消息缺少类型，可以基于等级、影响范围等确定的相似度较高的历史消息的类型，对该广播消息的类型进行补充。
59.可选地，该消息补齐模型存在对应的激励机制，能够强化其算法匹配度。
60.可选地，在进行消息补齐之前，还需要对消息补齐模型进行训练，训练过程如下：利用预先建立的分类模型对训练集中的历史消息进行分类，得到多个分类集合；利用所述消息补齐模型确定所述多个分类集合中与所述广播消息匹配的目标分类集合；基于所述目标分类集合中的历史消息，对所述广播消息进行内容补充；基于补充后的广播消息的播发完成度，对所述分类模型和所述消息补齐模型的参数进行更新，得到训练后的消息补齐模型。
61.具体的，例如，消息补齐模型可以基于k-最近邻（k-nearest neighbors，knn）算法建立。分类模型可以采用决策树（decision tree）算法建立。
62.分类模型可以用于对历史消息进行分类，按照同分类、级别、影响范围等对历史消息的训练集进行分类，得到多个分类集合，从而利用消息补齐模型定位到与当前广播消息匹配的目标分类集合。按照匹配度从高到低依次匹配，例如，选取匹配度最高的10个目标分类集合，基于该10个目标分类集合的历史消息，对当前的广播消息进行内容补充，并对基于补充后的广播消息的播发完成度，对分类模型和消息补齐模型的参数进行更新，得到训练后的消息补齐模型。
63.由于knn算法本身非常适用于文本分类、聚类分析等场景，所以利用其算法特点匹配应急广播消息分类集合的速度极快。
64.消息补齐模型通过在整个训练集（基于分类模型得到的多个分类集合）中搜索k个最匹配的分类集合，例如k个分类集合为播发完成度最高的分类集合，后续补充后的广播消息的播发完成度也会作为该训练奖励机制的一部分，对消息补齐模型的参数进行更新。
65.k的选择很关键：较小的值可能会得到大量的噪声和不准确的结果，而较大的值是不可行的。可选地，本发明实施例中k可以设定为1000，其中，用于评估消息之间相似性的距离可以是欧几里得距离（euclidean distance），欧几里得距离是两点之间的普通直线距离。它实际上是点坐标之差平方和的平方根。
66.示例性地，可以获取匹配度得分与最高分相差20以内的所有分类集合，然后筛选出匹配度得分最高的top10的目标分类集合。如果目标分类集合只有一个则直接进行内容补充，生成播发策略。对于多个消息队列的场景将多个目标分类集合按照每个消息队列均分原则对当前广播消息进行消息内容补充并生成不多于10种播发策略。
67.可选地，当客户端设备对应急广播消息完成播发时，要对播发完成情况进行反馈上报，由与该客户端设备连接的应急广播平台的服务器节点整理后层层上报；上报的数据将用来对各级服务器的模型进行样本训练同时由广播播发平台最终汇总播发结果，统计完播率，方便运营人员及时调整参数指标。
68.本发明实施例还提供一种应急广播消息播发系统，包括：应急广播平台的服务器和客户端设备；其中，应急广播平台的服务器可以包括一个或多个，例如转发平台的服务器，播发平台的服务器等。
69.示例性地，如图5所示，该方法流程如下：上游应急广播平台向应急广播转发平台推送播发预警；应急广播转发平台的接口收到一条播发预警并对比入库，应急广播转发平台可以生成一个或多个子任务，每个子任务对应一个消息队列mq，并将播发预警录入播发记录表并推送报文（即推送广播消息）；确定是否有附件，若有则将专网地址转换为本地的代理地址，然后将广播消息推送至下游应急广播平台；若没有附件，则直接将广播消息推送至下游应急广播平台；其中，应急广播转发平台还可以将播发预警进行解析录入主记录表，异步下载附件；下游应急广播平台的接收接口接收推送的广播消息，并进行播发处理，以及向应急广播转发平台进行播发反馈，应急广播转发平台将反馈的播发完成情况录入播发记录表；
应急广播转发平台还可以定期扫描播发结束任务并统计所有渠道的播发情况，例如不同的上游应急广播平台的播发消息的播发完成情况。
70.应急广播转发平台还可以向上游应急广播平台发送播发回执报文，上游应急广播平台接收播发回执。
71.图6是本发明提供的应急广播平台的消息播发方法的流程示意图之二。如图6所示，本实施例提供的方法包括：步骤201、接收目标应急广播平台基于消息队列发送的广播消息；步骤202、若广播消息具有附件信息，则基于广播消息中的附件信息的源地址，向目标应急广播平台发送请求消息；附件信息中的源地址为目标应急广播平台的上级应急广播平台的服务器的本地代理地址；步骤203、接收目标应急广播平台基于请求消息发送的附件信息对应的附件数据。
72.本发明实施例的方法，其实现原理和技术效果与服务器侧方法类似，此次不再赘述。
73.下面对本发明提供的应急广播平台的消息播发装置进行描述，下文描述的应急广播平台的消息播发装置与上文描述的应急广播平台的消息播发方法可相互对应参照。
74.图7是本发明提供的应急广播平台的消息播发装置的结构示意图之一。如图7所示，本实施例提供的应急广播平台的消息播发装置，应用于服务器，该应急广播平台的消息播发装置包括：获取模块110，用于获取上级应急广播平台的服务器发送的广播消息；处理模块120，用于若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息；传输模块，用于将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；所述传输模块130，还用于若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中。
75.可选地，在所述服务器为与所述客户端设备建立连接的服务器的情况下，所述获取模块110，还用于：接收客户端设备发送的请求消息，所述请求消息为所述客户端设备接收所述广播消息后发送的，用于请求所述广播消息中附件信息对应的附件数据；若所述服务器的本地未存储所述附件数据，则基于所述请求消息中附件信息对应的源地址，获取所述附件数据；所述源地址为所述服务器的上级应急广播平台的本地代理地址。
76.可选地，处理模块120，具体用于：从上级应急广播平台的服务器获取消息队列中的广播消息，基于所述广播消息对应的区域范围，确定多个下级应急广播平台对应的消息队列；传输模块130，具体用于：将所述广播消息，以组播形式传输至所述多个下级应急广播平台对应的消息队列。
77.可选地，处理模块120，还用于执行以下至少一项：利用消息补齐模型对所述广播消息进行内容补充；
在广播消息的播发策略出现冲突时，对所述广播消息的播发策略进行调整处理，所述播发策略为基于播发手段、播发次数、播发条件、消息适用范围中至少一项确定的。
78.可选地，处理模块120，具体用于：基于优先级顺序，对所述广播消息的播发策略进行调整处理；所述优先级顺序为播发手段的优先级大于播发次数的优先级。
79.可选地，处理模块120，具体用于：利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息；基于所述历史消息对所述广播消息进行内容补充；所述相似度为基于消息的属性信息确定的，所述属性信息包括以下至少一项：消息类型、消息等级、影响范围。
80.可选地，所述处理模块120，还用于：利用预先建立的分类模型对训练集中的历史消息进行分类，得到多个分类集合；利用所述消息补齐模型确定所述多个分类集合中与所述广播消息匹配的目标分类集合；基于所述目标分类集合中的历史消息，对所述广播消息进行内容补充；基于补充后的广播消息的播发完成度，对所述分类模型和所述消息补齐模型的参数进行更新，得到训练后的消息补齐模型。
81.本发明实施例的装置，其用于执行前述服务器侧任一方法实施例中的方法，其实现原理和技术效果类似，此次不再赘述。
82.图8是本发明提供的应急广播平台的消息播发装置的结构示意图之二。如图8所示，本实施例提供的应急广播平台的消息播发装置，应用于客户端设备，该应急广播平台的消息播发装置包括：接收模块210，用于接收目标应急广播平台基于消息队列发送的广播消息；发送模块220，用于若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；所述接收模块210，还用于接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
83.本发明实施例的装置，其用于执行前述客户端设备侧任一方法实施例中的方法，其实现原理和技术效果类似，此次不再赘述。
84.图9示例了一种电子设备的实体结构示意图，如图9所示，该电子设备可以包括：处理器(processor)1010、通信接口(communications interface)1020、存储器(memory)1030和通信总线1040，其中，处理器1010，通信接口1020，存储器1030通过通信总线1040完成相互间的通信。处理器1010可以调用存储器1030中的逻辑指令，以执行应急广播平台的消息播发方法，该方法包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台
向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中；或，接收目标应急广播平台基于消息队列发送的广播消息；若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
85.此外，上述的存储器1030中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备（可以是个人计算机，服务器，或者网络设备等）执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器（rom，read-only memory）、随机存取存储器（ram，random access memory）、磁碟或者光盘等各种可以存储程序代码的介质。
86.另一方面，本发明还提供一种计算机程序产品，所述计算机程序产品包括计算机程序，计算机程序可存储在非暂态计算机可读存储介质上，所述计算机程序被处理器执行时，计算机能够执行上述各方法所提供的应急广播平台的消息播发方法，该方法包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中；或，接收目标应急广播平台基于消息队列发送的广播消息；若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
87.又一方面，本发明还提供一种非暂态计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现以执行上述各方法提供的应急广播平台的消息播发方法，该方法包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；
若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中；或，接收目标应急广播平台基于消息队列发送的广播消息；若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。
88.以上所描述的装置实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。
89.通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中，如rom/ram、磁碟、光盘等，包括若干指令用以使得一台计算机设备（可以是个人计算机，服务器，或者网络设备等）执行各个实施例或者实施例的某些部分所述的方法。
90.最后应说明的是：以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

技术特征：
1.一种应急广播平台的消息播发方法，其特征在于，应用于服务器，所述方法包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中。2.根据权利要求1所述的应急广播平台的消息播发方法，其特征在于，在所述服务器为与所述客户端设备建立连接的服务器的情况下，所述方法还包括：接收客户端设备发送的请求消息，所述请求消息为所述客户端设备接收所述广播消息后发送的，用于请求所述广播消息中附件信息对应的附件数据；若所述服务器的本地未存储所述附件数据，则基于所述请求消息中附件信息对应的源地址，获取所述附件数据；所述源地址为所述服务器的上级应急广播平台的本地代理地址。3.根据权利要求1所述的应急广播平台的消息播发方法，其特征在于，所述方法还包括：从上级应急广播平台的服务器获取消息队列中的广播消息，基于所述广播消息对应的区域范围，确定多个下级应急广播平台对应的消息队列；将所述广播消息，以组播形式传输至所述多个下级应急广播平台对应的消息队列。4.根据权利要求1-3任一项所述的应急广播平台的消息播发方法，其特征在于，所述方法还包括以下至少一项：利用消息补齐模型对所述广播消息进行内容补充；在广播消息的播发策略出现冲突时，对所述广播消息的播发策略进行调整处理，所述播发策略为基于播发手段、播发次数、播发条件、消息适用范围中至少一项确定的。5.根据权利要求4所述的应急广播平台的消息播发方法，其特征在于，所述对所述广播消息进行调整处理，包括：基于优先级顺序，对所述广播消息的播发策略进行调整处理；所述优先级顺序为播发手段的优先级大于播发次数的优先级。6.根据权利要求4所述的应急广播平台的消息播发方法，其特征在于，所述利用消息补齐模型对所述广播消息进行内容补充，包括：利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息；基于所述历史消息对所述广播消息进行内容补充；所述相似度为基于消息的属性信息确定的，所述属性信息包括以下至少一项：消息类型、消息等级、影响范围。7.根据权利要求6所述的应急广播平台的消息播发方法，其特征在于，所述利用所述消息补齐模型获取与所述广播消息的相似度大于或等于第一阈值的历史消息之前，还包括：利用预先建立的分类模型对训练集中的历史消息进行分类，得到多个分类集合；利用所述消息补齐模型确定所述多个分类集合中与所述广播消息匹配的目标分类集合；
基于所述目标分类集合中的历史消息，对所述广播消息进行内容补充；基于补充后的广播消息的播发完成度，对所述分类模型和所述消息补齐模型的参数进行更新，得到训练后的消息补齐模型。8.一种应急广播平台的消息播发方法，其特征在于，应用于客户端设备，所述方法包括：接收目标应急广播平台基于消息队列发送的广播消息；若所述广播消息具有附件信息，则基于所述广播消息中的附件信息的源地址，向所述目标应急广播平台发送请求消息；所述附件信息中的源地址为所述目标应急广播平台的上级应急广播平台的服务器的本地代理地址；接收所述目标应急广播平台基于所述请求消息发送的附件信息对应的附件数据。9.一种电子设备，包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现如权利要求1至7任一项所述应急广播平台的消息播发方法，或如权利要求8所述应急广播平台的消息播发方法。10.一种非暂态计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现如权利要求1至7任一项所述应急广播平台的消息播发方法，或如权利要求8所述应急广播平台的消息播发方法。

技术总结
本发明提供一种应急广播平台的消息播发方法和设备，属于通信技术领域，该方法包括：获取上级应急广播平台的服务器发送的广播消息；若所述广播消息具有附件信息，则将所述广播消息中的附件信息对应的源地址替换为所述服务器的本地代理地址，得到预处理后的广播消息，并将所述预处理后的广播消息传输至下级应急广播平台对应的消息队列中，所述消息队列用于所述下级应急广播平台向客户端设备发送广播消息；若所述广播消息不具有附件信息，则直接将所述广播消息传输至下级应急广播平台对应的消息队列中。的消息队列中。的消息队列中。


技术研发人员：杜鹏
受保护的技术使用者：银河互联网电视有限公司
技术研发日：2023.06.15
技术公布日：2023/7/21