[go: up one dir, main page]

CN116708550A - Message pushing method, device, equipment and storage medium - Google Patents

Message pushing method, device, equipment and storage medium Download PDF

Info

Publication number
CN116708550A
CN116708550A CN202310903800.3A CN202310903800A CN116708550A CN 116708550 A CN116708550 A CN 116708550A CN 202310903800 A CN202310903800 A CN 202310903800A CN 116708550 A CN116708550 A CN 116708550A
Authority
CN
China
Prior art keywords
resource
message
resource message
target
sent
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202310903800.3A
Other languages
Chinese (zh)
Inventor
袁得钧
何黎明
欧阳鹏
王煜翔
徐倩
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Electronics Technology Network Security Technology Co ltd
Original Assignee
China Electronics Technology Network Security Technology Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Electronics Technology Network Security Technology Co ltd filed Critical China Electronics Technology Network Security Technology Co ltd
Priority to CN202310903800.3A priority Critical patent/CN116708550A/en
Publication of CN116708550A publication Critical patent/CN116708550A/en
Pending legal-status Critical Current

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/50Network services
    • H04L67/55Push-based network services
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L63/00Network architectures or network communication protocols for network security
    • H04L63/04Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks
    • H04L63/0428Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks wherein the data content is protected, e.g. by encrypting or encapsulating the payload
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L9/00Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols
    • H04L9/40Network security protocols
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D30/00Reducing energy consumption in communication networks
    • Y02D30/70Reducing energy consumption in communication networks in wireless communication networks

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Security & Cryptography (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer Hardware Design (AREA)
  • Computing Systems (AREA)
  • General Engineering & Computer Science (AREA)
  • Computer And Data Communications (AREA)

Abstract

本申请公开了一种消息推送方法、装置、设备及存储介质,涉及计算机技术领域。该方法包括:获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。可见,根据目标资源消息的资源依赖关系自动确定出目标资源消息对应的上级资源消息,并将上级资源消息和目标资源消息均存入待发送队列,由此解决资源消息创建过程中,存在依赖关系的相关资源需要手动创建订阅的问题。

The application discloses a message push method, device, equipment and storage medium, and relates to the technical field of computers. The method includes: acquiring a subscription policy for a target resource subscription system, determining a corresponding target resource message according to the subscription policy; determining a superior resource message corresponding to the target resource message according to resource dependencies of the target resource message; Adding the target resource message and the upper-level resource message to a corresponding to-be-sent queue, and sending the resource message in the to-be-sent queue to the target resource subscription system. It can be seen that according to the resource dependency of the target resource message, the upper-level resource message corresponding to the target resource message is automatically determined, and both the upper-level resource message and the target resource message are stored in the queue to be sent, thereby solving the dependency relationship in the process of creating resource messages Issues related to resources that require manual creation of subscriptions.

Description

一种消息推送方法、装置、设备及存储介质A message push method, device, equipment and storage medium

技术领域technical field

本发明涉及计算机技术领域,特别涉及一种消息推送方法、装置、设备及存储介质。The present invention relates to the field of computer technology, in particular to a message push method, device, equipment and storage medium.

背景技术Background technique

目前,随着信息网络平台的蓬勃发展,信息网络平台内各业务系统之间的资源需要相互订阅,所以资源消息发送的稳定性以及消息完整性需要得到保证。现有技术中,资源消息在各业务系统中的交互方法有较大的局限性,用户需要订阅某个资源时,需要依次订阅该资源的上级资源以及该资源,整个过程需要多次订阅操作,降低了资源消息加载和发送的效率,并且手动寻找订阅容易出现遗漏。At present, with the vigorous development of the information network platform, the resources among the various business systems in the information network platform need to subscribe to each other, so the stability and message integrity of resource message transmission need to be guaranteed. In the prior art, the interaction method of resource messages in various business systems has great limitations. When a user needs to subscribe to a certain resource, he needs to subscribe to the upper-level resource of the resource and the resource in turn. The whole process requires multiple subscription operations. The efficiency of resource message loading and sending is reduced, and manual search for subscriptions is prone to omissions.

发明内容Contents of the invention

有鉴于此,本发明的目的在于提供一种消息推送方法、装置、设备及介质,能够通过一次订阅实现存在依赖关系的所有相关资源的订阅。其具体方案如下:In view of this, the object of the present invention is to provide a message push method, device, device and medium, which can realize the subscription of all related resources with dependencies through one subscription. The specific plan is as follows:

第一方面,本申请公开了一种消息推送方法,包括:In the first aspect, the present application discloses a message push method, including:

获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;Obtain a subscription policy for the target resource subscription system, and determine the corresponding target resource message according to the subscription policy;

根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;determining a superior resource message corresponding to the target resource message according to the resource dependency of the target resource message;

将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。Adding the target resource message and the superior resource message to a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system.

可选的,所述将所述目标资源消息和所述上级资源消息加入对应的待发送队列,包括:Optionally, adding the target resource message and the superior resource message to a corresponding queue to be sent includes:

查询所述订阅策略中是否存在针对所述上级资源消息的筛选条件;Querying whether there is a filter condition for the upper-level resource message in the subscription policy;

若存在,则按照所述筛选条件对所述上级资源消息进行筛选,得到目标上级资源消息;If it exists, filter the upper-level resource message according to the filtering condition to obtain the target upper-level resource message;

将所述目标资源消息和所述目标上级资源消息加入待发送队列。Add the target resource message and the target superior resource message to a queue to be sent.

可选的,所述根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息,包括:Optionally, the determining the upper-level resource message corresponding to the target resource message according to the resource dependency of the target resource message includes:

根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的首个上级资源消息,再根据所述首个上级资源消息的资源依赖关系确定出所述首个上级资源消息对应的上级资源消息,直至查询得到所述目标资源消息对应的所有上级资源消息。Determine the first higher-level resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message, and then determine the upper-level resource message corresponding to the first higher-level resource message according to the resource dependency relationship of the first higher-level resource message resource messages until all upper-level resource messages corresponding to the target resource message are obtained.

可选的,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统,包括:Optionally, the sending the resource message in the queue to be sent to the target resource subscription system includes:

按照资源从上级到下级的顺序,依次向所述目标资源订阅系统发送所述待发送队列中的资源消息,并在发送每个资源消息前,判断该资源消息是否满足发送条件。Send the resource messages in the waiting queue to the target resource subscription system sequentially according to the order of the resources from the upper level to the lower level, and before sending each resource message, determine whether the resource message meets the sending condition.

可选的,所述发送条件包括所述资源消息为最上级资源消息,或所述资源消息直接的上级资源消息发送成功。Optionally, the sending condition includes that the resource message is the highest-level resource message, or that the resource message's direct upper-level resource message is sent successfully.

可选的,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统,包括:Optionally, the sending the resource message in the queue to be sent to the target resource subscription system includes:

将所述待发送队列中的资源消息发送给消息注册发送服务,以便所述消息注册发送服务进行通道检查和翻译加密之后,将资源消息发送给所述目标资源订阅系统;Send the resource message in the queue to be sent to the message registration sending service, so that the message registration sending service will send the resource message to the target resource subscription system after channel checking and translation and encryption;

所述消息注册发送服务还用于展示待发送资源消息、发送成功资源消息和发送异常资源消息。The message registration sending service is also used to display resource messages to be sent, resource messages sent successfully, and resource messages sent abnormally.

可选的,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统之后,还包括:Optionally, after sending the resource messages in the queue to be sent to the target resource subscription system, the method further includes:

接收所述目标资源订阅系统反馈的消息回执,并根据所述消息回执修改对应的资源消息的状态,以便重启后对未接收成功的资源消息进行重发。Receive the message receipt fed back by the target resource subscription system, and modify the status of the corresponding resource message according to the message receipt, so as to resend the unsuccessfully received resource message after restarting.

第二方面,本申请公开了一种消息推送装置,包括:In a second aspect, the present application discloses a message push device, including:

策略获取模块,用于获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;A policy acquisition module, configured to acquire a subscription policy for the target resource subscription system, and determine a corresponding target resource message according to the subscription policy;

上级资源确定模块,用于根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;An upper-level resource determination module, configured to determine the upper-level resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message;

资源消息发送模块,用于将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。A resource message sending module, configured to add the target resource message and the superior resource message to a corresponding queue to be sent, and send the resource message in the queue to be sent to the target resource subscription system.

第三方面,本申请公开了一种电子设备,包括:In a third aspect, the present application discloses an electronic device, comprising:

存储器,用于保存计算机程序;memory for storing computer programs;

处理器,用于执行所述计算机程序,以实现前述的消息推送方法。A processor, configured to execute the computer program, so as to implement the aforementioned method for pushing messages.

第四方面,本申请公开了一种计算机可读存储介质,用于存储计算机程序;其中计算机程序被处理器执行时实现前述的消息推送方法。In a fourth aspect, the present application discloses a computer-readable storage medium for storing a computer program; wherein, when the computer program is executed by a processor, the aforementioned message push method is implemented.

本申请中,获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。可见,根据目标资源消息的资源依赖关系自动确定出目标资源消息对应的上级资源消息,并将上级资源消息和目标资源消息均存入待发送队列,由此解决资源消息创建过程中,存在依赖关系的相关资源需要手动创建订阅的问题,即一次订阅就自动创建所有存在依赖关系的资源的订阅策略,实现针对资源具有依赖关系的离散消息推送。In this application, the subscription policy for the target resource subscription system is obtained, and the corresponding target resource message is determined according to the subscription policy; the upper-level resource message corresponding to the target resource message is determined according to the resource dependency of the target resource message; Adding the target resource message and the superior resource message to a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system. It can be seen that according to the resource dependency of the target resource message, the upper-level resource message corresponding to the target resource message is automatically determined, and both the upper-level resource message and the target resource message are stored in the queue to be sent, thereby solving the dependency relationship in the process of creating resource messages Related resources need to manually create a subscription, that is, a subscription strategy for all resources with dependencies is automatically created for one subscription, and discrete message push for resources with dependencies is realized.

附图说明Description of drawings

为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据提供的附图获得其他的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only It is an embodiment of the present invention, and those skilled in the art can also obtain other drawings according to the provided drawings without creative work.

图1为本申请提供的一种消息推送方法流程图;Fig. 1 is a flow chart of a message pushing method provided by the present application;

图2为本申请提供的一种具体的消息推送方法流程图;FIG. 2 is a flow chart of a specific message pushing method provided by the present application;

图3为本申请提供的一种消息推送装置结构示意图;FIG. 3 is a schematic structural diagram of a message push device provided by the present application;

图4为本申请提供的一种电子设备结构图。FIG. 4 is a structural diagram of an electronic device provided by the present application.

具体实施方式Detailed ways

为使本发明实施例的目的、技术方案和优点更加清楚,下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。In order to make the purpose, technical solutions and advantages of the embodiments of the present invention clearer, the technical solutions in the embodiments of the present invention will be clearly and completely described below in conjunction with the drawings in the embodiments of the present invention. Obviously, the described embodiments It is only some embodiments of the present invention, but not all embodiments. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

现有技术中,资源消息在各业务系统中的交互方法有较大的局限性,用户需要订阅某个资源时,需要依次订阅该资源的上级资源以及该资源,整个过程需要多次订阅操作,降低了资源消息加载和发送的效率。In the prior art, the interaction method of resource messages in various business systems has great limitations. When a user needs to subscribe to a certain resource, he needs to subscribe to the upper-level resource of the resource and the resource in turn. The whole process requires multiple subscription operations. Reduced the efficiency of resource message loading and sending.

本申请实施例公开了一种消息推送方法,参见图1所示,该方法可以包括以下步骤:The embodiment of the present application discloses a message push method, as shown in Figure 1, the method may include the following steps:

步骤S11:获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息。Step S11: Obtain the subscription policy for the target resource subscription system, and determine the corresponding target resource message according to the subscription policy.

本实施例中,首先获取用户针对目标资源订阅系统的订阅策略,然后根据该订阅策略确定出对应的目标资源消息,上述订阅策略可以为单选订阅策略,如针对某类学历的订阅。In this embodiment, first obtain the user's subscription policy for the target resource subscription system, and then determine the corresponding target resource message according to the subscription policy. The above-mentioned subscription policy may be a single-choice subscription policy, such as subscription for a certain type of education.

步骤S12:根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息。Step S12: Determine the upper-level resource message corresponding to the target resource message according to the resource dependency of the target resource message.

本实施例中,确定目标资源消息后,根据目标资源消息的资源依赖关系确定出目标资源消息对应的上级资源消息,可以理解的是,资源作为不可或缺的重要内容,其在业务系统中不会单独存在,一定会跟其他资源存在依赖关系,因此通过依赖关系确定出目标资源消息的上级资源消息。通常目标资源消息为最低级资源消息,然后据此向上寻找上级资源消息。In this embodiment, after the target resource message is determined, the upper-level resource message corresponding to the target resource message is determined according to the resource dependency of the target resource message. It will exist alone and must have a dependency relationship with other resources, so the parent resource message of the target resource message is determined through the dependency relationship. Usually the target resource message is the lowest-level resource message, and then look up the upper-level resource message accordingly.

本实施例中,所述根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息,可以包括:根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的首个上级资源消息,再根据所述首个上级资源消息的资源依赖关系确定出所述首个上级资源消息对应的上级资源消息,直至查询得到所述目标资源消息对应的所有上级资源消息。即上级资源消息可以包括目标资源消息的直接上级资源消息,也包括直接上级资源消息的再上级资源消息,直至到最高级资源类型消息。例如,上述目标资源消息为用户资源消息,用户资源消息的上级资源消息为组织资源消息,组织资源消息的上级资源消息为机构资源消息。In this embodiment, the determining the upper-level resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message may include: determining the target resource message according to the resource dependency relationship of the target resource message The corresponding first higher-level resource message, and then determine the upper-level resource message corresponding to the first higher-level resource message according to the resource dependency relationship of the first higher-level resource message, until all the upper-level resource messages corresponding to the target resource message are queried . That is, the upper-level resource message may include the immediate upper-level resource message of the target resource message, as well as the next-higher-level resource message of the direct upper-level resource message, up to the highest-level resource type message. For example, the above-mentioned target resource message is a user resource message, the superior resource message of the user resource message is an organization resource message, and the superior resource message of the organization resource message is an institution resource message.

步骤S13:将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。Step S13: adding the target resource message and the superior resource message to the corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system.

本实施例中,将确定出的目标资源消息和上级资源消息加入对应的待发送队列,然后将待发送队列中的资源消息发送给目标资源订阅系统,即通过为每个目标资源消息创建一个对应的待发送队列,该队列存储该目标资源消息以及存在依赖关系的相关上级资源消息。由此,当资源发送消息出现异常后,可以继续推送后续无依赖关系的资源消息,保证资源消息的时效性。同时,根据存在的待发送队列内内容进行并发操作,提高资源消息发送效率。In this embodiment, the determined target resource message and upper-level resource message are added to the corresponding queue to be sent, and then the resource message in the queue to be sent is sent to the target resource subscription system, that is, by creating a corresponding The queue to be sent, which stores the target resource message and related upper-level resource messages with dependencies. Therefore, when an abnormality occurs in sending a resource message, it can continue to push subsequent resource messages without dependencies to ensure the timeliness of the resource message. At the same time, concurrent operations are performed according to the content in the queue to be sent to improve the efficiency of sending resource messages.

本实施例中,所述将所述目标资源消息和所述上级资源消息加入对应的待发送队列,可以包括:查询所述订阅策略中是否存在针对所述上级资源消息的筛选条件;若存在,则按照所述筛选条件对所述上级资源消息进行筛选,得到目标上级资源消息;将所述目标资源消息和所述目标上级资源消息加入待发送队列。即目标资源消息的上级资源消息可能海量的,用户可以通过筛选条件选择上级资源消息中的部分资源消息,将该部分消息作为目标上级资源消息添加至待发送队列,提高资源消息的精确性,并节约传输带宽。具体的,可以通过在原有订阅策略的基础上,根据筛选条件自动构建针对组织资源的订阅策略,以及针对机构资源的订阅策略实现筛选,使资源消息构建策略更高效、更稳定。In this embodiment, adding the target resource message and the upper-level resource message to the corresponding queue to be sent may include: querying whether there is a filtering condition for the upper-level resource message in the subscription policy; if yes, Then, the upper-level resource message is screened according to the screening condition to obtain a target upper-level resource message; and the target resource message and the target upper-level resource message are added to a queue to be sent. That is, there may be a large number of upper-level resource messages of the target resource message. Users can select some resource messages in the upper-level resource messages through filter conditions, and add this part of messages as target upper-level resource messages to the queue to be sent to improve the accuracy of resource messages. Save transmission bandwidth. Specifically, based on the original subscription strategy, the subscription strategy for organizational resources can be automatically constructed according to the filter conditions, and the subscription strategy for institutional resources can be filtered to make resource message construction strategies more efficient and stable.

本实施例中,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统,可以包括:按照资源从上级到下级的顺序,依次向所述目标资源订阅系统发送所述待发送队列中的资源消息,并在发送每个资源消息前,判断该资源消息是否满足发送条件。即资源同步是按照依赖关系的级别来依次按序进行消息交互存储时也是按次序存储,并且在发送前需要判断是否符合发送条件。In this embodiment, the sending the resource messages in the queue to be sent to the target resource subscription system may include: sequentially sending the resource messages to the target resource subscription system according to the sequence of resources from the upper level to the lower level. Send resource messages in the queue, and before sending each resource message, determine whether the resource message meets the sending conditions. That is to say, resource synchronization is to perform message interaction and storage sequentially according to the level of dependency, and it is also stored in sequence, and it is necessary to judge whether the sending conditions are met before sending.

本实施例中,所述发送条件包括所述资源消息为最上级资源消息,或所述资源消息直接的上级资源消息发送成功。即依次从待发送队列中取出队列头部资源,检查该资源是否满足发送条件,即判断该资源的上级依赖资源是否成功发送,如果发送成功,则该资源可被发送,例如机构资源发送成功,则当前的组织资源即可发送;若该资源没有上级依赖资源,如机构资源,则满足发送条件。In this embodiment, the sending condition includes that the resource message is the highest-level resource message, or that the resource message's direct upper-level resource message is sent successfully. That is, take out the resources at the head of the queue from the queue to be sent in turn, check whether the resource meets the sending conditions, that is, judge whether the upper-level dependent resource of the resource is successfully sent, if the sending is successful, the resource can be sent, for example, the organization resource is sent successfully, Then the current organizational resource can be sent; if the resource does not have a superior dependent resource, such as an institutional resource, the sending condition is met.

本实施例中,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统,可以包括:将所述待发送队列中的资源消息发送给消息注册发送服务,以便所述消息注册发送服务进行通道检查和翻译加密之后,将资源消息发送给所述目标资源订阅系统;所述消息注册发送服务还用于展示待发送资源消息、发送成功资源消息和发送异常资源消息。In this embodiment, the sending the resource message in the queue to be sent to the target resource subscription system may include: sending the resource message in the queue to be sent to a message registration sending service, so that the message After channel checking, translation and encryption, the registration sending service sends the resource message to the target resource subscription system; the message registration sending service is also used to display the resource message to be sent, the resource message sent successfully, and the abnormal resource message sent.

即本实施例中可以应用于预创建的同步资源算法核心服务,具体将资源消息发送给消息注册发送服务,由消息注册发送服务进行通道检查和翻译加密之后,转发给目标资源订阅系统,消息注册发送服务具体会根据待发送资源的订阅策略,加载对应的目标资源订阅系统的相关信息,并对该资源订阅系统的消息交互通道进行检查;然后根据通信协议,对待发送资源进行翻译,并对翻译结果进行加密保护,构建发送消息;最后,根据资源订阅系统的消息交换地址,将资源消息发送给目标资源订阅系统。同时,消息注册发送服务还用于展示待发送资源消息、发送成功资源消息和发送异常资源消息;即用户可以在消息注册发送服务资源消息监控列表中查看待发送资源消息、发送成功资源消息、发送异常资源消息和具体异常原因。可见,通过消息注册发送服务实现更加完善的资源消息发送监控体系,可以监管资源消息发送生命周期,方便统一管理各个状态下的资源消息,降低了资源消息发送服务的运维成本。That is, this embodiment can be applied to the core service of the pre-created synchronization resource algorithm. Specifically, the resource message is sent to the message registration sending service. Specifically, the sending service will load the relevant information of the corresponding target resource subscription system according to the subscription strategy of the resource to be sent, and check the message interaction channel of the resource subscription system; then, according to the communication protocol, the resource to be sent will be translated, and the translated The result is encrypted and protected, and the sending message is constructed; finally, the resource message is sent to the target resource subscription system according to the message exchange address of the resource subscription system. At the same time, the message registration sending service is also used to display resource messages to be sent, resource messages sent successfully, and abnormal resource messages sent; that is, users can view resource messages to be sent, resource messages sent successfully, and resource messages sent in the message registration sending service resource message monitoring list. Exception resource message and specific exception reason. It can be seen that through the message registration and sending service, a more complete resource message sending monitoring system can be realized, which can monitor the resource message sending life cycle, facilitate unified management of resource messages in various states, and reduce the operation and maintenance cost of the resource message sending service.

本实施例中,所述将所述待发送队列中的资源消息发送给所述目标资源订阅系统之后,还可以包括:接收所述目标资源订阅系统反馈的消息回执,并根据所述消息回执修改对应的资源消息的状态,以便重启后对未接收成功的资源消息进行重发。即目标资源订阅系统接收到资源消息后反馈消息回执给消息注册发送服务,由消息注册发送服务转发给同步资源算法核心服务,以便根据消息回执修改对应的资源消息的状态,如已发送成功或未发送成功,以便重启后对未接收成功的资源消息进行重发。由此,针对发送失败的消息,通过合理的消息重发机制,不影响系统其他业务功能的使用。可见,针对现有技术中系统宕机重启恢复后,无法继续进行之前未完成的资源消息交互的问题,本实施例能够很好的解决系统中资源高效的加载,确保资源消息的发送能按照一定的依赖关系先后发送并一定成功;同时针对系统宕机后重启,可以继续的与其他系统进行未成功发送的资源的消息交互。In this embodiment, after sending the resource message in the queue to be sent to the target resource subscription system, it may further include: receiving a message receipt fed back by the target resource subscription system, and modifying the message according to the message receipt The state of the corresponding resource message, so that the resource message that has not been received successfully can be resent after restarting. That is, after receiving the resource message, the target resource subscription system feeds back the message receipt to the message registration and sending service, and the message registration and sending service forwards it to the core service of the synchronization resource algorithm, so as to modify the status of the corresponding resource message according to the message receipt, such as successfully sent or not Sending is successful, so that resource messages that have not been successfully received can be resent after restarting. Therefore, for messages that fail to be sent, a reasonable message resending mechanism will not affect the use of other business functions of the system. It can be seen that in view of the problem in the prior art that the unfinished resource message interaction cannot be continued after the system is restarted and restored, this embodiment can well solve the problem of efficient resource loading in the system and ensure that resource messages can be sent according to certain requirements. Dependencies have been sent successively and must be successful; at the same time, for restarting after a system crash, you can continue to interact with other systems for resources that have not been successfully sent.

由上可见,本实施例中获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。可见,根据目标资源消息的资源依赖关系自动确定出目标资源消息对应的上级资源消息,并将上级资源消息和目标资源消息均存入待发送队列,由此解决资源消息创建过程中,存在依赖关系的相关资源需要手动创建订阅的问题,即一次订阅就将自动创建所有存在依赖关系的资源的订阅策略,实现针对资源具有依赖关系的离散消息推送,显著提高了资源消息构建过程和消息发送过程对服务器资源的使用效率。It can be seen from the above that in this embodiment, the subscription policy for the target resource subscription system is obtained, and the corresponding target resource message is determined according to the subscription policy; the corresponding target resource message is determined according to the resource dependency of the target resource message. Upper-level resource message: adding the target resource message and the upper-level resource message to a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system. It can be seen that according to the resource dependency of the target resource message, the upper-level resource message corresponding to the target resource message is automatically determined, and both the upper-level resource message and the target resource message are stored in the queue to be sent, thereby solving the dependency relationship in the process of creating resource messages Related resources need to manually create a subscription, that is, a subscription will automatically create a subscription strategy for all resources with dependencies, and realize discrete message push for resources with dependencies, which significantly improves the resource message construction process and message sending process. Efficient use of server resources.

本申请实施例还公开了一种具体的消息推送方法,参见图2所示,该方法包括以下步骤:The embodiment of the present application also discloses a specific message push method, as shown in Figure 2, the method includes the following steps:

1.用户(即管理员)根据业务需求对具体的资源订阅系统创建需要的订阅策略,如单选订阅策略。1. The user (that is, the administrator) creates the required subscription strategy for the specific resource subscription system according to business requirements, such as a single-select subscription strategy.

2.创建的策略注入到同步资源算法核心服务中。2. The created strategy is injected into the core service of the synchronization resource algorithm.

3.同步资源算法核心服务根据订阅策略,找出满足该订阅策略的所有用户/应用/网关资源。可以理解的是,除确定出用户资源外,还可以根据该用户拥有的权限确定出对应的应用资源和网关资源。3. Algorithm for synchronizing resources The core service finds out all user/application/gateway resources that satisfy the subscription policy according to the subscription policy. It can be understood that, in addition to determining the user resource, the corresponding application resource and gateway resource can also be determined according to the user's authority.

4.同步资源算法核心服务根据算法自动加载与满足订阅策略的用户/应用/网关资源有依赖关系的组织资源。4. Synchronization resource algorithm The core service automatically loads organizational resources that are dependent on user/application/gateway resources that meet the subscription policy according to the algorithm.

5.同步资源算法核心服务根据算法自动加载与上一步的组织资源有依赖关系的机构资源。5. Synchronize resource algorithm The core service automatically loads institutional resources that are dependent on the organizational resources in the previous step according to the algorithm.

6.同步资源算法核心服务自动创建同一个资源订阅系统的属于机构的订阅策略。6. The core service of the synchronization resource algorithm automatically creates the subscription strategy belonging to the organization of the same resource subscription system.

7.将资源缓存中心的机构资源相关的订阅参数进行预标记,用于表征订阅。7. Pre-mark subscription parameters related to institutional resources in the resource cache center to represent subscriptions.

8.将机构资源放入待发送队列中。8. Put the institutional resources into the queue to be sent.

9.同步资源算法核心服务将自动创建同一个资源订阅系统的属于组织的订阅策略。9. The core service of the synchronization resource algorithm will automatically create a subscription policy belonging to the organization of the same resource subscription system.

10.将资源缓存中心的组织资源相关的订阅参数进行预标记,用于表征订阅。10. Pre-mark the subscription parameters related to the organizational resources of the resource cache center to represent the subscription.

11.将组织资源放入待发送队列中。11. Put the organizational resources in the queue to be sent.

12.将资源缓存中心的用户/应用/网关资源相关的订阅参数进行预标记,用于表征订阅。12. Pre-mark the subscription parameters related to the user/application/gateway resource in the resource cache center to represent the subscription.

13.将用户/应用/网关资源放入待发送队列中。13. Put the user/application/gateway resource into the queue to be sent.

14.同步资源算法核心服务从待发送队列中取出队列头部资源,检查该资源是否满足发送条件。如:该资源的上级依赖资源是否成功发送,如果发送成功,则该资源可被发送。若该资源没有上级依赖资源,如机构资源,则满足发送条件。14. The core service of the synchronization resource algorithm takes out the resource at the head of the queue from the queue to be sent, and checks whether the resource meets the sending condition. For example: the superior of the resource depends on whether the resource is sent successfully, and if the sending is successful, the resource can be sent. If the resource does not have a superior dependent resource, such as an institutional resource, the sending condition is met.

15.同步资源算法核心服务将符合发送条件的待发送资源通知给消息注册发送服务。15. The core service of the synchronization resource algorithm notifies the message registration sending service of the resources to be sent that meet the sending conditions.

16.消息注册发送服务根据待发送资源的订阅策略,加载资源订阅系统的相关信息,并对该资源订阅系统的消息交互通道进行检查。16. The message registration sending service loads the relevant information of the resource subscription system according to the subscription policy of the resource to be sent, and checks the message interaction channel of the resource subscription system.

17.根据通信协议,对待发送资源进行翻译,并对翻译结果进行加密保护,构建发送消息。17. According to the communication protocol, the resource to be sent is translated, and the translation result is encrypted and protected, and the sending message is constructed.

18.根据资源订阅系统的消息交换地址,将资源消息发送给资源订阅系统。18. Send the resource message to the resource subscription system according to the message exchange address of the resource subscription system.

19.用户在消息注册发送服务资源消息监控列表中查看待发送资源消息、发送成功资源消息、发送异常资源消息和具体异常原因。19. The user checks the resource message to be sent, the resource message sent successfully, the abnormal resource message sent and the specific abnormal reason in the resource message monitoring list of the message registration sending service.

20.消息注册发送服务接收资源订阅系统的消息回执结果,并根据通信协议进行解析翻译。20. The message registration sending service receives the message receipt result from the resource subscription system, and analyzes and translates it according to the communication protocol.

21.消息注册发送服务将翻译解析后的资源发送消息回执结果反馈给同步资源算法核心服务。21. The message registration and sending service feeds back the result of the resource sending message receipt after translation and analysis to the core service of the synchronization resource algorithm.

22.同步算法核心服务根据消息发送的回执结果,对资源缓存中心保存的订阅资源的相关订阅参数的值进行修改并保存。22. The core service of the synchronization algorithm modifies and saves the value of the relevant subscription parameters of the subscription resource saved in the resource cache center according to the result of the message sending receipt.

可见,本实施例中获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;将所述目标资源消息和所述上级资源消息加入待发送队列将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。可见,根据目标资源消息的资源依赖关系自动确定出目标资源消息对应的上级资源消息,并将上级资源消息和目标资源消息均存入待发送队列,由此解决资源消息创建过程中,存在依赖关系的相关资源需要手动创建订阅的问题,即一次订阅就将自动创建所有存在依赖关系的资源的订阅策略,实现针对资源具有依赖关系的离散消息推送。It can be seen that in this embodiment, the subscription policy for the target resource subscription system is obtained, and the corresponding target resource message is determined according to the subscription policy; the upper-level resource corresponding to the target resource message is determined according to the resource dependency of the target resource message message; add the target resource message and the upper-level resource message to the queue to be sent, add the target resource message and the upper-level resource message to the corresponding queue to be sent, and send the resource message in the queue to be sent to The target resource subscription system. It can be seen that according to the resource dependency of the target resource message, the upper-level resource message corresponding to the target resource message is automatically determined, and both the upper-level resource message and the target resource message are stored in the queue to be sent, thereby solving the dependency relationship in the process of creating resource messages Related resources need to manually create a subscription, that is, a subscription will automatically create a subscription strategy for all resources with dependencies, and realize discrete message push for resources with dependencies.

相应的,本申请实施例还公开了一种消息推送装置,参见图3所示,该装置包括:Correspondingly, the embodiment of the present application also discloses a message push device, as shown in Figure 3, the device includes:

策略获取模块11,用于获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;A policy acquisition module 11, configured to acquire a subscription policy for the target resource subscription system, and determine a corresponding target resource message according to the subscription policy;

上级资源确定模块12,用于根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;A superior resource determination module 12, configured to determine the superior resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message;

资源消息发送模块13,用于将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。A resource message sending module 13, configured to add the target resource message and the superior resource message to a corresponding queue to be sent, and send the resource message in the queue to be sent to the target resource subscription system.

由上可见,本实施例中获取针对目标资源订阅系统的订阅策略,根据所述订阅策略确定出对应的目标资源消息;根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的上级资源消息;将所述目标资源消息和所述上级资源消息加入对应的待发送队列,并将所述待发送队列中的资源消息发送给所述目标资源订阅系统。可见,根据目标资源消息的资源依赖关系自动确定出目标资源消息对应的上级资源消息,并将上级资源消息和目标资源消息均存入待发送队列,由此解决资源消息创建过程中,存在依赖关系的相关资源需要手动创建订阅的问题,即一次订阅就将自动创建所有存在依赖关系的资源的订阅策略,实现针对资源具有依赖关系的离散消息推送。It can be seen from the above that in this embodiment, the subscription policy for the target resource subscription system is obtained, and the corresponding target resource message is determined according to the subscription policy; the corresponding target resource message is determined according to the resource dependency of the target resource message. Upper-level resource message: adding the target resource message and the upper-level resource message to a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system. It can be seen that according to the resource dependency of the target resource message, the upper-level resource message corresponding to the target resource message is automatically determined, and both the upper-level resource message and the target resource message are stored in the queue to be sent, thereby solving the dependency relationship in the process of creating resource messages Related resources need to manually create a subscription, that is, a subscription will automatically create a subscription strategy for all resources with dependencies, and realize discrete message push for resources with dependencies.

在一些具体实施例中,所述资源消息发送模块13具体可以包括:In some specific embodiments, the resource message sending module 13 may specifically include:

筛选条件查询单元,用于查询所述订阅策略中是否存在针对所述上级资源消息的筛选条件;A filtering condition query unit, configured to query whether there is a filtering condition for the upper-level resource message in the subscription policy;

筛选单元,用于若存在,则按照所述筛选条件对所述上级资源消息进行筛选,得到目标上级资源消息;A filtering unit, configured to, if it exists, filter the upper-level resource message according to the filtering condition to obtain the target upper-level resource message;

将所述目标资源消息和所述目标上级资源消息加入待发送队列。Add the target resource message and the target superior resource message to a queue to be sent.

在一些具体实施例中,所述上级资源确定模块12具体可以包括:In some specific embodiments, the upper-level resource determination module 12 may specifically include:

上级资源确定单元,用于根据所述目标资源消息的资源依赖关系确定出所述目标资源消息对应的首个上级资源消息,再根据所述首个上级资源消息的资源依赖关系确定出所述首个上级资源消息对应的上级资源消息,直至查询得到所述目标资源消息对应的所有上级资源消息。The upper-level resource determination unit is configured to determine the first upper-level resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message, and then determine the first higher-level resource message according to the resource dependency relationship of the first upper-level resource message. The upper-level resource messages corresponding to the upper-level resource messages until all the upper-level resource messages corresponding to the target resource messages are obtained.

在一些具体实施例中,所述资源消息发送模块13具体可以包括:In some specific embodiments, the resource message sending module 13 may specifically include:

资源消息发送单元,用于按照资源从上级到下级的顺序,依次向所述目标资源订阅系统发送所述待发送队列中的资源消息,并在发送每个资源消息前,判断该资源消息是否满足发送条件。A resource message sending unit, configured to sequentially send the resource messages in the queue to be sent to the target resource subscription system according to the order of resources from upper level to lower level, and before sending each resource message, determine whether the resource message satisfies send conditions.

在一些具体实施例中,所述发送条件具体可以包括所述资源消息为最上级资源消息,或所述资源消息直接的上级资源消息发送成功。In some specific embodiments, the sending condition may specifically include that the resource message is the highest-level resource message, or that the resource message's direct upper-level resource message is sent successfully.

在一些具体实施例中,所述资源消息发送模块13具体可以包括:In some specific embodiments, the resource message sending module 13 may specifically include:

转发单元,用于将所述待发送队列中的资源消息发送给消息注册发送服务,以便所述消息注册发送服务进行通道检查和翻译加密之后,将资源消息发送给所述目标资源订阅系统;A forwarding unit, configured to send the resource message in the queue to be sent to the message registration sending service, so that the message registration sending service can send the resource message to the target resource subscription system after channel checking, translation and encryption;

所述消息注册发送服务还用于展示待发送资源消息、发送成功资源消息和发送异常资源消息。The message registration sending service is also used to display resource messages to be sent, resource messages sent successfully, and resource messages sent abnormally.

在一些具体实施例中,所述消息推送装置具体可以包括:In some specific embodiments, the message push device may specifically include:

状态更新单元,用于在将所述待发送队列中的资源消息发送给所述目标资源订阅系统之后,接收所述目标资源订阅系统反馈的消息回执,并根据所述消息回执修改对应的资源消息的状态,以便重启后对未接收成功的资源消息进行重发。A status updating unit, configured to receive a message receipt fed back by the target resource subscription system after sending the resource message in the queue to be sent to the target resource subscription system, and modify the corresponding resource message according to the message receipt status, so that the failed resource messages can be resent after restarting.

进一步的,本申请实施例还公开了一种电子设备,参见图4所示,图中的内容不能被认为是对本申请的使用范围的任何限制。Further, the embodiment of the present application also discloses an electronic device, as shown in FIG. 4 , and the content in the figure should not be regarded as any limitation on the application scope of the present application.

图4为本申请实施例提供的一种电子设备20的结构示意图。该电子设备20,具体可以包括:至少一个处理器21、至少一个存储器22、电源23、通信接口24、输入输出接口25和通信总线26。其中,所述存储器22用于存储计算机程序,所述计算机程序由所述处理器21加载并执行,以实现前述任一实施例公开的消息推送方法中的相关步骤。FIG. 4 is a schematic structural diagram of an electronic device 20 provided in an embodiment of the present application. The electronic device 20 may specifically include: at least one processor 21 , at least one memory 22 , a power supply 23 , a communication interface 24 , an input/output interface 25 and a communication bus 26 . Wherein, the memory 22 is used to store a computer program, and the computer program is loaded and executed by the processor 21 to implement the relevant steps in the message push method disclosed in any of the foregoing embodiments.

本实施例中,电源23用于为电子设备20上的各硬件设备提供工作电压;通信接口24能够为电子设备20创建与外界设备之间的数据传输通道,其所遵循的通信协议是能够适用于本申请技术方案的任意通信协议,在此不对其进行具体限定;输入输出接口25,用于获取外界输入数据或向外界输出数据,其具体的接口类型可以根据具体应用需要进行选取,在此不进行具体限定。In this embodiment, the power supply 23 is used to provide working voltage for each hardware device on the electronic device 20; the communication interface 24 can create a data transmission channel between the electronic device 20 and external devices, and the communication protocol it follows is applicable Any communication protocol in the technical solution of the present application is not specifically limited here; the input and output interface 25 is used to obtain external input data or output data to the external, and its specific interface type can be selected according to specific application needs, here Not specifically limited.

另外,存储器22作为资源存储的载体,可以是只读存储器、随机存储器、磁盘或者光盘等,其上所存储的资源包括操作系统221、计算机程序222及包括订阅策略在内的数据223等,存储方式可以是短暂存储或者永久存储。In addition, the memory 22, as a resource storage carrier, can be a read-only memory, random access memory, magnetic disk or optical disk, etc., and the resources stored therein include the operating system 221, computer programs 222, and data 223 including subscription policies, etc. The method can be temporary storage or permanent storage.

其中,操作系统221用于管理与控制电子设备20上的各硬件设备以及计算机程序222,以实现处理器21对存储器22中海量数据223的运算与处理,其可以是Windows Server、Netware、Unix、Linux等。计算机程序222除了包括能够用于完成前述任一实施例公开的由电子设备20执行的消息推送方法的计算机程序之外,还可以进一步包括能够用于完成其他特定工作的计算机程序。Wherein, the operating system 221 is used to manage and control each hardware device and computer program 222 on the electronic device 20, so as to realize the calculation and processing of the massive data 223 in the memory 22 by the processor 21, which can be Windows Server, Netware, Unix, Linux, etc. In addition to the computer program 222 that can be used to complete the message push method performed by the electronic device 20 disclosed in any of the foregoing embodiments, the computer program 222 can further include a computer program that can be used to complete other specific tasks.

进一步的,本申请实施例还公开了一种计算机存储介质,所述计算机存储介质中存储有计算机可执行指令,所述计算机可执行指令被处理器加载并执行时,实现前述任一实施例公开的消息推送方法步骤。Further, the embodiment of the present application also discloses a computer storage medium, the computer storage medium stores computer-executable instructions, and when the computer-executable instructions are loaded and executed by a processor, the implementation of any one of the foregoing embodiments is disclosed. Steps of the message push method.

本说明书中各个实施例采用递进的方式描述,每个实施例重点说明的都是与其它实施例的不同之处,各个实施例之间相同或相似部分互相参见即可。对于实施例公开的装置而言,由于其与实施例公开的方法相对应,所以描述的比较简单,相关之处参见方法部分说明即可。Each embodiment in this specification is described in a progressive manner, each embodiment focuses on the difference from other embodiments, and the same or similar parts of each embodiment can be referred to each other. As for the device disclosed in the embodiment, since it corresponds to the method disclosed in the embodiment, the description is relatively simple, and for relevant details, please refer to the description of the method part.

结合本文中所公开的实施例描述的方法或算法的步骤可以直接用硬件、处理器执行的软件模块,或者二者的结合来实施。软件模块可以置于随机存储器(RAM)、内存、只读存储器(ROM)、电可编程ROM、电可擦除可编程ROM、寄存器、硬盘、可移动磁盘、CD-ROM、或技术领域内所公知的任意其它形式的存储介质中。The steps of the methods or algorithms described in connection with the embodiments disclosed herein may be directly implemented by hardware, software modules executed by a processor, or a combination of both. Software modules can be placed in random access memory (RAM), internal memory, read-only memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, removable disk, CD-ROM, or any other Any other known storage medium.

最后,还需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。Finally, it should also be noted that in this text, relational terms such as first and second etc. are only used to distinguish one entity or operation from another, and do not necessarily require or imply that these entities or operations, any such actual relationship or order exists. Furthermore, the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article, or apparatus comprising a set of elements includes not only those elements, but also includes elements not expressly listed. other elements of or also include elements inherent in such a process, method, article, or device. Without further limitations, an element defined by the phrase "comprising a ..." does not exclude the presence of additional identical elements in the process, method, article or apparatus comprising said element.

以上对本发明所提供的一种消息推送方法、装置、设备及介质进行了详细介绍,本文中应用了具体个例对本发明的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本发明的方法及其核心思想;同时,对于本领域的一般技术人员,依据本发明的思想,在具体实施方式及应用范围上均会有改变之处,综上所述,本说明书内容不应理解为对本发明的限制。A message push method, device, equipment, and medium provided by the present invention have been introduced in detail above. In this paper, specific examples are used to illustrate the principle and implementation of the present invention. The description of the above embodiments is only for helping understanding The method of the present invention and its core idea; at the same time, for those of ordinary skill in the art, according to the idea of the present invention, there will be changes in the specific implementation and scope of application. In summary, the content of this specification should not be construed as a limitation of the invention.

Claims (10)

1. A message pushing method, comprising:
acquiring a subscription strategy aiming at a target resource subscription system, and determining a corresponding target resource message according to the subscription strategy;
determining a superior resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message;
and adding the target resource message and the superior resource message into a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system.
2. The message pushing method according to claim 1, wherein the adding the target resource message and the upper resource message to the corresponding queues to be sent includes:
inquiring whether screening conditions aiming at the superior resource information exist in the subscription strategy;
if yes, screening the superior resource message according to the screening condition to obtain a target superior resource message;
and adding the target resource message and the target superior resource message into a queue to be sent.
3. The message pushing method according to claim 1, wherein the determining, according to the resource dependency relationship of the target resource message, the upper resource message corresponding to the target resource message includes:
and determining a first superior resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message, and determining the superior resource message corresponding to the first superior resource message according to the resource dependency relationship of the first superior resource message until all the superior resource messages corresponding to the target resource message are obtained by inquiry.
4. The method for pushing a message according to claim 1, wherein the sending the resource message in the queue to be sent to the target resource subscription system includes:
and sequentially sending the resource messages in the queue to be sent to the target resource subscription system according to the sequence from the upper level to the lower level of the resource, and judging whether the resource messages meet the sending condition before sending each resource message.
5. The message pushing method according to claim 4, wherein the transmission condition includes that the resource message is an uppermost resource message or that the resource message is successfully transmitted as a direct upper resource message.
6. The method for pushing a message according to claim 1, wherein the sending the resource message in the queue to be sent to the target resource subscription system includes:
the resource information in the queue to be sent is sent to an information registration sending service, so that the information registration sending service sends the resource information to the target resource subscription system after channel checking and translation encryption;
the message registration sending service is also used for displaying the resource message to be sent, the successful resource message and the abnormal resource message.
7. The method for pushing a message according to claim 1, wherein after the sending the resource message in the queue to be sent to the target resource subscription system, the method further comprises:
and receiving a message receipt fed back by the target resource subscription system, and modifying the state of the corresponding resource message according to the message receipt so as to resend the resource message which is not successfully received after restarting.
8. A message pushing device, comprising:
the strategy acquisition module is used for acquiring a subscription strategy aiming at a target resource subscription system, and determining a corresponding target resource message according to the subscription strategy;
the upper resource determining module is used for determining an upper resource message corresponding to the target resource message according to the resource dependency relationship of the target resource message;
and the resource message sending module is used for adding the target resource message and the upper resource message into a corresponding queue to be sent, and sending the resource message in the queue to be sent to the target resource subscription system.
9. An electronic device, comprising:
a memory for storing a computer program;
a processor for executing the computer program to implement the message pushing method of any of claims 1 to 7.
10. A computer-readable storage medium storing a computer program; wherein the computer program when executed by a processor implements the message pushing method according to any of claims 1 to 7.
CN202310903800.3A 2023-07-21 2023-07-21 Message pushing method, device, equipment and storage medium Pending CN116708550A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202310903800.3A CN116708550A (en) 2023-07-21 2023-07-21 Message pushing method, device, equipment and storage medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202310903800.3A CN116708550A (en) 2023-07-21 2023-07-21 Message pushing method, device, equipment and storage medium

Publications (1)

Publication Number Publication Date
CN116708550A true CN116708550A (en) 2023-09-05

Family

ID=87831309

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202310903800.3A Pending CN116708550A (en) 2023-07-21 2023-07-21 Message pushing method, device, equipment and storage medium

Country Status (1)

Country Link
CN (1) CN116708550A (en)

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102687167A (en) * 2009-12-07 2012-09-19 国际商业机器公司 Contextual support for publish-subscribe systems
CN112966066A (en) * 2020-09-24 2021-06-15 王海宏 Information generation method and system based on block chain and financial subscription and service center
CN114817749A (en) * 2022-05-26 2022-07-29 中国建设银行股份有限公司 Information recommendation method and device, electronic equipment and storage medium
CN116233236A (en) * 2023-05-10 2023-06-06 深圳市东信时代信息技术有限公司 Information pushing method, device, equipment and medium based on message queue

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN102687167A (en) * 2009-12-07 2012-09-19 国际商业机器公司 Contextual support for publish-subscribe systems
CN112966066A (en) * 2020-09-24 2021-06-15 王海宏 Information generation method and system based on block chain and financial subscription and service center
CN114817749A (en) * 2022-05-26 2022-07-29 中国建设银行股份有限公司 Information recommendation method and device, electronic equipment and storage medium
CN116233236A (en) * 2023-05-10 2023-06-06 深圳市东信时代信息技术有限公司 Information pushing method, device, equipment and medium based on message queue

Similar Documents

Publication Publication Date Title
CN108600029B (en) A configuration file updating method, device, terminal device and storage medium
US9253265B2 (en) Hot pluggable extensions for access management system
US8788565B2 (en) Dynamic and distributed queueing and processing system
US8843580B2 (en) Criteria-based message publication control and feedback in a publish/subscribe messaging environment
US9348709B2 (en) Managing nodes in a distributed computing environment
US8615580B2 (en) Message publication feedback in a publish/subscribe messaging environment
US8793322B2 (en) Failure-controlled message publication and feedback in a publish/subscribe messaging environment
US20170048102A1 (en) Method of and system for managing computing resources
US10243919B1 (en) Rule-based automation of DNS service discovery
US20250323893A1 (en) Multi-cluster access method and system
US11061669B2 (en) Software development tool integration and monitoring
US11178189B1 (en) Managing network connections based on their endpoints
US10541961B2 (en) System and method for automating actions in distributed computing
US20080162690A1 (en) Application Management System
CN114900449B (en) Resource information management method, system and device
US20230086005A1 (en) System and methods for querying and updating databases
US12073263B1 (en) Dynamic processing of API requests
US8341254B2 (en) Middleware-driven server discovery
US10904327B2 (en) Method, electronic device and computer program product for searching for node
US20220053007A1 (en) System and method for device quarantine management
CN116708550A (en) Message pushing method, device, equipment and storage medium
US20250298897A1 (en) Security Scan With Backup
CN110764882B (en) Distributed management method, distributed management system and device
CN114945023B (en) Network connection multiplexing method, device, equipment and medium
CN115695315A (en) Request forwarding method, device, equipment and storage medium

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination