CN106899651B

CN106899651B - Communication processing method, system and network communication system

Info

Publication number: CN106899651B
Application number: CN201610520652.7A
Authority: CN
Inventors: 华洁
Original assignee: Alibaba Group Holding Ltd
Current assignee: Advanced New Technologies Co Ltd; Advantageous New Technologies Co Ltd
Priority date: 2016-07-04
Filing date: 2016-07-04
Publication date: 2020-06-30
Anticipated expiration: 2036-07-04
Also published as: CN106899651A

Abstract

The application discloses a communication processing method, a system and a network communication system, wherein the communication processing system comprises a first processing system and a second processing system, and the first processing system at least comprises a server; the second processing system comprises at least one server; a first server in the first processing system acquires the latest data information of a data identifier of which the data information is updated; actively pushing the latest data information of different data identifications to the second processing system; and when receiving the latest data information of different data identifications, a second server in the second processing system searches for the user identification corresponding to each data identification and actively pushes the latest data information of the data identification to the client corresponding to the user identification. The embodiment of the application ensures the accuracy of the data information and improves the system performance.

Description

Communication processing method, system and network communication system

Technical Field

The present application belongs to the field of communication technologies, and in particular, to a communication processing method, system and network communication system.

Background

In a current network communication structure, the network communication structure mainly comprises a client and a network, and after the client establishes connection with the network, real-time communication needs to be performed, so that the client can obtain latest data information corresponding to a concerned data identifier and provide the latest data information to a user.

In order to obtain the latest data information, in a communication mode in the prior art, a client performs a timing query, that is, the client sends a data query request to a network at a certain interval, and the network feeds back data information concerned by a user to the client according to the data query request.

However, since there are many clients establishing connection with the network, data information concerned by different users is not the same, and update frequency of different data information is also different, the accuracy of the acquired data information is affected if the interval time is long by using a timing query method. If the interval time is short, the client frequently makes queries, and particularly when a large number of clients exist, the processing pressure of the system is increased, and the performance of the system is affected.

Disclosure of Invention

In view of this, the present application provides a communication processing method, a communication processing system, and a network communication system, which not only ensure the accuracy of data information acquisition, but also reduce the influence on the system performance.

In order to solve the above technical problem, a first aspect of the present application provides a communication processing system, including a first processing system and a second processing system, where the first processing system includes at least one server; the second processing system comprises at least one server;

a first server in the first processing system acquires the latest data information of a data identifier of which the data information is updated; actively pushing the latest data information of different data identifications to the second processing system;

and when receiving the latest data information of different data identifications, a second server in the second processing system searches for the user identification corresponding to each data identification and actively pushes the latest data information of the data identification to the client corresponding to the user identification.

Preferably, a plurality of message middleware systems are further included; each message middleware system comprises at least one message middleware server;

the step of actively pushing the latest data information of different data identifiers to the second processing system by the first server specifically includes:

the first server actively pushes the latest data information of different data identifications to the corresponding message middleware system, and the message middleware server in the message middleware system actively pushes the latest data information of the received data identifications to the second processing system.

Preferably, the system further comprises a service processing system, wherein the service processing system comprises at least one service server;

the actively pushing, by the first server, the latest data information of the data identifier to the second processing system specifically includes:

the first server actively pushes the latest data information of different data identifications to the service processing system; and after the service server in the service processing system performs service processing on the latest data information of different data identifications, actively pushing the latest data information to the first processing system.

the first server actively pushes the latest data information of different data identifications to the corresponding message middleware systems, and the method comprises the following steps:

the first server actively pushes the latest data information of different data identifications to the service processing system; and after the service server in the service processing system performs service processing on the latest data information of different data identifications, the latest data information is actively pushed to the corresponding message middleware systems.

Preferably, the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated is specifically:

the first server inquires the data identification of the updated data information from different data servers and obtains the latest data information of the different data identifications of the updated data information.

Preferably, the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated specifically includes:

the first server receives the latest data information of the data identifier updated by the data information actively pushed by different data servers.

Preferably, each server in the second processing system stores a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier;

the second server is specifically configured to:

the second server searches the user identification of the login user corresponding to each data identification and the link channel identification corresponding to the user identification; and triggering a third server corresponding to the link channel identifier in the second processing system according to the link channel identifier to send the data identifier to the client from the link channel.

A second aspect of the present application provides a communication processing system, including a first gateway system and a second gateway system, where the first gateway system includes at least one gateway server, and the second gateway system includes at least one gateway server;

a first gateway server in the first gateway system acquires latest stock data of stock labels for updating the stock data from a dealer server; the latest stock information of different stock identifications is actively pushed to the second gateway system;

and when receiving the latest stock data of different stock identifications, a second gateway server in the second gateway system searches the user identification corresponding to each stock identification and sends the latest data information of the stock identifications to the stock client corresponding to the user identification.

the step of actively pushing the latest stock data of different stock identifications to the second processing system by the first gateway server specifically comprises the following steps:

the first gateway server actively pushes the latest stock data of different stock identifications to the corresponding message middleware system, and the message middleware system actively pushes the latest stock data of the received stock identifications to the second processing system.

the first gateway server actively pushes the latest stock data of different stock identifications to the corresponding message middleware systems, and the method comprises the following steps:

the first gateway server actively pushes the latest stock data of different data identifications to the service processing system; and after the business server in the business processing system carries out business processing on the latest stock data of different stock identifications, the latest stock data are actively pushed to the corresponding message middleware systems.

Preferably, each gateway server in the first gateway system stores a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier;

when the second gateway server receives the latest stock data of different stock identifications, searching for a user identification corresponding to each stock identification, and sending the latest data information of the stock identification to a stock client corresponding to the user identification specifically comprises the following steps:

the second gateway server searches for a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier; and triggering a third gateway server corresponding to the link channel identifier in the second gateway system according to the link channel identifier to send the latest stock data of the stock identifier to the stock client from the link channel.

A third aspect of the present application provides a communication processing method, applied to a communication processing system, where the communication processing system includes a first processing system and a second processing system, and the first processing system includes at least one server; the second processing system includes at least one server, the method comprising:

a first server in the first processing system acquires the latest data information of a data identifier of which the data information is updated;

the first server actively pushes the latest data information of different data identifications to the second processing system;

when a second server in the second processing system receives the latest data information of different data identifications, searching for a user identification corresponding to each data identification;

and the second server sends the latest data information of the data identification to the client corresponding to the user identification.

Preferably, the communication processing system further comprises a plurality of message middleware systems; each message middleware system comprises at least one message middleware server;

the first server actively pushes the latest data information of different data identifications to the second processing system, and the method comprises the following steps:

the first server actively pushes the latest data information of different data identifications to the corresponding message middleware systems;

and the message middleware server of the message middleware system actively pushes the latest data information of the received data identification to the second processing system.

Preferably, the communication processing system further comprises a service processing system, and the service processing system comprises at least one service server;

the first server actively pushes the latest data information of different data identifications to the service processing system;

and after the service server in the service processing system carries out service processing on the latest data information with different data identifications, the latest data information is actively pushed to the corresponding message middleware systems.

Preferably, the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated includes:

the first server inquires the data identification for updating the data information from different data servers, and obtains the latest data information of different data identifications.

when the second server receives the latest data information of different data identifiers, after searching for the user identifier corresponding to each data identifier, the method further includes:

the second server searches a link channel identifier corresponding to the user identifier;

the sending, by the second server, the latest data information of the data identifier to the client corresponding to the user identifier includes:

determining a third server corresponding to the link channel identifier in the second processing system;

and triggering the third server to send the data identification to the client from the link channel.

A fourth aspect of the present application provides a communication processing method, which is applied to a communication processing system, where the communication processing system includes a first gateway system and a second gateway system, the first gateway system includes at least one gateway server, and the second gateway system includes at least one gateway server;

the method comprises the following steps:

a first gateway server in the first gateway system acquires latest stock data of stock labels for updating the stock data from a dealer server;

the first gateway server actively pushes the latest stock information of different stock identifications to the second processing system;

when a second gateway server in the second gateway system receives the latest stock data of different stock identifications, searching a user identification corresponding to each stock identification;

and the second gateway server sends the latest data information of the stock identification to the stock client corresponding to the user identification.

the first gateway server actively pushes the latest stock data of different stock identifications to the second processing system, and the method comprises the following steps:

the first gateway server actively pushes the latest stock data of different stock identifications to the corresponding message middleware systems;

and the message middleware server of the message middleware system actively pushes the received latest stock data of the stock identification to the second processing system.

the first gateway server actively pushes the latest stock data of different data identifications to the service processing system;

and after the business server in the business processing system carries out business processing on the latest stock data of different stock identifications, the latest stock data are actively pushed to the corresponding message middleware systems.

A fifth aspect of the present application provides a communication processing method, which is applied in a network server, and the method includes:

acquiring the latest data information of a data identifier of which the data information is updated;

and searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to a client corresponding to the user identifier.

A sixth aspect of the present application provides a network communication system, including a client, the communication processing system of the first aspect, and a data server;

the communication processing system is used for acquiring the latest data information of the data identifier of which the data information is updated from the data server; searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to a client corresponding to the user identifier;

the client is used for caching the latest data information of any received data identifier; and when a data output request of the data identification is received, searching the latest data information corresponding to the data identification from the cache and outputting the latest data information.

Compared with the prior art, the application can obtain the following technical effects:

the latest data information of the data identification of which the data information is updated is actively pushed to the client corresponding to the user identification corresponding to the data information, so that the accuracy of the data information can be ensured, the system processing pressure can be reduced, the system performance is improved, and the flow of the client is not wasted. The client can acquire accurate latest data information in real time by adopting smaller flow.

Of course, it is not necessary for any one product to achieve all of the above-described technical effects simultaneously.

Drawings

The accompanying drawings, which are included to provide a further understanding of the application and are incorporated in and constitute a part of this application, illustrate embodiment(s) of the application and together with the description serve to explain the application and not to limit the application. In the drawings:

fig. 1 is a schematic structural diagram of an embodiment of a communication processing system according to an embodiment of the present application;

fig. 2 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application;

fig. 3 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application;

fig. 4 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application;

fig. 5 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application;

fig. 6 is a flowchart of an embodiment of a communication processing method according to an embodiment of the present application;

fig. 7 is a flowchart of a communication processing method according to another embodiment of the present application;

fig. 8 is a flowchart of a communication processing method according to another embodiment of the present application;

fig. 9 is a flowchart of a communication processing method according to another embodiment of the present application;

fig. 10 is a schematic structural diagram of an embodiment of a network server according to an embodiment of the present application.

Detailed Description

Embodiments of the present application will be described in detail with reference to the drawings and examples, so that how to implement technical means to solve technical problems and achieve technical effects of the present application can be fully understood and implemented.

The embodiment of the application is mainly suitable for a communication scene between the client and the network, and after the client is connected with the network, real-time communication is needed to be carried out so as to obtain the latest data information of the data identifier concerned by the client.

In the prior art, a client timing query mode is adopted, but because massive data information of data identification may exist, a timing time interval cannot be accurately determined, and if the interval time is long, the accuracy of the acquired data information is affected. If the interval time is short, frequent access of the client is caused, and especially when a large number of clients exist, the processing pressure of the system is increased, and the performance of the system is affected.

The inventor finds that the latest data information of the updated data identifier can be actively pushed to the client in an active pushing mode of the network side. However, the inventor finds that if all data information of the data identifier is pushed to the client, the data information pushed to the client is massive due to many data identifiers, which may result in waste of client traffic.

Therefore, through a series of researches, the inventor provides the technical scheme of the application, which can ensure the accuracy of data information, reduce the processing pressure of the system, improve the performance of the system and avoid wasting the flow of the client. The client can acquire accurate latest data information in real time by adopting smaller flow.

In a practical application, the data information may specifically refer to stock data, where stocks concerned by each user are different, and the stock data may include real-time information of self-selected stock prices, real-time stock trading information, and the like. There is a problem of real-time communication with a stock client due to the huge amount of stock data that may be generated during stock opening. By adopting the technical scheme, the stock client can acquire the latest stock data of each stock concerned by the user in real time.

In the embodiment of the present application, the network end mainly includes a communication processing system, and the system structure of the communication processing system may have a plurality of possible implementation manners.

The technical solution of the present application will be described in detail below with reference to the accompanying drawings.

Fig. 1 is a schematic structural diagram of an embodiment of a communication processing system according to the present invention, which may include a first processing system 100 and a second processing system 200, where the first processing system 100 includes at least one server 101, and the second processing system 200 includes at least one server 102.

A first server 101 in the first processing system 100 acquires the latest data information of a data identifier of which the data information is updated; actively pushing the latest data information of different data identifications to the second processing system;

when the second server 102 in the second processing system 200 receives the latest data information of different data identifiers, the user identifier corresponding to each data identifier is searched, and the latest data information of the data identifier is actively pushed to the client corresponding to the user identifier.

Specifically, the step of searching for the user identifier corresponding to each data identifier is to search for the user identifier of the login user corresponding to each data label. And the user logs in the second processing system through the client by using the login information, and successfully logs in the user. Therefore, the client in the embodiment of the present application refers to a client that logs in the second processing system by using the login information and establishes a long connection channel with the second processing system.

Where the first processing system 100 includes a plurality of servers, the first server may be any one of the servers, or may be one of the servers whose processing performance determined by the load balancing decision satisfies the processing condition. At the same time, there may be a plurality of first servers in the first processing system that perform data acquisition and pushing simultaneously.

When the second processing system 200 includes a plurality of servers, the second server may be any one of them or may be one that satisfies the processing condition in terms of performance as determined by the load balancing decision. Wherein, at the same time, there may exist a plurality of second servers in the second processing system to push data simultaneously.

The first server may actively push the latest data information of different data identifiers to each server in the second processing system, and then the latest data information is processed by the second server.

In the prior art, a client regularly sends a data query request to a second processing system, the second processing system then sends the data query request to a first processing system, and the first processing system sends data information of a data identifier requesting for query to the client through the second processing system. In this embodiment, the first server actively pushes the latest data information of different data identifiers to the second processing system, and the second server searches for the user identifier corresponding to each data identifier, so that only the latest data information of the data identifiers is actively pushed to the client corresponding to the corresponding user identifier, and the client only receives the latest data information of the data identifier concerned by the user identifier and pushes the latest data information to the client in an active pushing manner, so that the latest data information of the updated data identifiers can be pushed to the client in time, the accuracy of the latest data information received by the client is ensured, frequent queries by the client are not required, the processing pressure of the system is not too high, and the system performance is improved.

The client may establish a connection with any server of the second processing system, and if the third server is assumed to be the third server, the third server may establish a link channel with the client after verifying the login information of the client.

