CN115514814A - A message system, message processing method, device and equipment - Google Patents

Abstract

The application discloses a message system, a message processing method, a device and equipment, comprising: the message processing module is used for carrying out initialization operation, submission operation or cancellation operation on the business message corresponding to the business service of the business system; the service is a service corresponding to an access request of the service system, and the access request is a request of the service system for requesting to access the message system; the message routing module is used for storing basic information of the service message so that the message processing module can perform corresponding initialization operation, submission operation or cancellation operation on the service message according to the basic information. The message processing module and the message routing module of the message system interact with the service system to realize the initialization operation, the submission operation or the cancellation operation of the service message, and the message processing efficiency and the flexibility are improved.

Description

A message system, message processing method, device and equipment

technical field

The present invention relates to the technical field of communications, in particular to a message system, a message processing method, device and equipment.

Background technique

Message middleware is a common component in software systems. It is mostly used in communication scenarios between multiple services under the microservice architecture, and usually has message accumulation and persistence capabilities. The use of message middleware can alleviate communication loss and timeout problems caused by fluctuations or inconsistencies in processing capabilities between services.

For transaction-based message middleware that uses the "initialization→commit/cancel" mode to send messages, the producer needs to initialize the message, execute business logic, and then submit or cancel to decide whether to push the message to the consumer. The native API of this type of message middleware restricts the content of business messages to be provided in the initialization phase and cannot be modified during message delivery, which reduces the efficiency and maintainability of message delivery.

Contents of the invention

In view of this, the purpose of the present invention is to provide a message system, message processing method, device, and equipment, and the present invention also provides a corresponding storage medium, which can improve message processing efficiency and flexibility. The specific plan is as follows:

The first aspect of the present application provides a message system, including: a message processing module and a message routing module, wherein:

The message processing module is configured to perform an initialization operation, a submission operation, or a cancellation operation on a business message corresponding to a business service of the business system; wherein, the business service is a service corresponding to an access request of the business system, and the The access request is a request for the service system to access the message system;

The message routing module is configured to store the basic information of the service message, so that the message processing module performs a corresponding initialization operation, submission operation or cancellation operation on the service message according to the basic information.

Optionally, the message processing module includes a message initialization unit, a message submission unit and a message cancellation unit, wherein:

The message initialization unit is configured to perform an initialization operation according to the message to be initialized corresponding to the initialization service of the business system;

The message submission unit is configured to perform a submission operation according to the message to be submitted corresponding to the message submission service of the business system;

The message cancellation unit is configured to perform a cancellation operation according to the message to be canceled corresponding to the message cancellation service of the business system.

Optionally, the message initialization unit is configured to configure the basic information of the message to be initialized, and store the configured basic information of the message to be initialized in the remote dictionary service. Message routing module.

Optionally, the configured message to be initialized is also set with a corresponding expiration time.

Optionally, the message submission unit is configured to obtain the delivery address of the message to be submitted from the basic information of the message routing module, and send the message to be submitted and the corresponding delivery address to the message middleware, so that the message middleware delivers the message to be submitted according to the delivery address.

Optionally, the message processing module also includes:

The first state updating unit is configured to update the state corresponding to the service message to an initialization state after performing an initialization operation on the service message;

The second status updating unit is configured to update the status corresponding to the business message to the submitted status after the submit operation is performed on the business message;

The third status updating unit is configured to update the status corresponding to the business message to a canceled status after the cancel operation is performed on the business message.

The second aspect of the present application provides a message processing method, based on the aforementioned message system, including:

Obtaining an access request of a business system and an application interface of a business service corresponding to the access request provided by the messaging system; wherein, the access request is a request from the business system to access the messaging system;

Establish a connection relationship between the business system and the message system through the application interface, and use the message system to initialize, submit or cancel the business message corresponding to the business service, so that the business The service responds.

Optionally, the application interface is constructed based on Hypertext Transfer Protocol.

The third aspect of the present application provides a message processing device based on the aforementioned message system, including:

An acquisition module, configured to acquire an access request of a business system and an application interface of a business service provided by the message system corresponding to the access request; wherein, the access request is a request from the business system to access the Message system requests;

A service response module, configured to establish a connection relationship between the business system and the message system through the application interface, and use the message system to process business messages corresponding to the business service, so as to respond to the business service to respond.

The fourth aspect of the present application provides an electronic device, the electronic device includes a processor and a memory; wherein the memory is used to store a computer program, and the computer program is loaded and executed by the processor to realize the aforementioned message processing method.

