CN112887420B - Message pushing method and device, computer readable storage medium and electronic equipment - Google Patents

Abstract

The disclosure relates to a message pushing method, a message pushing device, a computer readable storage medium and an electronic device, and relates to the technical field of data processing. The method comprises the following steps: receiving a unified push message sent by an external system where a target user is located, analyzing the unified push message, and acquiring push content, a transmission protocol and a transmission address which are included in the unified push message; determining a message forwarding party corresponding to the target user according to the theme of the message queue corresponding to the unified push message; and pushing the push content to the target user by using the message forwarding party according to the transmission protocol and the transmission address so that the target user can view the push content. The method and the device reduce the coupling between the target user and the notification system and improve the timeliness of message pushing.

Description

Message push method and device, computer-readable storage medium, electronic device

Background technique

In order to facilitate the management of merchants, e-commerce platforms generally use a merchant notification system to notify settled merchants.

In the prior art, the merchant notification system accesses the encryption and decryption method of the external system where each merchant is located. When the merchant notification system receives the notification message sent by the external system where the merchant is located, it encrypts the message included in the notification message, and Send the encrypted message to the merchant.

However, there are the following problems in the notification through the above-mentioned merchant notification system: the merchant notification system needs to be redeveloped for different external systems, and different encryption and decryption algorithms need to be connected, which leads to serious coupling of the merchant notification system, which is not conducive to platform construction; Important merchants and ordinary merchants are not graded. When the merchant notification system fails, it will affect all merchants, resulting in low message push timeliness.

Therefore, a new message push method needs to be provided.

It should be noted that the information disclosed in the above background technology section is only used to enhance the understanding of the background of the present invention, and therefore may include information that does not constitute prior art known to those of ordinary skill in the art.

Contents of the invention

The purpose of the present invention is to provide a message push method, a message push device, a computer-readable storage medium, and an electronic device, so as to overcome the high degree of system coupling and the timeliness of message push caused by the limitations and defects of related technologies at least to a certain extent. low problem.

According to an aspect of the present disclosure, a message push method is provided, including:

receiving the unified push message sent by the external system where the target user is located, and analyzing the unified push message, and obtaining the push content, transmission protocol and transmission address included in the unified push message;

determining a message forwarder corresponding to the target user according to the subject of the message queue corresponding to the unified push message;

Using the message forwarding party to push the pushed content to the target user according to the transmission protocol and the transmission address, so that the target user can view the pushed content.

In an exemplary embodiment of the present disclosure, determining the message forwarder corresponding to the target user according to the topic of the message queue corresponding to the unified push message includes:

Establish a subscription relationship between the message forwarder and the topic;

determining the target user corresponding to the unified push message and the topic corresponding to the target user according to the access source included in the unified push message;

According to the topic corresponding to the target user, the message forwarders subscribing to the topic are acquired.

In an exemplary embodiment of the present disclosure, the transmission protocol includes hypertext transfer protocol or Jeff protocol;

Wherein, when the transmission protocol is the Jeff protocol, according to the transmission protocol and the transmission address, pushing the push content to the target users included in the external system includes:

Analyzing the transfer address to obtain a domain name corresponding to the transfer address;

Querying the Domain Name System according to the domain name to obtain an Internet Protocol address corresponding to the domain name;

A persistent connection is established based on the Internet protocol address, and the push content is pushed to target users included in the external system through the persistent connection.

In an exemplary embodiment of the present disclosure, after pushing the push content to target users included in the external system, the message push method further includes:

When the push content is successfully pushed, receive the push success message sent by the target user, store the push content and the push success message sent by the target user, and mark the push success content ;

When the pushing of the push content fails, mark and save the push content that fails to be pushed, and push the push content that fails to be pushed within a preset time interval.

In an exemplary embodiment of the present disclosure, after marking the successfully pushed content, the message pushing method further includes:

Obtaining the unique identifier when the push content is saved, and obtaining the successfully pushed push content corresponding to the unique identifier based on the unique identifier;

Based on the preset time, the pushed content that is successfully pushed is pushed to the target user again.

In an exemplary embodiment of the present disclosure, pushing the push content that failed to push within a preset time interval includes:

Determining a unified push message corresponding to the push content that failed to push;

Obtain a message forwarder corresponding to the unified push message, and use the message forwarder to push the push content that failed to be pushed to the target user again within a preset time interval.

In an exemplary embodiment of the present disclosure, after pushing the push content that fails to be pushed within a preset time interval, the message push method further includes:

After receiving the push success message sent by the target user, stop pushing the push content that failed to be pushed to the target user within a preset time interval.

According to an aspect of the present disclosure, a message push device is provided, including:

The unified push message receiving module is used to receive the unified push message sent by the external system where the target user is located, and analyze the unified push message to obtain the push content, transmission protocol and transmission address included in the unified push message;

A message forwarder determination module, configured to determine the message forwarder corresponding to the target user according to the topic of the message queue corresponding to the unified push message;

A message push module, configured to use the message forwarder to push the push content to the target user according to the transmission protocol and the transmission address, so that the target user can view the push content.

According to one aspect of the present disclosure, a computer-readable storage medium is provided, on which a computer program is stored, and when the computer program is executed by a processor, the message pushing method described in any one of the foregoing is implemented.

According to one aspect of the present disclosure, an electronic device is provided, comprising:

processor; and

a memory for storing executable instructions of the processor;

Wherein, the processor is configured to execute the message pushing method described in any one of the above by executing the executable instructions.

A message push method provided by an embodiment of the present disclosure, on the one hand, receives a unified push message sent by an external system where the target user is located, and analyzes the unified push message to obtain push content included in the unified push message, transmission protocol and transmission address; according to the topic of the message queue corresponding to the unified push message, determine the message forwarder corresponding to the target user; use the message forwarder to send the message according to the transmission protocol and the transmission address The push content is pushed to the target user, so that the target user can view the push content. Since the push content included in the unified push message is pushed to the target user through the message forwarding party, it solves the problem of the prior art. Among them, when accessing different external systems, the notification system needs to be developed again, which reduces the coupling between the target user and the notification system; on the other hand, since different target users correspond to different message forwarders, and through different The message forwarding party pushes messages to different target users, which solves the problem in the prior art that when the merchant notification system fails or the traffic of some target users increases sharply, the timeliness of message push is reduced, and the message push time is improved. time limit.

It is to be understood that both the foregoing general description and the following detailed description are exemplary and explanatory only and are not restrictive of the invention.

Description of drawings

The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the invention and together with the description serve to explain the principles of the invention. Apparently, the drawings in the following description are only some embodiments of the present invention, and those skilled in the art can obtain other drawings according to these drawings without creative efforts.

Fig. 1 schematically shows a flowchart of a message pushing method according to an exemplary embodiment of the present invention.

Fig. 2 schematically shows a block diagram of a message push system according to an exemplary embodiment of the present invention.

Fig. 3 schematically shows a schematic diagram of a topic of a message queue according to an exemplary embodiment of the present invention.

Fig. 4 schematically shows a flow chart of a method for pushing push content to target users using the Jeff protocol according to an exemplary embodiment of the present invention.

Fig. 5 schematically shows a flowchart of a method for establishing a persistent connection according to an exemplary embodiment of the present invention.

Fig. 6 schematically shows a message push method after a target user receives push content according to an exemplary embodiment of the present invention.

Fig. 7 schematically shows a schematic diagram of a scenario of a message pushing method according to an exemplary embodiment of the present invention.

Fig. 8 schematically outputs a flowchart of a message pushing method according to an exemplary embodiment of the present invention.

Fig. 9 schematically shows a block diagram of a message push device according to an exemplary embodiment of the present invention.

Fig. 10 schematically shows an electronic device for implementing the above message pushing method according to an exemplary embodiment of the present invention.

Detailed ways

Example embodiments will now be described more fully with reference to the accompanying drawings. Example embodiments may, however, be embodied in many forms and should not be construed as limited to the examples set forth herein; rather, these embodiments are provided so that this disclosure will be thorough and complete and fully convey the concept of example embodiments to those skilled in the art. The described features, structures, or characteristics may be combined in any suitable manner in one or more embodiments. In the following description, numerous specific details are provided in order to give a thorough understanding of embodiments of the invention. However, those skilled in the art will appreciate that the technical solution of the present invention may be practiced without one or more of the specific details, or other methods, components, devices, steps, etc. may be adopted. In other instances, well-known technical solutions have not been shown or described in detail to avoid obscuring aspects of the invention.

Furthermore, the drawings are merely schematic illustrations of the invention and are not necessarily drawn to scale. The same reference numerals in the drawings denote the same or similar parts, and thus repeated descriptions thereof will be omitted. Some of the block diagrams shown in the drawings are functional entities and do not necessarily correspond to physically or logically separate entities. These functional entities may be implemented in software, or in one or more hardware modules or integrated circuits, or in different network and/or processor means and/or microcontroller means.

The merchant notification system in the prior art requires system development for each connected external system, resulting in serious system coupling; and it does not classify important merchants and ordinary merchants. When the merchant notification system fails, all merchants will be affected. , resulting in low message push timeliness; when transmitting messages, only Hypertext Transfer Protocol is supported, and when the notification system fails, the notification content of the notification failure cannot be recorded, and when the failure is restored, the notification content of the notification failure is lost , the notification cannot be made again.

