CN114615315A - Communication method, device, equipment and storage medium for online conversation - Google Patents

Abstract

The application relates to the technical field of communication, and discloses a communication method, a device, equipment and a storage medium for online conversation, which establish conversation connection with first clients corresponding to N first clients of N first communication instances distributed by a proxy server according to received connection request information of the N first clients; then according to a communication request between a second client and a target first client generated by the proxy server, determining a target first communication instance corresponding to the target first client from the N first communication instances; after the communication request with the target first client and the signature information of the target first client are verified, session communication connection between the second client and the target first client is established based on the target first communication instance, the expansibility of the communication system in different application scenes is improved by using the proxy server, and meanwhile, the communication connection is carried out through a plurality of communication instances, so that the performance of the communication system is ensured.

Description

Communication method, device, device and storage medium for online session

technical field

The present application relates to the field of communication technologies, and in particular, to a communication method, device, computer equipment and storage medium for an online session.

Background technique

At present, PC-side communication services require more tedious operations such as application download and installation, which reduces communication efficiency. In the existing Web Instant Messaging (IM) technology, it has the advantages of not needing to install a client and penetrating firewalls. The scenario where the client receives messages from the server can be implemented through Ajax short polling, Comet, WebSocket, SSE, etc. By using the open source technology Socket.io for encapsulation, the instant messaging system is compatible with different browsers, but when using cluster servers, the instant messaging system still has the problem of poor system performance and system scalability for different business scenarios.

SUMMARY OF THE INVENTION

The present application provides an online session communication method, device, computer equipment and storage medium, which solve the problems of poor system performance and system scalability of the instant messaging system in the prior art in different business scenarios.

In a first aspect, an embodiment of the present application provides a communication method for an online session, including:

When receiving the connection request information of the N first clients according to the N first communication instances allocated by the proxy server, establishing first client session connections between the N first communication instances and the N first clients, Among them, N is an integer greater than 1;

According to the communication request of the second client and the target first client generated by the proxy server, the target first communication instance corresponding to the target first client is determined from the N first communication instances;

Verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the second client through the target first communication instance A session communication connection with the target first client.

In a second aspect, an embodiment of the present application further provides a communication device for an online session, including:

The communication establishment module, when receiving the connection request information of the N first clients according to the N first communication instances allocated by the proxy server, establishes the N first communication instances and the N first clients of the first clients End session connection, where N is an integer greater than 1;

The target communication matching module determines the target first communication instance corresponding to the target first client from the N first communication instances according to the communication request of the second client and the target first client generated by the proxy server ;

A communication connection module with the target, verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the target first communication instance through the target first client A session communication connection between the second client and the target first client.

In a third aspect, embodiments of the present application further provide a computer device, including a memory, a processor, and a computer program stored in the memory and executable on the processor, where the processor executes the computer program When implementing the steps of the above-mentioned communication method of the online session.

In a fourth aspect, an embodiment of the present application further provides a computer-readable storage medium, where the computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, implements the steps of the above-mentioned communication method for an online session .

The communication method, device, computer equipment and storage medium for an online session provided by the present application, wherein, a communication method for an online session is to establish a distribution with a proxy server according to the received connection request information of N first clients. The first client session connections corresponding to the N first clients of the N first communication instances; and then according to the communication request between the second client and the target first client generated by the proxy server, from the N first communication instances Confirm the target first communication instance corresponding to the target first client; when the target first client ID in the communication request with the target first client and the target first client signature information of the target first client are verified and passed, The session communication connection between the second client and the target first client is established through the target first communication instance, and the communication connection is performed through multiple communication instances while using the proxy server to improve the scalability of the communication system in different application scenarios, This ensures the performance of the communication system.

Description of drawings

In order to illustrate the technical solutions of the embodiments of the present application more clearly, the following briefly introduces the drawings that are used in the description of the embodiments of the present application. Obviously, the drawings in the following description are only some embodiments of the present application. , for those of ordinary skill in the art, other drawings can also be obtained from these drawings without creative labor.

1 is a schematic diagram of an application environment of a communication method for an online session provided by an embodiment of the present application;

2 is a flowchart of an implementation of a communication method for an online session provided by an embodiment of the present application;

