CN115277647A - Method and device for processing real-time session message, storage medium and terminal - Google Patents

Abstract

The invention discloses a method and a device for processing a real-time session message, a storage medium and a terminal, relates to the technical field of Internet, and mainly aims to solve the problems of session state redundancy, resource waste and low processing efficiency in real-time session message processing. The method comprises the following steps: when receiving the real-time conversation message, calling all message routing interfaces in a local area range; when the online session state matched with the real-time session message exists in each distributed cache in the local area range through the message routing interface, determining a target message routing interface and a target session connection, wherein the distributed caches correspond to one message routing interface; and calling the target session connection through the target message routing interface, and issuing the real-time session message after message processing through the target session connection.

Description

Method and device for processing real-time conversation messages, storage medium, and terminal

technical field

The invention relates to the technical field of the Internet, in particular to a processing method and device, a storage medium, and a terminal for real-time conversational messages.

Background technique

With the rapid development of Internet technology, in order to meet the needs of fast and low system consumption, the real-time communication of major social applications is also constantly improving. Among them, when social users in the same city conduct real-time conversations, the transmission and generation of messages are usually processed through multiple Internet data centers in the same city to build a system architecture, such as a multi-active architecture, to achieve short-distance and low network loss. deal with.

At present, in the process of processing real-time session messages, a main distributed cache library is usually selected from the distributed databases of multiple Internet data centers. The online session status searched in the corresponding Internet data center, so as to determine whether to distribute real-time session messages in this Internet data center. However, as a main distributed cache library, when a large number of users log in and log out frequently, the state writes surge, and the online session state is redundant, which seriously wastes system resources and affects all user session messages when the network is jittering. processing, which greatly reduces the processing efficiency of real-time conversation messages.

Contents of the invention

In view of this, the present invention provides a processing method, device, storage medium, and terminal for real-time session messages, the main purpose of which is to solve the problem of finding online sessions only from the main distributed cache in the current system architecture constructed by multiple Internet data centers. State redundancy, waste of resources, and low processing efficiency brought about by state.

According to one aspect of the present invention, a method for processing real-time conversation messages is provided, including:

When a real-time session message is received, call all message routing interfaces in the local area, where all message routing interfaces include a local message routing interface and at least one associated message routing interface associated with the local message routing interface;

When through the message routing interface, it is found that there is an online session state matching the real-time session message in each distributed cache in the local area, then determine the target message routing interface and the target session connection, and the distributed cache and A message routing interface corresponds to;

Invoking the target session connection through the target message routing interface, and delivering the processed real-time session message through the target session connection.

Further, before calling all message routing interfaces in the local area, the method further includes:

Searching for all non-local message routing interfaces in the local area, wherein each of the non-local message routing interfaces is matched with a corresponding session connection;

Establish an association relationship between the searched non-local message routing interface and a local message routing interface, and determine at least one associated message routing interface.

Further, before determining the target message routing interface and the target session connection, the method further includes:

Obtain interface parameters in the real-time session message, where the interface parameters include message content, target user information, and a session request identifier;

calling the message routing interface based on the interface parameters, and searching the distributed cache for a session state corresponding to the real-time session message;

If the session state is found and the session state is an online state, it is determined that there is an online session state matching the real-time session message in each distributed cache within the local area.

Further, the determining the target message routing interface and the target session connection includes:

Determine the target distributed cache stored in the session state corresponding to the online session state, and determine the message routing interface corresponding to the target distributed cache as the target message routing interface;

Obtain the connection service configured by the target message routing interface, and determine the session connection created by the connection service as the target session connection.

Further, the calling the target session connection through the target message routing interface, and delivering the processed real-time session message through the target session connection includes:

Configure the interface parameters of the target message routing interface through the message content, target user information, and session request identifier in the real-time session message;

Invoking the target session connection based on the target message routing interface that has completed the interface parameter configuration, and acquiring the real-time session message that completes message processing based on the message content;