A fifth aspect of the present application provides a computer-readable storage medium, where computer-executable instructions are stored in the computer-readable storage medium, and when the computer-executable instructions are loaded and executed by a processor, the aforementioned message processing method is implemented .

In the present application, the message system includes a message processing module and a message routing module, wherein the message processing module is used to initialize, submit or cancel business messages corresponding to the business services of the business system; Wherein, the business service is a service corresponding to an access request of the business system, and the access request is a request of the business system to access the message system; the message routing module is configured to store the Basic information of the service message, so that the message processing module performs corresponding initialization, submission or cancellation operations on the service message according to the basic information. This application interacts with the business system through the message processing module and the message routing module of the message system to realize the initialization operation, submission operation or cancellation operation of the business message, and improve the efficiency and flexibility of message processing .

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only It is an embodiment of the present invention, and those skilled in the art can also obtain other drawings according to the provided drawings without creative work.

FIG. 1 is a structural diagram of a messaging system provided by the present application;

FIG. 2 is a specific message system interaction structure diagram provided by the present application;

Fig. 3 is a kind of specific message system implementation logic diagram provided by the present application;

FIG. 4 is a flow chart of message initialization provided by the present application;

FIG. 5 is a flow chart of message submission provided by this application;

FIG. 6 is a flow chart of message cancellation provided by this application;

FIG. 7 is a flowchart of a message processing method provided by the present application;

FIG. 8 is a schematic structural diagram of a message processing device provided by the present application;

FIG. 9 is a structural diagram of a message processing electronic device provided by the present application.

detailed description

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

Existing message middleware for transaction-based messages uses the "initialization→commit/cancel" mode to send messages. The producer needs to initialize the message, execute business logic, and then submit or cancel to decide whether to push the message to the consumer. The native API of this type of message middleware restricts the content of business messages to be provided in the initialization phase and cannot be modified during message delivery, which reduces the efficiency and maintainability of message delivery. In view of the above-mentioned technical defects, this application provides a message system and a message processing solution, through which the message processing module and the message routing module of the message system interact with the service system to realize the initialization of the service message Operation, submit operation or cancel operation, improve the efficiency and flexibility of message processing.

FIG. 1 is a structural diagram of a message system provided by this application. Referring to Fig. 1, the message system 01 includes a message processing module 011 and a message routing module 012, wherein:

The message processing module 011 is configured to perform an initialization operation, a submission operation, or a cancellation operation on a business message corresponding to a business service of the business system; wherein, the business service is a service corresponding to an access request of the business system, The access request is a request for the service system to access the message system. The message routing module 012 is configured to store the basic information of the service message, so that the message processing module performs corresponding initialization operation, submission operation or cancellation operation on the service message according to the basic information. That is, the message routing module 012 stores different message types and corresponding topics and delivery methods, and provides data to the message processing module 011 . The business service may be initializing a business message, submitting a business message, canceling a business message, and the like. In this embodiment, the message processing module 011 and the message routing module correspond to different programs, and may be virtualized servers under the framework of containerized microservices.

Further, FIG. 2 is a specific message system interaction structure diagram provided by the present application. As shown in FIG. 2 , the message system 01 performs data interaction with the business system 02 and the message middleware 03, To respond to the business message corresponding to the business service of the business system 02 . In this embodiment, the message system 01 provides an interface of the Hypertext Transfer Protocol (HTTP protocol) for the business service, without introducing additional dependencies, and access can be completed only by using a commonly used HTTP client/server. The business system 02 directly sends an HTTP request to the service to complete the operations of message initialization, submission, and cancellation. Of course, in addition to the HTTP protocol, the message system 01 retains the scalability of accessing other protocols, such as the Thrift protocol, which is not limited in this embodiment of the present application.

In this embodiment, the business system 02 can be various programs that need to send communication messages. Here, it can be a payment transaction system, and the transaction system sends transaction-related data messages to the accounting system through the message system 01 . The service message refers to a message sent by the service system 02 to the message middleware 03 through the message system 01 . The message middleware 03 in this embodiment is RocketMQ, wherein RocketMQ is a widely used message middleware, its message persistence accumulation capability, transaction-based message, retry push and other functions are widely used in payment In the software system of trade-related industries. Through the message system 01 to transfer the business messages of the business system 02, the content of the business messages can be changed during the message initialization and message submission stages, which improves the maintainability of the message system 01 and flexibility, for details, refer to the implementation logic shown in FIG. 3 .

