通信方法、设备及控制装置与流程

1.本发明涉及通信技术领域，特别是涉及一种通信方法、设备及控制装置。


背景技术：

2.现有的通讯控制中，服务器向客户端发送指令消息，且每隔一段时间需发送心跳包消息，一般都是使用临界区的机制，保证每次只能发送一个消息包。
3.然而，由于一次只能发送一个消息包，从而在实际使用过程中存在信息链路堵塞，进而重要信息不能及时处理的情况，用户没有较好的用户体验。


技术实现要素：

4.本发明主要解决的技术问题是提供一种通信方法、设备及控制装置，便于信息的管控，并减小了信息链路堵塞的可能性，重要信息可以优先处理，能够优化对于失效消息的管控，进而提高了用户的使用感受。
5.为解决上述技术问题，本发明采用的一个技术方案是：提供一种通信方法，所述通信方法包括：响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息；将所述目标待处理信息发送至客户端。
6.其中，所述响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息的步骤之前，还包括：
7.获取到待处理信息，并将所述待处理信息按照其优先级别添加到对应的队列信息中；
8.所述响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息的步骤，包括：
9.响应于检测到当前到达心跳包的发送周期，从优先级别最高的队列信息中按照顺序选择所述目标待处理信息。
10.其中，所述将所述目标待处理信息发送至客户端的步骤包括：检测所述目标待处理消息是否出现异常；如果出现异常，弹出提醒消息。
11.其中，所述检测所述目标待处理消息是否出现异常的步骤，包括：如果检测到发送所述目标待处理信息超过设定时间、所述目标待处理信息的重复发送次数超过设定次数中的至少一种，确定所述目标待处理信息出现异常。
12.其中，如果在设定次数的心跳包内所述目标待处理信息未发送成功，确定所述目标待处理信息超过设定时间。
13.其中，如果在设定的重发次数内所述目标待处理信息未发送成功，确定所述目标待处理信息的重复发送次数超过设定次数。
14.其中，所述如果检测到发送所述目标待处理信息超过设定时间、所述所述目标待处理信息的重复发送次数超过设定次数中的至少一种，确定所述目标待处理信息出现异常的步骤之前，还包括：获取目标待处理信息并校验，将所述目标待处理信息进行标注；判断
目标处理消息是否需要发送协议消息到客户端，如有则发送。
15.其中，所述将所述目标待处理信息发送至客户端的步骤，还包括：将异常的所述目标待处理消息的执行指令删除。
16.为解决上述技术问题，本发明采用的第二个技术方案是：提供一种通信设备，包括处理器、存储器，其中，所述处理器配置有第一个技术方案中任一项所述的通信方法。
17.为解决上述技术问题，本发明采用的第三个技术方案是：提供一种通信控制装置，包括：调度模块：用于调度与管理待处理的消息；接收模块：用于接收所述待处理消息判断并标记是否检测完成；执行模块：用于将所述待处理的消息进行判断并进行发送；检查模块：判断发送的所述待处理的消息是否异常，并对异常的所述待处理消息进行报错。
18.以上方案，通过先检测心跳包的发送周期，随后根据优先级对消息队列进行管理，发送结束后处理的消息进行检测并判断是否异常，对此类异常消息进行处理，并向客户端弹送提醒消息，从而加强了对消息列队的中对于异常消息的管理，减小了重复发送的可能性，减小了信息链堵塞的可能，同时也使得用户了解到未完成的消息，提高了用户在使用客户端时的体验与感受。
附图说明
19.图1是本发明通信方法第一实施例的流程图；
20.图2是本发明通信方法第二实施例的流程图；
21.图3是本发明通信设备一实施例的结构示意图；
22.图4是本发明通信控制装置一实施例的结构示意图。
具体实施方式
23.下面将结合本技术实施例中的附图，对本技术实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅是本技术的一部分实施例，而不是全部的实施例。基于本技术中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本技术保护的范围。
24.若本技术技术方案涉及个人信息，应用本技术技术方案的产品在处理个人信息前，已明确告知个人信息处理规则，并取得个人自主同意。若本技术技术方案涉及敏感个人信息，应用本技术技术方案的产品在处理敏感个人信息前，已取得个人单独同意，并且同时满足“明示同意”的要求。例如，在摄像头等个人信息采集装置处，设置明确显著的标识告知已进入个人信息采集范围，将会对个人信息进行采集，若个人自愿进入采集范围即视为同意对其个人信息进行采集；或者在个人信息处理的装置上，利用明显的标识/信息告知个人信息处理规则的情况下，通过弹窗信息或者请个人自行上传其个人信息等方式获得个人授权；其中，个人信息处理规则可包括个人信息处理者、个人信息处理目的、处理方式以及处理个人信息种类等信息。
25.请参阅图1，图1是本发明通信方法第一实施例的流程图。需注意的是，若有实质上相同的结果，本发明的方法并不以图1所示的流程顺序为限。如图1所示，该方法包括如下步骤：
26.s101：响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的
目标待处理信息。
27.在本实施例中，首先在对信息进行处理前需要检测心跳包的发送周期，获取到心跳包的发送周期，可以提高在发送信息时通信通道的稳定性。接着将优先级别最高的处理信息从队列中选中，进而可以使得较为紧急的信息可以优先进行处理，使得消息的发送更加合理，以防止重要信息不能第一时间进行传递。
28.s102：将所述目标待处理信息发送至客户端。
29.在本实施例中，从队列中选取的优先级最高且在同优先级中排序第一的信息进行处理，在所有待处理的信息之中，优先级最高且同优先级中排序第一位的信息即为目标待处理信息，随后将目标待处理信息发送至客户端。
30.本实施例中，通过设立优先级队列对待处理信息进行精准的排序，并检测心跳包周期，从而便于消息的准确发送与对待处理信息的管控，以避免通信道路的拥堵，提高信息处理的速度。
31.请参阅图2，图2是本发明通信方法第二实施例的流程图。需注意的是，若有实质上相同的结果，本发明的方法并不以图2所示的流程顺序为限。如图2所示，该方法包括如下步骤：
32.s201：获取到待处理信息，并将所述待处理信息按照其优先级别添加到对应的队列信息中。
33.本实施例中，首先将需要处理的信息进行收集，并对不同的信息判断分类，不同的信息可能属于不同的优先级，将收集的待处理信息按优先级进行分类，并将所以的待处理信息加入队列中，相同的优先级按照进入队列的先后依次进行排序。
34.其中，队列中设置有多个二级队列即多个优先级不同的队列，各个二级队列之间的先后顺序更具优先级的高低进行排序，即在同一个二级队列中的待处理信息为同一个优先级别，二级队列中的先后顺序通过处理信息的添加时间一次排序。即每次用户键入操作或者需要请求客户端数据时，根据该信息的优先级向与该信息优先级相对应的二级队列的末尾添加消息。
35.例如，当报警信息与天气信息同在队列中时，由于报警信息与天气信息属于不同的优先级别，即报警信息与天气信息位于两个不同的二级队列中，在添加信息时，将报警信息与天气信息添加至与之对应的二级队列之中，位于对应优先级二级队列的队列尾部。在处理信息时，按照各二级队列的优先级排序又高到低依次处理，在处理各二级队列中时，按照先后排序依次进行处理。
36.s202：响应于检测到当前到达心跳包的发送周期，从优先级别最高的队列信息中按照顺序选择所述目标待处理信息。
37.在本实施例中，在选择需要发送的信息前，需要检测与客户端之间心跳包的发送周期。首先判断此时是否有正在发送的信息，若此时有信息正在处理，则等待该消息处理结束后，再次判断是否有正在发送的信息，直至当前没有信息正在处理，接着需要检查此时心跳包是否到达一个心跳包周期，若此时心跳包到了一个周期，则需要创建一个心跳包并进行处理，处理后即可处理队列中的待处理信息；若此时未到一个心跳包周期，则继续处理待处理的信息。首先检查优先级最高的二级队列是否有待处理的信息，若有待处理的信息，则取出进行处理；若无待处理信息则检查优先级其次的二级队列，同样检查优先级其次的二
级队列是否有待处理信息，直至检测到有待处理信息。可以理解为选取优先级最高且在同优先级中排序第一的待处理信息进行处理，位于优先级最高且在同优先级中排序第一的即为目标待处理信息。若检测完所有二级队列没有待处理信息，则返回检测是否有正在发送的信息进行循环检查。
38.其中，通过判断是否需要插入心跳包，判断单条响应是否超时，从而保证在通信过程中的稳定性，减小通信链路堵塞的可能性，进一步通过上述步骤进行检测，可以更加合理处理信息。
39.s203：获取目标待处理信息并校验，将所述目标待处理信息进行标注。
40.在本实施例中，将获取到的目标待处理信息，需要判断目标待处理信息是否是当前信息，判断消息的内容是否通过校验无误，是否需要重发等操作等，当检测完毕后，将目标待处理信息标记为完成状态，则此信息检测完成可以进行发送。
41.s204：判断目标处理消息是否需要发送协议消息到客户端，如有则发送。
42.本本实施例中，在对目标处理信息进行检测完成后，需要判断即将发送的目标处理信息的协议信息是否需要发送到客户端，进而保证可能识别目标处理信息，如果需要则发送与之对应的协议至客户端。
43.s205：如果检测到发送所述目标待处理信息超过设定时间、所述所述目标待处理信息的重复发送次数超过设定次数中的至少一种，确定所述目标待处理信息出现异常。
44.在本实施例中，将目标待处理信息进行发送，并对目标待处理信息进行检测。首先需要设置检测的判断条件，本实施例中通过检测发送目标待处理信息的时间、目标待处理信息重发的次数等，在其他实施例中还可以是发生报警的次数等等，通过检测判断目标待处理信息是否异常。
45.其中，如果在设定次数的心跳包内目标待处理信息未发送成功，则确定目标待处理信息超过设定时间，检测目标处理信息发送异常；如果在设定的重发次数内目标待处理信息未发送成功，则确定目标待处理信息的重复发送次数超过设定次数，检测目标处理信息发送异常。通过设置不同的检测条件，从而将不同的异常状态进行归类，从而可以设置与之对应的处理方法，进而更好的对异常状态的信息进行重发处理，从而更合理的管理信息队列，提高用户的使用感受。
46.s206：将异常的所述目标待处理消息的执行指令删除。
47.本实施例中，对于检测后为异常的目标待处理信息，任意某一项异常到达预设的上限后，则此目标待处理信息存在错误，会删除目标待处理信息的执行命令，不在执行以异常的信息。从而可以减小异常目标处理信息反复发送的可能性，减小因故障长时间占用信息链路从而影响通信效率的可能性，使得通信道路更加通常，通信效率更加快捷。
48.s207：如果出现异常，弹出提醒消息。
49.在本实施例中，对目标待处理信息进行检测，检测结果为异常的信息需要进行报错并弹出消息，结果正常的信息则结束检测。
50.具体的，开始检测目标处理信息是否处于异常状态，首先判断当前是否有正在发送的信息，若没有真在发送的信息，则检测结束；若当前有正在发送的信息，则对在发送的信息进行检测，即对目标处理信息进行检测。若检测完成则结束；若检测未完成即需要对检测未完成的目标处理信息进行判断。将目标处理信息进行拷贝并检测目标处理信息是否超
时、超重发次数等异常状态，若不存在异常状态侧检测完成；若存在异常状态则判断目标处理信息是否可以重发，若可以重发则等待自动重发并检测完成；若不能进行重发则进行报错，并结束检测。最后回到检测目标处理信息是否处于异常状态的步骤，循环检测。
51.通过对目标处理信息进行检测，了解目标处理信息的发送状态，并对异常的状态进行重发或是报错等，进而使得用户可以更好地了解信息的实际状态，同时也是对每一条待处理信息进行更好的管理与追踪。
52.请参阅图3，图3是通信设备一实施例的结构示意图。本实施例中，通信设备包括：通信总线30、处理器31、用户接口32、网络接口33、存储器34。
53.在本实施例中，通信设备设置于服务器上，并管理服务器向用户接口32发送信息。其中，通信总线30用于实现上述组件之间的通信。处理器31可以为中央处理器(central processing unit，cpu)。用户接口32可以为显示屏，也可以包括标准的有线接口和无线接口。网络接口33包括标准的有线接口和无线接口(例如，wifi接口)。存储器34可以是随机存取存储器(random access memory，ram)；也可以是稳定的存储器，例如，非易失存储器(non-volatile memory)。
54.在本实施例中，存储器34为计算机可读存储器，其内部设置有操作系统、用户接口模块、网络通信模块以及通信控制程序。通信设备通过处理器31调用存储器34中的通信控制程序并执行本技术通信方法第一实施例或第二实施例中的任一方法或步骤。
55.另外，在本发明各个实施方式中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)或处理器(processor)执行本发明各个实施方式所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器(rom，read-only memory)、随机存取存储器(ram，random access memory)、磁碟或者光盘等各种可以存储程序代码的介质。
56.请参阅图4，图4是通信控制装置一实施例的结构示意图。本实施例中，通信控制装置40包括：调度模块41、接收模块42、执行模块43、检查模块44。
57.其中，在通信控制装置40工作时，首先调度模块41工作，对消息队列中的信息根据优先级进行排序并设置有多个二队队列进行排序，调度模块41并确定管理下一个需要进行处理的信息；当确认目标信息后，接收模块42对目标信息进行检测，检测完成后将目标信息标注为完成状态；接着执行模块43将目标信息进行处理，并判断是有需要加入与目标信息相对应的协议；目标信息发送后，检查模块44工作，检测目标信息的发送时候异常，并对异常的目标消息进行报错。
58.本实施例中的通信控制装置40，通过设置有多个二级队列进行排序，并在发送信息前判断是否需要插入心跳包，从而使得通信控制装置40在通信传输过程中避免了信息链拥堵，使得重要信息可以更快更可靠的进行传输。
59.以上所述仅为本发明的实施方式，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本发明的专利保护范围内。

技术特征：
1.一种通信方法，其特征在于，所述通信方法包括：响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息；将所述目标待处理信息发送至客户端。2.根据权利要求1所述的通信方法，其特征在于，所述响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息的步骤之前，还包括：获取到待处理信息，并将所述待处理信息按照其优先级别添加到对应的队列信息中；所述响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息的步骤，包括：响应于检测到当前到达心跳包的发送周期，从优先级别最高的队列信息中按照顺序选择所述目标待处理信息。3.根据权利要求1所述的通信方法，其特征在于，所述将所述目标待处理信息发送至客户端的步骤包括：检测所述目标待处理消息是否出现异常；如果出现异常，弹出提醒消息。4.根据权利要求3所述的通信方法，其特征在于，所述检测所述目标待处理消息是否出现异常的步骤，包括：如果检测到发送所述目标待处理信息超过设定时间、所述目标待处理信息的重复发送次数超过设定次数中的至少一种，确定所述目标待处理信息出现异常。5.根据权利要求4所述的通信方法，其特征在于，如果在设定次数的心跳包内所述目标待处理信息未发送成功，确定所述目标待处理信息超过设定时间。6.根据权利要求4所述的通信方法，其特征在于，如果在设定的重发次数内所述目标待处理信息未发送成功，确定所述目标待处理信息的重复发送次数超过设定次数。7.根据权利要求4所述的通信方法，其特征在于，所述如果检测到发送所述目标待处理信息超过设定时间、所述所述目标待处理信息的重复发送次数超过设定次数中的至少一种，确定所述目标待处理信息出现异常的步骤之前，还包括：获取目标待处理信息并校验，将所述目标待处理信息进行标注。判断目标处理消息是否需要发送协议消息到客户端，如有则发送。8.根据权利要求3所述的通信方法，其特征在于，所述将所述目标待处理信息发送至客户端的步骤，还包括：将异常的所述目标待处理消息的执行指令删除。9.一种通信设备，其特征在于，包括：处理器、存储器，其中，所述处理器配置有上述权利要求1-8任一项所述的方法。10.一种通信控制装置，其特征在于，包括：调度模块：用于调度与管理待处理的消息；接收模块：用于接收所述待处理消息判断并标记是否检测完成；执行模块：用于将所述待处理的消息进行判断并进行发送；检查模块：判断发送的所述待处理的消息是否异常，并对异常的所述待处理消息进行报错。

技术总结
本申请公开了一种通信方法、设备及控制装置，通信方法包括：响应于检测到当前到达心跳包的发送周期，从队列中选择优先级别最高的目标待处理信息；将所述目标待处理信息发送至客户端。本申请通过设置多个不同级别的优先级队列，在发送信息前检测心跳包的发送周期，从而便于信息的管控，并减小了信息链路堵塞的可能性，重要信息可以优先处理，进而提高了用户的使用感受。使用感受。使用感受。


技术研发人员：何海平 赵悦斌 曾泉 刘建辉
受保护的技术使用者：天芯互联科技有限公司
技术研发日：2022.12.30
技术公布日：2023/8/9