Based on one or more of the above problems, this exemplary embodiment firstly provides a message push method, which can run on a server, server cluster, or cloud server, etc. Of course, those skilled in the art can also run this message on other platforms according to requirements. The inventive method is not specifically limited in this exemplary embodiment. Referring to Fig. 1, the message push method may include the following steps:

Step S110. Receive the unified push message sent by the external system where the target user is located, and analyze the unified push message to obtain the push content, transmission protocol and transmission address included in the unified push message;

Step S120. Determine the message forwarder corresponding to the target user according to the subject of the message queue corresponding to the unified push message;

Step S130. Using the message forwarder to push the push content to the target user according to the transmission protocol and the transmission address, so that the target user can view the push content.

The above message push method, on the one hand, receives a unified push message sent by an external system where the target user is located, and analyzes the unified push message to obtain the push content, transmission protocol, and transmission address included in the unified push message; The subject of the message queue corresponding to the unified push message, determine the message forwarder corresponding to the target user; use the message forwarder to push the push content to the target user according to the transmission protocol and the transmission address The target user is described so that the target user can view the push content. Since the push content included in the unified push message is pushed to the target user through the message forwarder, it solves the problem in the prior art when accessing different When using an external system, the notification system needs to be redeveloped to reduce the coupling between the target user and the notification system; on the other hand, since different target users correspond to different message forwarders, and different message Target users push messages, which solves the problem in the prior art that the timeliness of message pushes decreases when the merchant notification system fails or the traffic of some target users increases sharply, and improves the timeliness of message pushes.

In the following, each step involved in the message push method of the exemplary embodiment of the present disclosure will be explained and described in detail.

First, the application scenarios and the purpose of the invention of the exemplary embodiments of the present disclosure are explained and described.

Specifically, the exemplary embodiments of the present disclosure can be used in a notification system to determine the data forwarder corresponding to the target user, and push the push content included in the unified push message to the target user through the data forwarder, reducing the number of problems between the target user and the notification system. and when the traffic of some target users suddenly increases sharply, through different data forwarders, the impact on the push timeliness of other target users is reduced.

The exemplary embodiments of the present disclosure are based on the received unified push message. After receiving the unified push message, the unified push message is analyzed to obtain the push content, transmission protocol and transmission address included in the unified push message, and pass the unified The topic of the message queue corresponding to the push message determines the data forwarder corresponding to the target user, which reduces the coupling between the target user and the notification system; secondly, after the data forwarder is determined, the data forwarder is used to transfer data according to the analysis. The protocol and transmission address will push the push content to the target users. When the traffic of some target users suddenly increases, the push will be done through different data forwarders, which will not affect the push timeliness of all target users and improve the efficiency of message push.

Secondly, the message push system involved in the exemplary embodiment of the present disclosure is explained and illustrated. Referring to FIG. 2 , the message push system may include: an external system 210 , a notification system 220 , a notification system front 230 , a target user client 240 and a task platform 250 . Wherein, the external system 210 may include one or more target user clients 240 for sending a unified push message, wherein the unified push message includes push content, transmission protocol, transmission address and access source; the notification system 220, and The external system 210 is connected to the network for receiving the unified push message sent by the external system 210, analyzing the received unified push message, obtaining the push content, transmission protocol, transmission address and access source, and according to the unified push message access The source determines the data sender corresponding to the target user; the notification system front 230, that is, the data forwarder, is connected to the network of the notification system 220, and is used to push the push content to the target user according to the transmission address and transmission protocol; the target user customer Terminal 240 may include common target user clients and important target users (target users with advantages in many aspects such as passenger flow and development potential) clients, which are used to receive push content sent by notification system front 230; task platform 250, It is used to store the successfully pushed push content, the successful push message sent by the target user, and the failed push content.

Hereinafter, step S110-step S130 will be explained and described in conjunction with FIG. 2 .

In step S110, the unified push message sent by the external system where the target user is located is received, and the unified push message is analyzed to obtain the push content, transmission protocol and transmission address included in the unified push message.

Among them, the unified push message can be one or multiple. The data format of the unified push message is defined by the notification system. The push content included in the unified push message sent by the external system is encrypted, and the encryption and decryption algorithm is determined by the The target users included in the external system are determined jointly with the external system, where the encryption and decryption algorithm may be a symmetric encryption algorithm or an asymmetric encryption algorithm, which is not specifically limited in this embodiment. Wherein, the transmission protocol may be hypertext transfer protocol or Jeff protocol, which is not specifically limited in this embodiment.

Specifically, the external system 210 generates a unified push message according to the format of the push message defined by the notification system, and sends the unified push message to the notification system 220, wherein the push content included in the unified push message is encrypted, ensuring that the message For transmission security, when the notification platform 220 receives a unified push message sent by an external system, it analyzes the unified push message to obtain the push content, transmission protocol, transmission address and access source included in the unified push message. The notification system defines the format of the push message and the external system encrypts the notification content, and encapsulates the encrypted push content, transmission address, and transmission protocol into a unified push message, which reduces the coupling between the push system and the target user.

In step S120, a message forwarder corresponding to the target user is determined according to the topic of the message queue corresponding to the unified push message.

Among them, in the queue model of the message queue, any message can only be received by one of the receivers, but in this example embodiment, the relationship between the external system and the message forwarder can be one-to-one, or For one-to-many, in order to ensure that all target users can receive the push content pushed by the external system through the message forwarder, another message model can be adopted: "publish-subscribe" model; the topic of the message queue is the message The topics included in the "publish-subscribe" model; as shown in Figure 3, the publish-subscribe model includes an external system (publisher) 301, a topic, and a message forwarder (subscriber) 302, wherein the topic is used to store the published The message published by the author, and forward the stored message to all message forwarders who subscribe to the topic. The subscription between the message forwarder and the topic can be either a subscription action or a logical copy of the topic during consumption. In each subscription, all subscribers can receive all the messages of the topic.

In this example embodiment, according to the subject of the message queue corresponding to the unified push message, determining the message forwarder corresponding to the target user includes:

Establish a subscription relationship between the message forwarder and the topic; wherein, one message forwarder corresponds to one or more of the target users;

determining the target user corresponding to the unified push message and the topic corresponding to the target user according to the access source included in the unified push message;

According to the topic corresponding to the target user, obtain the message forwarder who subscribes to the topic

Specifically, first, establish a subscription relationship between the message forwarder and the topic, that is, when the topic receives the push content sent by the external system, it can send all the received push content to the message forwarder, that is, the notification system front 230; Then, obtain the access source included in the unified push message, where the access source is used to determine the target user corresponding to the unified push message and the subject corresponding to the target user, that is, according to the access source, it can be determined that the Unified push the target user corresponding to the message and the topic corresponding to the target user; finally, after obtaining the topic corresponding to the target user, all message forwarders who subscribe to the topic can be determined according to the subscription relationship between the topic and the message forwarder .

In step S130, the message forwarding party is used to push the pushed content to the target user according to the transmission protocol and the transmission address, so that the target user can view the pushed content.

Wherein, the transmission protocol may be hypertext transfer protocol or Jeff protocol, which is not specifically limited in this embodiment. When the transmission protocol is the hypertext transfer protocol, whenever a new request is sent, a corresponding new response will be generated. The Jeff protocol uses Netty (a client-side and server-side programming framework based on NIO (New IO, new input and output)) to implement the network protocol stack and asynchronous event communication framework. Netty's NIO model is the Reactor response heap model (Reactor can For a multiplexer with a distribution function), each connection corresponds to a channel; specifically, as shown in Figure 4, when the transmission protocol is the Jeff protocol, according to the transmission protocol and the transmission address, Pushing the push content to the target users included in the external system may include step S410-step S430:

Step S410. Analyzing the transfer address to obtain a domain name corresponding to the transfer address;

Step S420. Query the domain name system according to the domain name, and obtain the IP address corresponding to the domain name;

Step S430. Establish a persistent connection based on the Internet protocol address, and push the pushing content to target users included in the external system through the persistent connection.

Hereinafter, step S410-step S430 will be explained and illustrated. First, analyze the transmission address included in the unified push message to obtain the domain name corresponding to the transmission address; secondly, obtain the IP address (Internet Protocol Address, Internet Protocol) corresponding to the domain name according to the domain name; finally, based on the IP The address establishes a long connection, and pushes the push content to the target user through the long connection. Wherein, as shown in FIG. 5, establishing a persistent connection may include steps S510-step S530:

Step S510. Establishing a channel between the external system and the server;

Step S520. Using the channel to send a heartbeat packet to the server;

Step S530. Send push content to the server, and close the connection when the server does not receive a heartbeat packet for a period of time or the external system actively closes.

Hereinafter, step S510-step S530 will be explained and described. First, establish a connection between the external system and the server. The connection can be a Channel (channel), and the connection can be saved in a Map collection. The unique identifier can be the hash value of the channel, and it will not be disconnected immediately after the connection is successfully established. Open, and multiple message interactions can be performed on the basis of the connection; then, use the channel to send a heartbeat packet to the server, and the heartbeat packet is used to keep the active (in use) state of the channel; finally, when the channel is in the active state, based on This channel sends push content. When the server does not receive a heartbeat packet within a period of time or the external system actively shuts down, the connection is closed. Due to the use of long connections, the Jeff protocol reduces the time-consuming data transmission and reduces the overhead of establishing and closing connections.

When the transmission protocol is the hypertext transfer protocol, pushing the push content to the target users included in the external system may include the following steps: firstly, analyzing the transmission address to obtain the domain name; secondly, obtaining the IP address corresponding to the domain name according to the domain name (Internet Protocol Address, Internet Protocol); Finally, establish a TCP (Transmission Control Protocol, Transmission Control Protocol) connection through a three-way handshake, and push the push content to the target user based on the established TCP connection.

Referring to FIG. 6 , after the target user included in the external system receives the push content, the message push method may further include step S610 and step S620:

Step S610. When the push content is successfully pushed, receive the push success message sent by the target user, store the push content and the push success message sent by the target user, and store the push success message sent by the target user. mark the content;

Step S620. When the push content fails to be pushed, mark and save the push content that fails to be pushed, and push the push content that fails to be pushed within a preset time interval.

Hereinafter, step S610 and step S620 will be explained and described. Specifically, after the message forwarder pushes the push content to the target user, it needs to judge whether the push content is successfully pushed to the target user; when the push content is successfully pushed to the target user, the target user will send a push success message to the notification The system front 230, the notification system front 230 sends the message of successful push to the notification system 220, and the notification system 220 saves the message of successful push and the pushed content of the successful push to the task platform 250, and the content of the successful push Marked as push success; when the push content push fails due to network problems or target user system problems, the data forwarder, that is, the notification system front 230 will asynchronously send the push failure message to the notification system 220, and the notification system will push The failed push content is saved to the task platform, and the push content is marked as push failure, and the task platform 250 will push the content marked as failed again within a preset time interval, wherein the preset time interval can be 1s, 5s, 10s, 20s, 40s, 90s are not specifically limited in this embodiment; the task platform 250 will push the push content marked as failed again within a preset time interval, including:

Determining a unified push message corresponding to the push content that failed to push;

Obtain a message forwarder corresponding to the unified push message, and use the message forwarder to push the push content that failed to be pushed to the target user again within a preset time interval.

Specifically, when the push of the push content fails, that is, when the push system does not receive the push success message sent by the target user within the preset time, the task platform calls back the notification system, and the notification system determines the push content related to the push failure The corresponding unified push message is forwarded asynchronously to the topic corresponding to the target user, so that the push system obtains the unified push message in advance and forwards the unified push message to the target user.

After the failed push content is pushed again, the message push method further includes: after receiving the push success message sent by the target user, stop pushing the push failure to the target user within a preset time interval push content. Specifically, in the process of the task platform 250 calling back the notification system, after the notification system receives the push success message sent by the target user, the notification system sends a push success message to the task platform, and changes the status of the push content from the push failure state to the task platform 250. The modification is that the push is successful, and the task platform stops sending push content to the target user within the preset time interval.

In this example embodiment, after marking and saving the successfully pushed content, the message pushing method further includes:

Obtaining the unique identifier when the push content is saved, and obtaining the successfully pushed push content corresponding to the unique identifier based on the unique identifier;

Based on the preset time, the pushed content that is successfully pushed is pushed to the target user again.

Specifically, when the push content is successfully pushed and the target user needs the push content at a certain time, the push content corresponding to the unique identifier can be obtained in the task platform according to the unique identifier generated when the push content is saved, and according to the user The push content is sent to the target user at a preset time, which improves the efficiency of message push.

Further, there may be multiple data senders included in this example embodiment, each data sender may correspond to one or more target users, the target users may be target merchants, and target users may also be important target users or common targets Users, as shown in FIG. 7 , the target users included in the external system 710 may be ordinary target users 731 and important target users 732, wherein the ordinary target users may include: ordinary target users 1, ordinary target users 2, and ordinary target users 3, Among them, the data forwarding party corresponding to ordinary target user 1, common target user 2, and common target user 3 is 721 notification system pre-1, and the data forwarding party corresponding to important target users is 722 notification system pre-2. When the traffic of target user 732 increases sharply, if the data forwarders of ordinary target users and important target users are fronted by the same notification system, it will affect the push timeliness of all target users, but when different data forwarders are used, it will not It will affect the push timeliness of ordinary target users.

The message push method and the message push system provided by the exemplary embodiments of the present disclosure have at least the following advantages: target users are classified and processed, and merchants of different levels correspond to different data senders. When the system fails or the traffic of some target merchants increases sharply , it will not affect the push timeliness of all target users; on the other hand, when the system fails and the push content fails to be pushed, the failed push content will be saved, so that after the fault is recovered, the failed push content can be pushed again. Pushing improves the push efficiency; on the other hand, the transmission protocol supports the Jeff protocol, which reduces the total time-consuming data transmission and the overhead of connection establishment and closing, and improves the efficiency of data transmission.