Sending the real-time session message to the target user matching the target user information and the session request identifier through the target session connection.

Further, the method also includes:

Detecting whether the multiple call times for calling all the message routing interfaces are greater than a preset call time threshold;

If the invocation time is greater than the preset invocation time threshold, it is determined that the message routing interface corresponding to the invocation time is invocation failure;

When the real-time session message is received again, re-call the message routing interface that failed to call, and query whether there is an online session state that matches the real-time session message in the corresponding distributed cache through the message routing interface that failed to call, to determine whether the message routing interface whose call fails is the target message routing interface.

Further, the method also includes:

When it is detected that the real-time session message after message processing has not been delivered to the target user through the target session connection, the real-time session message that has not been successfully delivered is transferred to the message delivery queue, and the message delivery The sending queue is used to send real-time session messages in a polling manner;

When the polling delivery condition corresponding to the real-time session message in the message delivery queue is triggered, the real-time session message is delivered to the target user.

According to another aspect of the present invention, a real-time conversation message processing device is provided, including:

An interface calling module, configured to call all message routing interfaces in the local area when receiving a real-time session message, where all message routing interfaces include a local message routing interface and at least one message routing interface associated with the local message routing interface Associate message routing interface;

A determining module, configured to determine the target message routing interface and the target session connection when it is found that there is an online session state matching the real-time session message in each distributed cache in the local area through the message routing interface, The above distributed cache corresponds to a message routing interface;

A message delivery module, configured to call the target session connection through the target message routing interface, and deliver the processed real-time session message through the target session connection.

According to yet another aspect of the present invention, a storage medium is provided, wherein at least one executable instruction is stored in the storage medium, and the executable instruction causes a processor to perform operations corresponding to the above-mentioned real-time conversation message processing method.

According to another aspect of the present invention, a terminal is provided, including:

A processor, a memory, a communication interface, and a communication bus, wherein the processor, the memory, and the communication interface complete mutual communication through the communication bus;

The memory is used to store at least one executable instruction, and the executable instruction causes the processor to perform an operation corresponding to the method for processing a real-time conversation message as described in any one of the above.

With the above technical solutions, the technical solutions provided by the embodiments of the present invention have at least the following advantages:

The present invention provides a processing method and device, a storage medium, and a terminal for a real-time session message. Compared with the prior art, the embodiment of the present invention calls all message routes within the local area when a real-time session message is received. interface, all the message routing interfaces include a local message routing interface and at least one associated message routing interface associated with the local message routing interface; If there is an online session state matching the real-time session message, then determine a target message routing interface and a target session connection, the distributed cache corresponds to a message routing interface; call the target session connection through the target message routing interface, and send the processed real-time session message through the target session connection. In the system architecture built in multiple Internet data centers, the online session status is searched from various distributed caches in the local area, and the message content in the session request is delivered to the target user in the local area. Since there is no need to update the session states in each distributed cache to the main distributed cache, the redundancy of online session states and the waste of resources are avoided. Since there is no need to search the online session state across Internet data centers, the influence of factors such as network jitter is avoided, and the processing efficiency of real-time session messages is improved.

The above description is only an overview of the technical solution of the present invention. In order to better understand the technical means of the present invention, it can be implemented according to the contents of the description, and in order to make the above and other purposes, features and advantages of the present invention more obvious and understandable , the specific embodiments of the present invention are enumerated below.

Description of drawings

Various other advantages and benefits will become apparent to those of ordinary skill in the art upon reading the following detailed description of the preferred embodiment. The drawings are only for the purpose of illustrating a preferred embodiment and are not to be considered as limiting the invention. Also throughout the drawings, the same reference numerals are used to designate the same parts. In the attached picture:

FIG. 1 shows a flowchart of a method for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 2 shows a flowchart of another method for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 3 shows a flow chart of another method for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 4 shows a flowchart of another method for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 5 shows a flow chart of another method for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 6 shows a schematic structural diagram of an apparatus for processing real-time conversation messages provided by an embodiment of the present invention;

FIG. 7 shows a schematic structural diagram of a terminal provided by an embodiment of the present invention.

Detailed ways

Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. Although exemplary embodiments of the present disclosure are shown in the drawings, it should be understood that the present disclosure may be embodied in various forms and should not be limited by the embodiments set forth herein. Rather, these embodiments are provided for more thorough understanding of the present disclosure and to fully convey the scope of the present disclosure to those skilled in the art.

The embodiment of the present invention provides a method for processing real-time conversation messages, as shown in Figure 1, the method includes:

101. When a real-time session message is received, call all message routing interfaces within the local area;

In the embodiment of the present invention, when the current execution end receives the user's real-time session message, it calls all the message routing interfaces within the local area where the current execution end is located, and the all message routing interfaces include the local message routing interface and the At least one associated message routing interface associated with the local message routing interface; the local area can be used to represent the geographically located area, such as the urban area; it can also be used to represent a network composed of multiple interconnected Internet data centers The scope, such as the scope of the network system of the multi-active architecture, is not specifically limited in this embodiment of the present invention. The message routing is a soft routing for determining the next hop address of the message, which has high stability.

It should be noted that since there are multiple execution ends in the local area, when performing data communication between multiple execution ends, the work efficiency of the message routing interface can be improved by calling all the message routing interfaces in the local area at the same time .

102. When it is found through the message routing interface that there is an online session state matching the real-time session message in each distributed cache in the local area, determine the target message routing interface and the target session connection;

In the embodiment of the present invention, the current execution end performs online session query on each distributed cache in the local area. The message routing interface is identified as the target message routing interface. Since the message routing interface is matched with a corresponding session connection, the target session connection is obtained through the determined target message routing interface. The session connection is a physical link established by the server process for the user to participate in the session. Once the user establishes a connection, a server process is created and processes the user's session request. When the user disconnects, the server process for the user to participate in the session just terminate.

It should be noted that each message routing interface in the local area corresponds to a distributed cache, which is used to store the user's session state information. When the user is in the login state, the user's online session state is written into the corresponding distributed cache. In the cache, when the user is in the logout state, the user's online session state is removed from the distributed cache.

103. Call the target session connection through the target message routing interface, and deliver the processed real-time session message through the target session connection.

In the embodiment of the present invention, the current execution end invokes the target session connection of the target user through the found target message routing interface, and delivers the processed real-time session message to the target user through the target session connection. Message processing is used to represent the process of storing and verifying messages sent by users. During verification, it can be verified whether the message sender and the target user are friends, whether the sender is a group member, or whether the sender is in the group. Forbidden, no specific limitation is made in the embodiment of the present invention. Only messages that pass the verification during message processing can be sent through the target session connection.

In another embodiment of the present invention, for further limitation and description, as shown in FIG. 2, before calling all message routing interfaces in the local area in the step, the method further includes:

201. Search for all non-local message routing interfaces in the local area;

In the embodiment of the present invention, in order to find the session state of the target user on a non-local data center or server, it is necessary to first establish a network system within a local area. The current execution end needs to search for all non-local message routing interfaces in the local area, and each non-local message routing interface is matched with a corresponding session connection; the session connection here is the physical link established by the server process where the non-local user participates in the session , once the user establishes a connection, a server process is created and processes the user's session request. When the user disconnects, the server process in which the user participates in the session is terminated, that is, the terminated session service process cannot be uploaded or downloaded. Send the content of the conversation message.

202. Establish an association relationship between the searched non-local message routing interface and a local message routing interface, and determine at least one associated message routing interface.

In the embodiment of the present invention, the current execution end associates the searched non-local message routing interface with the local message routing interface, and the non-local message routing interface associated with the local message routing interface is called an associated message routing interface. The number of associated message routing interfaces in the local area is greater than or equal to one, that is, information communication between local message routing and non-local message routing is realized.