3 is a flowchart of step S20 in an online session communication method provided by an embodiment of the present application;

4 is a schematic structural diagram of a communication device for an online session provided by an embodiment of the present application;

FIG. 5 is a schematic diagram of a computer device provided by an embodiment of the present application.

Detailed ways

The technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present application. Obviously, the described embodiments are part of the embodiments of the present application, not all of the embodiments. Based on the embodiments in the present application, all other embodiments obtained by those of ordinary skill in the art without creative work fall within the protection scope of the present application.

The communication method for an online session provided by the embodiment of the present application can be applied in the application environment shown in FIG. 1 . As shown in Figure 1, a client (computer device) communicates with a server through a network. Among them, the client (computer equipment) includes but is not limited to various personal computers, notebook computers, smart phones, tablet computers, cameras and portable wearable devices. The server can be an independent server, or it can provide cloud services, cloud databases, cloud computing, cloud functions, cloud storage, network services, cloud communications, middleware services, domain name services, security services, and Content Delivery Network (CDN). ), as well as cloud servers for basic cloud computing services such as big data and artificial intelligence platforms.

The communication method for an online session provided by this embodiment may be performed by a server. For example, the first client sends connection request information to the server, and the server executes the online session provided by this embodiment based on the connection request information. In the communication method of the invention, a first communication instance is established, the second client is connected to the server, the connection is made to the first communication instance through a communication request with the target first client, and the session communication connection is performed with the first client.

In some scenarios other than FIG. 1 , the communication method of the online session may also be performed by the first client, and the connection is directly requested by the second client and the communication with the target first client. The communication method of the online session is to establish a session communication connection with the first client, and then send the communication result of the online session to the server for storage.

In this embodiment, Web Instant Messaging (IM) is established based on the WebSocket protocol. WebSocket is a protocol in HTML5 for full-duplex communication based on a single TCP connection. Its feature is that the server can actively push information to the client , the client can also actively send information to the server, which is a real two-way equal dialogue, which belongs to a kind of server push technology.

Among them, Socket.io technology is also used. Socket.io is a JS that supports real-time communication of WebSocket across browsers. Socket.io supports timely, two-way, event-based communication, and can work on different platforms, browsers, and devices. , reliability and speed stability. Common application scenarios of Socket.io include real-time analysis, push data to the client, and the client behaves as a real-time counter, chart, log client; real-time communication; binary streaming transmission, Socket.io supports any form of binary file transmission, such as pictures , video, audio, etc.; document merging: allows multiple users to edit a document at the same time and be able to see the changes made by each user.

FIG. 2 shows a flowchart of an implementation of a communication method for an online session provided by an embodiment of the present application. As shown in FIG. 2, a communication method for an online session is provided, and its technical solution mainly includes the following steps S10-S30:

Step S10, when receiving connection request information of N first clients according to N first communication instances allocated by the proxy server, establishing N first communication instances and first clients of N first clients Session connection, where N is an integer greater than 1.

In step S10, a Web instant messaging (Instant Messaging, IM) technology is used for communication between the server and the client. Among them, web instant messaging technology has the characteristics of not needing to install a client, penetrating firewalls, and being closely integrated with the community. By setting multiple server instances on the server as communication instances to perform services between the server and the client, the system can complete the task of communicating with each client.

In one embodiment, when the proxy server of the cluster server receives the connection request information of the N first clients, the proxy server allocates a corresponding first communication instance to each first client for establishing the connection between the server and the first client. The first client session connection corresponding to the client.

In one embodiment, since the instant messaging system has a large number of visits and is real-time, the communication system is deployed in a distributed cluster server manner, thereby reducing server costs, improving server scalability and server stability.

Understandably, a server instance is also called a service, and it can also be understood as a virtual machine. It is usually used to create one or more additional application server instances depending on the user environment. When the server instance is based on a cluster server , a server instance can only belong to one cluster server.

Understandably, a cluster server is a large computer service system composed of several independent computers using a high-speed communication network. Each cluster node (ie, each computer in the cluster) runs its own service. Standalone server. These servers can communicate with each other, collaboratively provide applications, system resources and data to users, and manage them as a single system. When a user requests a cluster system, the cluster feels to the user as a single independent server, but in fact the user requests a group of cluster servers.