Correspondingly, the message processing module 011 includes a message initialization unit, a message submission unit, and a message cancellation unit, wherein: the message initialization unit is configured to perform an initialization operation according to the message to be initialized corresponding to the initialization service of the business system 02; The message submission unit is used to perform a submit operation according to the message to be submitted corresponding to the message submission service of the business system 02; the message cancellation unit is used to perform a cancellation operation according to the message to be canceled corresponding to the message cancellation service of the business system 02 .

Specifically, the message initialization unit is configured to configure the basic information of the message to be initialized, and store the configured basic information of the message to be initialized in the message through a remote dictionary service Routing module 012. The initialization message will create a message record inside the message system 01, which stores information such as the id, content, and delivery status of the business message. Wherein, the id of the business message is generally a unique id assigned to each business message by the business system 02, usually a character string such as a transaction order number. In the message system 01, different message types correspond to the topic to which the service message will be delivered and the interface address for checking the message status. The delivery status of the business message in the message system 01 can be divided into initialization status, submitted status, canceled status, etc., and the delivery status is mainly used in the context of message status review.

As shown in Figure 4, when an initialization operation is initiated, the basic information of the message configuration is obtained first through the message routing module 012, and then the basic information is initialized and correspondingly configured, and the configured message to be initialized The basic information of the message is stored in the message routing module 012 through a remote dictionary service. Of course, in order to improve the response efficiency, the configured basic information of the message to be initialized may also be directly stored in the message processing module 01 through a remote dictionary service. The remote dictionary service (Redis) is a remote memory database with high availability, high concurrency and high scalability. In addition, in order to improve the timeliness of the message, the message to be initialized after the configuration can also be set with a corresponding expiration time. The information about the business message stored in Redis includes message type, message id, message delivery status, business message content, and the like.

The message submission unit is configured to obtain the delivery address of the message to be submitted from the basic information of the message routing module 012, and send the message to be submitted and the corresponding delivery address to the message middleware 03 , so that the message middleware 03 delivers the message to be submitted according to the delivery address. As shown in Figure 5, when a message submission operation is initiated, the business message that needs to be submitted is determined by querying Redis, and then the basic configuration of the business message is queried through the message routing module 012, and then the business message is sent to RocketMQ , and modify the delivery status of the message record in the system to the submitted status. During this process, the content of the business message can be updated. In this embodiment, the state of the message to be submitted is the initialization state, that is, when the message is submitted, the content of the message whose state is initialization is sent to the corresponding topic in RocketMQ. Among them, topic (topic) is a concept in RocketMQ, which is equivalent to the destination of the message. Each topic can have one or more subscribers, that is, consumer 04. Whenever a new message is sent to the topic, the consumer 04 can get this message.

As shown in Figure 6, when a message cancellation operation is initiated, the business message that needs to be canceled is determined by querying Redis, and then its delivery status is changed to a canceled status, and subsequent submission or status review cannot be initiated. In this embodiment, generally, the state of the service message whose delivery state is the initialization state is modified to obtain the service message whose state is the cancel state.

Therefore, it is not difficult to understand that the message processing module 011 also includes: a first state updating unit, configured to update the state corresponding to the business message to an initialization state after performing an initialization operation on the business message; A unit, configured to update the status corresponding to the business message to the submitted status after performing a submit operation on the business message; a third status update unit, configured to update the status of the business message after canceling the business message The status corresponding to the message is updated to Canceled.

It can be seen that the message system in the embodiment of the present application includes a message processing module and a message routing module, wherein the message processing module is used to initialize and submit business messages corresponding to the business services of the business system or cancel operation; wherein, the business service is a service corresponding to an access request of the business system, and the access request is a request of the business system to access the message system; the message routing module, It is used to store the basic information of the service message, so that the message processing module performs corresponding initialization operation, submission operation or cancellation operation on the service message according to the basic information. In the embodiment of the present application, the message processing module and the message routing module of the message system interact with the service system to realize the initialization operation, submission operation or cancellation operation of the service message, and improve message processing efficiency and flexibility.

FIG. 7 is a flow chart of a message processing method provided by an embodiment of the present application. Referring to Fig. 7, the message processing method is based on the message system described in the foregoing embodiments, including:

S11: Obtain the access request of the business system and the application interface of the business service provided by the message system corresponding to the access request; wherein, the access request is the service system's request to access the message system ask.

In this embodiment, the access request of the business system and the application interface of the business service provided by the message system corresponding to the access request are obtained first. The access request is a request for the service system to access the message system, and the service service may be initializing a service message, submitting a service message, canceling a service message, and the like.