In another embodiment of the present invention, for further limitation and description, as shown in FIG. 3, before the step of determining the target message routing interface and the target session connection, the method further includes:

301. Acquire interface parameters in the real-time session message;

In the embodiment of the present invention, in order to match a target user within a local area, it is necessary to process the real-time session message sent by the local user first. The current execution end needs to obtain the interface parameters in the real-time session message sent by the local user, and the interface parameters include message content, target user information, and session request identifier. The content of the message is the specific dialogue content that the local user needs to send to the target user. The target user information includes target user id, target user online information, etc., which are not specifically limited in this embodiment of the present invention. The target user information may also be stored in the form of a list during message processing, which is not specifically limited in this embodiment of the present invention. The session request identifier is used to mark the identifier of the Internet data center or server where the local user (that is, the session sender) is located.

302. Call the message routing interface based on the interface parameter, and search the distributed cache for a session state corresponding to the real-time session message;

In the embodiment of the present invention, after the current execution end obtains the interface parameters, it invokes all the message routing interfaces in the local area based on the interface parameters, and searches the real-time session message corresponding to the real-time session message request from the distributed cache corresponding to the message routing interface. user session state.

303. If the session state is found and the session state is an online state, determine that an online session state matching the real-time session message exists in each distributed cache within the local area.

In the embodiment of the present invention, in order to match the target user in the local area, it is necessary to first match the online session status in the local area. If the current execution end finds the user session status and the corresponding user session status is online, it can determine that the online session status matching the real-time session message is found in each distributed cache within the local area. Finding the matching online session state is the premise of determining the target message routing interface and the target session connection. The current execution end will find the message routing interface corresponding to the distributed cache where the matching online session state is located as the target message routing interface, and from Find the session connection corresponding to the target user in the distributed cache where the matching online session state is located, and set it as the target session connection.

In another embodiment of the present invention, for further definition and description, the step of determining the target message routing interface and the target session connection includes:

Determine the target distributed cache stored in the session state corresponding to the online session state, and determine the message routing interface corresponding to the target distributed cache as the target message routing interface;

Obtain the connection service configured by the target message routing interface, and determine the session connection created by the connection service as the target session connection.

In the embodiment of the present invention, in order to update and store the session state, a distributed cache is set; in order to create a session connection between users, a connection service is configured in the message routing interface. A connection service is a form of service that establishes a network connection. After determining the online session state, the current execution end determines the distributed cache corresponding to the online session state as the target distributed cache, and determines the message routing interface corresponding to the target distributed cache as the target message routing interface. After obtaining the target message routing interface, the current execution end needs to obtain the connection service configured by the target message routing interface, and find the target session connection corresponding to the target user through the connection service.

In another embodiment of the present invention, for further limitation and description, as shown in FIG. 4 , the step is to call the target session connection through the target message routing interface, and pass the processed real-time session message through The delivery of the target session connection includes:

401. Configure the interface parameters of the target message routing interface according to the message content, target user information, and session request identifier in the real-time session message;

In the embodiment of the present invention, in order to accurately send the processed message to the target client, parameter configuration needs to be performed on the target message routing interface to realize message communication between the target message routing and the local message routing of the current execution end. The current execution end configures the interface parameters of the target message routing interface through the message content in the real-time session message, the target user information, and the session request identifier. The content of the message is the specific dialogue content that the local user needs to send to the target user. The target user information includes target user id, target user online information, etc., which are not specifically limited in this embodiment of the present invention. The target user information may also be stored in the form of a list during message processing, which is not specifically limited in this embodiment of the present invention. The session request identifier is used to mark the identifier of the Internet data center or server where the local user (that is, the session sender) is located.

402. Invoke the target session connection based on the target message routing interface that has completed the interface parameter configuration, and acquire the real-time session message that completes message processing based on the message content;

403. Deliver the real-time session message to a target user matching the target user information and the session request identifier through the target session connection.

In the embodiment of the present invention, the current execution end invokes the target session connection corresponding to the target user at the target message routing interface where the interface parameter configuration is completed. After calling the target session connection, the current execution end obtains the real-time session processed by the message information. Message processing is used to represent the process of storing and verifying messages sent by users. During verification, it can be verified whether the message sender and the target user are friends, whether the sender is a group member, or whether the sender is in the group. Forbidden, no specific limitation is made in the embodiment of the present invention. Only messages that pass the verification during message processing can be sent through the target session connection.

After obtaining the processed real-time session message, the current execution end sends the real-time session message to the corresponding target user matching both the target user information and the session request identifier through the target session connection. The target user information includes, but is not limited to, the target user id, the online information of the target user, etc., which are not specifically limited in this embodiment of the present invention. The session request identifier is used to mark the identifier of the Internet data center or server where the local user (that is, the session sender) is located.

In another embodiment of the present invention, for further definition and description, as shown in FIG. 5, the method further includes:

501. Detect whether multiple call times for calling all the message routing interfaces are greater than a preset call time threshold;

502. If the invocation time is greater than the preset invocation time threshold, determine that the message routing interface corresponding to the invocation time is invocation failure;

In the embodiment of the present invention, in order to deal with the call timeout situation, a call time threshold is preset. The current execution end detects multiple call times of all message routing interfaces, and compares the detected multiple call times with a preset call time threshold. When the invocation time is greater than the preset invocation time threshold among the multiple invocation times, the message routing interface corresponding to the invocation time greater than the preset invocation time is identified as the message routing interface that fails to be invoked. The preset call time is a time value set manually, which may be 2 seconds, 3 seconds, 4 seconds, etc., which is not specifically limited in the embodiment of the present invention.

503. When the real-time session message is received again, re-call the message routing interface that failed to call, and query whether there is an online session that matches the real-time session message in the corresponding distributed cache through the message routing interface that failed to call Status, to determine whether the message routing interface where the call fails is the target message routing interface.

In the embodiment of the present invention, in order to improve the efficiency of calling the message routing interface and save the processing time of the real-time session message, when the current execution end receives the real-time session message again, it will not repeatedly call the successfully called message routing interface, and only for calling Failed message routes are called repeatedly. After the call is successful, check whether there is an online session status that matches the real-time session message in the corresponding distributed cache by calling the failed message route interface. If there is an online session status that matches the real-time session message session state, the corresponding message routing interface whose call fails is determined as the target message routing interface. The current execution end invokes the target session connection through the target message routing interface, and delivers the processed real-time session message to the corresponding target user through the target session connection.

In another embodiment of the present invention, for further definition and description, the method further includes:

When it is detected that the real-time session message after message processing has not been delivered to the target user through the target session connection, the real-time session message that has not been successfully delivered is transferred to the message delivery queue;

When the polling delivery condition corresponding to the real-time session message in the message delivery queue is triggered, the real-time session message is delivered to the target user.

In the embodiment of the present invention, in order to deal with the problem of message delivery failure, a message delivery queue is set up to process the real-time session messages of message delivery failure, so as to ensure that it can also be realized under the influence of factors such as network disconnection or power failure. Delivery of real-time session messages. The current execution end needs to detect the delivery of real-time session messages. When it detects that the processed real-time session messages have not been delivered to the target user through the target session connection, the current execution end needs to send the real-time session messages that have not been delivered successfully The message is dumped to the preset message queue. The message sending queue is for sending real-time session messages in a polling manner, and the polling method is a manner of repeatedly executing a certain operation at a certain time interval. In the embodiment of the present invention, the current execution end first sets a time interval as the condition for polling delivery, such as 5 seconds, 7 seconds, etc., which is not specifically limited in the embodiment of the present invention. When the polling delivery condition corresponding to the real-time session message in the message queue is triggered, the real-time session message is delivered to the target user.

