CN114531481A - Message pushing method and system - Google Patents

Abstract

The present application discloses a message pushing method and system. The method includes: an application server determining the contents of multiple messages to be pushed; the application server determining at least one grouped message corresponding to at least one regional server based on the multiple message contents; Each grouping message is sent to the region server corresponding to the grouping message; for each region server, after receiving the calling request sent by the user terminal, it is determined whether to send the message content in the grouping message to the user terminal based on the calling request. It can solve the problems of high network overhead and low push efficiency during the message push process.

Description

Message push method and system

technical field

The present application generally relates to the technical field of data push, and specifically relates to a message push method and system.

Background technique

The message push technology has played an important role in improving the user viscosity and the number of active users of the application (English: Application; Abbreviation: APP). Push messages from the user terminal.

In the related art, the implementation process of message push is generally as follows: after the user terminal is connected to the application server, the application server opens a thread for the user terminal, and stores the content of the message to be pushed in the message queue, and the user terminal consumes the message by connecting to the thread. The message content in the message queue implements message push.

However, in the process of message push, since the application server can push the message of the next terminal after completing the message push of one user terminal, when the application server faces a large number of cross-region user terminals that need to push the message , which requires constant switching of threads, which will result in high network overhead, low message push efficiency, delay in message push, and users cannot get a good APP experience.

SUMMARY OF THE INVENTION

In view of the above-mentioned defects or deficiencies in the prior art, it is desirable to provide a message push method and system that can reduce network overhead and improve message push efficiency.

In a first aspect, an embodiment of the present application provides a message push method, including:

The application server determines the content of multiple messages to be pushed;

The application server determines at least one grouped message corresponding to the at least one regional server based on the contents of the plurality of messages;

The application server sends each grouped message to the region server corresponding to the grouped message;

For each regional server, after receiving the call request sent by the user terminal, it is determined whether to send the message content in the packet message to the user terminal based on the call request.

In a second aspect, an embodiment of the present application provides a message push system, including an application server, at least one regional server, and at least one user terminal,

an application server, configured to determine the contents of a plurality of messages to be pushed, determine at least one grouped message corresponding to at least one regional server based on the contents of the plurality of messages, and send each grouped message to the regional server corresponding to the grouped message;

The regional server is used for receiving the grouping message sent by the application server. For each region server, after receiving the calling request sent by the user terminal, it determines whether to send the message content in the grouping message to the user terminal based on the calling request.

The technical solutions provided by the embodiments of the present application may include the following beneficial effects:

In the message pushing method and system provided by the embodiments of the present application, the application server determines the content of multiple messages to be pushed; the application server determines at least one grouped message corresponding to at least one regional server based on the content of the multiple messages; the application server sends each grouped message Send to the regional server corresponding to the grouped message; for each regional server, after receiving the invocation request sent by the user terminal, determine whether to send the message content in the grouped message to the user terminal based on the invocation request. Realize the batch push of message content for user terminals in different regions, reduce network overhead, improve the efficiency of message push, and solve the delay phenomenon of message push.

Description of drawings

Other features, objects and advantages of the present application will become more apparent by reading the detailed description of non-limiting embodiments made with reference to the following drawings:

1 is a schematic structural diagram of a message push system provided by an embodiment of the application;

FIG. 2 is a flowchart of a message pushing method provided by an embodiment of the application;

3 is a schematic structural diagram of an application server provided by an embodiment of the application;

4 is a schematic structural diagram of another application server provided by an embodiment of the application;

FIG. 5 is a schematic structural diagram of a regional server provided by an embodiment of the application.

Detailed ways

The present application will be further described in detail below with reference to the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are only used to explain the related invention, but not to limit the invention. In addition, it should be noted that, for the convenience of description, only the parts related to the invention are shown in the drawings.

It should be noted that the embodiments in the present application and the features of the embodiments may be combined with each other in the case of no conflict. The present application will be described in detail below with reference to the accompanying drawings and in conjunction with the embodiments.