Hereinafter, the message pushing method of the exemplary embodiment of the present disclosure will be further explained and illustrated with reference to FIG. 8 . Wherein, the message push method may include the following steps:

Step S800. The external system sends a unified push message to the notification system;

Step S802. The notification system asynchronously pushes the push content included in the unified push message to the front of the notification system;

Step S804. Notify the system to push the pushed content to the target user;

Step S806. The target user pushes the successful push message to the current notification system;

Step S808. The notification system pre-forwards the push success message to the notification system;

Step S810. The notification system saves the successfully pushed content and the successfully pushed message to the task platform;

Step S812. When the notification system does not receive the push success message sent by the target user, send the push failure message to the notification system;

Step S814. Notify the system to save the push content that failed to push to the task platform;

Step S816. The task platform calls back the notification system to push the push content that failed to push again;

Step S818. When the callback of the task platform is successful, the notification system stops sending the unified push message corresponding to the push content that failed to push.

The exemplary embodiment of the present disclosure also provides a message push device, as shown in FIG. in:

The unified push message receiving module 910 is configured to receive the unified push message sent by the external system where the target user is located, and analyze the unified push message, and obtain the push content, transmission protocol and transmission address included in the unified push message;

A message forwarder determining module 920, configured to determine the message forwarder corresponding to the target user according to the subject of the message queue corresponding to the unified push message;

The message push module 930 is configured to use the message forwarder to push the push content to the target user according to the transmission protocol and the transmission address, so that the target user can view the push content.

In an exemplary embodiment of the present disclosure, determining the message forwarder corresponding to the target user according to the topic of the message queue corresponding to the unified push message includes:

Establish a subscription relationship between the message forwarder and the topic;

determining the target user corresponding to the unified push message and the topic corresponding to the target user according to the access source included in the unified push message;

According to the topic corresponding to the target user, the message forwarders subscribing to the topic are obtained.

In an exemplary embodiment of the present disclosure, the transmission protocol includes hypertext transfer protocol or Jeff protocol;

Wherein, when the transmission protocol is the Jeff protocol, according to the transmission protocol and the transmission address, pushing the push content to the target users included in the external system includes:

Analyzing the transfer address to obtain a domain name corresponding to the transfer address;

Querying the Domain Name System according to the domain name to obtain an Internet Protocol address corresponding to the domain name;

A persistent connection is established based on the Internet protocol address, and the push content is pushed to target users included in the external system through the persistent connection.

In an exemplary embodiment of the present disclosure, after pushing the push content to target users included in the external system, the message push method further includes:

When the push content is successfully pushed, receive the push success message sent by the target user, store the push content and the push success message sent by the target user, and mark the push success content ;

When the pushing of the push content fails, mark and save the push content that fails to be pushed, and push the push content that fails to be pushed within a preset time interval.

In an exemplary embodiment of the present disclosure, after marking the successfully pushed content, the message pushing method further includes:

Obtaining the unique identifier when the push content is saved, and obtaining the successfully pushed push content corresponding to the unique identifier based on the unique identifier;

Based on the preset time, the pushed content that is successfully pushed is pushed to the target user again.

In an exemplary embodiment of the present disclosure, pushing the push content that failed to push within a preset time interval includes:

Determining a unified push message corresponding to the push content that failed to push;

Obtain a message forwarder corresponding to the unified push message, and use the message forwarder to push the push content that failed to be pushed to the target user again within a preset time interval.

In an exemplary embodiment of the present disclosure, after pushing the push content that fails to be pushed within a preset time interval, the message push method further includes:

After receiving the push success message sent by the target user, stop pushing the push content that failed to be pushed to the target user within a preset time interval.

The specific details of each module in the above message push device have been described in detail in the corresponding message push method, so details will not be repeated here.

It should be noted that although several modules or units of the device for action execution are mentioned in the above detailed description, this division is not mandatory. Actually, according to the embodiment of the present invention, the features and functions of two or more modules or units described above may be embodied in one module or unit. Conversely, the features and functions of one module or unit described above can be further divided to be embodied by a plurality of modules or units.

In addition, although the steps of the methods of the present invention are described in a particular order in the drawings, this does not require or imply that the steps must be performed in that particular order, or that all illustrated steps must be performed to achieve the desired result. Additionally or alternatively, certain steps may be omitted, multiple steps may be combined into one step for execution, and/or one step may be decomposed into multiple steps for execution, etc.

In an exemplary embodiment of the present invention, an electronic device capable of implementing the above data conversion method is also provided.

Those skilled in the art can understand that various aspects of the present invention can be implemented as systems, methods or program products. Therefore, various aspects of the present invention can be embodied in the following forms, that is: a complete hardware implementation, a complete software implementation (including firmware, microcode, etc.), or a combination of hardware and software implementations, which can be collectively referred to herein as "circuit", "module" or "system".

