CN114020412A - A message processing method, apparatus, device and storage medium - Google Patents
A message processing method, apparatus, device and storage medium Download PDFInfo
- Publication number
- CN114020412A CN114020412A CN202111300257.5A CN202111300257A CN114020412A CN 114020412 A CN114020412 A CN 114020412A CN 202111300257 A CN202111300257 A CN 202111300257A CN 114020412 A CN114020412 A CN 114020412A
- Authority
- CN
- China
- Prior art keywords
- customer service
- message
- information
- customer
- client
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
- G06F9/45533—Hypervisors; Virtual machine monitors
- G06F9/45558—Hypervisor-specific management and integration aspects
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
- G06F9/45533—Hypervisors; Virtual machine monitors
- G06F9/45558—Hypervisor-specific management and integration aspects
- G06F2009/4557—Distribution of virtual machine instances; Migration and load balancing
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention discloses a message processing method, a message processing device, message processing equipment and a storage medium. The method comprises the following steps: the method comprises the following steps that a core system receives a first message sent by a client system and a second message sent by a customer service system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information; the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the customer server system acquires the second message from the distributed cluster according to second subscription information.
Description
Technical Field
The embodiment of the invention relates to the technical field of computers, in particular to a message processing method, a message processing device, message processing equipment and a storage medium.
Background
Under the internet financial background, the remote online customer service platform can provide a one-to-many interaction mode, support and integrate contents such as intelligent service, multimedia service and the like, provide richer service channels for customers and fully meet the customer requirements. At present, most remote online customer service platforms are based on a browser/server mode and are mainly divided into four parts: the client access terminal provides an entrance for accessing a remote online platform for a client, and performs primary processing and recording on related information of the client; secondly, the customer service access end provides a customer service platform for customer service personnel, and supports the customer service personnel to process customer requirements such as character exchange, video verification and the like in real time on line; thirdly, a client scheduling and message communication part provides functions of client queuing, client service personnel allocation, message management service and the like; and fourthly, the online customer service management terminal provides functions of role and personnel management, parameter configuration, visitor record look-up after the fact and the like for the manager.
The existing realization mode of the remote online customer service platform establishes contact with a background system by adopting an interface calling mode based on an HTTP protocol in a client access part; and the customer service access part realizes the communication between the browser and the background system based on a Socket interface provided by the JavaApplet and Java. The JavaApplet is a small application program written by Java language, can be directly embedded into a browser webpage for running, and then completes communication with a server end through a Socket interface provided by Java. When the client is dispatched, the client service personnel are distributed by adopting a first-come-first-serve or longest waiting time priority mode, the session information is stored in a local memory of the server, the message management adopts JMS message management service, and JMS is a Java message service application program interface and is used for providing the functions of generating, sending and receiving messages between Java application programs.
The main advantages of the existing implementation mode of the remote online platform are that the function is simple and direct, but the limitation is large, the expandability is poor, and the requirement change of practical application is difficult to adapt. The existing remote online platform mainly has the following problems:
1. the client service access part realizes the communication between the browser and the background system based on the JavaApplet, and the JavaApplet is a technology which tends to eliminate the past service, and supports the JavaApplet to install the JVM plug-in at the browser end, thereby increasing the use cost of the system.
2. Based on a first-come-first-serve or longest-wait-time-first customer scheduling mode, only single attributes of customers are considered, targeted scheduling for customers of different levels is lacked, and differences of service efficiency of different customer service staff are not considered.
3. The client and the session information are stored in the local memory of the server and can only be used by the current server, and information sharing can not be realized among a plurality of servers, so that the usability and the expandability of the system are limited.
4. The method between each module is called in an RMI mode, the coupling is high, and the modular upgrading and reconstruction are difficult to perform independently.
Disclosure of Invention
Embodiments of the present invention provide a message processing method, an apparatus, a device, and a storage medium, which solve the problems of high system cost, high coupling, and incapability of implementing information sharing among multiple servers, and limiting availability and extensibility of a system, and also solve the problems of lack of targeted scheduling for clients of different levels and lack of difference in service efficiency between different customer service staff due to consideration of a single attribute of a client, and can improve system performance, and availability and extensibility of a system.
In a first aspect, an embodiment of the present invention provides a message processing method, including:
the method comprises the following steps that a core system receives a first message sent by a client system and a second message sent by a customer service system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information;
the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the customer server system acquires the second message from the distributed cluster according to second subscription information.
Further, before the core system receives the first message sent by the client system and the second message sent by the client system, the method further includes:
the core system acquires a client access instruction sent by at least one client system, wherein the client access instruction comprises: interface information and customer information;
the core system determines a customer grade according to the customer information;
and the core system determines target customer service according to the customer grade and the interface information.
Further, the core system determines the target customer service according to the customer level and the interface information, and includes:
the core system determines a target skill customer service group according to the interface information;
and selecting the target customer service in the target skill customer service group according to the customer grade.
Further, the core system determines a target skill customer service group according to the interface information, including:
if the interface information carries a financial identification, the core system determines the financial skill customer service group as a target skill customer service group;
and if the interface information carries an enterprise identifier, the core system determines the enterprise skill customer service group as a target skill customer service group.
Further, the method also comprises the following steps:
the method comprises the following steps that a core system acquires a customer service end system and establishes at least two skill customer service groups in advance, wherein each skill customer service group comprises: and if the same skill customer service group comprises at least two customer services, determining the service priority of each customer service according to the customer service information.
Further, the method also comprises the following steps:
the core system receives a customer service state information modification instruction sent by the customer service end system, and modifies the customer service state to a target state corresponding to the customer service state information modification instruction according to the customer service state information modification instruction;
after a customer service state modification success instruction is sent to the customer service end system, the core system receives a query instruction started by the customer service end system;
the core system determines the customer service state information to be in a first state according to the query instruction;
if the first state is the same as the target state, the customer service end system determines that the customer service state is successfully modified;
and if the first state is different from the target state, sending a modification instruction to the customer service end system so that the customer service end system modifies the customer service state information into the target state.
In a second aspect, an embodiment of the present invention further provides a message processing apparatus, where the apparatus includes: a core system, the core system comprising: the device comprises a receiving module and a storage module;
the receiving module is configured to receive a first message sent by a client system and a second message sent by a client system, where the first message includes: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information;
the storage module is configured to store the first message and the second message in a distributed cluster, so that the client system obtains the first message from the distributed cluster according to first subscription information, and the client system obtains the second message from the distributed cluster according to second subscription information.
Further, the core system further includes: the device comprises an acquisition module, a first determination module and a second determination module;
the obtaining module is configured to obtain, before a core system receives a first message sent by a client system and a second message sent by a client system, at least one client access instruction sent by the client system, where the client access instruction includes: interface information and customer information;
the first determining module is used for determining the customer grade according to the customer information;
and the second determining module is used for determining the target customer service according to the customer grade and the interface information.
In a third aspect, an embodiment of the present invention further provides an electronic device, which includes a memory, a processor, and a computer program stored in the memory and executable on the processor, where the processor executes the computer program to implement the message processing method according to any one of the embodiments of the present invention.
In a fourth aspect, the embodiment of the present invention further provides a computer-readable storage medium, on which a computer program is stored, and the computer program, when executed by a processor, implements the message processing method according to any one of the embodiments of the present invention.
The embodiment of the invention receives a first message sent by a client system and a second message sent by a customer service system through a core system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information; the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the client system acquires the second message from the distributed cluster according to second subscription information, thereby solving the problems of high system cost, high coupling, incapability of realizing information sharing among a plurality of servers and limitation on the availability and expandability of the system, and also solving the problems of only considering single attribute of a client, lack of targeted scheduling on clients of different levels and no consideration on difference of service efficiency of different client personnel, and improving the system performance, the availability and the expandability of the system.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the drawings needed to be used in the embodiments will be briefly described below, it should be understood that the following drawings only illustrate some embodiments of the present invention and therefore should not be considered as limiting the scope, and for those skilled in the art, other related drawings can be obtained according to the drawings without inventive efforts.
Fig. 1 is a flowchart of a message processing method in an embodiment of the present invention;
FIG. 1a is a schematic diagram of the general architecture of a remote online customer service platform in an embodiment of the invention;
FIG. 1b is a diagram of the overall architecture of a message interaction system in an embodiment of the present invention;
FIG. 1c is a block diagram of a general architecture of a cache system according to an embodiment of the present invention;
FIG. 1d is a diagram of a customer scheduling algorithm in an embodiment of the present invention;
fig. 2 is a schematic structural diagram of a message processing apparatus in an embodiment of the present invention;
fig. 3 is a schematic structural diagram of an electronic device in an embodiment of the present invention;
fig. 4 is a schematic structural diagram of a computer-readable storage medium containing a computer program in an embodiment of the present invention.
Detailed Description
The present invention will be described in further detail with reference to the accompanying drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the invention and are not limiting of the invention. It should be further noted that, for the convenience of description, only some of the structures related to the present invention are shown in the drawings, not all of the structures. In addition, the embodiments and features of the embodiments in the present invention may be combined with each other without conflict.
Before discussing exemplary embodiments in more detail, it should be noted that some exemplary embodiments are described as processes or methods depicted as flowcharts. Although a flowchart may describe the operations (or steps) as a sequential process, many of the operations can be performed in parallel, concurrently or simultaneously. In addition, the order of the operations may be re-arranged. The process may be terminated when its operations are completed, but may have additional steps not included in the figure. The processes may correspond to methods, functions, procedures, subroutines, and the like. In addition, the embodiments and features of the embodiments in the present invention may be combined with each other without conflict.
The term "include" and variations thereof as used herein are intended to be open-ended, i.e., "including but not limited to". The term "based on" is "based, at least in part, on". The term "one embodiment" means "at least one embodiment".
It should be noted that: like reference numbers and letters refer to like items in the following figures, and thus, once an item is defined in one figure, it need not be further defined and explained in subsequent figures. Meanwhile, in the description of the present invention, the terms "first", "second", and the like are used only for distinguishing the description, and are not to be construed as indicating or implying relative importance.
Fig. 1 is a flowchart of a message processing method according to an embodiment of the present invention, where the present embodiment is applicable to a message processing situation, and the method may be executed by a message processing apparatus according to an embodiment of the present invention, where the message processing apparatus may be implemented in a software and/or hardware manner, as shown in fig. 1, the message processing method specifically includes the following steps:
s110, a core system receives a first message sent by a client system and a second message sent by a customer service system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information.
For example, if the first customer identifier and the second customer identifier are for a one-pass session, the first customer identifier and the second customer identifier are the same, and the first customer identifier and the second customer identifier are the same, if the first customer identifier and the second customer identifier are for a different session, the first customer identifier and the second customer identifier are the same, or different, and the first customer identifier and the second customer identifier are the same, or different.
The first session information is the text information which is sent by the client system and is input when a client chats online and customer service, and the second session information is the text information which is sent by the customer service system and is input when the customer service answers a client question online.
Specifically, before the core system receives the first message sent by the client system and the second message sent by the client system, the method further includes: the core system acquires a client access instruction sent by at least one client system, wherein the client access instruction comprises: interface information and customer information; the core system determines a customer grade according to the customer information; and the core system determines target customer service according to the customer grade and the interface information. And the core system sends the client identification and the customer service identification corresponding to the target customer service to the client system and the customer service system. And the client system acquires the first message from the distributed cluster according to the client identifier and the client identifier corresponding to the target client service, and the client system acquires the second message from the distributed cluster according to the client identifier and the client identifier corresponding to the target client service.
S120, the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the customer server system acquires the second message from the distributed cluster according to second subscription information.
The first subscription information may be a client identifier and a customer service identifier determined by the core system according to the client access instruction. For example, the client access instruction carries a client identifier and interface information, and the client service identifier is determined according to the interface information. Or, the client access instruction carries client information and interface information, where the client information includes: and the customer identification is used for determining the customer grade according to the customer information and determining the customer service identification according to the customer grade and the interface information.
Specifically, the way for the core system to store the first message and the second message in the distributed cluster may be: and the core system stores the first message and the second message to a message queue through message queue middleware, and stores the message queue to a distributed cluster.
Specifically, the client system and the client system respectively send messages to the core system, the core system generates messages to the message queue, the client system and the client system respectively consume respective subscribed messages to perform related processing, in addition, the client system also consumes internal messages produced by the client system per se to perform state synchronization and the like, through the message queue middleware, the systems are interacted through messages, the coupling among the systems is reduced, and the client system ensures the accuracy of the seat state through a write-back mechanism of self-receiving internal messages.
Optionally, before the core system receives the first message sent by the client system and the second message sent by the client system, the method further includes:
the core system acquires a client access instruction sent by at least one client system, wherein the client access instruction comprises: interface information and customer information;
the core system determines a customer grade according to the customer information;
and the core system determines target customer service according to the customer grade and the interface information.
The manner of determining the customer grade according to the customer information by the core system may be: inquiring a database according to the customer identification to obtain a customer grade corresponding to the customer identification; the mode of the core system determining the customer grade according to the customer information can also be as follows: the database is queried according to the customer information to obtain the customer grade corresponding to the customer information, which is not limited in the embodiment of the present invention.
The method for determining the target customer service by the core system according to the customer level and the interface information may be: and the core system determines a target skill customer service group according to the interface information, and selects the target customer service in the target skill customer service group according to the customer grade. The method for the core system to determine the target customer service according to the customer level and the interface information can also be as follows: the core system determines a target skill customer service group according to the interface information, and determines the target customer service according to the priority of the customer service for the skill group, the maximum number of customer service receptions in the skill group and the customer level, which is not limited in the embodiment of the invention.
Specifically, as shown in fig. 1a, the generation manner of the client access instruction may be: after the customer enters through the internet bank, generating an access instruction; the generation mode of the client access instruction can also be as follows: after a client enters through a visitor entrance, generating an access instruction; the generation mode of the client access instruction can also be as follows: after entering through a mobile phone APP, a user generates an access instruction; the generation mode of the client access instruction can also be as follows: after entering through the chat application, the user generates an access instruction; the generation mode of the client access instruction can also be as follows: and after entering through the VTM, the user generates an access instruction. The client access instruction comprises: the core system schedules clients according to the client grades and the interface information and determines client service identifications corresponding to client access instructions.
In an example, as shown in fig. 1b and fig. 1c, an embodiment of the present invention provides a cache system based on Redis and a Session sharing design scheme, where a client server system obtains a client server chat message from a Redis cluster; the core system stores the seat state information, the client information, the skill group information, the queuing information and the session information in a distributed cluster, and utilizes the characteristic of a Redis single thread to realize distributed locking by using a package Redisson frame; other systems such as a customer service system, a management system and the like use Redis to store agent login information and authentication information, cache hot spot data and reduce database access. The client system, the client server system and the management system store the Session information in the Redis, Session sharing is achieved, the browser requests any one server to acquire the Session information under a distributed environment, and the problem that the Session of a traditional web system cannot be shared is solved. All information stored in Redis is set with expiration time, so that excessive memory occupation caused by that the application cannot be deleted is prevented, and meanwhile, Redis data is persisted to a disk by using a Redis persistence mechanism, so that accidental data loss is prevented.
Optionally, the determining, by the core system, the target customer service according to the customer level and the interface information includes:
the core system determines a target skill customer service group according to the interface information;
and selecting the target customer service in the target skill customer service group according to the customer grade.
Specifically, the manner of selecting the target customer service in the target skill customer service group according to the customer level may be: if the number of the target skill customer service groups is one, directly selecting the target customer service with the highest priority in the target skill customer service groups according to the customer level; and if the number of the target skill customer service groups is two, determining the corresponding relation between the customer service and the customers according to the priority of the customer service aiming at the two target skill customer service groups and the number of the customers which can be received by the customer service in the target skill customer service group at most.
Optionally, the determining, by the core system, the target skill customer service group according to the interface information includes:
if the interface information carries a financial identification, the core system determines the financial skill customer service group as a target skill customer service group;
and if the interface information carries an enterprise identifier, the core system determines the enterprise skill customer service group as a target skill customer service group.
Optionally, the method further includes:
the method comprises the following steps that a core system acquires a customer service end system and establishes at least two skill customer service groups in advance, wherein each skill customer service group comprises: and if the same skill customer service group comprises at least two customer services, determining the service priority of each customer service according to the customer service information.
Optionally, the method further includes:
the core system receives a customer service state information modification instruction sent by the customer service end system, and modifies the customer service state to a target state corresponding to the customer service state information modification instruction according to the customer service state information modification instruction;
after a customer service state modification success instruction is sent to the customer service end system, the core system receives a query instruction started by the customer service end system;
the core system determines the customer service state information to be in a first state according to the query instruction;
if the first state is the same as the target state, the customer service end system determines that the customer service state is successfully modified;
and if the first state is different from the target state, sending a modification instruction to the customer service end system so that the customer service end system modifies the customer service state information into the target state.
Specifically, a client system sends a customer service state information modification instruction to a core system, the customer service state is modified to a target state corresponding to the customer service state information modification instruction according to the customer service state information modification instruction, after the core system sends a customer service state modification success instruction to the customer service system, the core system receives an inquiry instruction started by the customer service system, if the customer service state information is the same as the target state, the customer service state modification is successful, and if the customer service state information is different from the target state, the customer service end modifies the customer service state information to the target state.
In an example, as shown in fig. 1d, if a skill set, B skill set, and C skill set are simultaneously each incoming 3 customers, skill set incoming line priority a is 2, B and C are 1, a skill set incoming line priority > B skill set incoming line priority and C skill set incoming line priority, and B skill set incoming line priority and C skill set incoming line priority are the same. 2. Agent skill set service receptivity: 1 agent of skill group A can take care of 3 customers, 1 agent of skill group B can take care of 2 customers, and 1 agent of skill group C can take care of 1 customer. So 3 customers of skill set a will be assigned a priority to the server side up, followed by B and C. If the first seat belongs to the skill group A and the skill group B, the service priority of the first seat for the skill group A is higher than that of the first seat for the skill group B, and one seat in the skill group A can receive 3 customers, the service condition of the first seat is as follows: and 3 customers of the skill group A are received, if the second seat belongs to the skill group B and the skill group C, the service priority of the second seat for the skill group B is higher than that of the second seat for the skill group C, one seat in the skill group B can receive 2 customers, one seat in the skill group C can receive 1 customer, and the service condition of the second seat is as follows: 2 customers of reception skill group B, if agent C belongs to skill group A, skill group B and skill group C, the service priority of agent C to skill group C is higher than that of agent C to skill group B, the service priority of agent C to skill group B is higher than that of agent C to skill group A, and the incoming line service condition of agent C is as follows: one customer of reception skill set C, one customer of reception skill set B.
The embodiment of the invention provides a customer scheduling algorithm based on customer service skill priority and skill service priority. The online customer service personnel can configure a plurality of skill groups, a one-to-many mode is adopted when external service is carried out, each skill group can have different skill priorities, meanwhile, different service priorities are provided for each customer service, and the service efficiency of the customer service personnel can be improved by reasonably utilizing the different priorities. The customer service skill priority refers to that when the telephone traffic is busy, the conversation of the skill group with high priority is preferentially distributed to the seats under the condition that a plurality of skill queues are queued at the same time, and the priority takes the skill group as a dimension. The skill service priority refers to that when the telephone traffic is busy and a plurality of skills are queued, the system distributes the telephone traffic to the seat end according to the priority of the skills possessed by the seat, and the priority takes customer service personnel as the dimension.
According to the technical scheme of the embodiment, a core system is used for receiving a first message sent by a client system and a second message sent by a client system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information; the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the client system acquires the second message from the distributed cluster according to second subscription information, thereby solving the problems of high system cost, high coupling, incapability of realizing information sharing among a plurality of servers and limitation on the availability and expandability of the system, and also solving the problems of only considering single attribute of a client, lack of targeted scheduling on clients of different levels and no consideration on difference of service efficiency of different client personnel, and improving the system performance, the availability and the expandability of the system.
Fig. 2 is a schematic structural diagram of a message processing apparatus according to an embodiment of the present invention. The present embodiment may be applied to the case of message processing, where the message processing apparatus may be implemented in a software and/or hardware manner, and the apparatus may be integrated in any device that provides a message processing function, as shown in fig. 2, where the message processing apparatus specifically includes: a core system, the core system comprising: a receiving module 210 and a storing module 220.
The receiving module is configured to receive a first message sent by a client system and a second message sent by a client system, where the first message includes: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information;
the storage module is configured to store the first message and the second message in a distributed cluster, so that the client system obtains the first message from the distributed cluster according to first subscription information, and the client system obtains the second message from the distributed cluster according to second subscription information.
Optionally, the core system further includes: the device comprises an acquisition module, a first determination module and a second determination module;
the obtaining module is configured to obtain, before a core system receives a first message sent by a client system and a second message sent by a client system, at least one client access instruction sent by the client system, where the client access instruction includes: interface information and customer information;
the first determining module is used for determining the customer grade according to the customer information;
and the second determining module is used for determining the target customer service according to the customer grade and the interface information.
The product can execute the method provided by any embodiment of the invention, and has corresponding functional modules and beneficial effects of the execution method.
According to the technical scheme of the embodiment, a core system is used for receiving a first message sent by a client system and a second message sent by a client system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information; the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the client system acquires the second message from the distributed cluster according to second subscription information, thereby solving the problems of high system cost, high coupling, incapability of realizing information sharing among a plurality of servers and limitation on the availability and expandability of the system, and also solving the problems of only considering single attribute of a client, lack of targeted scheduling on clients of different levels and no consideration on difference of service efficiency of different client personnel, and improving the system performance, the availability and the expandability of the system.
Fig. 3 is a schematic structural diagram of an electronic device according to a third embodiment of the present invention. FIG. 3 illustrates a block diagram of an electronic device 312 suitable for use in implementing embodiments of the present invention. The electronic device 312 shown in fig. 3 is only an example, and should not bring any limitation to the functions and the scope of the use of the embodiment of the present invention. Device 312 is a computing device for typical trajectory fitting functions.
As shown in fig. 3, electronic device 312 is in the form of a general purpose computing device. The components of the electronic device 312 may include, but are not limited to: one or more processors 316, a storage device 328, and a bus 318 that couples the various system components including the storage device 328 and the processors 316.
The processor 316 executes various functional applications and data processing by executing programs stored in the storage 328, for example, implementing the message processing method provided by the above-described embodiment of the present invention:
the method comprises the following steps that a core system receives a first message sent by a client system and a second message sent by a customer service system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information;
the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the customer server system acquires the second message from the distributed cluster according to second subscription information.
Fig. 4 is a schematic structural diagram of a computer-readable storage medium containing a computer program according to an embodiment of the present invention. Embodiments of the present invention provide a computer-readable storage medium 61, on which a computer program 610 is stored, which when executed by one or more processors implements the message processing method as provided by all embodiments of the invention of the present application:
the method comprises the following steps that a core system receives a first message sent by a client system and a second message sent by a customer service system, wherein the first message comprises: a first customer identification, a first customer service identification, first session information, and state class information, the second message comprising: the second client identifier, the second customer service identifier, the second session information and the state class information;
the core system stores the first message and the second message to a distributed cluster, so that the client system acquires the first message from the distributed cluster according to first subscription information, and the customer server system acquires the second message from the distributed cluster according to second subscription information.
Any combination of one or more computer-readable media may be employed. The computer readable medium may be a computer readable signal medium or a computer readable storage medium or any combination of the two. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples (a non-exhaustive list) of the computer readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
A computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device.
Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
In some embodiments, the clients, servers may communicate using any currently known or future developed network Protocol, such as HTTP (Hyper Text Transfer Protocol), and may interconnect with any form or medium of digital data communication (e.g., a communications network). Examples of communication networks include a local area network ("LAN"), a wide area network ("WAN"), the Internet (e.g., the Internet), and peer-to-peer networks (e.g., ad hoc peer-to-peer networks), as well as any currently known or future developed network.
The computer readable medium may be embodied in the electronic device; or may exist separately without being assembled into the electronic device.
Computer program code for carrying out operations for aspects of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C + +, or the like, as well as conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any type of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet service provider).
The flowchart and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present disclosure. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams and/or flowchart illustration, and combinations of blocks in the block diagrams and/or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The units described in the embodiments of the present disclosure may be implemented by software or hardware. Where the name of an element does not in some cases constitute a limitation on the element itself.
The functions described herein above may be performed, at least in part, by one or more hardware logic components. For example, without limitation, exemplary types of hardware logic components that may be used include: field Programmable Gate Arrays (FPGAs), Application Specific Integrated Circuits (ASICs), Application Specific Standard Products (ASSPs), systems on a chip (SOCs), Complex Programmable Logic Devices (CPLDs), and the like.
In the context of this disclosure, a machine-readable medium may be a tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. The machine-readable medium may be a machine-readable signal medium or a machine-readable storage medium. A machine-readable medium may include, but is not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any suitable combination of the foregoing. More specific examples of a machine-readable storage medium would include an electrical connection based on one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing.
It is to be noted that the foregoing is only illustrative of the preferred embodiments of the present invention and the technical principles employed. It will be understood by those skilled in the art that the present invention is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, although the present invention has been described in greater detail by the above embodiments, the present invention is not limited to the above embodiments, and may include other equivalent embodiments without departing from the spirit of the present invention, and the scope of the present invention is determined by the scope of the appended claims.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111300257.5A CN114020412B (en) | 2021-11-04 | 2021-11-04 | A message processing method, device, equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111300257.5A CN114020412B (en) | 2021-11-04 | 2021-11-04 | A message processing method, device, equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114020412A true CN114020412A (en) | 2022-02-08 |
| CN114020412B CN114020412B (en) | 2025-06-17 |
Family
ID=80060732
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111300257.5A Active CN114020412B (en) | 2021-11-04 | 2021-11-04 | A message processing method, device, equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114020412B (en) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN116132927A (en) * | 2022-11-28 | 2023-05-16 | 深圳市云洲创新科技有限公司 | Service quality assurance method and system for unmanned equipment cluster message |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101909019A (en) * | 2010-07-27 | 2010-12-08 | 中兴通讯股份有限公司 | Method and system for processing request message |
| US20160371756A1 (en) * | 2015-06-19 | 2016-12-22 | T-Mobile, Usa, Inc. | Seamless sharing of customer support chat sessions |
| CN111212135A (en) * | 2019-12-31 | 2020-05-29 | 北京金山云网络技术有限公司 | Message subscription method, device, system, electronic equipment and storage medium |
| CN111726462A (en) * | 2019-03-22 | 2020-09-29 | 阿里巴巴集团控股有限公司 | Resource scheduling system, method, device and electronic device in customer service system |
| CN112613919A (en) * | 2020-12-31 | 2021-04-06 | 中国农业银行股份有限公司 | Information processing method and related device |
| CN112634510A (en) * | 2020-12-17 | 2021-04-09 | 广州佰锐网络科技有限公司 | Intelligent queuing system for online business handling |
| CN113329069A (en) * | 2021-05-24 | 2021-08-31 | 西安统信软件技术有限公司 | Instant messaging method, system and computing equipment |
-
2021
- 2021-11-04 CN CN202111300257.5A patent/CN114020412B/en active Active
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101909019A (en) * | 2010-07-27 | 2010-12-08 | 中兴通讯股份有限公司 | Method and system for processing request message |
| US20160371756A1 (en) * | 2015-06-19 | 2016-12-22 | T-Mobile, Usa, Inc. | Seamless sharing of customer support chat sessions |
| CN111726462A (en) * | 2019-03-22 | 2020-09-29 | 阿里巴巴集团控股有限公司 | Resource scheduling system, method, device and electronic device in customer service system |
| CN111212135A (en) * | 2019-12-31 | 2020-05-29 | 北京金山云网络技术有限公司 | Message subscription method, device, system, electronic equipment and storage medium |
| CN112634510A (en) * | 2020-12-17 | 2021-04-09 | 广州佰锐网络科技有限公司 | Intelligent queuing system for online business handling |
| CN112613919A (en) * | 2020-12-31 | 2021-04-06 | 中国农业银行股份有限公司 | Information processing method and related device |
| CN113329069A (en) * | 2021-05-24 | 2021-08-31 | 西安统信软件技术有限公司 | Instant messaging method, system and computing equipment |
Non-Patent Citations (2)
| Title |
|---|
| ALEXANDER SMIRNOV; MIKHAIL PASHKIN; NIKOLAI CHILOV: "Personalized customer service management for networked enterprises", 2005 IEEE INTERNATIONAL TECHNOLOGY MANAGEMENT CONFERENCE (ICE), 28 April 2016 (2016-04-28) * |
| 周哲敏: "多媒体呼叫中心在线客服系统的设计与实现", 中国优秀硕士学位论文全文数据库信息科技辑, 15 April 2015 (2015-04-15) * |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN116132927A (en) * | 2022-11-28 | 2023-05-16 | 深圳市云洲创新科技有限公司 | Service quality assurance method and system for unmanned equipment cluster message |
| CN116132927B (en) * | 2022-11-28 | 2024-08-06 | 深圳市云洲创新科技有限公司 | Service quality assurance method and system for unmanned equipment cluster message |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114020412B (en) | 2025-06-17 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110096344B (en) | Task management method, system, server cluster and computer readable medium | |
| US8554855B1 (en) | Push notification delivery system | |
| US6895425B1 (en) | Using an expert proxy server as an agent for wireless devices | |
| US8886787B2 (en) | Notification for a set of sessions using a single call issued from a connection pool | |
| WO2021088641A1 (en) | Data transmission method, data processing method, data reception method and device, and storage medium | |
| WO2018103709A1 (en) | Group conversation processing method, terminal, server, and system, and storage medium | |
| US20090287761A1 (en) | Cached message distribution via http redirects | |
| US7836123B2 (en) | System and method for non-HTTP session based publish/subscribe support using pre-emptive subscriptions | |
| US10454795B1 (en) | Intermediate batch service for serverless computing environment metrics | |
| US20130132582A1 (en) | Apparatus and method for supporting qos in middleware for data distribution service | |
| CN112600878B (en) | Data transmission method and device | |
| CN101926138A (en) | Method and system for messaging in a messaging network | |
| WO2019047568A1 (en) | User call processing method, apparatus, computer device, and storage medium | |
| CN114866528A (en) | Data communication method based on MQTT and Websocket | |
| US10409656B2 (en) | Efficiently receiving messages across a large number of messaging entities | |
| CN112686528A (en) | Method, apparatus, server and medium for allocating customer service resources | |
| CN114020412B (en) | A message processing method, device, equipment and storage medium | |
| US20130066828A1 (en) | Scale-out system to acquire event data | |
| US20090132582A1 (en) | Processor-server hybrid system for processing data | |
| CN116319810A (en) | Distributed system flow control method, device, equipment, medium and product | |
| CN112713969B (en) | Data transmission method and device and system using the method | |
| CN102150151A (en) | Asynchronous queued messaging for Web applications | |
| CN114629866A (en) | Method for establishing real-time communication between multiple systems by random online customer service | |
| US20190109945A1 (en) | Technologies for managing unresolved customer interactions | |
| JP2009157786A (en) | Message transmission control method, message transmission control device, and message transmission control program |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |