一种数据传输方法、装置及介质与流程

1.本申请涉及信息技术领域，特别是涉及一种数据传输方法、装置及介质。


背景技术：

2.随着科技的发展，集群节点间的通信、大数据的获取和后续处理已逐渐成为生产中必不可少的环节，因此各个用户对获取的数据的准确性有着较强的依赖。
3.目前，数据传输的方法主要是通过消息队列(mq)进行数据的传输。由于在mq通信即数据传输过程中，只是将消息发送至mq，无法感知那个用户需要什么消息、消息是否送达、判断mq发送的数据是否存在错发或漏发，从而在数据传输过程中降低了数据的准确性。
4.由此可见，如何在数据传输过程中提高数据的准确性是本领域技术人员亟待解决的问题。


技术实现要素：

5.本申请的目的是提供一种数据传输方法，用以在数据传输过程中提高数据的准确性。本申请的目的是还提供一种数据传输装置及介质。
6.为解决上述技术问题，本申请提供一种数据传输方法，包括：
7.根据预先设置的各用户终端和各订阅规则的对应关系，确定与所述目标用户终端对应的目标订阅规则；
8.接收用于表征发送给目标用户终端的目标待发送数据；
9.在所述目标待发送数据与所述目标订阅规则中包含的目标推送数据不匹配的情况下，获取所述目标待发送数据对应的目标原始数据；
10.根据所述目标原始数据、所述目标订阅规则和所述目标推送数据恢复所述目标待发送数据；
11.向所述目标用户终端发送所述目标待发送数据或经过恢复处理后的所述目标待发送数据。
12.优选的，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据具体包括：
13.根据所述目标订阅规则中包含的数据发送规则向所述目标用户终端发送经过恢复处理后的所述目标待发送数据。
14.优选的，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据后，还包括：
15.在所述目标待发送数据发送失败的情况下，按照所述目标订阅规则中包含的重试规则重新发送所述目标待发送数据；
16.在所述目标待发送数据的重新发送次数超过所述重试规则中包含的预设重试次数的情况下，将所述目标待发送数据标记为僵死数据；
17.在接收到所述目标用户终端发送的表征可接收数据的信号的情况下，激活所述僵
死数据，以便于向所述目标用户终端发送激活后的所述僵死数据。
18.优选的，所述接收用于表征发送给目标用户终端的目标待发送数据后，还包括：
19.存储所述目标待发送数据和与所述目标原始数据一一对应的数据。
20.优选的，所述接收目标用户终端的目标待发送数据后，还包括：
21.将所述目标待发送数据进行分区处理；
22.其中，同一事件对应的目标待发送数据分为同一数据区域。
23.优选的，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据前，还包括：
24.对所述目标待发送数据和/或经过恢复处理后的所述目标待发送数据进行去重处理。
25.优选的，所述对所述目标待发送数据和/或经过恢复处理后的所述目标待发送数据进行去重处理后，还包括：
26.根据所述目标订阅规则在所述目标待发送数据或经过恢复处理后的所述目标待发送数据中添加对应的订阅内容。
27.为解决上述技术问题，本申请还提供一种数据传输装置，基于如上所述的数据传输方法，包括：
28.确定模块，用于根据预先设置的各用户终端和各订阅规则的对应关系，确定与所述目标用户终端对应的目标订阅规则；
29.第一接收模块，用于接收用于表征发送给目标用户终端的目标待发送数据；
30.获取模块，用于在所述目标待发送数据与所述目标订阅规则中包含的目标推送数据不匹配的情况下，获取所述目标待发送数据对应的目标原始数据；
31.恢复模块，用于根据所述目标原始数据、所述目标订阅规则和所述目标推送数据恢复所述目标待发送数据；
32.第一发送模块，用于向所述目标用户终端发送所述目标待发送数据或经过恢复处理后的所述目标待发送数据。
33.为解决上述技术问题，本申请还提供一种数据传输装置，包括：
34.存储器，用于存储计算机程序；
35.处理器，用于执行所述计算机程序时实现如上所述的数据传输方法的步骤。
36.为解决上述技术问题，本申请还提供一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上所述的数据传输方法的步骤。
37.本申请所提供的数据传输方法，根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送完整的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，且订阅规则中包含了目标推送数据，因此能够在将待发送数据发送至用户前，判断待发送数据是否与目标推送数据匹配，如果不匹配则可以恢复丢失的数据或修改错误的数据，从而保证了数据传输过程中数据不会丢失或者错误，提高了在数据传输过程中数据的准确性。
38.此外，本申请提供的一种数据传输装置及介质，与上述数据传输方法对应，效果同上。
附图说明
39.为了更清楚地说明本申请实施例，下面将对实施例中所需要使用的附图做简单的介绍，显而易见地，下面描述中的附图仅仅是本申请的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
40.图1为本申请实施例提供的一种数据传输方法的流程图；
41.图2为本申请实施例提供的一种应用场景下的数据传输方法的流程图；
42.图3为本申请实施例提供的一种数据传输装置的结构示意图；
43.图4为本申请实施例提供的另一种数据传输装置的结构示意图。
具体实施方式
44.下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本申请一部分实施例，而不是全部实施例。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下，所获得的所有其他实施例，都属于本申请保护范围。
45.本申请的核心是提供一种数据传输方法，用以在数据传输过程中提高数据的准确性。本申请的核心是还提供一种数据传输装置及介质。
46.为了使本技术领域的人员更好地理解本申请方案，下面结合附图和具体实施方式对本申请作进一步的详细说明。
47.图1为本申请实施例提供的一种数据传输方法的流程图。如图1所示，该方法包括：
48.s10：根据预先设置的各用户终端和各订阅规则的对应关系，确定与目标用户终端对应的目标订阅规则。
49.s11：接收用于表征发送给目标用户终端的目标待发送数据。
50.本申请实施例中，目标待发送数据具体为经过归一化处理后的目标待发送数据。可以理解的是，为了保证向用户推送的数据的全面性，在具体实施中，常常从大量第三方平台中获取数据，而不同平台之间的数据其格式可能存在差异，为了避免后续推送过程中推送数据出错，同时降低传输的工作量，在接收目标待发送数据后，将对所有数据进行归一化处理以便于使得所有数据格式相同。
51.s12：判断目标待发送数据与目标订阅规则中包含的目标推送数据是否匹配，如果否，则进入s13，如果是，则进入s16。
52.需要说明的是，目标推送数据与目标待发送数据不同，目标推送数据是本中间件根据具体业务场景及订阅规则判断应该向业务方发送的全量数据，而目标待发送数据是本中间件接收到数据发送方数据后经过处理产生的待发送数据，属于实时数据。
53.在具体实施中，可以通过两种不同的方法判断目标待发送数据与目标订阅规则和目标推送数据是否匹配。例如可以构建分发控制组件，通过在分发控制组件推送待发送数据的过程中，实时判断目标待发送数据是否错误或丢失；还可以构建对账恢复组件，在推送目标待发送数据前，或者在获取到目标待发送数据后，通过对账恢复组件主动判断目标待
发送数据是否错误或丢失。需要说明的是，为了进一步提高在数据传输过程中数据的准确性，可以在具体实施中，采取多种方法相结合的方式进行判断。当对账恢复组件和分发控制组件两种方法进行判断时，为了增加判断的准确性，可以选择对账恢复组件按周期进行判断。
54.s13：获取目标待发送数据对应的目标原始数据。
55.s14：根据目标原始数据、目标订阅规则和目标推送数据恢复目标待发送数据。
56.需要说明的是，根据目标原始数据、目标订阅规则和目标推送数据恢复目标待发送数据具体为：根据目标订阅规则和目标推送数据从原始数据中恢复目标待发送数据，使得恢复后的目标待发送数据与目标需求数据匹配。
57.s15：向目标用户终端发送经过恢复处理后的目标待发送数据。
58.s16：向目标用户终端发送目标待发送数据。
59.可以理解的是，在具体实施中，各用户与各用户终端存在对应关系，将目标待发送数据或经过恢复处理后的目标待发送数据发送至目标用户终端，即表征着将目标待发送数据或经过恢复处理后的目标待发送数据推送至与目标用户终端对应的目标用户。
60.具体的，在实施中，可以根据构建的分发控制组件，将目标待发送数据或经过恢复处理后的目标待发送数据，通过超文本传输协议(hypertext transfer protocol，http)接口、或者远程过程调用协议(remote procedure call protocol，rpc)接口推送至目标用户终端。
61.本申请实施例所提供的数据传输方法，根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送恢复处理后的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，且订阅规则中包含了目标推送数据，因此能够在将待发送数据发送至用户前，判断当前节点已发送与待发送数据是否与目标推送数据匹配，如果不匹配则可以恢复丢失的数据或修改错误的数据，从而保证了数据传输过程中数据不会丢失或者错误，提高了在数据传输过程中数据的准确性。
62.在上述实施例的基础上，s15具体为：
63.根据目标订阅规则中包含的数据发送规则向目标用户终端发送经过恢复处理后的目标待发送数据。
64.可以理解的是，可以根据目标订阅规则中包含的数据发送规则，按照用户选择的数据推送模式发送恢复处理后的目标待发送数据。其中数据发送规则或数据推送模式可以包括顺序推送、无序推送、延迟推送等等。需要说明的是，顺序推送具体是指将目标待发送数据按照事件发展的顺序进行推送，无序推送具体是指按照本例所述系统接收到发送方消息的顺序推送给订阅方，不对接收到的待发送数据按照事件发展的顺序进行顺序校正。例如事件发展的顺序为：a、b、c、d，接收到的目标推送数据先后顺序为a、c、d，用户订阅的事件消息为a、c、d，则顺序推送为：先向用户推送a、再向用户推送c、最后向用户推送d，无序推送可以为：先向用户推送a、再向用户推送d、最后向用户推送c。
65.本申请实施例所提供的数据传输方法，由于按照目标订阅规则中包含的数据发送规则向目标用户终端发送目标待发送数据，因此能够按照用户选择的推送方式推送目标待
发送数据，从而提高了用户的使用体验感。
66.在上述实施例的基础上，s15后，还包括：
67.在目标待发送数据发送失败的情况下，按照目标订阅规则中包含的重试规则重新发送目标待发送数据。
68.在目标待发送数据的重新发送次数超过重试规则中包含的预设重试次数的情况下，将目标待发送数据标记为僵死数据。
69.在接收到目标用户终端发送的表征可接收数据的信号的情况下，激活僵死数据，以便于向目标用户终端发送激活后的僵死数据。
70.需要说明的是，重试规则中可以具体包含预设重试次数以及预设重发周期。可以理解的是，本申请实施例可以按照预设重发周期向目标用户终端重新发送目标待发送数据，并记录重发次数，当重发次数到达预设重试次数时，则将目标待发送数据标记为僵死数据。在具体实施中，可以将标记的僵死数据暂时缓存在构建的分发控制组件，也可以将僵死数据缓存于数据库中。
71.本申请实施例所提供的数据传输方法，由于能够按照目标订阅规则中包含的重试规则重新发送目标待发送数据，且当重发次数过多(超过预设次数)时，能够保留未成功发送的目标待发送数据，因此能够在目标用户终端的接收装置或系统出现故障时，能够保留未成功发送的数据，并在目标用户终端的接收装置或系统恢复正常时重新激活未成功发送的数据，进一步提高了用户的使用体验感，保证了数据的完整性。
72.在上述实施例的基础上，s10后，还包括：存储目标待发送数据和与目标原始数据一一对应的数据。
73.需要说明的是，可基于分库分表中间件sharding
‑
jdbc进行哈希分库，将与目标原始数据一一对应的数据和目标待发送数据存储至多个数据库中。
74.可以理解的是，在接收目标用户终端的目标待发送数据后，将与目标原始数据对应的数据和目标待发送数据存储至数据库中，因此能够快速的判断目标待发送数据与目标订阅规则中包含的目标推送数据是否匹配。
75.在上述实施例的基础上，s10后，还包括：将目标待发送数据进行分区处理，其中，同一事件对应的目标待发送数据分为同一数据区域。
76.在具体实施中，可以基于分布式应用程序协调服务(zookeeper)构建插槽管理器，通过插槽管理器将从kafka或其他消息中间件接收的、由第三方发送的目标待发送数据进行分区处理，并将不同的数据区域分配给集群中的从属节点进行数据传输。需要说明的是，可按需求扩展槽管理器中槽的个数(默认30个槽)，将30个槽根据本实例所述集群节点个数进行分区得到数据分区。
77.本申请实施例所提供的数据传输方法，将目标待发送数据进行分区处理后，能够将不同的数据区域分配给不同的节点进行数据的处理和推送，使得多台终端能够同时处理从第三方平台获取的同一批原始数据，进一步提高了数据传输的速度。
78.在上述实施例的基础上，在s15前，还包括：对目标待发送数据和/或经过恢复处理后的目标待发送数据进行去重处理。
79.在具体实施中，可构建消息记录拦截处理组件，通过多个不同功能的拦截器对目标待发送数据和/或经过恢复处理后的目标待发送数据进行去重处理。需要说明的是，可以
在s16前对目标待发送数据进行去重处理，还可以在s15前对经过恢复处理后的目标待发送数据进行去重处理。
80.进一步的，为了提高用户的使用体验感，作为优选的实施例，对目标待发送数据进行去重处理后，还包括：根据目标订阅规则在目标待发送数据或经过恢复处理后的目标待发送数据中添加对应的订阅内容，以便于向目标用户终端提供特殊的业务处理。其中，订阅内容具体为与用户需求对应的需要添加的数据内容。
81.可以理解的是，通过对目标待发送数据和/或经过恢复处理后的目标待发送数据进行去重处理，能够避免重复发送同一数据，进一步提高了数据传输的准确性以及用户的使用体验感。
82.为了让本领域技术人员更加清楚本申请提供的技术方案，本文还给出一种具体应用场景进行说明，该场景中涉及到第三方、终端集群、客户端，图2为本申请实施例提供的一种应用场景下的数据传输方法的流程图。如图2所示，以下为具体应用，将会按照本实例的具体实现方式去修改：
83.s20：终端集群节点从消息中间件(例如kafka)中接收第三方发送的消息。
84.s21：将消息转换成待发送消息并将待发送消息进行分区，使用消息中的身份标识进行分区，同一身份标识的消息分到同一个区域、基于终端集群节点将待发送消息推送至各消息分区对应的redis队列，并将对应的redis队列的有效期每隔1分钟进行延长，其中同一区域的消息推送至同一redis队列中，redis队列与集群节点相对应，一个节点对应一个区域，一个节点处理一个区域中的数据。
85.s22：根据节点对应的消息区域，从redis队列中获取待发送的消息。
86.s23：在根据订阅规则判断待发送消息存在漏发、错发现象的情况下，恢复待发送消息。
87.s24：按照订阅规则的数据发送规则向客户端推送待发送消息。
88.s25：在客户端接收失败的情况下，按照订阅规则的重发规则向客户端重新推送待发送消息，并记录重试次数。
89.s26：在重试次数超过重发规则中的预设次数的情况下，将未成功推送的待发送消息标记为僵死数据。
90.s27：在接收到客户端发送的信号的情况下，激活僵死数据，并将激活后的僵死数据发送至客户端。
91.s28：在终端集群节点发生变更的情况下，通过主节点清除redis现有队列，并重新将未推送消息推送至各消息分区对应的redis队列。
92.以上步骤是一种具体应用场景，在其他应用场景中还可以适当增加相应的步骤，在此不作限定。
93.在上述实施例中，对于数据传输方法进行了详细描述，本申请还提供数据传输装置对应的实施例。需要说明的是，本申请从两个角度对装置部分的实施例进行描述，一种是基于功能模块的角度，另一种是基于硬件的角度。
94.图3为本申请实施例提供的一种数据传输装置的结构示意图。如图3所示，基于功能模块的角度，该装置包括：
95.确定模块10，用于根据预先设置的各用户终端和各订阅规则的对应关系，确定与
目标用户终端对应的目标订阅规则。
96.第一接收模块11，用于接收用于表征发送给目标用户终端的目标待发送数据。
97.获取模块12，用于在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标待发送数据对应的目标原始数据。
98.恢复模块13，用于根据目标原始数据、目标订阅规则和目标推送数据恢复目标待发送数据。
99.第一发送模块14，用于向目标用户终端发送目标待发送数据或经过恢复处理后的目标待发送数据。
100.由于装置部分的实施例与方法部分的实施例相互对应，因此装置部分的实施例请参见方法部分的实施例的描述，这里暂不赘述。
101.作为优选的实施例，还包括：
102.第二发送模块，用于根据目标订阅规则中包含的数据发送规则向目标用户终端发送经过恢复处理后的目标待发送数据。
103.还包括：
104.重发模块，用于在目标待发送数据发送失败的情况下，按照目标订阅规则中包含的重试规则重新发送目标待发送数据。
105.标记模块，用于在目标待发送数据的重新发送次数超过重试规则中包含的预设重试次数的情况下，将目标待发送数据标记为僵死数据。
106.激活模块，用于在接收到目标用户终端发送的表征可接收数据的信号的情况下，激活僵死数据，以便于向目标用户终端发送激活后的僵死数据。
107.还包括：
108.存储模块，用于存储目标待发送数据和与目标原始数据一一对应的数据。
109.还包括：
110.第一处理模块，用于将原始数据进行分区处理；其中，同一事件对应的待发送数据分为同一数据区域。
111.还包括：
112.第二处理模块，用于对目标待发送数据和/或经过恢复处理后的目标待发送数据进行去重处理。
113.还包括：
114.添加模块，用于根据目标订阅规则在目标待发送数据或经过恢复处理后的目标待发送数据中添加对应的订阅内容。
115.本申请实施例所提供的数据传输装置，根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送恢复处理后的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，且订阅规则中包含了用户所需的目标推送数据，因此能够在将待发送数据发送至用户前，判断当前节点已发送与待发送数据是否与目标推送数据匹配，如果不匹配则可以恢复丢失的数据或修改错误的数据，从而保证了数据传输过程中数据不会丢失或者错误，提高了在数据传输过程中数据的准确
性。
116.图4为本申请实施例提供的另一种数据传输装置的结构示意图。如图4所示，基于硬件结构的角度，该装置包括：
117.存储器20，用于存储计算机程序；
118.处理器21，用于执行计算机程序时实现如上述实施例中数据传输方法的步骤。
119.其中，处理器21可以包括一个或多个处理核心，比如4核心处理器、8核心处理器等。处理器21可以采用数字信号处理(digital signal processing，dsp)、现场可编程门阵列(field－programmable gate array，fpga)、可编程逻辑阵列(programmable logic array，pla)中的至少一种硬件形式来实现。处理器21也可以包括主处理器和协处理器，主处理器是用于对在唤醒状态下的数据进行处理的处理器，也称中央处理器(central processing unit，cpu)；协处理器是用于对在待机状态下的数据进行处理的低功耗处理器。在一些实施例中，处理器21可以在集成有图像处理器(graphics processing unit，gpu)，gpu用于负责显示屏所需要显示的内容的渲染和绘制。一些实施例中，处理器21还可以包括人工智能(artificial intelligence，ai)处理器，该ai处理器用于处理有关机器学习的计算操作。
120.存储器20可以包括一个或多个计算机可读存储介质，该计算机可读存储介质可以是非暂态的。存储器20还可包括高速随机存取存储器，以及非易失性存储器，比如一个或多个磁盘存储设备、闪存存储设备。本实施例中，存储器20至少用于存储以下计算机程序201，其中，该计算机程序201被处理器21加载并执行之后，能够实现前述任一实施例公开的数据传输方法的相关步骤。另外，存储器20所存储的资源还可以包括操作系统202和数据203等，存储方式可以是短暂存储或者永久存储。其中，操作系统202可以包括windows、unix、linux等。数据203可以包括但不限于数据传输方法中涉及的数据等。
121.在一些实施例中，数据传输装置还可包括有显示屏22、输入输出接口23、通信接口24、电源25以及通信总线26。
122.本领域技术人员可以理解，图4中示出的结构并不构成对数据传输装置的限定，可以包括比图示更多或更少的组件。
123.本申请实施例提供的数据传输装置，包括存储器和处理器，处理器在执行存储器存储的程序时，能够实现如下方法：根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送恢复处理后的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，且订阅规则中包含了用户所需的目标推送数据，因此能够在将待发送数据发送至用户前，判断当前节点已发送与待发送数据是否与目标推送数据匹配，如果不匹配则可以恢复丢失的数据或修改错误的数据，从而保证了数据传输过程中数据不会丢失或者错误，提高了在数据传输过程中数据的准确性。
124.最后，本申请还提供一种计算机可读存储介质对应的实施例。计算机可读存储介质上存储有计算机程序，计算机程序被处理器执行时实现如上述方法实施例中记载的步骤。
125.可以理解的是，如果上述实施例中的方法以软件功能单元的形式实现并作为独立
的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本申请实施例的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，执行本申请各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器(read
‑
only memory，rom)、随机存取存储器(random access memory，ram)、磁碟或者光盘等各种可以存储程序代码的介质。
126.本申请实施例提供的计算机可读存储介质，该介质上存储有计算机程序，计算机程序被处理器执行时，能够实现如下方法：根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送恢复处理后的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，且订阅规则中包含了用户所需的目标推送数据，因此能够在将待发送数据发送至用户前，判断当前节点已发送与待发送数据是否与目标推送数据匹配，如果不匹配则可以恢复丢失的数据或修改错误的数据，从而保证了数据传输过程中数据不会丢失或者错误，提高了在数据传输过程中数据的准确性。
127.以上对本申请所提供的一种数据传输方法、装置及介质进行了详细介绍。说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。对于实施例公开的装置而言，由于其与实施例公开的方法相对应，所以描述的比较简单，相关之处参见方法部分说明即可。应当指出，对于本技术领域的普通技术人员来说，在不脱离本申请原理的前提下，还可以对本申请进行若干改进和修饰，这些改进和修饰也落入本申请权利要求的保护范围内。
128.还需要说明的是，在本说明书中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个
……”
限定的要素，并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。

技术特征：
1.一种数据传输方法，其特征在于，包括：根据预先设置的各用户终端和各订阅规则的对应关系，确定与所述目标用户终端对应的目标订阅规则；接收用于表征发送给目标用户终端的目标待发送数据；在所述目标待发送数据与所述目标订阅规则中包含的目标推送数据不匹配的情况下，获取所述目标待发送数据对应的目标原始数据；根据所述目标原始数据、所述目标订阅规则和所述目标推送数据恢复所述目标待发送数据；向所述目标用户终端发送所述目标待发送数据或经过恢复处理后的所述目标待发送数据。2.根据权利要求1所述的数据传输方法，其特征在于，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据具体包括：根据所述目标订阅规则中包含的数据发送规则向所述目标用户终端发送经过恢复处理后的所述目标待发送数据。3.根据权利要求1或2所述的数据传输方法，其特征在于，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据后，还包括：在所述目标待发送数据发送失败的情况下，按照所述目标订阅规则中包含的重试规则重新发送所述目标待发送数据；在所述目标待发送数据的重新发送次数超过所述重试规则中包含的预设重试次数的情况下，将所述目标待发送数据标记为僵死数据；在接收到所述目标用户终端发送的表征可接收数据的信号的情况下，激活所述僵死数据，以便于向所述目标用户终端发送激活后的所述僵死数据。4.根据权利要求1所述的数据传输方法，其特征在于，所述接收用于表征发送给目标用户终端的目标待发送数据后，还包括：存储所述目标待发送数据和与所述目标原始数据一一对应的数据。5.根据权利要求1或4所述的数据传输方法，其特征在于，所述接收目标用户终端的目标待发送数据后，还包括：将所述目标待发送数据进行分区处理；其中，同一事件对应的目标待发送数据分为同一数据区域。6.根据权利要求1所述的数据传输方法，其特征在于，所述向所述目标用户终端发送经过恢复处理后的所述目标待发送数据前，还包括：对所述目标待发送数据和/或经过恢复处理后的所述目标待发送数据进行去重处理。7.根据权利要求6所述的数据传输方法，其特征在于，所述对所述目标待发送数据和/或经过恢复处理后的所述目标待发送数据进行去重处理后，还包括：根据所述目标订阅规则在所述目标待发送数据或经过恢复处理后的所述目标待发送数据中添加对应的订阅内容。8.一种数据传输装置，其特征在于，基于如权利要求1至7任意一项所述的数据传输方法，包括：确定模块，用于根据预先设置的各用户终端和各订阅规则的对应关系，确定与所述目
标用户终端对应的目标订阅规则；第一接收模块，用于接收用于表征发送给目标用户终端的目标待发送数据；获取模块，用于在所述目标待发送数据与所述目标订阅规则中包含的目标推送数据不匹配的情况下，获取所述目标待发送数据对应的目标原始数据；恢复模块，用于根据所述目标原始数据、所述目标订阅规则和所述目标推送数据恢复所述目标待发送数据；第一发送模块，用于向所述目标用户终端发送所述目标待发送数据或经过恢复处理后的所述目标待发送数据。9.一种数据传输装置，其特征在于，包括：存储器，用于存储计算机程序；处理器，用于执行所述计算机程序时实现如权利要求1至7任意一项所述的数据传输方法的步骤。10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1至7任意一项所述的数据传输方法的步骤。
技术总结
本申请公开了一种数据传输方法、装置及介质，其中方法包括，根据预先设置的各用户终端和各订阅规则的对应关系，确定对应的目标订阅规则，接收目标用户终端的目标待发送数据后，在目标待发送数据与目标订阅规则中包含的目标推送数据不匹配的情况下，获取目标用户终端的目标原始数据，以便于恢复目标待发送数据，从而向目标用户终端发送完整的目标待发送数据。由于预先设置了各用户和各订阅规则的对应关系，因此能够在将待发送数据发送至用户前，判断待发送数据是否与目标推送数据匹配，从而恢复丢失的数据或修改错误的数据，提高了在数据传输过程中数据的准确性。据传输过程中数据的准确性。据传输过程中数据的准确性。


技术研发人员：靳程煜 接宝强
受保护的技术使用者：上海微盟企业发展有限公司
技术研发日：2021.04.21
技术公布日：2021/7/8