FIG. 1 is a schematic structural diagram of a message push system involved in a message push method provided by an embodiment of the present application. As shown in FIG. 1 , the message push system 100 includes: an application server 110 , at least one region server 120 and a server corresponding to each region server 120 . At least one user terminal 130 in the push area, each of the area servers 120 is deployed in a push area, and is used to provide a message push service for the user terminals 130 using the APP in the push area.

The application server 110 is configured to determine the contents of multiple messages to be pushed, determine at least one grouped message corresponding to at least one region server 120 based on the multiple message contents, and send each grouped message to the region corresponding to the grouped message The server 120, wherein the message content is the message content in the third-party server obtained by the application server 120. For example, if the APP is a stock trading APP, the third-party server is a server of a banking system, a server of an exchange system or/and a server of a securities company system.

The region server 120 is configured to receive the grouping message sent by the application server 120. For each region server, after receiving the calling request sent by the user terminal 130, it determines whether to send the message content in the grouping message to the user terminal based on the calling request. 130.

Optionally, a wired or wireless network communication connection is established between the application server 110 and each regional server 120 through a dedicated regional line, and a communication connection is established between the regional server 120 and the user terminal 130 through a wired or wireless network. Wherein, the above-mentioned wireless network or wired network uses standard communication technologies and/or protocols. The network is usually the Internet, but can be any network, including but not limited to Local Area Network (LAN), Metropolitan Area Network (MAN), Wide Area Network (WAN), mobile, wired or wireless network , private network, or any combination of virtual private networks. The application server 110 and the domain server 120 may be one server, or a server cluster composed of several servers, or the application server 110 and the domain server 120 may include one or more virtualization platforms, or the application server 110 and the domain server 120 may include one or more virtualization platforms. The server 120 may be a cloud computing service center. The user terminal 130 may be a device such as a smart phone, a tablet computer, a desktop computer, or an electronic reader.

An embodiment of the present application provides a message push method, which can be applied to the message push system shown in FIG. 1 . As shown in FIG. 2 , the method includes:

Step 201: The application server determines the contents of multiple messages to be pushed.

In this step, the application server may obtain the message content from at least one third-party server connected to the application server, store the message content in the message database, and determine the multiple message contents stored in the database as the multiple messages to be pushed. Message content. The application server may establish a connection with the third-party server through the interface server, so as to obtain the message content in the third-party server from the third-party server through the interface server. Optionally, the application server may acquire the message content in real time from the third-party server, and store the real-time acquired message content in the message database; or, the application server may acquire the message content from the third-party server according to a preset period, and will The content of the messages acquired within each cycle is stored in the message database, where the preset cycle may be determined based on actual needs, which is not limited in this embodiment of the present application.

Optionally, in the process of obtaining the message content by the application server, the message content of the same message attribute may be obtained. In the process of message content, it can be determined whether at least two message contents of the same message attribute are obtained within a preset time period, and if so, the at least two message contents are combined into batch messages, and the batch messages are determined as message contents and stored in the message database , and multiple batch messages are determined as the contents of multiple messages to be pushed. The message attribute may be the type of the message content, the source of the message content, or the function of the message content, and the like.

Step 202: The application server determines at least one grouping message corresponding to at least one regional server based on the contents of the multiple messages.

In this embodiment of the present application, the application server may perform grouping message distribution services for at least one regional server that pushes the region. After receiving the grouping message sent by the application server, each region server may access the region server based on the grouping message. The user terminal provides message push service. The grouping message is determined by the application server based on a message attribute in a subscription message corresponding to each user account in at least one user terminal that accesses each regional server within a preset period. Since the subscription messages of each user account are different in at least one user terminal accessing each regional server, the application server can generate different grouping messages for each regional server. The user account may be a user account logged in an APP carried in the user terminal, the application server may provide a message push service for the APP, and the subscription message is a set of message attributes corresponding to the user account of the message content subscribed by the user. The set period may be determined based on actual needs, which is not limited in this embodiment of the present application.

In this step, for each regional server, the application server may select at least one message content matching the regional server from multiple message contents, and generate a grouped message corresponding to the regional server. The process may be: the application server may For a preset duration, read the subscription information corresponding to each user account in at least one user terminal that accesses the regional server provided in the user information table sent by the regional server of the push region; From the multiple message contents stored in the database, filter out at least one message content corresponding to the message attribute in each subscription message; package the at least one message content and assign a region number corresponding to the regional server to generate a group corresponding to the regional server information. The first preset duration may be determined based on actual needs, which is not limited in this embodiment of the present application. Wherein, the user information table is used to store the corresponding relationship between the terminal identifier of the user terminal and the user account, and/or store the corresponding relationship between the terminal identifier of the user terminal, the user account and the subscription message. It can be understood that if a corresponding relationship between a terminal identifier and a user account is stored in the user information table, it indicates that the user corresponding to the user account has not subscribed to any messages.

It should be noted that, in this embodiment of the present application, each regional server may update the user information table corresponding to the regional server within a preset period, and the update of the user information ratio table may be: deleting the preset period The user information of the user account for internal cancellation, the addition of the user information of the newly registered user account, and the user information of the user account whose information has not been changed are saved, and the updated user information table is sent to the application server for storage, so that the application server can be based on the updated user information. The user information table of the user information table matches the grouping message for the region server. Since the user information is constantly updated, the application server can match the region server with more accurate grouping messages.

The process of adding the user information of the newly registered user account by the regional server in the user information table may be: for any user terminal, the user terminal responds to the user's user account registration operation, and sends a message to the regional server closest to the user terminal. User account registration request, the regional server can complete the user account registration in response to the user account registration request, and obtain the terminal identification and user account of the user terminal, determine the corresponding relationship between the two as user information, or obtain the terminal identification of the user terminal, The corresponding relationship between the user account and the subscription message is determined as user information, and the user information is stored in the user information table of the regional server. Since the user terminal can be connected to the server to perform user account registration and message push according to the principle of proximity, the efficiency of user account registration and message push can be improved, and the user experience can be optimized.

Step 203 , the application server sends each grouping message to the region server corresponding to the grouping message.

In this embodiment of the present application, the application server and each regional server are connected through a regional dedicated line. In this step, the application server may send each grouped message to the corresponding grouped message through the regional dedicated line corresponding to each regional server. The corresponding regional server. The distribution efficiency of grouped messages can be improved, and the phenomenon of message push delay can be solved.

Optionally, the process for the application server to send each grouping message to the region server corresponding to the grouping message may be: for each grouping message, reading the region number in each grouping message, and determining the region server corresponding to the region number. , and send the packet message to the regional server.

It should be noted that, in this embodiment of the present application, after receiving the grouping message sent by the application server, the local area server may feed back information on the successful reception of the grouping message to the application server; If the grouping message sent by the application server is not received, prompt information may be sent to the application server to prompt the application server to send the grouping message to the region server.

Step 204: For each regional server, after receiving the invocation request sent by the user terminal, determine whether to send the message content in the grouped message to the user terminal based on the invocation request.

In this step, for each regional server, the regional server can receive the grouping message sent by the application server, and store at least one message content in the grouping message into the delivery queue; after the user enables the APP in the user terminal, The user terminal can access the regional server and send a calling request to the regional server. After receiving the calling request sent by the user terminal, the regional server can determine whether to send the message content in the packet message to the user terminal based on the calling request.

Optionally, the process of the regional server determining whether to send the message content in the grouping message to the user terminal based on the calling request may be: based on the calling request, judging whether the user terminal is an authorized terminal; message content; send the message content corresponding to the user terminal to the user terminal, so that the user terminal can display the message content; when the domain server determines that the user terminal is an unauthorized terminal, send a prompt message to the user terminal to prompt the user to subscribe to the message . The authorized terminal is a user terminal with the right to receive packet messages, and the regional server accessed by the user terminal may be: a regional service accessed when the user account is registered by using an APP mounted on the user terminal.

Wherein, the calling request sent by the user terminal may include the terminal identification and user account of the user terminal, and the process of determining whether the user terminal is an authorized terminal based on the calling request by the regional server may be: combining the terminal identification and user account with the pre-stored user information At least one group of terminal identifiers in the table is compared with the user account; if the comparison is successful, the message attribute in the subscription message corresponding to the user account is determined; if there is a message content corresponding to the message attribute in the grouped message, the user terminal is determined as Authorized terminal; if the comparison is unsuccessful, or the message content corresponding to the message attribute does not exist in the grouped message, it is determined that the user terminal is an unauthorized terminal.

It can be understood that, in this embodiment of the present application, the process of determining the message content corresponding to the user terminal in the grouping message may be: determining the message content corresponding to the message attribute in the grouping message; determining the message content as corresponding to the user terminal. Message content.

It should be noted that, in this embodiment of the present application, the regional server sends the content of the message corresponding to the user terminal to the user terminal by using the coroutine technology, even if the regional server determines that multiple user terminals accessing the regional server are available The right terminal needs to send message content to the multiple user terminals at the same time, and the message content can also be sent with the lowest network overhead, which reduces the data processing pressure of the regional server and improves the message push efficiency.

Optionally, in this embodiment of the present application, for an authorized terminal, after the local domain server sends the content of the message to the user terminal, it can obtain the terminal identifier of the user terminal, the user account, and the content of the message sent to the user terminal, and generate a message. A push table is sent, and the message push table is sent to the application server, and the application server can analyze the message push result based on the message push table.

For example, for a stock trading APP, it is assumed that the application server S of the stock trading APP establishes connections with the regional server A1 in the A region, the regional server B1 in the B region, and the regional server C1 in the C region through three dedicated communication lines. The server of the exchange system, the server of the bank system, and the server of the securities company system are connected through the interface server, wherein the application server S can obtain a plurality of stock trading market change information from the exchange server in real time, and obtain a plurality of information from the securities company server. For asset distribution data in the trading market, user asset data is obtained from the bank server, stored in the message database, and determined as the content of multiple messages to be pushed.

Further, it is assumed that the application server S determines that 20 user information are stored in the user information table provided by the regional server A1 within 7 days, and it is assumed that there are subscription messages corresponding to 12 user accounts, and the message content corresponding to the message attribute in the subscription message. It provides information on changes in stock trading conditions and asset distribution data in the trading market. Then, the stock trading market change information and the trading market asset distribution data can be read from the message database every 5 minutes to form a grouped message M1 of the regional server A1, and the grouped message M1 can be sent to the regional server A1.

The regional server A1 receives the grouped message M1, and stores the stock trading market change information and the trading market asset distribution data in the delivery queue. After receiving the call request sent by the user terminal, obtain the terminal identifier a1 and the user account c1 in the call request, and compare the terminal identifier a1, the user account c1 and the 20 groups of terminal identifiers and the user information table stored in the regional server A1. The user accounts are compared. Assuming that the comparison is successful, the message attributes in the subscription messages corresponding to the user account c1 are determined, and the information corresponding to the message attributes in the stock trading market change information in the message queue and the asset distribution data in the trading market is determined. The content is stock transaction quotation change information, and the stock transaction quotation change information is determined as the message content corresponding to the user terminal whose terminal identifier is a1, and the stock transaction quotation change information is sent to the user terminal whose terminal identifier is a1.

To sum up, in the message push method provided by the embodiments of the present application, the application server determines the contents of multiple messages to be pushed; the application server determines at least one grouped message corresponding to at least one regional server based on the contents of the multiple messages; Each grouping message is sent to the region server corresponding to the grouping message; for each region server, after receiving the invocation request sent by the user terminal, it determines whether to send the message content in the grouping message to the user terminal based on the invocation request; for each region After receiving the calling request sent by the user terminal, the server determines whether to send the message content in the packet message to the user terminal based on the calling request. Realize the batch push of message content for user terminals in different regions, reduce network overhead, improve the efficiency of message push, and solve the delay phenomenon of message push.

An embodiment of the present application is a message push system. A schematic structural diagram of the message push system is shown in FIG. 1 . The message push system 100 includes: an application server 110 , at least one regional server 120 and at least one user terminal 130 ,

Wherein, as shown in FIG. 3, the application server 110 includes:

The service access module 111 is configured to determine the content of multiple messages to be pushed, and call the push engine module 112 to send the content of the multiple messages to be pushed to the push engine module 112;

The push engine module 112 is configured to receive multiple message contents to be pushed, determine at least one grouped message corresponding to at least one regional server based on the multiple message contents, and send each grouped message to the regional server corresponding to the grouped message .

Optionally, the push engine module 112 is configured to, for each regional server, filter at least one message content matching the regional server from multiple message contents, and generate a grouped message corresponding to the regional server.

Optionally, the push engine module 112 is configured to:

Determine the subscription message corresponding to each user account in at least one user terminal accessing the regional server within the preset period;

Filter out at least one message content corresponding to the message attribute in each subscription message from multiple message contents;

Packing at least one message content and assigning an area number corresponding to the area server to generate a grouping message corresponding to the area server.

Optionally, the push engine module 112 is configured to:

For each grouping message, read the region number in each grouping message;

Determine the region server corresponding to the region number;

Send grouped messages to the geoserver.

Optionally, the service access module 111 is configured to determine whether at least two message contents of the same message attribute are acquired within a preset time period;

If so, combine at least two message contents into a batch message, and determine the batch message as the message contents to be pushed.

Optionally, as shown in FIG. 4 , the application server 110 further includes:

The service access management module 113 is configured to call the service access module to determine the contents of multiple messages to be pushed;

The push link management module 114 is configured to monitor the connection status of each regional dedicated line and the load information of each regional dedicated line;

The push statistics report module 115 is configured to receive a message push table sent by a regional server, and analyze the message push result based on the message push table.

Wherein, for each regional server, as shown in FIG. 5 , the regional server 40 includes:

The regional access point module 121 is configured to receive the grouping message sent by the application server;

The authentication module 122 is configured to, after receiving the call request sent by the user terminal, judge whether the user terminal is an authorized terminal based on the call request, and if so, call the regional access point module 121, and send the judgment result to the regional access point module 121;

The regional access point module 121 is configured to determine the message content corresponding to the user terminal in the packet message, and send the message content corresponding to the user terminal to the user terminal, so that the user terminal can display the message content.

Optionally, the authentication module 122 is configured to:

Compare the terminal identification and user account with at least one group of terminal identification and user account in the pre-stored user information table;

If the comparison is successful, determine the message attribute in the subscription message corresponding to the user account;

If the message content corresponding to the message attribute exists in the grouped message, it is determined that the user terminal is an authorized terminal.

Optionally, the regional access point module 121 is configured to:

Determine the message content corresponding to the message attribute in the packet message;

The message content is determined as the message content corresponding to the user terminal.

It should be noted that, in the embodiments of the present application, module invocation and data interaction are implemented between modules through streaming transmission technology, which can improve data transmission efficiency between modules and improve the timeliness of message push.

To sum up, in the message push system provided by the embodiments of the present application, the application server determines the contents of multiple messages to be pushed; the application server determines at least one grouped message corresponding to at least one regional server based on the contents of the multiple messages; Each grouping message is sent to the region server corresponding to the grouping message; for each region server, after receiving the invocation request sent by the user terminal, it determines whether to send the message content in the grouping message to the user terminal based on the invocation request; for each region After receiving the calling request sent by the user terminal, the server determines whether to send the message content in the packet message to the user terminal based on the calling request. Realize the batch push of message content for user terminals in different regions, reduce network overhead, improve the efficiency of message push, and solve the delay phenomenon of message push.