Each server in the second processing system may store a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier.

The second server specifically searches for a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier; and triggering a third server corresponding to the link channel identifier in the second processing system according to the link channel identifier to send the data identifier to the client from the link channel. Specifically, the user id of the login user corresponding to each data id can be searched,

because the data identifier corresponding to the user identifier of each login user can be obtained, in order to conveniently search the user identifier corresponding to the data identifier, the data identifier and the user identifier can be stored in the following mapping mode:

SH001：A；

SH002：A，B；

SH003：B；

wherein, SH001, SH002 and SH003 are data marks; a and B are user identities. The storage can be performed in a key-value mode, the key value is a data identifier, and the value is a user identifier list.

The user identifier and the link channel identifier may be stored in the following mapping manner:

a: a link channel identifier A;

b: a link channel identifier B;

the storage can be performed in a key-value mode, the key value is a user identifier, and the value is a link channel identifier.

In one possible implementation, the first processing system may be a system that generates data information of different data identifications, and the second processing system may be a gateway system that is responsible for the client and the first processing system. For example, in an instant messaging scenario, the first processing system may be an instant messaging system, and the second processing system may be a client gateway system, which is responsible for communication of the client.

In order to improve processing performance, facilitate flexible expansion to support more processing services, and improve system performance, the second processing system may include a plurality of servers.

In yet another possible implementation manner, the data information may be obtained from a data server in the third-party system, and thus the first processing system may be a gateway system of the third-party system, and the second processing system may be a gateway system of the client, and the communication between the client and the third-party system is realized through the first processing system and the second processing system.

For example, in a stock query scenario, the third-party system is a system composed of dealer servers of different dealers, each dealer only provides one or a limited number of stocks, and therefore the communication processing system is responsible for obtaining stock data of different stock labels from the different dealer servers and providing the stock data to the client.

In order to ensure processing performance, facilitate flexible expansion to support more processing services, and improve system performance, the first processing system 100 and the second processing system 200 may be cluster systems respectively and each include a plurality of servers.

In this possible implementation manner, the obtaining, by the first server, the latest data information of the data identifier of which the data information is updated may be a data identifier for querying, from a different data server, to update the data information, and the latest data information of the different data identifiers is obtained.

The query may be a timed query or a real-time query, wherein the timed time interval may be relatively short. Because the first server and the data server are both subjected to performance matching in advance according to the number of the existing data identifiers, even if the timing query or the real-time query is carried out, the processing performance of the first server is not influenced.

Of course, the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated may also be:

When finding that the data identifier updated by the data information exists, the data server can actively push the latest data information of the data identifier updated by the data information to the first processing system. The data can be pushed to each server in the first processing system, and the first server performs subsequent processing.

Fig. 2 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application, which is different from the embodiment shown in fig. 1 in that the communication processing system further includes a plurality of message middleware systems 300, and each message middleware system 300 may include at least one message middleware server 103.

A first server 101 in the first processing system 100 acquires the latest data information of a data identifier of which the data information is updated; the latest data information of different data identifications is actively pushed to the corresponding message middleware system 300;

the message middleware server 103 in the message middleware system 300 actively pushes the latest data information of the received data identifier to the second processing system 200.

When there are a plurality of message middleware servers, any message middleware server or a message middleware server whose processing performance satisfies the processing condition may push the message.

Each message middleware system corresponds to one or more data identifications, and data push between the first processing system and the second processing system is decoupled through the message middleware system. Each message middleware system can be responsible for pushing the latest data information of one or more data identifiers, so that the pushing pressure of the first processing system can be relieved, the first processing system does not need to cache the data information to reduce the resource occupation, the latest data information of each data identifier can be distributed to the corresponding message middleware system and cached by the corresponding message middleware system, so that the data persistence can be ensured, and if the latest data information is pushed to the second processing system by the first processing system, the data is likely to be lost due to the possibility of a large number of data identifiers, the data can be ensured not to be lost through the message middleware system, and the data pushing success is ensured.

The calling amount between the first processing system and the message middleware system is only in direct proportion to the number of the data identifications and is not influenced by the second processing system; the calling quantity between the message middleware system and the second processing system is only in direct proportion to the number of the servers in the second processing system and is not influenced by the first processing system, so that the processing capacity of the system can be improved, and the system can be conveniently expanded.

The message middleware system can be arranged according to the updating frequency of different data identifications, if the data information of one data identification is low in updating frequency, one message middleware system can be correspondingly arranged for a plurality of data identifications low in updating frequency without high processing performance. And for the data identification with higher updating frequency, a message middleware system with higher processing performance can be independently arranged.

In different practical applications, particularly when the data information is obtained from a third-party system, the communication processing system may perform corresponding service processing, such as data format conversion, on the latest data information of the obtained data identifier, so that the server in the second processing system may perform service processing on the latest data information of the received data identifier and then actively push the latest data information to the client.

Of course, as another embodiment, in order to improve the processing capability, the communication processing system may further include a service processing system, where the service processing system is composed of at least one service server, and the service processing system performs service processing.