When using clustered servers can facilitate load balancing by distributing the load across multiple machines and can provide high availability through instance-level failover. Computer cluster architecture usually has the following categories according to function and structure: load balancing cluster, high availability cluster, high performance computing cluster and grid computing cluster.

Step S10 in this embodiment: when receiving connection request information of N first clients according to N first communication instances allocated by the proxy server, establish a first communication between N first communication instances and N first clients A client session connection, where N is an integer greater than 1. As an example, step S10 includes:

Step S101 , the proxy server allocates the corresponding N first communication instances to the N first clients according to the load state of the cluster server corresponding to the communication system.

In step S101, since the communication system is deployed on the cluster server, the proxy server allocates a first communication instance on the node to each first client according to the load status of each node of the cluster server used by the communication system, thereby ensuring that System load balancing.

In one embodiment, the cluster server utilizes a load balancing cluster, and through the load balancing cluster, the load pressure of access requests concentrated by many clients can be distributed as evenly as possible in the computer cluster for processing, and the client access request load usually includes application processing load and network processing load. traffic load. Using the same set of applications to serve a large number of users, each node can bear a certain load of access requests, and access requests can be dynamically distributed among nodes to achieve load balancing.

Understandably, a Load Balance Cluster (LB or LBC) is a type of cluster server, which generally distributes client access requests to a set of servers at the back end through one or more front-end load balancers, so as to achieve For the high performance and high availability of the entire system, the high availability cluster and the load balancing cluster will use similar technologies, or have the characteristics of high availability and load balancing at the same time.

Step S102: Establish first client session connections between the N first communication instances and the N first clients according to the N first client signature information.

In step S102, when establishing the connection between the server and the first client, the first client signature information corresponding to the first client needs to be acquired and stored in the server for authentication of the session connection with the client.

In one embodiment, N pieces of the first client signature information sent by the N first clients are received, the signature information is verified through the N first communication instances, and N pieces of the first client are established. The communication instance is connected with the first client sessions of the N first clients; the first communication instance address of the N first communication instances, the N signature information of the first client, and the N first communication instances A client session connection ID is stored to the cluster server.

Wherein, the address of the first communication instance is the IP address corresponding to the first communication instance, which is used for subsequent connection to the second client to find the target first communication instance; the signature information of the first client usually includes the client ip corresponding to the first client and mac address, etc.; the first client session connection ID is the ID number of the first client session connection established by the first client and the server, which is used to maintain the session state; the Redis server in the saved cluster server is based on memory storage The Redis server can greatly improve the performance of data storage and query, and the cluster architecture can also ensure the high availability of the system and the storage of large amounts of data.

Understandably, Redis (Remote Dictionary Server) is a remote dictionary service. It is a high-performance key-value database that supports many types of stored values, including string (string), list (linked list), and set (collection). , zset (sorted set - ordered set) and hash (hash type). Redis supports sorting in various ways. In order to ensure efficiency, data is cached in memory, and it will periodically write updated data to disk or write modification operations to appended record files, and implement it on this basis. Master-slave (master-slave) synchronization. In the process of client communication, due to the high requirement for timeliness, the storage and query data based on the Redis memory server can reduce the time of data io, and Reids in cluster mode can also carry the storage of large data volume messages and ensure high availability.

Step S20 , determining a target first communication instance corresponding to the target first client from the N first communication instances according to the communication request between the second client and the target first client generated by the proxy server.

In step S20, the request of each client is received through the proxy server, and preprocessing is performed to achieve load balancing of the cluster server. In this embodiment, the proxy server also has a corresponding target first client allocated according to the service request of the second client , and generate a target client matching application that communicates with the target first client, but the target client matching application is not limited to being set on the proxy server, but can also be set on other servers or service instances to meet the needs of the second client Communication service with the first client.

Since the server has N first communication instances, when the second client connects to the target first client, it needs to find the first communication instance corresponding to the connection target first client, that is, the target first communication instance, and then establish the connection between the second client and the target first client. The communication connection of the target first client.

