一种消息处理方法及装置与流程

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.消息处理的需求存在于各种终端设备中，目前对消息的处理方法大部分是采用队列处理机制，队列是一种特殊的线性表，只允许在队尾插入数据，在队首处理数据，因此最先进入队列的消息可以最先处理掉，也就是按照队列中的消息顺序处理消息。但该方法的问题在于只对消息进行顺序处理，并不会考虑到重复消息，即使新增的消息和队列中的消息相同，也会放入队列中全部处理，但处理相同消息不仅效率低下，还会增加脏数据。为此，本发明提供了一种消息处理方法，提高消息处理的效率，且可以减少引入脏数据的可能性。其具体执行步骤如图1所示，包括：
25.101、接收新增待处理消息。
26.在本发明中，存在消息管理系统，消息队列内嵌于消息管理系统中，本发明执行主体为消息管理系统。消息管理系统负责连接外部消息通知源，与外部消息通知源进行通信以及对消息队列进行控制及处理消息。
27.当外部消息通知源每一次向消息管理系统推送新消息时，消息管理系统就可以接收到外部消息通知源推送的新消息，因此，外部消息通知源在当次向消息管理系统推送新消息时，消息管理系统可以接收到外部消息通知源当次推送的新增待处理消息。
28.需要说明的是，消息管理系统每次在接收到外部消息通知源推送的待处理消息后，都会将待处理消息添加到消息队列中，得到消息队列中的已有待处理消息。
29.102、检测消息队列的已有待处理消息中是否存在与新增待处理消息相同的目标已有待处理消息。
30.在本步骤中，由于消息管理系统每次在接收到待处理消息时都会将待处理消息在消息队列的尾端插入至消息队列，得到消息队列中的已有待处理消息。又由于在步骤101接收到外部消息通知源当次推送的新增待处理消息前，消息管理系统可能已经接收过多次待处理消息，也就是说消息队列中形成了已有待处理消息。这时，可以检测消息队列的已有待处理消息中是否存在与新增待处理消息相同的目标已有待处理消息。检测方式可以是比对消息的消息类型或者消息来源等。在本发明中消息来源定义为消息所对应的应用。若存在目标已有待处理消息，可以执行步骤103，若不存在目标已有待处理消息的话，就可以直接将新增待处理消息添加至消息队列中，然后按序进行处理。
31.示例性的，外部消息通知源向消息管理系统先推送了消息a，消息管理系统可以将消息a从消息队列的尾端插入至消息队列，得到消息队列中的已有待处理消息a。从尾端插入至消息队列并不是说此时消息a就位于消息队列的尾端了，而是经由尾端插入，若在消息a之前消息队列中无消息的话，消息a会经由尾端到消息队列的首端，而后，若外部消息通知源又向消息管理系统推送了消息b的话，消息管理系统可以将消息b也经由消息队列的尾端插入，最终放置于消息队列中的已有待处理消息a的后边，得到已有待处理消息b，在处理时，也是先处理已有待处理消息a，再处理已有待处理消息b。
32.103、将消息队列中的目标已有待处理消息删除，并将新增待处理消息添加至消息队列中以便处理。
33.若步骤102检测出消息队列中存在与新增待处理消息相同的目标已有待处理消息，就可以将消息队列中的目标已有待处理消息删除，然后将新增待处理消息添加至消息队列中，由于新增待处理消息是当次新接收到的，因此，在将新增待处理消息添加到消息队列后，新增待处理消息就位于消息队列的最末尾。这样一来，可以只处理相同消息中的最新消息。处理最新消息的原因可以是最新消息对应的是最新的需求，例如，待处理消息是应用的版本更新，已有待处理消息a是更新版本1，新增待处理消息a1是更新版本2，这种情况下，直接更新版本2即可。
34.基于上述图1的实现方式可以看出，本发明提供的一种消息处理方法，可以接收外部新推送的新增待处理消息，之后可以确定出消息队列中的已有待处理消息，看已有的待处理消息中是否有与新增待处理消息相同的目标已有待处理消息，如果有的话，就可以将消息队列中的目标已有待处理消息删除，将新增待处理消息添加至消息队列中进行处理。本发明通过将多个相同的消息中，在前的待处理消息删除，保留最新的待处理消息进行处理，相较于现有技术中重复的消息都进行处理，不仅可以提高消息处理的效率，且可以减少引入脏数据的可能性。
35.进一步的，作为对图1所示实施例的细化及扩展，本发明实施例还提供了另一种消息处理方法，如图2所示，其具体步骤如下：
36.201、接收新增待处理消息。
37.202、检测消息队列的已有待处理消息中是否存在与新增待处理消息相同的目标已有待处理消息。
38.其中，步骤201和步骤202中提出了一种区别于步骤101及步骤102的更优实施方式。
39.具体的，在步骤201中，可以先检测下外部消息通知源推送的新增待处理消息的数
量，有可能存在外部消息通知源同时推送多个新增待处理消息的情况，若新增待处理消息存在多个的情况下，就可以进一步检测这多个新增待处理消息是否均相同，如果每个都不一样的话，就可以针对每个新增待处理消息，检测在消息队列中是否有与每个新增待处理消息相同的目标已有待处理消息；如果多个都相同的话，就可以只保留一个新增待处理消息，然后检测消息队列中是否有与该新增待处理消息相同的目标已有待处理消息。若存在，就可以执行步骤203。
40.另外，若多个新增待处理消息中，部分相同，就在相同的新增待处理消息中保留一个新增待处理消息，然后针对保留的这个新增待处理消息和其他不同的新增待处理消息，在消息队列中查找是否有相同的目标已有待处理消息。
41.无论新增待处理消息的数量有多少，针对每个新增待处理消息，检测消息队列的已有待处理消息中是否存在与每个新增待处理消息相同的目标已有待处理消息的步骤，可以是：
42.先确定出已有待处理消息的已有消息类型，然后再确定出新增待处理消息的新增消息类型，然后可以将已有消息类型和新增消息类型进行比对，若比对出已有消息类型中有和新增消息类型相同的，就可以将已有消息类型中与新增消息类型相同的指定已有消息类型所对应的指定已有待处理消息确定为与新增待处理消息相同的目标已有待处理消息。然后可以执行步骤203。这样一来，相同类型的消息只处理最新的，可舍弃过期消息，提高消息处理的效率。
43.示例性的，若消息队列中的已有待处理消息有3个，按照消息队列顺序依次为：消息a-消息b-消息c，新增待处理消息为消息b1，若消息a的消息类型为系统消息、消息b的消息类型为应用消息、消息c的消息类型的游戏消息，消息b1的消息类型也为应用消息。经比对可知，新增待处理消息b1与已有待处理消息b的消息类型相同，都为应用消息，可以将消息b确定为目标已有待处理消息。
44.在只根据消息类型来检测的基础上，还可以进一步结合消息的来源来进行判定，可以是在确定出消息类型相同的指定已有待处理消息后，进一步确定指定已有待处理消息和新增待处理消息的消息来源，因为可能存在一种特殊情况，就是二者消息类型相同，但来源不同，例如二者消息类型相同，都为应用消息，那进一步考虑，如果一个消息所针对的是应用a，另一个消息所针对的是应用b，那如果只保留一者，很可能导致另一个应用的消息不能及时处理。
45.因此，可以进一步确定指定已有待处理消息及新增待处理消息对应的消息来源，然后确定指定已有待处理消息的消息来源与新增待处理消息的消息来源是否相同，若相同，则将指定已有待处理消息确定为所述目标待处理消息，结合了消息的来源，可以使确认两个消息是否相同的工作更加精准，从而可以更好的保留有用的最新消息，舍弃无用消息。然后可以执行步骤203。
46.203、将消息队列中的目标已有待处理消息删除，并将新增待处理消息添加至消息队列中以便处理。
47.其中，步骤203的实施方式与步骤103相同，并且可以达到相同的技术效果，解决相同的技术问题，在此不做重复赘述。
48.204、基于新增待处理消息的处理情况调整消息队列中的新增待处理消息。
49.在该步骤中，将新增待处理消息添加到消息队列后，可以先确认下新增待处理消息是不是已经被处理过了，如果没有处理，就可以再次检测是否接收到与新增待处理消息相同的更新待处理消息(确定方法如上述)，如果接收到就可以将消息队列中的新增待处理消息删除，然后将更新待处理消息添加至消息队列。这样一来，可一直保证处理的消息为最新的消息。
50.进一步的，作为对上述图1所示方法的实现，本发明实施例还提供了一种消息处理装置，用于对上述图1所示的方法进行实现。该装置实施例与前述方法实施例对应，为便于阅读，本装置实施例不再对前述方法实施例中的细节内容进行逐一赘述，但应当明确，本实施例中的装置能够对应实现前述方法实施例中的全部内容。如图3所示，该装置包括：
51.消息接收单元301，用于接收新增待处理消息；
52.消息检测单元302，用于检测消息队列的已有待处理消息中是否存在与所述消息接收单元301接收的所述新增待处理消息相同的目标已有待处理消息；
53.消息处理单元303，用于若所述消息检测单元302检测出存在，则将所述消息队列中的目标已有待处理消息删除，并将所述新增待处理消息添加至所述消息队列中以便处理。
54.进一步的，作为对上述图2所示方法的实现，本发明实施例还提供了另一种消息处理装置，用于对上述图2所示的方法进行实现。该装置实施例与前述方法实施例对应，为便于阅读，本装置实施例不再对前述方法实施例中的细节内容进行逐一赘述，但应当明确，本实施例中的装置能够对应实现前述方法实施例中的全部内容。如图4所示，该装置包括：
55.消息接收单元301，用于接收新增待处理消息；
56.消息检测单元302，用于检测消息队列的已有待处理消息中是否存在与所述消息接收单元301接收的所述新增待处理消息相同的目标已有待处理消息；
57.消息处理单元303，用于若所述消息检测单元302检测出存在，则将所述消息队列中的目标已有待处理消息删除，并将所述新增待处理消息添加至所述消息队列中以便处理。
58.一种可选的实施方式中，所述消息检测单元302包括：
59.类型确定模块3021，用于确定所述已有待处理消息的已有消息类型、所述新增待处理消息的新增消息类型；
60.第一消息确定模块3022，用于基于所述类型确定模块3021确定的已有待处理消息的已有消息类型和所述新增待处理消息的新增消息类型，确定所述已有待处理消息中是否存在所述目标已有待处理消息。
61.一种可选的实施方式中，所述第一消息确定模块3022包括：
62.类型比对子模块30221，用于将所述已有消息类型和所述新增消息类型进行比对，确定所述已有待处理消息中是否存在与所述新增待处理消息的新增消息类型相同的指定已有待处理消息；
63.第一消息确定子模块30222，用于若类型比对子模块30221确定存在，则将所述指定已有待处理消息确定为所述目标已有待处理消息。
64.一种可选的实施方式中，在所述类型比对子模块30221将所述已有消息类型和所述新增消息类型进行比对，确定所述已有待处理消息中是否存在与所述新增待处理消息的
新增消息类型相同的指定已有待处理消息后，所述装置还包括消息确定单元304，所述消息确定单元304包括：
65.来源确定模块3041，用于若所述已有待处理消息中存在与所述新增待处理消息的新增消息类型相同的指定已有待处理消息，则确定所述指定已有待处理消息及所述新增待处理消息对应的消息来源；
66.第二消息确定模块3042，用于基于所述来源确定模块3041确定的指定已有待处理消息及所述新增待处理消息的消息来源，确定所述已有待处理消息中是否存在所述目标已有待处理消息。
67.一种可选的实施方式中，所述第二消息确定模块3042包括：
68.来源确定子模块30421，用于确定所述指定已有待处理消息的消息来源与所述新增待处理消息的消息来源是否相同；
69.第二消息确定子模块30422，用于若所述来源确定子模块30421确定相同，则将所述指定已有待处理消息确定为所述目标已有待处理消息。
70.一种可选的实施方式中，所述装置还包括数量检测单元305，所述数量检测单元305包括：
71.数量检测模块3051，用于检测所述新增待处理消息的数量；
72.第三消息确定模块3052，用于若所述数量检测模块3051确定的新增待处理消息的数量为多个，则检测多个新增待处理消息是否相同；
73.第四消息确定模块3053，用于若所述第三消息确定模块3052确定出不相同，则检测所述消息队列的已有待处理消息中是否存在与所述多个新增待处理消息相同的多个目标已有待处理消息；
74.第五消息确定模块3054，用于若所述第四消息确定模块3053确定出相同，则保留所述多个新增待处理消息中的一个新增待处理消息。
75.一种可选的实施方式中，在所述消息处理单元303将所述新增待处理消息添加至所述消息队列中以便处理后，所述装置还包括消息更新单元306，所述消息更新单元306包括：
76.处理确定模块3061，用于检测所述新增待处理消息是否已处理；
77.更新消息确定模块3062，用于若所述处理确定模块3061确定否，则检测是否接收到与所述新增待处理消息相同的更新待处理消息；
78.消息删除模块3063，用于若所述更新消息确定模块3062确定是，则将所述消息队列中的所述新增待处理消息删除，并将所述更新待处理消息添加至所述消息队列。
79.进一步的，本发明实施例还提供一种存储介质，所述存储介质用于存储计算机程序，其中，所述计算机程序运行时控制所述存储介质所在设备执行上述图1-2中所述的消息处理方法。
80.进一步的，本发明实施例还提供一种处理器，所述处理器用于运行程序，其中，所述程序运行时执行上述图1-2中所述的消息处理方法。
81.在上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其他实施例的相关描述。
82.可以理解的是，上述方法及装置中的相关特征可以相互参考。另外，上述实施例中
的“第一”、“第二”等是用于区分各实施例，而并不代表各实施例的优劣。
83.所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，上述描述的系统，装置和单元的具体工作过程，可以参考前述方法实施例中的对应过程，在此不再赘述。
84.在此提供的算法和显示不与任何特定计算机、虚拟系统或者其它设备固有相关。各种通用系统也可以与基于在此的示教一起使用。根据上面的描述，构造这类系统所要求的结构是显而易见的。此外，本发明也不针对任何特定编程语言。应当明白，可以利用各种编程语言实现在此描述的本发明的内容，并且上面对特定语言所做的描述是为了披露本发明的最佳实施方式。
85.此外，存储器可能包括计算机可读介质中的非永久性存储器，随机存取存储器(ram)和/或非易失性内存等形式，如只读存储器(rom)或闪存(flash ram)，存储器包括至少一个存储芯片。
86.本领域内的技术人员应明白，本技术的实施例可提供为方法、系统、或计算机程序产品。因此，本技术可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本技术可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、cd-rom、光学存储器等)上实施的计算机程序产品的形式。
87.本技术是参照根据本技术实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
88.这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
89.这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
90.在一个典型的配置中，计算设备包括一个或多个处理器(cpu)、输入/输出接口、网络接口和内存。
91.存储器可能包括计算机可读介质中的非永久性存储器，随机存取存储器(ram)和/或非易失性内存等形式，如只读存储器(rom)或闪存(flash ram)。存储器是计算机可读介质的示例。
92.计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(pram)、静态随机存取存储器(sram)、动态随机存取存储器(dram)、其他类型的随机存取存储器(ram)、只读存储器(rom)、电可擦除
可编程只读存储器(eeprom)、快闪记忆体或其他内存技术、只读光盘只读存储器(cd-rom)、数字多功能光盘(dvd)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括暂存电脑可读媒体(transitory media)，如调制的数据信号和载波。
93.还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个
……”
限定的要素，并不排除在包括要素的过程、方法、商品或者设备中还存在另外的相同要素。
94.本领域技术人员应明白，本技术的实施例可提供为方法、系统或计算机程序产品。因此，本技术可采用完全硬件实施例、完全软件实施例或结合软件和硬件方面的实施例的形式。而且，本技术可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、cd-rom、光学存储器等)上实施的计算机程序产品的形式。
95.以上仅为本技术的实施例而已，并不用于限制本技术。对于本领域技术人员来说，本技术可以有各种更改和变化。凡在本技术的精神和原理之内所作的任何修改、等同替换、改进等，均应包含在本技术的权利要求范围之内。

技术特征：
1.一种消息处理方法，其特征在于，所述方法包括：接收新增待处理消息；检测消息队列的已有待处理消息中是否存在与所述新增待处理消息相同的目标已有待处理消息；若存在，则将所述消息队列中的目标已有待处理消息删除，并将所述新增待处理消息添加至所述消息队列中以便处理。2.根据权利要求1所述的方法，其特征在于，检测消息队列的已有待处理消息中是否存在与所述新增待处理消息相同的目标已有待处理消息，包括：确定所述已有待处理消息的已有消息类型、所述新增待处理消息的新增消息类型；基于所述已有待处理消息的已有消息类型和所述新增待处理消息的新增消息类型，确定所述已有待处理消息中是否存在所述目标已有待处理消息。3.根据权利要求2所述的方法，其特征在于，基于所述已有待处理消息的已有消息类型和所述新增待处理消息的新增消息类型，确定所述已有待处理消息中是否存在所述目标已有待处理消息，包括：将所述已有消息类型和所述新增消息类型进行比对，确定所述已有待处理消息中是否存在与所述新增待处理消息的新增消息类型相同的指定已有待处理消息；若存在，则将所述指定已有待处理消息确定为所述目标已有待处理消息。4.根据权利要求3所述的方法，其特征在于，将所述已有消息类型和所述新增消息类型进行比对，确定所述已有待处理消息中是否存在与所述新增待处理消息的新增消息类型相同的指定已有待处理消息后，所述方法还包括：若所述已有待处理消息中存在与所述新增待处理消息的新增消息类型相同的指定已有待处理消息，则确定所述指定已有待处理消息及所述新增待处理消息对应的消息来源；基于所述指定已有待处理消息及所述新增待处理消息的消息来源，确定所述已有待处理消息中是否存在所述目标已有待处理消息。5.根据权利要求4所述的方法，其特征在于，基于所述指定已有待处理消息及所述新增待处理消息的消息来源，确定所述已有待处理消息中是否存在所述目标已有待处理消息，包括：确定所述指定已有待处理消息的消息来源与所述新增待处理消息的消息来源是否相同；若相同，则将所述指定已有待处理消息确定为所述目标已有待处理消息。6.根据权利要求1所述的方法，其特征在于，所述方法还包括：检测所述新增待处理消息的数量；若所述新增待处理消息的数量为多个，则检测多个新增待处理消息是否相同；若不相同，则检测所述消息队列的已有待处理消息中是否存在与所述多个新增待处理消息相同的多个目标已有待处理消息；若相同，则保留所述多个新增待处理消息中的一个新增待处理消息。7.根据权利要求1所述的方法，其特征在于，在将所述新增待处理消息添加至所述消息队列中以便处理后，所述方法还包括：检测所述新增待处理消息是否已处理；
若否，则检测是否接收到与所述新增待处理消息相同的更新待处理消息；若是，则将所述消息队列中的所述新增待处理消息删除，并将所述更新待处理消息添加至所述消息队列。8.一种消息处理装置，其特征在于，所述装置包括：消息接收单元，用于接收新增待处理消息；消息检测单元，用于检测消息队列的已有待处理消息中是否存在与所述消息接收单元接收的所述新增待处理消息相同的目标已有待处理消息；消息处理单元，用于若所述消息检测单元检测出存在，则将所述消息队列中的目标已有待处理消息删除，并将所述新增待处理消息添加至所述消息队列中以便处理。9.一种存储介质，其特征在于，所述存储介质包括存储的程序，其中，在所述程序运行时控制所述存储介质所在设备执行如权利要求1至权利要求7中任意一项所述的消息处理方法。10.一种处理器，其特征在于，所述处理器用于运行程序，其中，所述程序运行时执行如权利要求1至权利要求7中任意一项所述的消息处理方法。

技术总结
本发明公开了一种消息处理方法及装置，涉及数据处理技术领域，主要目的在于提高消息处理的效率，减少引入脏数据的可能性。本发明主要的技术方案为：接收新增待处理消息；检测消息队列的已有待处理消息中是否存在与所述新增待处理消息相同的目标已有待处理消息；若存在，则将所述消息队列中的目标已有待处理消息删除，并将所述新增待处理消息添加至消息队列中以便处理。本发明用于消息处理。本发明用于消息处理。本发明用于消息处理。


技术研发人员：刘亚峰 李燕舞 董宏旭
受保护的技术使用者：北京国基科技股份有限公司
技术研发日：2023.04.21
技术公布日：2023/8/21