The above description is only a preferred embodiment of the present application and an illustration of the applied technical principles. Those skilled in the art should understand that the scope of the invention involved in this application is not limited to the technical solution formed by the specific combination of the above-mentioned technical features, and should also cover the above-mentioned technical features without departing from the inventive concept. Other technical solutions formed by any combination of its equivalent features. For example, a technical solution is formed by replacing the above-mentioned features with the technical features disclosed in this application (but not limited to) with similar functions.

Claims (10)

1. A message pushing method, comprising:

the application server determines a plurality of message contents to be pushed;

the application server determines at least one grouping message corresponding to at least one regional server based on the plurality of message contents;

the application server sends each grouping message to a region server corresponding to the grouping message;

and for each region server, after receiving a calling request sent by a user terminal, determining whether to send the message content in the grouping message to the user terminal based on the calling request.

2. The method of claim 1, wherein the determining, by the application server, the at least one group message corresponding to the at least one zone server based on the plurality of message contents comprises:

for each region server, the application server screens at least one message content matched with the region server from the plurality of message contents, and generates a group message corresponding to the region server.

3. The method as claimed in claim 2, wherein the application server filters at least one message content matching the region server from the plurality of message contents, and generates the group message corresponding to the region server, including:

determining a subscription message corresponding to each user account in at least one user terminal accessed to the region server within a preset period;

screening out at least one message content corresponding to the message attribute in each subscription message from the plurality of message contents;

and packaging at least one message content, distributing a region number corresponding to the region server, and generating a packet message corresponding to the region server.

4. The method according to claim 1, wherein the determining whether to send the message content in the packet message to the user terminal based on the invocation request comprises:

judging whether the user terminal is an authorized terminal or not based on the calling request;

if yes, determining message content corresponding to the user terminal in the packet message;

and sending the message content corresponding to the user terminal so as to enable the user terminal to display the message content.

5. The method according to claim 4, wherein the invoking request includes a terminal identifier and a user account of the user terminal, and the determining whether the user terminal is an authorized terminal based on the invoking request includes:

comparing the terminal identification and the user account with at least one group of terminal identification and user account in a pre-stored user information table;

if the comparison is successful, determining the message attribute in the subscription message corresponding to the user account;

and if the message content corresponding to the message attribute exists in the grouped message, determining that the user terminal is an authorized terminal.

6. The method of claim 5, wherein the determining the message content corresponding to the user terminal in the packet message comprises:

determining message content corresponding to the message attribute in the grouped message;

and determining the message content as the message content corresponding to the user terminal.

7. The method of claim 1, wherein the application server is connected to each regional server via a regional dedicated line, and the application server sends each of the group messages to the regional server corresponding to the group message via the regional dedicated line.

8. The method of claim 3, wherein the sending, by the application server, each of the group messages to a zone server corresponding to the group message comprises:

for each group message, reading a region number in each group message;

determining a region server corresponding to the region number;

and sending the grouping message to the region server.

9. The method according to any one of claims 1-8, wherein the determining the message content to be pushed comprises:

determining whether at least two message contents with the same message attribute are acquired within a preset time length;

and if so, combining the at least two message contents into a batch message, and determining the batch message as the message content to be pushed.

10. A message push system, comprising: an application server, at least one zone server and at least one user terminal,

the application server is used for determining a plurality of message contents to be pushed, determining at least one group message corresponding to at least one region server based on the plurality of message contents, and sending each group message to the region server corresponding to the group message;

the region server is used for receiving the grouping message sent by the application server, and for each region server, after receiving a calling request sent by the user terminal, determining whether to send the message content in the grouping message to the user terminal based on the calling request.

Images