S12: Establish a connection relationship between the business system and the message system through the application interface, and use the message system to initialize, submit, or cancel the business message corresponding to the business service, so as to The above business service responds.

In this embodiment, after obtaining the access request of the business system and the application interface of the business service corresponding to the access request provided by the message system, the business system is further connected to the The message system establishes a connection relationship, and uses the message system to perform an initialization operation, a submission operation, or a cancellation operation on the business message corresponding to the business service, so as to respond to the business service. The message system fully takes over the interaction with the message middleware, and the business system can be accessed and used only by coding the interface provided by the message system, saving learning costs and dependency management costs, and improving development efficiency and maintainability. In addition, the application interface described in this embodiment can be constructed based on the hypertext transfer protocol, and of course, the extensibility of accessing other protocols, such as the Thrift protocol, can also be reserved.

It can be seen that in the embodiment of the present application, the access request of the business system and the application interface of the business service corresponding to the access request provided by the message system are obtained first, and then the business system is connected with the message through the application interface. The system establishes a connection relationship, and uses the message system to perform an initialization operation, a submission operation or a cancellation operation on the business message corresponding to the business service, so as to respond to the business service. The message system in this embodiment provides application interfaces of different types of access services, and the service system connects to the message system through the application interface to indirectly perform initialization operations, submission operations, or cancellation operations on the service messages, Avoid the limitation caused by directly processing the business message through the native application interface of the message middleware.

Referring to Fig. 8, the embodiment of the present application also discloses a message processing device correspondingly. The message processing device is based on the message system described in the foregoing embodiments, including:

The obtaining module 11 is used to obtain the access request of the business system and the application interface of the business service corresponding to the access request provided by the message system; request from the messaging system;

The service response module 12 is configured to establish a connection relationship between the business system and the message system through the application interface, and use the message system to process business messages corresponding to the business service, so as to respond to the business The service responds.

It can be seen that in the embodiment of the present application, the access request of the business system and the application interface of the business service corresponding to the access request provided by the message system are obtained first, and then the business system is connected with the message through the application interface. The system establishes a connection relationship, and uses the message system to perform an initialization operation, a submission operation or a cancellation operation on the business message corresponding to the business service, so as to respond to the business service. The message system in this embodiment provides application interfaces of different types of access services, and the service system connects to the message system through the application interface to indirectly perform initialization operations, submission operations, or cancellation operations on the service messages, Avoid the limitation caused by directly processing the business message through the native application interface of the message middleware.

Further, the embodiment of the present application also provides an electronic device. Fig. 9 is a structural diagram of an electronic device 20 according to an exemplary embodiment, and the content in the diagram should not be regarded as any limitation on the application scope of this application.

FIG. 9 is a schematic structural diagram of an electronic device 20 provided by an embodiment of the present application. The electronic device 20 may specifically include: at least one processor 21 , at least one memory 22 , a power supply 23 , a communication interface 24 , an input/output interface 25 and a communication bus 26 . Wherein, the memory 22 is used to store a computer program, and the computer program is loaded and executed by the processor 21, so as to implement relevant steps in the message processing method disclosed in any of the foregoing embodiments. In addition, the electronic device 20 in this embodiment may specifically be a server.

In this embodiment, the power supply 23 is used to provide working voltage for each hardware device on the electronic device 20; the communication interface 24 can create a data transmission channel between the electronic device 20 and external devices, and the communication protocol it follows is applicable Any communication protocol in the technical solution of the present application is not specifically limited here; the input and output interface 25 is used to obtain external input data or output data to the external, and its specific interface type can be selected according to specific application needs, here Not specifically limited.

In addition, the memory 22, as a resource storage carrier, can be a read-only memory, random access memory, magnetic disk or optical disk, etc., and the resources stored thereon can include the operating system 221, computer programs 222 and data 223, etc., and the storage method can be short-term storage or permanent storage.

Wherein, the operating system 221 is used to manage and control each hardware device and computer program 222 on the electronic device 20, so as to realize the operation and processing of the massive 223 in the memory 22 by the processor 21, which can be Windows Server, Netware, Unix, Linux Wait. In addition to the computer program 222 that can be used to complete the message processing method performed by the electronic device 20 disclosed in any of the foregoing embodiments, the computer program 222 can further include a computer program that can be used to complete other specific tasks. The data 223 may include business messages collected by the electronic device 20 .