An electronic device 1000 according to this embodiment of the present invention is described below with reference to FIG. 10 . The electronic device 1000 shown in FIG. 10 is only an example, and should not limit the functions and scope of use of this embodiment of the present invention.

As shown in Figure 10, the electronic device takes the form of a general-purpose computing device. The components of the electronic device may include, but are not limited to: the at least one processing unit 1010 mentioned above, the at least one storage unit 1020 mentioned above, the bus 1030 connecting different system components (including the storage unit 1020 and the processing unit 1010 ), and the display unit 1040.

Wherein, the storage unit stores program codes, and the program codes can be executed by the processing unit 1010, so that the processing unit 1010 executes various exemplary methods according to the present invention described in the "Exemplary Methods" section of this specification. Implementation steps. For example, the processing unit 1010 may perform step S110 as shown in FIG. 1: receive a unified push message sent by an external system where the target user is located, and analyze the unified push message, and obtain the unified push message including push content, transmission protocol, and transmission address; Step S120: Determine the message forwarder corresponding to the target user according to the topic of the message queue corresponding to the unified push message; Step S130: Use the message forwarder to The transmission protocol and the transmission address are used to push the push content to the target user, so that the target user can view the push content.

The storage unit 1020 may include a readable medium in the form of a volatile storage unit, such as a random access storage unit (RAM) 10201 and/or a cache storage unit 10202 , and may further include a read-only storage unit (ROM) 10203 .

The storage unit 1020 may also include a program/utility 10204 having a set (at least one) of program modules 10205, such program modules 10205 including but not limited to: an operating system, one or more application programs, other program modules, and program data, Implementations of networked environments may be included in each or some combination of these examples.

Bus 1030 may represent one or more of several types of bus structures, including a memory cell bus or memory cell controller, a peripheral bus, an accelerated graphics port, a processing unit, or a local area using any of a variety of bus structures. bus.

The electronic device 1000 can also communicate with one or more external devices 1100 (such as keyboards, pointing devices, Bluetooth devices, etc.), and can also communicate with one or more devices that enable the user to interact with the electronic device 1000, and/or communicate with Any device (eg, router, modem, etc.) that enables the electronic device 1000 to communicate with one or more other computing devices. Such communication may occur through input/output (I/O) interface 1050 . Moreover, the electronic device 1000 can also communicate with one or more networks (such as a local area network (LAN), a wide area network (WAN) and/or a public network such as the Internet) through the network adapter 1060 . As shown, the network adapter 1060 communicates with other modules of the electronic device 1000 through the bus 1030 . It should be appreciated that although not shown, other hardware and/or software modules may be used in conjunction with electronic device 1000, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives And data backup storage system, etc.

Through the description of the above implementations, those skilled in the art can easily understand that the example implementations described here can be implemented by software, or by combining software with necessary hardware. Therefore, the technical solution according to the embodiment of the present invention can be embodied in the form of a software product, and the software product can be stored in a non-volatile storage medium (which can be a CD-ROM, U disk, mobile hard disk, etc.) or on a network , including several instructions to make a computing device (which may be a personal computer, server, terminal device, or network device, etc.) execute the method according to the embodiment of the present invention.

In an exemplary embodiment of the present invention, a computer-readable storage medium is also provided, on which a program product capable of implementing the above-mentioned method in this specification is stored. In some possible implementations, various aspects of the present invention can also be implemented in the form of a program product, which includes program code, and when the program product is run on a terminal device, the program code is used to make the The terminal device executes the steps according to various exemplary embodiments of the present invention described in the "Exemplary Method" section above in this specification.

According to the program product for implementing the above method according to the embodiment of the present invention, it may adopt a portable compact disc read-only memory (CD-ROM) and include program codes, and may run on a terminal device such as a personal computer. However, the program product of the present invention is not limited thereto. In this document, a readable storage medium may be any tangible medium containing or storing a program, and the program may be used by or in combination with an instruction execution system, apparatus or device.

The program product may reside on any combination of one or more readable media. The readable medium may be a readable signal medium or a readable storage medium. The readable storage medium may be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, device, or device, or any combination thereof. More specific examples (non-exhaustive list) of readable storage media include: electrical connection with one or more conductors, portable disk, hard disk, random access memory (RAM), read only memory (ROM), erasable programmable read-only memory (EPROM or flash memory), optical fiber, portable compact disk read-only memory (CD-ROM), optical storage devices, magnetic storage devices, or any suitable combination of the foregoing.

A computer readable signal medium may include a data signal carrying readable program code in baseband or as part of a carrier wave. Such propagated data signals may take many forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A readable signal medium may also be any readable medium other than a readable storage medium that can transmit, propagate, or transport a program for use by or in conjunction with an instruction execution system, apparatus, or device.