In one embodiment, the proxy server uses Nginx as a reverse proxy server, and the proxy server acts as a load balancing device in the reverse proxy mode of the load balancing cluster. When the proxy server receives the client request, it will record the message. (usually including source IP address, destination IP address, protocol number, source port, destination port, service type, and interface index), change the destination address of the packet to the IP address of the optimized cluster server, the destination port number remains unchanged, the source The address is modified to the IP address of the proxy server downlink and the corresponding cluster server device interface, and the source port number is randomly sent to the cluster server;

Understandably, Nginx (engine x) is a high-performance HTTP and reverse proxy web server, and also provides IMAP/POP3/SMTP services. When Nginx is used as a load balancing service, Nginx can directly directly It supports Rails and PHP programs to provide external services, and can also support external services as HTTP proxy services.

As shown in FIG. 3 , step S20 of this embodiment is shown: according to the communication request of the second client and the target first client generated by the proxy server, determine the target first client from the N first communication instances The specific implementation process of the target first communication instance corresponding to the terminal, as an example, in step S20, including:

Step S201, receiving the communication request with the target first client generated by the proxy server according to the communication service requirements of the second client;

Step S202, matching the target first client session connection ID corresponding to the target first client ID in the cluster server according to the target first client ID in the communication request with the target first client;

Step S203: Determine a target first communication instance corresponding to the target first client from the N first communication instances according to the session connection ID of the target first client.

In step S201, by receiving the proxy server matching the corresponding target first client according to the communication service requirements of the second client, a communication request with the target first client having information such as the target first client ID, business related information, etc. is generated, and then The communication service requirements of the second client are solved.

In one embodiment, the proxy server performs business requirement target matching according to the received communication service requirement of the second client, and obtains the target first client; according to the target first client and the second client The client generates the communication request with the target first client. Wherein, the proxy server performs corresponding retrieval according to the keywords of the communication service requirements of the second client, so as to match the corresponding target first client.

In another embodiment, using an accessory inquiry scenario as an example, after the accessory dealer (the first client) establishes a connection with the server through the browser, it publishes its own accessory supply business, and the user of the repair shop (the second client) uses the browser Publish the inquiry price request, process the inquiry-related business through the proxy server, or use the proxy server to forward it to the inquiry transaction system to process the inquiry-related business. The communication request with the target first client, and then the next connection is carried out to meet the business communication seeking of the user and the merchant.

In step S202, since the first client generates a corresponding first client session connection based on the first communication instance, the target first client session corresponding to the target first client is queried on the cluster server through the target first client ID connection ID, and then find the corresponding target first communication instance through the target first client session connection ID, and perform communication connection between clients.

In step S203, the target first communication instance corresponding to the target first client is determined from the plurality of first communication capabilities in the server, thereby establishing a communication connection between the second client and the target first client.

In one embodiment, if the first communication instance ID of the first communication instance used by the second client to connect to the cluster server is the target first communication instance, the target first client is directly determined the corresponding target first communication instance;

If the first communication instance used by the second client is not the target first communication instance, the target first client session connection ID is determined from the N first communication instances to determine the target first communication instance. A communication instance.

In one embodiment, the target first communication instance will monitor the message sent by the server, and when monitoring that the message sent by the server is a communication request with the target first client having the session connection ID of the target first client, Then the response server determines the target first communication instance.

Step S30, verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the first target communication instance through the target first communication instance. A session communication connection between the second client and the target first client.

In step S30, when the first communication instance is determined, the information in the communication request with the target first client is verified according to the signature information of the target first client, and if the verification is passed, the second client is established through the target first communication instance It is connected to the session communication connection with the target first client, and if there is a problem in the verification, the communication request with the target first client is verified. By means of signature verification, the security of the connection between the second client and the target first client is ensured, and at the same time, the message system has better protection and interception in response to malicious requests.

In one embodiment, the target first client ID in the communication request with the target first client is combined with the target first client signature information of the target first client through the target first communication instance The target first client ID in is verified; the session communication connection between the second client and the target first client is established through the target first communication instance.

In another embodiment, the accessory dealer connects to the target first communication instance where the target first client session is located, based on the service request with the accessory dealer that is monitored in time by the server publish and subscribe function, and the established session, in the service , according to the session connection ID of the target first client terminal, the inquiry message is transmitted to the accessories dealer user of the client terminal.