Further, the embodiment of the present application also discloses a storage medium, in which a computer program is stored. When the computer program is loaded and executed by a processor, the steps of the message processing method disclosed in any of the foregoing embodiments are implemented.

Each embodiment in this specification is described in a progressive manner, each embodiment focuses on the difference from other embodiments, and the same or similar parts of each embodiment can be referred to each other. As for the device disclosed in the embodiment, since it corresponds to the method disclosed in the embodiment, the description is relatively simple, and for the related part, please refer to the description of the method part.

Finally, it should also be noted that in this text, relational terms such as first and second etc. are only used to distinguish one entity or operation from another, and do not necessarily require or imply that these entities or operations, any such actual relationship or order exists. Furthermore, the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article or apparatus comprising a set of elements includes not only those elements, but also includes elements not expressly listed. other elements of or also include elements inherent in such a process, method, article, or device. Without further limitations, an element defined by the phrase "comprising a" does not exclude the presence of additional same elements in the process, method, article or apparatus comprising said element.

The message system, message processing method, device, equipment and storage medium provided by the present invention have been introduced in detail above. In this paper, specific examples have been used to illustrate the principle and implementation of the present invention. The description of the above embodiments is only for To help understand the method of the present invention and its core idea; at the same time, for those of ordinary skill in the art, according to the idea of the present invention, there will be changes in the specific implementation and scope of application. In summary, the content of this specification It should not be construed as a limitation of the invention.

Claims (10)

1. A message system, characterized in that it includes a message processing module and a message routing module, wherein: The message processing module is configured to perform an initialization operation, a submission operation, or a cancellation operation on a business message corresponding to a business service of the business system; wherein, the business service is a service corresponding to an access request of the business system, and the The access request is a request for the service system to access the message system; The message routing module is configured to store the basic information of the service message, so that the message processing module performs a corresponding initialization operation, submission operation or cancellation operation on the service message according to the basic information. 2. The message system according to claim 1, wherein the message processing module includes a message initialization unit, a message submission unit and a message cancellation unit, wherein: The message initialization unit is configured to perform an initialization operation according to the message to be initialized corresponding to the initialization service of the business system; The message submission unit is configured to perform a submission operation according to the message to be submitted corresponding to the message submission service of the business system; The message cancellation unit is configured to perform a cancellation operation according to the message to be canceled corresponding to the message cancellation service of the business system. 3. The message system according to claim 2, wherein the message initialization unit is configured to configure the basic information of the message to be initialized, and configure the information of the message to be initialized The basic information is stored in the message routing module through the remote dictionary service. 4. The message system according to claim 3, wherein the message to be initialized after the configuration is further set with a corresponding expiration time. 5. The message system according to claim 2, wherein the message submitting unit is configured to obtain the delivery address of the message to be submitted from the basic information of the message routing module, and send the message to be submitted The submit message and the corresponding delivery address are sent to the message middleware, so that the message middleware delivers the message to be submitted according to the delivery address. 6. The message system according to any one of claims 1 to 5, wherein the message processing module further comprises: The first state updating unit is configured to update the state corresponding to the service message to an initialization state after performing an initialization operation on the service message; The second status updating unit is configured to update the status corresponding to the business message to the submitted status after the submit operation is performed on the business message; The third status updating unit is configured to update the status corresponding to the business message to a canceled status after the cancel operation is performed on the business message. 7. A message processing method, characterized in that, based on the message system according to any one of claims 1 to 6, comprising: Obtaining an access request of a business system and an application interface of a business service corresponding to the access request provided by the messaging system; wherein, the access request is a request from the business system to access the messaging system; Establish a connection relationship between the business system and the message system through the application interface, and use the message system to initialize, submit or cancel the business message corresponding to the business service, so that the business The service responds. 8. The message processing method according to claim 7, wherein the application interface is constructed based on Hypertext Transfer Protocol. 9. A message processing device, characterized in that, based on the message system according to any one of claims 1 to 6, comprising: An acquisition module, configured to acquire an access request of a business system and an application interface of a business service provided by the message system corresponding to the access request; wherein, the access request is a request from the business system to access the Message system requests; A service response module, configured to establish a connection relationship between the business system and the message system through the application interface, and use the message system to process business messages corresponding to the business service, so as to respond to the business service to respond. 10. An electronic device, characterized in that the electronic device comprises a processor and a memory; wherein the memory is used to store a computer program, and the computer program is loaded and executed by the processor to implement claim 7 or The message processing method described in 8.

Images