The embodiment of the present invention provides a processing method for a real-time session message. Compared with the prior art, the embodiment of the present invention invokes all message routing interfaces within the local area when a real-time session message is received, and all of the The message routing interface includes a local message routing interface and at least one associated message routing interface associated with the local message routing interface; If the online session state of the session message matches, the target message routing interface and the target session connection are determined, and the distributed cache corresponds to a message routing interface; the target session connection is called through the target message routing interface, and the message is processed The real-time session message is delivered through the target session connection. In the system architecture built in multiple Internet data centers, the online session status is searched from various distributed caches in the local area, and the message content in the session request is delivered to the target user in the local area. Since there is no need to update the session states in each distributed cache to the main distributed cache, the redundancy of online session states and the waste of resources are avoided. Since there is no need to search the online session state across Internet data centers, the influence of factors such as network jitter is avoided, and the processing efficiency of real-time session messages is improved.

Further, as an implementation of the method shown in FIG. 1 above, an embodiment of the present invention provides a device for processing real-time conversation messages. As shown in FIG. 6 , the device includes:

The interface calling module 61 is configured to call all the message routing interfaces in the local area when receiving the real-time session message, and the all message routing interfaces include the local message routing interface and at least the message routing interface associated with the local message routing interface. an associated message routing interface;

The determination module 62 is configured to determine the target message routing interface and the target session connection when it is found that there is an online session state matching the real-time session message in each distributed cache in the local area through the message routing interface, The distributed cache corresponds to a message routing interface;

The message delivery module 63 is configured to invoke the target session connection through the target message routing interface, and deliver the processed real-time session message through the target session connection.

Further, the device also includes:

An interface search module, configured to search for all non-local message routing interfaces in the local area, wherein each of the non-local message routing interfaces is matched with a corresponding session connection;

An associating module, configured to establish an association relationship between the searched non-local message routing interface and a local message routing interface, and determine at least one associated message routing interface.

Further, the device also includes:

A parameter acquisition module, configured to acquire interface parameters in the real-time session message, where the interface parameters include message content, target user information, and session request identifier;

A state lookup module, configured to call the message routing interface based on the interface parameters, and look up the session state corresponding to the real-time session message from the distributed cache;

The matching determining module is configured to determine that if the session state is found and the session state is an online state, it is found that there is an online session state matching the real-time session message in each distributed cache within the local area.

Further, the determining module 62 includes:

A target message routing interface determining unit, configured to determine the target distributed cache stored in the session state corresponding to the online session state, and determine the message routing interface corresponding to the target distributed cache as the target message routing interface;

The target session connection determining unit is configured to acquire the connection service configured by the target message routing interface, and determine the session connection created by the connection service as the target session connection.

Further, the message sending module 63 includes:

An interface parameter configuration unit, configured to configure the interface parameters of the target message routing interface through the message content, target user information, and session request identifier in the real-time session message;

A message obtaining unit, configured to call a target session connection based on the target message routing interface that has completed the configuration of the interface parameters, and obtain the real-time session message that completes message processing based on the message content;

A sending unit, configured to send the real-time session message to a target user matching the target user information and the session request identifier through the target session connection.

Further, the device also includes:

A calling time detection module, configured to detect whether multiple calling times for calling all the message routing interfaces are greater than a preset calling time threshold;

An invocation failure determination module, configured to determine that the message routing interface corresponding to the invocation time is an invocation failure if the invocation time is greater than a preset invocation time threshold;

The target message routing interface re-determining module is used to re-call the failed message routing interface when the real-time session message is received again, and query the corresponding distributed cache by calling the failed message routing interface. The online session status matched with the real-time session message to determine whether the message routing interface whose call failed is the target message routing interface.

Further, the device also includes:

Sending an abnormal preprocessing module, for when it is detected that the real-time session message after message processing has not been sent to the target user through the target session connection, then the real-time session message that has not been delivered successfully is transferred to the message In the sending queue, the sending message queue is to execute the sending of real-time session messages in a polling manner;

The message re-delivery module is configured to deliver the real-time session message to the target user when the polling delivery condition corresponding to the real-time session message in the message delivery queue is triggered.

The embodiment of the present invention provides a real-time session message processing device. Compared with the prior art, the embodiment of the present invention invokes all message routing interfaces in the local area when receiving a real-time session message, and all The message routing interface includes a local message routing interface and at least one associated message routing interface associated with the local message routing interface; If the online session state of the session message matches, the target message routing interface and the target session connection are determined, and the distributed cache corresponds to a message routing interface; the target session connection is called through the target message routing interface, and the message is processed The real-time session message is delivered through the target session connection. In the system architecture built in multiple Internet data centers, the online session status is searched from various distributed caches in the local area, and the message content in the session request is delivered to the target user in the local area. Since there is no need to update the session states in each distributed cache to the main distributed cache, the redundancy of online session states and the waste of resources are avoided. Since there is no need to search the online session state across Internet data centers, the influence of factors such as network jitter is avoided, and the processing efficiency of real-time session messages is improved.

According to one embodiment of the present invention, a storage medium is provided, the storage medium stores at least one executable instruction, and the computer-executable instruction can execute the real-time session processing method in any of the above method embodiments.

Fig. 7 shows a schematic structural diagram of a terminal provided according to an embodiment of the present invention, and the specific embodiment of the present invention does not limit the specific implementation of computer equipment.

As shown in FIG. 7 , the computer device may include: a processor (processor) 702 , a communication interface (Communications Interface) 704 , a memory (memory) 706 , and a communication bus 708 .

Wherein: the processor 702 , the communication interface 704 , and the memory 706 communicate with each other through the communication bus 708 .

The communication interface 704 is configured to communicate with network elements of other devices such as clients or other servers.

The processor 702 is configured to execute the program 710, specifically, may execute relevant steps in the above-mentioned embodiment of the method for processing public service data.

Specifically, the program 710 may include program codes including computer operation instructions.

The processor 702 may be a central processing unit CPU, or an Application Specific Integrated Circuit (ASIC), or one or more integrated circuits configured to implement the embodiments of the present invention. The one or more processors included in the computer device may be of the same type, such as one or more CPUs, or may be different types of processors, such as one or more CPUs and one or more ASICs.

The memory 706 is used to store the program 710 . The memory 706 may include a high-speed RAM memory, and may also include a non-volatile memory (non-volatile memory), such as at least one disk memory.

The program 710 can specifically be used to make the processor 702 perform the following operations:

When a real-time session message is received, call all message routing interfaces in the local area, where all message routing interfaces include a local message routing interface and at least one associated message routing interface associated with the local message routing interface;

When through the message routing interface, it is found that there is an online session state matching the real-time session message in each distributed cache in the local area, then determine the target message routing interface and the target session connection, and the distributed cache and A message routing interface corresponds to;

Invoking the target session connection through the target message routing interface, and delivering the processed real-time session message through the target session connection.

Obviously, those skilled in the art should understand that each module or each step of the above-mentioned present invention can be realized by a general-purpose computing device, and they can be concentrated on a single computing device, or distributed in a network formed by multiple computing devices Alternatively, they may be implemented in program code executable by a computing device so that they may be stored in a storage device to be executed by a computing device, and in some cases in an order different from that shown here The steps shown or described are carried out, or they are separately fabricated into individual integrated circuit modules, or multiple modules or steps among them are fabricated into a single integrated circuit module for implementation. As such, the present invention is not limited to any specific combination of hardware and software.

The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the present invention. For those skilled in the art, the present invention may have various modifications and changes. Any modifications, equivalent replacements, improvements, etc. made within the spirit and principles of the present invention shall be included within the protection scope of the present invention.

Claims (10)

1. A method for processing a real-time session message, comprising:

when a real-time session message is received, all message routing interfaces in a local area range are called, wherein all message routing interfaces comprise a local message routing interface and at least one associated message routing interface associated with the local message routing interface;

when the online session state matched with the real-time session message exists in each distributed cache in the local area range through the message routing interface, determining a target message routing interface and a target session connection, wherein the distributed caches correspond to one message routing interface;

and calling the target session connection through the target message routing interface, and issuing the real-time session message after message processing through the target session connection.

2. The method of claim 1, wherein prior to said invoking all message routing interfaces within a local area scope, the method further comprises:

searching all non-local message routing interfaces of a local area range, wherein each non-local message routing interface is matched with corresponding session connection;

and establishing an association relation between the searched non-local message routing interface and a local message routing interface, and determining at least one associated message routing interface.

3. The method of claim 1, wherein prior to determining the target message routing interface and the target session connection, the method further comprises:

acquiring interface parameters in the real-time session message, wherein the interface parameters comprise message content, target user information and session request identification;

calling the message routing interface based on the interface parameters, and searching a session state corresponding to the real-time session message from the distributed cache;

and if the session state is found and the session state is an online state, determining that the online session state matched with the real-time session message exists in each distributed cache in the local area range.

4. The method of claim 3, wherein determining the target message routing interface and the target session connection comprises:

determining a target distributed cache stored in a session state corresponding to the online session state, and determining a message routing interface corresponding to the target distributed cache as a target message routing interface;

and acquiring the connection service configured by the target message routing interface, and determining the session connection established by the connection service as the target session connection.

5. The method of claim 1, wherein the invoking the target session connection through the target message routing interface and issuing the message-processed real-time session message through the target session connection comprises:

configuring interface parameters of the target message routing interface through message content, target user information and a session request identifier in the real-time session message;

calling a target session connection based on a target message routing interface which completes the interface parameter configuration, and acquiring the real-time session message which completes message processing based on the message content;

and sending the real-time session message to a target user matched with the target user information and the session request identifier through the target session connection.

6. The method of claim 1, further comprising:

detecting whether a plurality of calling times for calling all the message routing interfaces are greater than a preset calling time threshold value or not;

if the calling time is larger than a preset calling time threshold, determining that a message routing interface corresponding to the calling time is calling failure;

when the real-time session message is received again, the message routing interface which is failed to call is called again, whether an online session state matched with the real-time session message exists in the corresponding distributed cache is inquired through the message routing interface which is failed to call, and whether the message routing interface which is failed to call is a target message routing interface is determined.

7. The method according to any one of claims 1-6, further comprising:

when the real-time session message processed by the message is detected not to be issued to a target user through the target session connection, the real-time session message which is not successfully issued is transferred to a message issuing queue, and the message issuing queue executes the issuing of the real-time session message according to a polling mode;

and when the polling issuing condition corresponding to the real-time session message in the message issuing queue is triggered, issuing the real-time session message to a target user.

8. An apparatus for processing a real-time conversation message, comprising:

the interface calling module is used for calling all message routing interfaces in a local area range when a real-time session message is received, wherein the all message routing interfaces comprise a local message routing interface and at least one associated message routing interface associated with the local message routing interface;

a determining module, configured to determine a target message routing interface and a target session connection when an online session state matching the real-time session message exists in each distributed cache in the local area range through the message routing interface, where the distributed cache corresponds to one message routing interface;

and the message issuing module is used for calling the target session connection through the target message routing interface and issuing the real-time session message after message processing through the target session connection.

9. A storage medium, wherein at least one executable software is stored in the storage medium, and the executable software performs an operation corresponding to the processing method of the real-time conversation message according to any one of claims 1 to 7.

10. A terminal comprises a processor, a memory, a communication interface and a communication bus, wherein the processor, the memory and the communication interface are communicated with each other through the communication bus;

the memory is used for storing at least one executable instruction, and the executable instruction causes the processor to execute the operation corresponding to the processing method of the real-time conversation message according to any one of claims 1-7.

Images