The actively pushing, by the first server, the latest data information of the data identifier to the second processing system may specifically be:

the first server actively pushes the latest data information of different data identifications to the service processing system; after the business server in the business processing system processes the business of the latest data information with different data identifications, the latest data information is actively pushed to the first processing system,

fig. 3 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application, which is different from the embodiment shown in fig. 2 in that the communication processing system may further include service processing systems 400, and each service processing system 400 may include at least one service server 104.

A first server 101 in the first processing system 100 acquires the latest data information of a data identifier of which the data information is updated; actively pushing the latest data information of different data identifications to the service processing system 400;

after the service server 104 in the service processing system 400 performs service processing on the latest data information of different data identifiers, the latest data information is actively pushed to the corresponding message middleware system 300;

In the communication processing system of the network side provided in the above embodiment, in a practical application, the data identifier is a stock identifier, and the data information is stock data, such as stock trading data, stock price information, and the like. The client is a stock client specifically, stock data and the like provided by the dealer server can be obtained through the communication processing system, a user can log in the communication processing system through the stock client and can select stocks needing attention, the stock data is changed rapidly, so that the stock data of the stocks concerned by the user can be accurately obtained in real time through the embodiment, and different stocks are distinguished through stock marks.

Because one stock dealer usually provides only one stock, the stock client can conveniently obtain stock data of different stock labels, and the connection with the stock dealer servers of different stock dealers can be established through the communication processing system.

Fig. 4 is a schematic structural diagram of another embodiment of a communication processing system according to an embodiment of the present application.

The system may include a first gateway system 41 and a second gateway system 42, the first gateway system 41 includes at least one gateway server 411, the second gateway system 42 includes at least one gateway server 421;

the first gateway server 411 in the first gateway system 41 obtains the latest stock data of the stock labels whose stock data are updated from the dealer server; actively pushing the latest stock information of different stock identifications to the second gateway system 42;

when receiving the latest stock data of different stock identifiers, the second gateway server 421 in the second gateway system 42 searches for a user identifier corresponding to each stock identifier, and sends the latest data information of the stock identifiers to the stock client corresponding to the user identifier.

The first gateway server may periodically query the stock labels for updating stock data from the dealer server to obtain the latest stock data of different stock labels, or may receive the latest stock data of the stock labels for updating stock data actively pushed by the dealer server.

The dealer server may include a plurality of servers.

The first gateway server may be any one of the gateway servers in the first gateway system, or may be one that satisfies the processing condition with respect to processing performance determined by the load balancing decision. At the same time, there may be a plurality of first gateway servers in the first gateway system that perform data acquisition and push simultaneously.

The second gateway server may be any one of the second gateway servers in the second gateway system or may be one that satisfies the performance satisfaction processing condition as determined by the load balancing decision. At the same time, there may be a plurality of second gateway servers in the second gateway system to push data simultaneously.

The first gateway server can actively push the latest stock data of different stock identifications to each gateway server in the second gateway system, and then the latest stock data is processed by the second gateway server.

In this embodiment, the first gateway server actively pushes the latest stock data of different stock identifiers to the second gateway system, and the second gateway server searches for the user identifier corresponding to each stock identifier, so that only the latest data information of the stock identifiers is actively pushed to the stock client corresponding to the corresponding user identifier, and the stock client only receives the latest stock data of the stocks concerned by the user identifiers and pushes the latest stock data to the stock client in an active pushing manner, so that the latest stock data of the updated stock identifiers can be pushed to the client in time, and the accuracy of the latest stock data received by the client is ensured, and the client does not need to frequently query, thereby reducing the system pressure and improving the system performance.

The stock client can establish connection with any gateway server in the second gateway system, and if connection is established with a third gateway server, the third gateway server can establish a link channel with the stock client after verifying the login information of the stock client.

Each gateway server in the second gateway system may store a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier.

The second gateway server specifically searches for a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier; and triggering a third gateway server corresponding to the link channel identifier in the second gateway system according to the link channel identifier to send the latest stock data of the stock identifier to the stock client from the link channel.

As still another embodiment, in order to further improve the system performance, as described in fig. 5, the apparatus may further include a plurality of message middleware systems 43, and each message middleware system 43 may include at least one message middleware server 431, unlike the embodiment shown in fig. 4.

The first gateway server 411 in the first gateway system 41 obtains the latest stock data of the stock labels whose stock data are updated from the dealer server; the latest stock information of different stock identifications is actively pushed to the corresponding message middleware system 43;

the message middleware server 431 of the message middleware system 43 actively pushes the received latest stock data of the stock identifications to the second gateway system 42.

In addition, in practical application, in order to facilitate the client to view the stock data, the latest stock data obtained from the dealer server needs to be subjected to business processing, including data format conversion, stock data statistics, reprocessing and the like, which is the same as the business processing in the prior art and is not described herein again.

Therefore, as a further embodiment, as shown in fig. 5, the system may further include service processing systems 44, and each service processing system 44 may include at least one service server 441.

The first gateway server 411 actively pushes the latest stock data of different stock identifiers to the corresponding message middleware system, specifically, actively pushes the latest stock data of different data identifiers to the service processing system 44; after the business server 441 in the business processing system 44 performs business processing on the latest stock data of different stock identifications, the latest stock data are actively pushed to the corresponding message middleware systems 43.

In this embodiment, the stock data push processing of the service processing system and the second gateway system may be decoupled by the message middleware system. The calling quantity between the business processing system and the message middleware system is only in direct proportion to the stock quantity and is not influenced by the second gateway system; the calling amount between the message middleware system and the second gateway system is only in direct proportion to the number of gateway servers in the second gateway system and is not influenced by the service processing system. Therefore, the processing capacity of the system can be improved, and the system can be conveniently expanded.

Each message middleware system is responsible for pushing the latest data information of one or more data identifiers, so that the pushing pressure of the service processing system can be relieved, the service processing system does not need to cache the data information to reduce resource occupation, the latest data information of each data identifier can be distributed to the corresponding message middleware system and cached by the corresponding message middleware system, so that the data persistence can be ensured, and if the business processing system pushes stock data to a human gateway system, the data is likely to be lost due to the possibility of existence of a large amount of stock data of the stock identifiers, the data can be ensured not to be lost through the message middleware system, and the data pushing success is ensured.

Fig. 6 is a flowchart of an embodiment of a communication processing method according to an embodiment of the present application, where the method is specifically applied to a communication processing system, where the communication processing system includes a first processing system and a second processing system, and the first processing system includes at least one server; the second processing system includes at least one server, as shown in FIG. 1.

The method may comprise the steps of:

601: and a first server in the first processing system acquires the latest data information of the data identifier of which the data information is updated.

602: and the first server actively pushes the latest data information of different data identifications to the second processing system.

603: and when the second server in the second processing system receives the latest data information of different data identifications, searching for the user identification corresponding to each data identification.

604: and the second server sends the latest data information of the data identification to the client corresponding to the user identification.

Wherein, as another embodiment, the communication processing system may further comprise a plurality of message middleware systems; each message middleware system comprises at least one message middleware server; as shown in fig. 2, step 602 may specifically include:

As another embodiment, in step 601, the obtaining, by the first server, the latest data information of the data identifier whose data information is updated may be a data identifier whose data information is updated by querying from a different data server, obtaining the latest data information of a different data identifier, or receiving the latest data information of a data identifier whose data information is updated by being actively pushed by a different data server.

As another embodiment, each server in the second processing system stores a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier;

step 603, when the second server receives the latest data information of different data identifiers, after searching for a user identifier corresponding to each data identifier, the method further includes:

then, in step 604, the sending, by the second server, the latest data information of the data identifier to the client corresponding to the user identifier includes:

Wherein, as another embodiment, the communication processing system may further comprise a plurality of message middleware systems; each message middleware system comprises at least one message middleware server; and a service processing system, the service processing system comprising at least one service server;

as shown in fig. 2, step 602 may specifically include:

after the business server in the business processing system processes the business of the latest data information with different data identifications, the latest data information is actively pushed to the corresponding message middleware systems;

Fig. 7 is a flowchart of an embodiment of a communication processing method according to an embodiment of the present application, where the method is specifically applied to a communication processing system, where the communication processing system includes a first gateway system and a second gateway system, the first gateway system includes at least one gateway server, and the second gateway system includes at least one gateway server, as shown in fig. 4.

The method may comprise the steps of:

701: and the first gateway server in the first gateway system acquires the latest stock data of the stock mark updated by the stock data from the dealer server.

702: and the first gateway server actively pushes the latest stock information of different stock identifications to the second processing system.

703: and when the second gateway server in the second gateway system receives the latest stock data of different stock identifications, searching for the user identification corresponding to each stock identification.

604: and the second gateway server sends the latest data information of the stock identification to the stock client corresponding to the user identification.

Wherein, as a further embodiment, when the communication processing system further comprises a plurality of message middleware systems; each message middleware system comprises at least one message middleware server; as shown in fig. 2, step 602 may specifically include:

As another embodiment, the communication processing system further includes a service processing system, and the service processing system includes at least a service server; and multiple message middleware systems; each message middleware system comprises at least one message middleware server; as shown in fig. 5, step 602 may specifically include:

after the business server in the business processing system carries out business processing on the latest stock data of different stock identifications, the latest stock data are actively pushed to the corresponding message middleware systems;

As another embodiment, each gateway server in the first gateway system stores a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier;

The embodiment of the present application further provides a network communication system, as shown in fig. 8, the system includes a client 801, a communication processing system 802, and a data server 803.

The client 801 may include a plurality of clients, and the data server 803 may include a plurality of clients.

The specific structure of the communication processing system 802 can be described with reference to any one of the embodiments in fig. 1 to fig. 3.

The user logs in the communication processing system 802 through the client 801, and the communication processing system 802 can verify the login information used by the client for logging in and record the login user identifier, so that the user identifier of the login user corresponding to the data identifier can be determined. Specifically, the first processing system in the communication processing system 802 is responsible for establishing a link channel with the client, and storing the link channel identifier and the user identifier in a corresponding manner.

The communication processing system 802 is configured to obtain the latest data information of the data identifier of which the data information is updated from the data server 803; searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to a client 801 corresponding to the user identifier;

the client 801 caches the latest data information of any received data identifier; and when a data output request of the data identification is received, searching the latest data information corresponding to the data identification from the cache and outputting the latest data information.

The client caches the received latest data information of any data identifier, so that the latest data information of the data identifier can be directly read from the cache when a data output request aiming at the data identifier is received, and the client does not need to initiate any network request to the network terminal.

In practical applications, the data information may specifically refer to stock data, and the client may be a stock client and the data server, that is, the data server may specifically be a dealer server.

In another possible implementation manner, the network may specifically be a network server that can directly communicate with the client.

Therefore, as shown in fig. 9, a flowchart of another embodiment of a communication processing method provided in this embodiment of the present application is applied to a network server, and the method may include the following steps:

901: and acquiring the latest data information of the data identifier of which the data information is updated.

902: and searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to a client corresponding to the user identifier.

In this embodiment, the latest data information of each data identifier is actively pushed to the user identifier corresponding to the data identifier, so that the latest data information of the updated data identifier can be pushed to the client in time, the accuracy of the latest data information received by the client is ensured, frequent query by the client is not required, the system bearing pressure is reduced, and the system performance is improved.

As shown in fig. 10, an embodiment of the present application further provides a schematic structural diagram of an embodiment of a network server, which may include a memory 1001 and a processing component 1002,

the memory 1001 stores one or more sets of program instructions;

the processing component 1002 invokes the one or more sets of program instructions of the memory 1002 to perform the following operations:

and acquiring the latest data information of the data identifier of which the data information is updated.

The processing components may include one or more processors; of course, the processing elements may also be implemented as one or more Application Specific Integrated Circuits (ASICs), Digital Signal Processors (DSPs), Digital Signal Processing Devices (DSPDs), Programmable Logic Devices (PLDs), Field Programmable Gate Arrays (FPGAs), controllers, micro-controllers, microprocessors or other electronic components configured to perform the methods described in fig. 9.

The memory is configured to store various types of data to support operations at the communications server. The memory may be implemented by any type or combination of volatile or non-volatile memory devices, such as Static Random Access Memory (SRAM), electrically erasable programmable read-only memory (EEPROM), erasable programmable read-only memory (EPROM), programmable read-only memory (PROM), read-only memory (ROM), magnetic memory, flash memory, magnetic or optical disks.

In addition, an embodiment of the present application further provides a communication processing apparatus, including:

and the acquisition module is used for acquiring the latest data information of the data identifier of which the data information is updated.

And the pushing module is used for searching the user identification corresponding to each data identification and actively pushing the latest data information of the data identification to the client corresponding to the user identification.

The communication processing apparatus may be integrated into a processor of the network server as described in 10 in practical application, as a function that the processor can implement.

By the embodiment of the application, the accuracy of the data information can be ensured, the system processing pressure can be reduced, the system performance is improved, and the flow of the client cannot be wasted. The client can acquire accurate latest data information in real time by adopting smaller flow.

As used in the specification and in the claims, certain terms are used to refer to particular components. As one skilled in the art will appreciate, manufacturers may refer to a component by different names. This specification and claims do not intend to distinguish between components that differ in name but not function. In the following description and in the claims, the terms "include" and "comprise" are used in an open-ended fashion, and thus should be interpreted to mean "include, but not limited to. "substantially" means within an acceptable error range, and a person skilled in the art can solve the technical problem within a certain error range to substantially achieve the technical effect. Furthermore, the term "coupled" is intended to encompass any direct or indirect electrical coupling. Thus, if a first device couples to a second device, that connection may be through a direct electrical coupling or through an indirect electrical coupling via other devices and couplings. The description which follows is a preferred embodiment of the present application, but is made for the purpose of illustrating the general principles of the application and not for the purpose of limiting the scope of the application. The protection scope of the present application shall be subject to the definitions of the appended claims.

It is also noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a good or system that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such good or system. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other like elements in a commodity or system that includes the element.

The foregoing description shows and describes several preferred embodiments of the present application, but as aforementioned, it is to be understood that the application is not limited to the forms disclosed herein, but is not to be construed as excluding other embodiments and is capable of use in various other combinations, modifications, and environments and is capable of changes within the scope of the application as described herein, commensurate with the above teachings, or the skill or knowledge of the relevant art. And that modifications and variations may be effected by those skilled in the art without departing from the spirit and scope of the application, which is to be protected by the claims appended hereto.

Claims

1. A communication processing system comprising a first processing system and a second processing system, said first processing system comprising at least one server; the second processing system comprises at least one server;