In an embodiment, a communication device for an online session is provided, and the communication device for an online session corresponds one-to-one with the communication method for an online session in the above embodiment. As shown in FIG. 4 , the communication device for the online session includes a communication establishment module 11, a target communication matching module 12 and a target communication connection module 13. The detailed description of each functional module is as follows:

The communication establishment module, when receiving the connection request information of the N first clients according to the N first communication instances allocated by the proxy server, establishes the N first communication instances and the N first clients of the first clients End session connection, where N is an integer greater than 1;

The target communication matching module determines the target first communication instance corresponding to the target first client from the N first communication instances according to the communication request of the second client and the target first client generated by the proxy server ;

A communication connection module with the target, verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the target first communication instance through the target first client A session communication connection between the second client and the target first client.

In another embodiment, a communication device for online conversation is provided, further comprising:

A proxy service module, wherein the proxy server performs business requirement target matching according to the received communication service requirements of the second client to obtain the target first client; according to the target first client and the second client The communication request with the target first client is generated.

For the specific limitation of the communication device of the online session, reference may be made to the limitation of the communication method of the online session above, which will not be repeated here. All or part of the modules in the communication device for the above online session can be implemented by software, hardware and combinations thereof. The above modules can be embedded in or independent of the processor in the computer device in the form of hardware, or stored in the memory in the computer device in the form of software, so that the processor can call and execute the operations corresponding to the above modules.

In one embodiment, a computer device is provided, the computer device may be a client or a server, and its internal structure diagram may be as shown in FIG. 5 . The computer device includes a processor, memory, a network interface, and a database connected by a system bus. Among them, the processor of the computer device is used to provide computing and control capabilities. The memory of the computer device includes a readable storage medium, an internal memory. The readable storage medium stores an operating system, a computer program, and a database. The internal memory provides an environment for the execution of the operating system and computer programs in the readable storage medium. The network interface of the computer device is used to communicate with an external terminal through a network connection. When the computer program is executed by the processor, an online conversation communication method is realized.

In one embodiment, a computer device is provided, including a memory, a processor, and a computer program stored in the memory and running on the processor. When the processor executes the computer program, the communication method for an online session in the above embodiment is implemented .

In one embodiment, a computer-readable storage medium is provided, on which a computer program is stored, and when the computer program is executed by a processor, the communication method of the online session in the above-mentioned embodiment is implemented.

Those of ordinary skill in the art can understand that all or part of the processes in the methods of the above embodiments can be implemented by instructing relevant hardware through a computer program, and the computer program can be stored in a non-volatile computer-readable storage In the medium, when the computer program is executed, it may include the processes of the above-mentioned method embodiments. Wherein, any reference to memory, storage, database or other medium used in the various embodiments provided in this application may include non-volatile and/or volatile memory. Nonvolatile memory may include read only memory (ROM), programmable ROM (PROM), electrically programmable ROM (EPROM), electrically erasable programmable ROM (EEPROM), or flash memory. Volatile memory may include random access memory (RAM) or external cache memory. By way of illustration and not limitation, RAM is available in various forms such as static RAM (SRAM), dynamic RAM (DRAM), synchronous DRAM (SDRAM), double data rate SDRAM (DD cluster server DRAM), enhanced SDRAM (ESDRAM) , Synchlink DRAM (SLDRAM), memory bus (Rambus) direct RAM (RDRAM), direct memory bus dynamic RAM (DRDRAM), and memory bus dynamic RAM (RDRAM), etc.

Those skilled in the art can clearly understand that, for the convenience and simplicity of description, only the division of the above-mentioned functional units and modules is used as an example. Module completion, that is, dividing the internal structure of the device into different functional units or modules to complete all or part of the functions described above.

The above-mentioned embodiments are only used to illustrate the technical solutions of the present application, but not to limit them; although the present application has been described in detail with reference to the above-mentioned embodiments, those of ordinary skill in the art should understand that: it can still be used for the above-mentioned implementations. The technical solutions described in the examples are modified, or some technical features thereof are equivalently replaced; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions in the embodiments of the application, and should be included in the within the scope of protection of this application.