Program code embodied on a readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.

Program code for carrying out the operations of the present invention may be written in any combination of one or more programming languages, including object-oriented programming languages—such as Java, C++, etc., as well as conventional procedural programming languages. Programming language - such as "C" or a similar programming language. The program code may execute entirely on the user's computing device, partly on the user's device, as a stand-alone software package, partly on the user's computing device and partly on a remote computing device, or entirely on the remote computing device or server to execute. In cases involving a remote computing device, the remote computing device may be connected to the user computing device through any kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computing device (e.g., using an Internet service provider). business to connect via the Internet).

In addition, the above-mentioned figures are only schematic illustrations of the processes included in the method according to the exemplary embodiments of the present invention, and are not intended to be limiting. It is easy to understand that the processes shown in the above figures do not imply or limit the chronological order of these processes. In addition, it is also easy to understand that these processes may be executed synchronously or asynchronously in multiple modules, for example.

Other embodiments of the invention will be readily apparent to those skilled in the art from consideration of the specification and practice of the invention invented herein. This application is intended to cover any modification, use or adaptation of the present invention, these modifications, uses or adaptations follow the general principles of the present invention and include common knowledge or conventional technical means in the technical field not invented by the present invention . The specification and examples are to be considered exemplary only, with the true scope and spirit of the invention indicated by the appended claims.

Claims (9)

1. A message push method, characterized in that, comprising: receiving the unified push message sent by the external system where the target user is located, and analyzing the unified push message, and obtaining the push content, transmission protocol and transmission address included in the unified push message; Establish a subscription relationship between the message forwarder and the topic of the message queue corresponding to the unified push message; determining the target user corresponding to the unified push message and the topic corresponding to the target user according to the access source included in the unified push message; According to the topic corresponding to the target user, obtain the message forwarder who subscribes to the topic; Using the message forwarding party to push the pushed content to the target user according to the transmission protocol and the transmission address, so that the target user can view the pushed content. 2. The message push method according to claim 1, wherein the transmission protocol comprises Hypertext Transfer Protocol or Jeff protocol; Wherein, when the transmission protocol is the Jeff protocol, according to the transmission protocol and the transmission address, pushing the push content to the target users included in the external system includes: Analyzing the transfer address to obtain a domain name corresponding to the transfer address; Querying the Domain Name System according to the domain name to obtain an Internet Protocol address corresponding to the domain name; A persistent connection is established based on the Internet protocol address, and the push content is pushed to target users included in the external system through the persistent connection. 3. The message push method according to claim 2, wherein, after the push content is pushed to the target user included in the external system, the message push method further comprises: When the push content is successfully pushed, receive the push success message sent by the target user, store the push content and the push success message sent by the target user, and mark the push success content ; When the pushing of the push content fails, mark and save the push content that fails to be pushed, and push the push content that fails to be pushed within a preset time interval. 4. The message push method according to claim 3, characterized in that, after marking the successfully pushed content, the message push method further comprises: Obtaining the unique identifier when the push content is saved, and obtaining the successfully pushed push content corresponding to the unique identifier based on the unique identifier; Based on the preset time, the pushed content that is successfully pushed is pushed to the target user again. 5. The message push method according to claim 4, wherein pushing the push content that failed to push within a preset time interval includes: Determining a unified push message corresponding to the push content that failed to push; Obtain a message forwarder corresponding to the unified push message, and use the message forwarder to push the push content that failed to be pushed to the target user again within a preset time interval. 6. The message push method according to claim 5, characterized in that, after pushing the push content that fails to be pushed within a preset time interval, the message push method further comprises: After receiving the push success message sent by the target user, stop pushing the push content that failed to be pushed to the target user within a preset time interval. 7. A message push device, characterized in that it comprises: The unified push message receiving module is used to receive the unified push message sent by the external system where the target user is located, and analyze the unified push message to obtain the push content, transmission protocol and transmission address included in the unified push message; A message forwarder determination module, configured to establish a subscription relationship between the message forwarder and the topic of the message queue corresponding to the unified push message; determining the target user corresponding to the unified push message and the topic corresponding to the target user according to the access source included in the unified push message; According to the topic corresponding to the target user, obtain the message forwarder who subscribes to the topic; A message push module, configured to use the message forwarder to push the push content to the target user according to the transmission protocol and the transmission address, so that the target user can view the push content. 8. A computer-readable storage medium, on which a computer program is stored, wherein, when the computer program is executed by a processor, the message pushing method according to any one of claims 1-6 is implemented. 9. An electronic device, characterized in that it comprises: processor; and a memory for storing executable instructions of the processor; Wherein, the processor is configured to execute the message pushing method according to any one of claims 1-6 by executing the executable instructions.

Images