a first server in the first processing system acquires latest data information of a plurality of data identifiers of which the data information is updated; actively pushing the latest data information of different data identifications to the second processing system; the first processing system comprises a plurality of the first servers; each first server is respectively used for acquiring the latest data information of the corresponding data identifier;

2. The system of claim 1, further comprising a plurality of message middleware systems; each message middleware system comprises at least one message middleware server;

3. The system of claim 1, further comprising a business processing system, the business processing system comprising at least one business server;

4. The system of claim 2, further comprising a business processing system, the business processing system comprising at least one business server;

5. The system according to claim 1, wherein the obtaining, by the first server, latest data information of the data identifier at which the data information is updated is specifically:

6. The system according to claim 1, wherein the obtaining, by the first server, latest data information of the data identifier at which the data information is updated is specifically:

7. The system according to claim 1, wherein each server in the second processing system stores therein a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier;

the second server is specifically configured to:

the second server searches the user identification of the login user corresponding to each data identification and the link channel identification corresponding to the user identification; and triggering a third server corresponding to the link channel identifier in the second processing system according to the link channel identifier, and sending the data identifier to the client from the link channel corresponding to the link channel identifier.

8. A communication processing system is characterized by comprising a first gateway system and a second gateway system, wherein the first gateway system at least comprises a gateway server, and the second gateway system at least comprises a gateway server;

a first gateway server in the first gateway system acquires latest stock data of a plurality of stock labels, which are updated by the stock data, from a plurality of dealer servers; the latest stock information of different stock identifications is actively pushed to the second gateway system; the first gateway system comprises a plurality of the first gateway servers; each first gateway server is respectively used for acquiring the latest data information of the stock identification corresponding to each first gateway server;

9. The system of claim 8, further comprising a plurality of message middleware systems; each message middleware system comprises at least one message middleware server;

10. The system of claim 9, further comprising a business processing system, the business processing system comprising at least one business server;

the first gateway server actively pushes the latest stock data of different stock identifications to the business processing system; and after the business server in the business processing system carries out business processing on the latest stock data of different stock identifications, the latest stock data are actively pushed to the corresponding message middleware systems.

11. The system according to claim 8, wherein each gateway server in the first gateway system stores a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier;

the second gateway server searches for a user identifier corresponding to each stock identifier and a link channel identifier corresponding to the user identifier; and triggering a third gateway server corresponding to the link channel identifier in the second gateway system according to the link channel identifier, and sending the latest stock data of the stock identifier to the stock client from the link channel corresponding to the link channel identifier.

12. The communication processing method is applied to a communication processing system, wherein the communication processing system comprises a first processing system and a second processing system, and the first processing system at least comprises a server; the second processing system includes at least one server, the method comprising:

a first server in the first processing system acquires latest data information of a plurality of data identifiers of which the data information is updated; the first processing system comprises a plurality of the first servers; each first server is respectively used for acquiring the latest data information of the corresponding data identifier;

13. The method of claim 12, wherein the communication processing system further comprises a plurality of message middleware systems; each message middleware system comprises at least one message middleware server;

14. The method of claim 13, wherein the communication processing system further comprises a service processing system, the service processing system comprising at least one service server;

15. The system of claim 12, wherein the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated comprises:

16. The system of claim 12, wherein the obtaining, by the first server, the latest data information of the data identifier at which the data information is updated comprises:

17. The system of claim 12, wherein each server in the second processing system stores therein a user identifier corresponding to each data identifier and a link channel identifier corresponding to the user identifier;

and triggering the third server to send the data identifier to the client from the link channel corresponding to the link channel identifier.

18. A communication processing method is applied to a communication processing system, wherein the communication processing system comprises a first gateway system and a second gateway system, the first gateway system at least comprises a gateway server, and the second gateway system at least comprises a gateway server;

the method comprises the following steps:

a first gateway server in the first gateway system acquires latest stock data of a plurality of stock labels, which are updated by the stock data, from a plurality of dealer servers; the first gateway system comprises a plurality of the first gateway servers; each first gateway server is respectively used for acquiring the latest data information of the stock identification corresponding to each first gateway server;

19. The method of claim 18, wherein the communication processing system further comprises a plurality of message middleware systems; each message middleware system comprises at least one message middleware server;

20. The method of claim 19, wherein the communication processing system further comprises a service processing system, the service processing system comprising at least one service server;

the first gateway server actively pushes the latest stock data of different stock identifications to the business processing system;

21. A communication processing method is applied to a network end server, wherein the network end server comprises a plurality of servers; the method comprises the following steps:

respectively acquiring the latest data information of the data identification of which the corresponding data information is updated from a plurality of data servers through each server;

and searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to the client corresponding to each user identifier.

22. A network communication system comprising a client, a communication processing system according to any one of claims 1 to 7, and a data server;

the communication processing system is used for acquiring the latest data information of a plurality of data identifications with updated data information from a plurality of data servers; searching a user identifier corresponding to each data identifier, and actively pushing the latest data information of the data identifiers to a client corresponding to the user identifier;