Claims (10)

1. a communication method of online session, is characterized in that, comprises: When receiving the connection request information of the N first clients according to the N first communication instances allocated by the proxy server, establishing first client session connections between the N first communication instances and the N first clients, Among them, N is an integer greater than 1; According to the communication request of the second client and the target first client generated by the proxy server, the target first communication instance corresponding to the target first client is determined from the N first communication instances; Verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the second client through the target first communication instance A session communication connection with the target first client. 2. The communication method of online session as claimed in claim 1, wherein, when receiving the connection request information of N first clients according to N first communication instances allocated by the proxy server, establish N The first communication instance is connected with the first client sessions of N first clients, where N is an integer greater than 1, including: The proxy server allocates the corresponding N first communication instances to the N first clients according to the load state of the cluster server corresponding to the communication system; Establish first client session connections between the N first communication instances and the N first clients according to the N first client signature information. 3. The communication method for an online session according to claim 2, wherein the N first communication instances and the N first clients are established according to the N first client signature information. side of the first client session connection, including: Receive the N first client signature information sent by the N first clients, verify the signature information through the N first communication instances, and establish the N first communication instances and the N first communication instances. the first client session connection of the first client; The N first communication instance addresses, the N first client signature information and the N first client session connection IDs of the N first communication instances are saved to the cluster server. 4 . The communication method for an online session according to claim 1 , wherein, according to the communication request between the second client and the target first client generated by the proxy server, from N said first clients. 5 . In the communication instance, the target first communication instance corresponding to the target first client is determined, including: receiving the communication request with the target first client generated by the proxy server according to the communication service requirements of the second client; Match the target first client session connection ID corresponding to the target first client ID in the cluster server according to the target first client ID in the communication request with the target first client; The target first communication instance corresponding to the target first client is determined from the N first communication instances according to the session connection ID of the target first client. 5 . The communication method for an online session according to claim 1 , wherein the verifying the target first client ID in the communication request with the target first client and the target of the target first client. 6 . The first client signature information, establishing a session communication connection between the second client and the target first client through the target first communication instance, including: Through the target first communication instance, the target first client ID in the communication request with the target first client is compared with the target first client ID in the target first client signature information of the target first client A client ID for verification; A session communication connection between the second client and the target first client is established through the target first communication instance. 6 . The communication method for an online session according to claim 4 , wherein, according to the session connection ID of the target first client, determining the address of the target first client from the N first communication instances. 7 . The corresponding target first communication instance includes: If the first communication instance ID of the first communication instance used by the second client to connect to the cluster server is the target first communication instance, directly determine the target first communication instance corresponding to the target first client communication instance; If the first communication instance used by the second client is not the target first communication instance, the target first client session connection ID is determined from the N first communication instances to determine the target first communication instance. A communication instance. 7. The communication method for an online session according to claim 4, wherein the receiving the communication request with the target first client generated by the proxy server according to the communication service requirements of the second client, the The communication request with the target first client generated by the proxy server according to the communication service requirements of the second client includes: The proxy server performs business requirement target matching according to the received communication business requirement of the second client to obtain the target first client; The communication request with the target first client is generated according to the target first client and the second client. 8. A communication device for an online session, comprising: The communication establishment module, when receiving the connection request information of the N first clients according to the N first communication instances allocated by the proxy server, establishes the N first communication instances and the N first clients of the first clients End session connection, where N is an integer greater than 1; The target communication matching module determines the target first communication instance corresponding to the target first client from the N first communication instances according to the communication request of the second client and the target first client generated by the proxy server ; A communication connection module with the target, verifying the target first client ID in the communication request with the target first client and the target first client signature information of the target first client, and establishing the target first communication instance through the target first client A session communication connection between the second client and the target first client. 9. A computer device comprising a memory, a processor, and a computer program stored in the memory and executable on the processor, wherein the processor implements the computer program as claimed in the claims The communication method for the online conversation described in any one of 1 to 7. 10. A computer-readable storage medium storing a computer program, characterized in that, when the computer program is executed by a processor, the online session according to any one of claims 1 to 7 is implemented method of communication.

Images