CN111679918B

CN111679918B - Message transmission method and device

Info

Publication number: CN111679918B
Application number: CN201910181044.1A
Authority: CN
Inventors: 苑威
Original assignee: Huawei Cloud Computing Technologies Co Ltd
Current assignee: Huawei Cloud Computing Technologies Co Ltd
Priority date: 2019-03-11
Filing date: 2019-03-11
Publication date: 2024-04-26
Anticipated expiration: 2039-03-11
Also published as: CN111679918A

Abstract

The embodiment of the application provides a message transmission method and a message transmission device, relates to the technical field of communication, and can simplify a message transmission flow and improve the efficiency of message transmission. The method comprises the following steps: acquiring a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, and the keyword of the first message is a first keyword; converting the first keyword into a second keyword according to a keyword conversion rule, wherein the second keyword corresponds to a second topic, and the consumer terminal has subscribed to the second topic; and distributing the first message to a queue corresponding to the second theme according to the second keyword.

Description

Message transmission method and device

Technical Field

The embodiment of the application relates to the technical field of communication, in particular to a message transmission method and device.

Background

Message Queue (MQ) is an intermediate for message transmission, and can forward a message generated by a producer side to a consumer side, so as to realize communication between the producer side and the consumer side.

Typically, the producer side writes messages into the MQ, where the consumer side can read the messages or subscribe to messages of some topic or topics (topics) in the MQ. In one type of MQ, the MQ includes a message exchanger (exchange) and a queue (queue), where the message exchanger is configured to forward a message written by a producer side to a corresponding queue according to a certain rule, so that a consumer side can obtain a message from the corresponding queue according to a message subscribed by the consumer side. Specifically, when the producer side writes a message into the MQ, the message includes a message key, and then a message exchanger (exchange) in the MQ can determine a topic corresponding to the message according to the message key, where the message exchanger is configured with a mapping rule between the message key and the topic, and further forwards the message to a queue corresponding to the topic, so that the consumer side reads the message from the corresponding queue according to the topic subscribed by the message exchanger.

In practical applications, the consumer side needs to receive not only the message corresponding to the topic subscribed to by the consumer side (i.e. the above-described message, referred to as the generic message of the topic), but also the associated message corresponding to the topic subscribed to by the consumer side, for example, assuming that the topic is topic 1, the generic message of the topic 1 is message 1, the associated message is message 2, and the topic corresponding to the associated message is topic 2, however, in the message transmission method in the MQ, the consumer side needs to subscribe to the topic 2 to receive the message 2, that is, can receive the associated message of the topic 1, and in the case that the number of consumers is more or the association relationship between the topic and the message is dynamically changed, the message transmission in the MQ may be complex.

Disclosure of Invention

The embodiment of the application provides a message transmission method and a message transmission device, which can simplify the message transmission flow and improve the message transmission efficiency.

In order to achieve the above purpose, the embodiment of the application adopts the following technical scheme:

in a first aspect, an embodiment of the present application provides a message transmission method, including: acquiring a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, and the keyword of the first message is a first keyword; according to the keyword conversion rule, converting keywords of the first message from the first keywords to second keywords, wherein the topics of the message corresponding to the second keywords are second topics, and the consumer side has subscribed to the second topics; and distributing the first message to a queue corresponding to the second theme according to the second keyword.

In the embodiment of the application, the message generated by the producer side contains the keyword of the message, and the keyword is used for identifying the theme of the message, namely, determining the theme of the message, and further, the message queue server distributes the message to the queue corresponding to the theme of the message, so that the correct forwarding of the message is completed.

The embodiment of the application provides a message transmission method which is applied to a scene that a consumer side needs to receive an associated message corresponding to a certain theme (for example, theme 2), but the consumer side does not subscribe to the theme of the associated message (for example, the theme of the associated message is theme 1), so as to realize that the consumer side receives the associated message corresponding to the certain theme smoothly. Because the key word conversion can be completed in the message queue server, the transmission of the associated message corresponding to a certain theme can be successfully completed, so that the message transmission flow is simplified, and the message transmission efficiency is improved.

In one possible implementation, the keyword conversion rule is set according to a target feature in the keyword matching rule.

In the embodiment of the application, a keyword conversion rule is preconfigured in the message queue server, and the keyword conversion rule can be set according to actual use requirements, so that the keyword to be converted can be flexibly specified to be converted into a keyword which can be matched with a certain theme, for example, the keyword to be converted is a first keyword, the converted keyword is a second keyword, and the keyword conversion rule specifies that the first keyword can be converted into the keyword which can be matched with the second theme, and the keyword which can be matched with the second theme is the second keyword.

Optionally, the keyword matching rule is preconfigured in the message queue server, specifically, the keyword matching rule is configured in a message exchanger of the message queue server, the keyword matching rule is used for determining a theme of the first message according to a keyword of the first message received by the message queue server, the keyword matching rule includes a plurality of groups of corresponding relations between target features and the theme, and one group of corresponding relations includes the theme corresponding to the target features. Alternatively, in the embodiment of the present application, the target feature may be the whole content of the keyword, or may be a prefix of the keyword or a suffix of the keyword, etc., and specifically, the target feature may be determined according to the use requirement, which is not limited in the embodiment of the present application. By way of example, the keyword of a message may be in the form of a string, the prefix of the keyword may be the first N characters (N.gtoreq.1) of the string of keywords, the suffix of the keyword may be the last M characters (M.gtoreq.1) of the keyword, the prefix of the keyword may be represented by "x.," the suffix of the keyword may be represented by "y..e., e.g., the keyword of a message is b..c, the prefix of the keyword of the message may be b..c, and the suffix of the keyword of the message may be. C.

In the embodiment of the application, the keyword matching rule can be flexibly set, and can be set as that one target feature can correspond to one theme, or one target feature can also correspond to a plurality of themes, or a plurality of target features can also correspond to one theme.

In the embodiment of the application, the keyword conversion rule is configured on a keyword converter in the message queue server. Alternatively, the keyword conversion rule may be issued to the keyword converter by a control apparatus (e.g., a controller), and the keyword conversion process may be performed by the keyword converter. Specifically, after the message exchanger receives the first message, the message exchanger sends the first message to the keyword converter, the keyword converter converts the keyword of the first message from the first keyword to the second keyword, and then the keyword converter sends the first message to the message exchanger. It should be noted that the key carried in the first message sent by the key converter to the message exchanger has changed, which key is no longer the first key but the second key.

In a possible implementation manner, the method for distributing the first message to the queue corresponding to the second topic according to the second keyword may include: determining the topic of the first message as a second topic according to the second keyword and a keyword matching rule, wherein the keyword matching rule comprises a plurality of groups of corresponding relations between target features and topics; and distributing the first message to a queue corresponding to the second topic.

In the embodiment of the application, in the process of determining the topic of the message according to the keyword matching rule, the topic of the message corresponding to the keyword may be determined in a complete matching manner or in a fuzzy matching manner, where the fuzzy matching manner may include prefix matching of the keyword (which may be understood as that the target feature in the keyword matching rule is the prefix of the keyword) or suffix matching of the keyword (which may be understood as that the target feature in the keyword matching rule is the suffix of the keyword), and the embodiment of the application is not particularly limited.

It should be appreciated that, after determining that the topic corresponding to the first message is the second topic, the topic is one-to-one corresponding to the queue, and then it may be determined to assign the first message to the queue corresponding to the second topic.

In the embodiment of the application, since the first message is the associated message corresponding to the second topic, after the consumer terminal subscribes to the second topic, the consumer terminal can receive the message corresponding to the second topic, but the consumer terminal also needs to receive the associated message corresponding to the second topic, namely the first message, so that the keyword conversion rule can be set according to the requirement and the target feature corresponding to the second topic in the keyword matching rule, and the keyword of the first message is converted from the first keyword to the second keyword which can be matched with the target feature corresponding to the second topic according to the keyword conversion rule, so that the consumer terminal can successfully receive the first message.

It should be understood that, after the keyword converter receives the first message, the keyword conversion rule corresponding to the first keyword is searched first, and if the keyword conversion rule corresponding to the first keyword can be found, the first keyword is converted into the second keyword according to the conversion rule. If the keyword converter does not find the keyword conversion rule corresponding to the first keyword according to the first keyword, the keyword converter discards the first message, and the first message is not allocated to any one of the queues.

In a possible implementation manner, the method for determining the topic of the first message as the second topic according to the second keyword and the keyword matching rule may include: and determining the theme corresponding to the target feature matched with the second keyword in the keyword matching rule as a second theme.

For example, when the matching mode is a complete matching mode, if the character string of the second keyword is identical to all characters of the character string of a certain target feature in the keyword matching rule, determining a topic corresponding to the target feature as a second topic; when the matching mode is a fuzzy matching mode, the fuzzy matching mode is assumed to be prefix matching of the keyword, so that the prefix of the character string of the second keyword is identical to a certain target feature (the target feature is a character string in the form of prefix) in the keyword matching rule, and the topic corresponding to the target feature is determined to be the second topic.

In a possible implementation manner, the message transmission method provided by the embodiment of the application further may include: determining whether a first theme exists according to the first keywords and the keyword matching rules; and in the case that the first topic exists, distributing the first message to a queue corresponding to the first topic.

In one possible implementation manner, the method for determining whether the first topic exists according to the first keyword and the keyword matching rule may include: if the first keyword is matched with the first target feature in the keyword matching rule, determining that a first topic exists, wherein the first topic is the topic corresponding to the first target feature; and if the first keyword is not matched with the target feature in the keyword matching rule, determining that the first theme does not exist.

In a possible implementation manner, the message transmission method provided by the embodiment of the application further may include: the first message is sent to a consumer end subscribing to a second topic.

In the embodiment of the application, the consumer subscribes to the second topic, but does not subscribe to the first topic, the first message is used as the message corresponding to the first topic and is used as the associated message corresponding to the second topic, and the first message can be smoothly distributed to the queue corresponding to the second topic through the keyword conversion, so that the consumer side can receive the first message without subscribing to the first topic.

In one possible implementation, the first theme includes one or more themes.

In a second aspect, an embodiment of the present application provides a message transmission apparatus, including: the device comprises an acquisition module, a conversion module and an allocation module. The acquisition module is used for acquiring a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, and the keyword of the first message is a first keyword; the conversion module is used for converting the keywords of the first message from the first keywords to the second keywords according to the keyword conversion rule, wherein the topics of the message corresponding to the second keywords are second topics, and the consumer side has subscribed to the second topics; the allocation module is used for allocating the first message to a queue corresponding to the second theme according to the second keyword.

In a possible implementation manner, the message transmission device provided by the embodiment of the application further includes a determining module, configured to determine, according to the second keyword and a keyword matching rule, that a topic of the first message is the second topic, where the keyword matching rule includes a plurality of sets of correspondence between target features and topics; the allocation module is specifically configured to allocate the first message to a queue corresponding to the second topic.

In a possible implementation manner, the determining module is specifically configured to determine, as the second topic, a topic corresponding to the target feature matched with the second keyword in the keyword matching rule.

In a possible implementation manner, the determining module is further configured to determine whether a first topic exists according to a first keyword and a keyword matching rule, where the keyword matching rule includes correspondence between multiple sets of target features and topics; the allocation module is further configured to allocate the first message to a queue corresponding to the first topic if the first topic exists.

In a possible implementation manner, the determining module is specifically configured to determine that a first topic exists when a first keyword matches a first target feature in the keyword matching rule, where the first topic is a topic corresponding to the first target feature; in the event that the first keyword does not match a target feature in the keyword matching rule, it is determined that the first topic does not exist.

In a possible implementation manner, the message transmission device provided by the embodiment of the application may further include a sending module, where the sending module is configured to send the first message to a consumer end subscribed to the second topic.

In one possible implementation, the first theme includes one or more themes.

In a third aspect, an embodiment of the present application provides a message transmission apparatus, including: a non-volatile memory and a processor coupled to each other, the processor invoking program code stored in the memory to perform the method of any of the above-described first aspect and possible implementations thereof.

In a fourth aspect, embodiments of the present application provide a computer readable storage medium, which may comprise computer instructions which, when run on a computer, cause a message transmission apparatus to perform the method of any one of the above-mentioned first aspect and possible implementations thereof.

In a fifth aspect, embodiments of the present application provide a computer program product comprising computer instructions which, when run on a computer, cause a message transmission apparatus to perform the method of any one of the first aspect and its possible implementation forms.

It should be appreciated that, the technical solutions of the second aspect to the fifth aspect and the corresponding possible embodiments of the present application may refer to the technical effects of the first aspect and the corresponding possible embodiments, which are not described herein.

Drawings

Fig. 1 is a schematic diagram of a message transmission system according to an embodiment of the present application;

fig. 2 is a schematic diagram of a message transmission method according to an embodiment of the present application;

Fig. 3 is a schematic diagram of a second message transmission method according to an embodiment of the present application;

Fig. 4 is a schematic diagram III of a message transmission method according to an embodiment of the present application;

Fig. 5 is a schematic diagram of a message transmission method according to an embodiment of the present application;

Fig. 6 is a schematic diagram fifth of a message transmission method according to an embodiment of the present application;

Fig. 7 is a schematic structural diagram of a message transmission device according to an embodiment of the present application;

fig. 8 is a schematic diagram of a message transmission device according to an embodiment of the present application.

Detailed Description

The term "and/or" is herein merely an association relationship describing an associated object, meaning that there may be three relationships, e.g., a and/or B, may represent: a exists alone, A and B exist together, and B exists alone.

The terms first and second and the like in the description and in the claims of embodiments of the application, are used for distinguishing between different objects and not necessarily for describing a particular sequential order of objects. For example, a first topic and a second topic, etc. are used to distinguish between different topics and not to describe a particular order of topics, a first keyword and a second keyword, etc. are used to distinguish between different keywords and not to describe a particular order of keywords.

In embodiments of the application, words such as "exemplary" or "such as" are used to mean serving as an example, instance, or illustration. Any embodiment or design described herein as "exemplary" or "e.g." in an embodiment should not be taken as preferred or advantageous over other embodiments or designs. Rather, the use of words such as "exemplary" or "such as" is intended to present related concepts in a concrete fashion.

In the description of the embodiments of the present application, unless otherwise indicated, the meaning of "a plurality" means two or more. For example, the plurality of processing units refers to two or more processing units; the plurality of systems means two or more systems.

First, some concepts related to a message transmission method and device provided by the embodiment of the application are explained.

Message Queue (MQ): in general, there are two ways in which a message can go from a sender (also referred to as a producer) to a receiver (also referred to as a consumer), one is instant messaging, that is, a message arrives from one end (the message sender) to the other end (the message receiver) immediately after it is sent out; the other is to delay the message communication, i.e. after the message is sent from one end, the message first enters a container for temporary storage, and after a certain condition is reached, the message is sent from the container to the other end. One specific implementation of this container is MQ, which is seen to be an intermediate between the sender and the receiver of the message.

In the embodiment of the application, a sender generates a message and writes the message into the MQ; the receiver may obtain messages from the MQ or subscribe to some of the messages in the MQ. In the following embodiments, devices that generate messages and write messages into MQ are collectively referred to as producer side, and devices that receive messages or subscribe to messages are collectively referred to as consumer side, so that producer side, consumer side, and MQ constitute a consumer-producer model.

Subject matter: each message has a subject (i.e. topic) to which it belongs, and a subject that a message may include one subject or a plurality of subjects, in this embodiment of the present application, each subject has a corresponding message (which may be understood as a generic message of the subject), and each subject may also have a corresponding associated message (which is not a generic message of the subject, but which the consumer side needs to receive when receiving a message corresponding to the subject), it should be noted that an associated message corresponding to a subject is actually a message, and is not substantially different from a message, and only the roles of the message and the associated message are different for the subject.

The concept of the association message is illustrated by taking a scenario on the cloud platform as an example, a computing node (a consumer side) carrying the virtual machine needs to obtain a configuration change message of the virtual machine, and meanwhile needs to obtain configuration information of a subnet to which the virtual machine belongs or a security group to which the virtual machine belongs, and if the configuration change message of the virtual machine belongs to a topic-VM1, the configuration information of the subnet to which the virtual machine belongs or the security group to which the virtual machine belongs is the association message corresponding to the topic-VM 1.

It may be understood that in the embodiment of the present application, both the producer side and the consumer side may be terminal devices or internet of things devices, and the MQ is an application program (i.e., the MQ is implemented by software), for example, the MQ may be carried on a cloud platform, or may be carried on a server (referred to as a message queue server at this time), and complex computation such as processing of a message may be implemented on the MQ. Specifically, the MQ includes one or more components, such as a message exchanger (exchange) and a queue (queue), and is responsible for distributing (dropping or routing) the message to the corresponding queue after the message exchanger receives the message first; a queue is a message queue carrier for holding messages, a message may be put into one or more queues, and a binding mechanism is provided between a message switch and a queue, i.e. the message switch and the queue are bound by a certain routing rule. For example, one key factor in the binding mechanism is a key of a message, and the message exchanger may distribute the message to a corresponding queue according to the key of the message, specifically, may determine a topic of the message according to the key of the message, and further distribute the message to the queue corresponding to the topic.

Based on the problems existing in the background technology, the embodiment of the application provides a message transmission method, a message queue server acquires a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, and a keyword of the first message is a first keyword; according to a keyword conversion rule, converting keywords of a first message from the first keywords to second keywords, wherein the topics of the message corresponding to the second keywords are second topics, and the consumer side has subscribed to the second topics; and distributing the first message to a queue corresponding to the second theme according to the second keyword, and smoothly completing the transmission of the associated message corresponding to a certain theme by the technical scheme of the embodiment of the application, so that the message transmission flow is simplified, and the message transmission efficiency is improved.

The message transmission method provided by the embodiment of the present application may be applied to a message transmission system, as shown in fig. 1, where the message transmission system includes a producer side 10, an MQ 11, and a consumer side (indicated by three consumer sides in fig. 1, and denoted as a consumer side 12a, a consumer side 12b, and a consumer side 12c respectively), where the MQ 11 may include a message exchanger, a keyword converter, and a queue, where the message exchanger is preconfigured with a keyword matching rule, and the keyword converter is configured with a keyword conversion rule. Optionally, the message transmission system may include one or more message exchanges and may also include one or more queues.

The producer side 10 generates a message and writes the message into the MQ 11, the message generated by the producer side 10 contains the keyword of the message, the message exchanger matches the keyword of the message received by the message exchanger according to the preset keyword matching rule to determine the topic of the message received by the message exchanger, when the keyword of the message meets the keyword matching rule, the topic of the message is determined to exist, the message exchanger distributes the message to a queue corresponding to the topic, and when the keyword of the message does not meet the keyword matching rule, the topic of the message is determined to not exist.

In the embodiment of the application, the message exchanger interacts with the keyword converter, and the keyword converter converts the keyword of a certain message according to the keyword conversion rule, so that the converted keyword meets the keyword matching rule, and thus another new topic of the message can be determined, and the message is further sent to the queue corresponding to the new topic, and the specific details are described in detail in the following embodiments.

The message transmission method provided by the embodiment of the application can be applied to a scene that a consumer side needs to receive the associated message corresponding to a certain theme (for example, the theme 2), but the consumer side does not subscribe to the theme of the associated message (for example, the theme of the associated message is the theme 1), so that the consumer side can successfully receive the associated message corresponding to the certain theme. For example, the consumer side subscribes to the topic 2, but the consumer side does not subscribe to the topic 1, if the related message is recorded as the message 1, it is known that the message 1 is the related message corresponding to the topic 2, and the message 1 is the message corresponding to the topic 1, and in general, the consumer side subscribes to which topic, and can receive the message corresponding to the topic, for example, the consumer side subscribes to the topic 2, and the consumer side can receive the message corresponding to the topic 2, and since the consumer does not subscribe to the topic 1, the consumer side cannot receive the message corresponding to the topic 1, that is, the consumer cannot receive the message 1. That is, in the prior art, in the case that the consumer side does not subscribe to the topic of the association message corresponding to topic 2 (i.e. topic 1 described above), the consumer side cannot receive the association message corresponding to topic 2 (i.e. cannot receive message 1), and the technical problem solved by the embodiment of the present application is that: how to realize the receiving of the associated message by the consumer side under the condition that the consumer side does not subscribe to the topic of the associated message corresponding to the topic 2.

In the embodiment of the present application, a message transmission method is introduced by taking an MQ carried on a server as an example, hereinafter, the server carrying the MQ is referred to as a message queue server, and in combination with the above-mentioned message transmission system, as shown in fig. 2, from the perspective of the message queue server (i.e. taking the message queue server as an execution body), the message transmission method provided in the embodiment of the present application may include S101-S103:

S101, the message queue server acquires a first message from a producer side.

The first message is a message corresponding to a first topic and is an associated message corresponding to a second topic, the keyword of the first message is a first keyword, and the consumer terminal subscribes to the second topic. Wherein the topics of a message may include one or more topics, the first topic being the topic of the first message, the first topic including one or more topics.

S102, the message queue server converts the keywords of the first message from the first keywords to the second keywords according to the keyword conversion rule.

Wherein the topic of the second keyword corresponding message is a second topic.

In the embodiment of the application, the keyword conversion rule is preconfigured in the message queue server, and specifically, the keyword conversion rule is configured on the keyword converter in the message queue server. Alternatively, the keyword conversion rule may be issued to the keyword converter by a control apparatus (e.g., a controller), and the keyword conversion process may be performed by the keyword converter. Specifically, after the message exchanger receives the first message, the message exchanger sends the first message to the keyword converter, the keyword converter converts the keyword of the first message from the first keyword to the second keyword, and then the keyword converter sends the first message to the message exchanger. It should be noted that the key carried in the first message sent by the key converter to the message exchanger has changed, which key is no longer the first key but the second key.

It should be noted that, in the embodiment of the present application, the keyword conversion rule may be set according to an actual use requirement, so that it is flexibly specified that a keyword to be converted may be converted into a keyword that can be matched with a certain topic, for example, the keyword to be converted is a first keyword, the converted keyword is a second keyword, and it is specified in the keyword conversion rule that the first keyword may be converted into a keyword that can be matched with the second topic, where the keyword that can be matched with the second topic is the second keyword.

Optionally, in an embodiment of the present application, the keyword conversion rule is set according to a target feature in the keyword matching rule. The keyword matching rule is preconfigured in the message queue server, specifically, the keyword matching rule is configured in a message exchanger of the message queue server, and the keyword matching rule is used for determining the topic of the first message according to the keyword of the first message received by the message queue server.

First, a keyword matching rule is briefly introduced, the keyword matching rule comprises a plurality of groups of corresponding relations between target features and topics, and one group of corresponding relations comprises topics corresponding to the target features. Alternatively, in the embodiment of the present application, the target feature may be the whole content of the keyword, or may be a prefix of the keyword or a suffix of the keyword, etc., and specifically, the target feature may be determined according to the use requirement, which is not limited in the embodiment of the present application.

In the embodiment of the application, the keyword of the message may be in the form of a character string, the prefix of the keyword may be the first N characters (n.gtoreq.1) of the character string of the keyword, the suffix of the keyword may be the last M characters (m.gtoreq.1) of the keyword, the prefix of the keyword may be represented by "x..and the suffix of the keyword may be represented by" y, "for example, the keyword of a certain message is b..c, the prefix of the keyword of the message may be b..and the suffix of the keyword of the message may be c.

Optionally, in the embodiment of the present application, the keyword matching rule may be flexibly set, and may be set so that one target feature may correspond to one theme, or one target feature may also correspond to a plurality of themes, or may be set so that a plurality of target features correspond to one theme.

By way of example, table 1 below illustrates several keyword matching rules.

TABLE 1

Target feature	Theme
		Prefix a.	Topic1，Topic3
Prefix b.	Topic2
		Suffix. C	Topic2
Prefix d.	Topic2
		Prefix e.	Topic4

As can be seen from table 1, when the target feature is the prefix e, the target feature corresponds to a Topic which is Topic4 (i.e. the case that the target feature corresponds to a Topic); when the target feature is the prefix a, the target feature corresponds to two topics, namely Topic1 and Topic3 (namely, the case that one target feature corresponds to a plurality of topics).

In table 1, it can be seen that the prefix b., the prefix d, and the suffix c each correspond to a Topic of Topic2 (i.e., the case that the above-mentioned multiple target features correspond to a Topic), and when the multiple target features correspond to a Topic, the multiple target features may be the same type of target feature, or may be different types of target features, for example, the prefix b, and the prefix d, each correspond to Topic2, and each of the two target features is a prefix of a keyword; the prefix b, and the suffix c correspond to Topic2, and the two target features are different types of target features, one is the prefix and the other is the suffix.

In combination with the above description of the keyword matching rule, the consumer end has subscribed to the second topic, so that the keyword matching rule configured by the message queue server includes a matching rule corresponding to the second topic, that is, the pre-configured keyword matching rule includes a correspondence between a certain target feature and the second topic, and the second keyword can be matched with the target feature.

Based on the description of the keyword matching rule, in the embodiment of the present application, since the first message is an associated message corresponding to the second topic, after the consumer terminal subscribes to the second topic, the consumer terminal can receive the message corresponding to the second topic, but the consumer terminal also needs to receive the associated message corresponding to the second topic, that is, the first message, so that the keyword conversion rule can be set according to the requirement and the target feature corresponding to the second topic in the keyword matching rule, and the keyword of the first message can be converted from the first keyword to the second keyword capable of being matched with the target feature corresponding to the second topic according to the keyword conversion rule, so that the consumer terminal can successfully receive the first message.

For example, in combination with the keyword matching rule shown in table 1, for example, the second Topic is Topic1, the keyword of the first message (i.e., the first keyword) is g. Adding a prefix a to the first keyword, and according to the conversion rule, converting the second keyword after the first keyword is a.g. For another example, the second Topic is Topic2, the keyword of the first message is g..f, and the keyword conversion rule set according to the target feature corresponding to Topic2 may be: adding a prefix b to the first keyword, then converting the first keyword to a second keyword b.g. Or the keyword conversion rule may be: adding a prefix d to the first keyword, then converting the first keyword to a second keyword d.g. Or the keyword conversion rule may be: when the second Topic is Topic2, the keyword converter may perform keyword conversion according to any one of the above 3 keyword conversion rules, which is not limited in the embodiment of the present application.

S103, the message queue server distributes the first message to a queue corresponding to the second theme according to the second keyword.

As can be seen from the related description of the above embodiment, S103 is performed by the message exchanger in the message queue server.

In the embodiment of the application, the second keyword is converted according to the target feature corresponding to the configured topic in the message queue server, and the keyword of the first message is changed into the second keyword, and the second keyword can be matched with the target feature corresponding to the second topic in the keyword matching rule, so that the corresponding relation between the first message and the second topic is established, the topic corresponding to the message (i.e. the first message) corresponding to the second keyword can be determined to be the topic (i.e. the second topic) corresponding to the target feature, that is, the topic of the first message can be determined to be the second topic.

It should be understood that, after the keyword converter receives the first message, the keyword conversion rule corresponding to the first keyword is searched first, and if the keyword conversion rule corresponding to the first keyword can be found, the first keyword is converted into the second keyword according to the keyword conversion rule. If the keyword converter does not find the keyword conversion rule corresponding to the first keyword according to the first keyword, the keyword converter discards the first message, and the first message is not allocated to any one of the queues.

Alternatively, referring to fig. 2, as shown in fig. 3, S103 may be specifically implemented by S1031-S1032:

S1031, the message queue server determines that the theme of the first message is the second theme according to the second keyword and the keyword matching rule.

Optionally, in the embodiment of the present application, in determining the topic of the message according to the keyword matching rule, the topic of the message corresponding to the keyword may be determined by a perfect matching manner or a fuzzy matching manner, where the fuzzy matching manner may include prefix matching of the keyword (which may be understood that the target feature in the keyword matching rule is the prefix of the keyword) or suffix matching of the keyword (which may be understood that the target feature in the keyword matching rule is the suffix of the keyword), and the embodiment of the present application is not specifically limited.

Referring to fig. 3, as shown in fig. 4, S1031 may be specifically implemented by S1031 a:

S1031a, determining the theme corresponding to the target feature matched with the second keyword in the keyword matching rule as a second theme.

In one implementation manner, when the matching manner is a complete matching manner, if the character string of the second keyword is identical to all characters of the character string of a certain target feature in the keyword matching rule, determining a theme corresponding to the target feature as a second theme; in another implementation manner, when the matching manner is a fuzzy matching manner, it is assumed that the fuzzy matching manner is prefix matching of the keyword, so that the prefix of the character string of the second keyword is identical to a certain target feature (the target feature is a character string in the form of a prefix) in the keyword matching rule, and then the topic corresponding to the target feature is determined as the second topic.

In connection with the description of the keyword matching rule in S102, by way of example, still in connection with the keyword matching rule shown in table 1, the second Topic is Topic1, the keyword of the first message, the first keyword is g..f, and the keyword conversion rule set according to the target feature corresponding to Topic1 may be: adding a prefix a to the first keyword, according to the conversion rule, the second keyword after the first keyword is converted is a.g..f (the keyword of the first message becomes a.g..f), and further, according to the second keyword a.g..f and the keyword matching rule, the second keyword a.g..f can be matched with the target feature a..because the prefix a exists in the second keyword a.g..f), and because the corresponding Topic of the target feature a..is Topic1, the Topic (i.e. the second Topic) corresponding to the first message is Topic1.

S1032, the message queue server distributes the first message to the queue corresponding to the second theme.

After determining that the topic corresponding to the first message is the second topic, the first message may be allocated to a queue corresponding to the second topic. It should be noted that, in the embodiment of the present application, the topics are in one-to-one correspondence with the queues, and table 2 below is an example of a correspondence between topics and queues.

TABLE 2

Theme	Queues
		Topic1	Queue1
Topic2	Queue2
		Topic3	Queue3
Topic4	Queue4

Illustratively, in combination with table 2 above, assuming that the second Topic is Topic2, and knowing that the Queue corresponding to Topic2 is Queue2, the message exchanger assigns the first message to Queue2.

Table 3 illustrates the case of several topics subscribed to by the consumer side.

TABLE 3 Table 3

In combination with table 2 and table 3, one Topic corresponds to one Queue, and one consumer may subscribe to one Topic or multiple topics, so that one consumer may correspond to one Queue or multiple queues, for example, the consumer side subscribes to one Topic as Topic2, and the consumer may obtain a message and/or an associated message corresponding to Topic2 from Queue2 corresponding to Topic 2; for another example, if the consumer terminal subscribes to Topic1 and subscribes to Topic3, the consumer terminal may obtain the message\or the associated message corresponding to Topic1 from the Queue1 corresponding to Topic1, and obtain the message\or the associated message corresponding to Topic3 from the Queue3 corresponding to Topic 3.

Of course, different consumers may subscribe to the same Topic, in table 3, both consumer side 1 and consumer side 2 subscribe to Topic1 and Topic3, topic1 corresponds to Queue1, topic3 corresponds to Queue3, then consumer side 1 obtains the message\or related message corresponding to Topic1 from Queue1, obtains the message\or related message corresponding to Topic3 from Queue3, and consumer side 2 obtains the message\or related message corresponding to Topic1 from Queue1, and obtains the message\or related message corresponding to Topic3 from Queue 3.

Optionally, in conjunction with fig. 2, as shown in fig. 5, after S103, the message transmission method provided by the embodiment of the present application may further include S104:

S104, the message queue server sends the first message to a consumer end subscribing to the second theme.

Optionally, in conjunction with fig. 5, as shown in fig. 6, after S101, the message transmission method provided by the embodiment of the present application may further include S105:

S105, the message queue server determines whether the first theme exists according to the first keyword and the keyword matching rule.

In the embodiment of the present application, the S105 may specifically include S1051 or S1052:

s1051, if the first keyword is matched with the first target feature in the keyword matching rule, determining that a first topic exists, wherein the first topic is a topic corresponding to the first target feature.

In connection with the above description of the keyword matching rule, by way of example, it is assumed that the preset keyword matching rule is recorded as the keyword matching rule shown in the above table 1, if the keyword of the first message received by the message queue server is b, according to the keyword matching rule in table 1, the prefix b of the keyword of the first message can be matched with the target feature (prefix b) in the keyword matching rule, and at this time, the first target feature is b, so that it can be determined that the first Topic exists and the first Topic is the Topic corresponding to the first target feature b.

S1052, if the first keyword is not matched with the target feature in the keyword matching rule, determining that the first theme does not exist.

Similarly, assuming that the pre-configured keyword matching rule is recorded as the keyword matching rule shown in the above table 1, if the keyword of the first message received by the message queue server is g.

In the embodiment of the present application, as shown in fig. 6, when the message queue server determines that the first topic exists according to the first keyword, the message queue server executes S106 described below.

S106, the message queue server distributes the first message to a queue corresponding to the first theme according to the first keyword.

In the embodiment of the application, a message exchanger in a message queue server determines that the topic of a first message exists according to a first keyword, determines that the topic of the first message is a first topic, and further distributes the first message to a queue corresponding to the first topic according to the corresponding relation between the topic and the queue.

For the description of S105 and S106, reference may be made to the description of S1031 and S1032 in the above embodiment, and the description is not repeated here.

It can be understood that, whether the first topic exists or not, the message queue server executes a keyword conversion process to convert the keywords of the first message from the first keyword to the second keyword, so as to expand the topic of the first message, that is, the topic of the first message also includes the second topic, so that the first message can be allocated to the queue corresponding to the second topic.

According to the message transmission method provided by the embodiment of the application, a message queue server acquires a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, and the keyword of the first message is a first keyword; according to a keyword conversion rule, converting keywords of a first message from the first keywords to second keywords, wherein the topics of the message corresponding to the second keywords are second topics, and the consumer side has subscribed to the second topics; and distributing the first message to a queue corresponding to the second theme according to the second keyword. Because the key word conversion can be completed in the message queue server, the transmission of the associated message corresponding to a certain theme can be successfully completed, so that the message transmission flow is simplified, and the message transmission efficiency is improved.

The above description has been presented mainly in terms of a message transmission device (message queue server) according to the embodiment of the present application. It will be appreciated that the message transmission means, in order to achieve the above-described functions, comprise corresponding hardware structures and/or software modules performing the respective functions. Those of skill in the art will readily appreciate that the various illustrative elements and algorithm steps described in connection with the embodiments disclosed herein may be implemented as hardware or combinations of hardware and computer software. Whether a function is implemented as hardware or computer software driven hardware depends upon the particular application and design constraints imposed on the solution. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present application.

The embodiment of the application can divide the functional modules of the message transmission device according to the method example, for example, each functional module can be divided corresponding to each function, or two or more functions can be integrated in one processing module. The integrated modules may be implemented in hardware or in software functional modules. It should be noted that, in the embodiment of the present application, the division of the modules is schematic, which is merely a logic function division, and other division manners may be implemented in actual implementation.

In the case of dividing the respective functional modules with the respective functions, fig. 7 shows a schematic diagram of one possible configuration of the message transmission apparatus involved in the above-described embodiment, and as shown in fig. 7, the message transmission apparatus 1000 may include: an acquisition module 1001, a conversion module 1002 and an allocation module 1003. The obtaining module 1001 may be configured to support the message transmission apparatus 1000 to perform S101 in the above-described method embodiment; the conversion module 1002 may be configured to support the message transmission apparatus 1000 to perform S102 in the above-described method embodiment; the assignment module 1003 may be used to support the message transmission apparatus 1000 to perform S103 (including S1032) and S106 in the above-described method embodiments.

Optionally, as shown in fig. 7, the message transmission apparatus 1000 provided in the embodiment of the present application may further include a determining module 1004 and a sending module 1005, where the determining module 1004 is configured to support the message transmission apparatus 1000 to perform S1031 (S1031 may be specifically implemented by S1031 a) and S105 (including S1051 or S1052) in the foregoing method embodiment; the sending module 1005 is configured to support the message transmission apparatus 1000 to perform S104 in the above-described method embodiment. All relevant contents of each step related to the above method embodiment may be cited to the functional description of the corresponding functional module, which is not described herein.

In the case of an integrated unit, fig. 8 shows a schematic diagram of one possible structure of the message transmission device involved in the above-described embodiment. As shown in fig. 8, the message transmission apparatus 2000 may include: a processing module 2001 and a communication module 2002. The processing module 2001 may be used for controlling and managing the operation of the message transmitting apparatus 2000, for example, the processing module 2001 supports the message transmitting apparatus 2000 to perform S101, S102, S103 (including S1031-S1032), S105 (including S1051 or S1052), and S106 in the above-described method embodiment. The communication module 2002 may be used to support communication of the message transmission device 2000 with other network entities, e.g. the communication module 2002 supports the message transmission device 2000 to perform S104 in the above-described method embodiments. Optionally, as shown in fig. 8, the message transmission device 2000 may further include a storage module 2003 for storing program codes and data of the message transmission device 2000.

The processing module 2001 may be a processor or controller, such as a central processing unit (central processing unit, CPU), a general purpose processor, a digital signal processor (DIGITAL SIGNAL processor, DSP), an application-specific integrated circuit (ASIC), a field programmable gate array (field programmable GATE ARRAY, FPGA), or other programmable logic device, a transistor logic device, a hardware component, or any combination thereof. Which may implement or perform the various exemplary logic blocks, modules and circuits described in connection with the disclosure of embodiments of the application. The processor described above may also be a combination that performs the function of a computation, e.g., a combination comprising one or more microprocessors, a combination of a DSP and a microprocessor, and so on. The communication module 2002 may be a transceiver, a transceiver circuit, a communication interface, or the like. The storage module 2003 may be a memory.

When the processing module 2001 is a processor, the communication module 2002 is a transceiver, and the storage module 2003 is a memory, the processor, the transceiver, and the memory may be connected through a bus. The bus may be a peripheral component interconnect standard (PERIPHERAL COMPONENT INTERCONNECT, PCI) bus, or an extended industry standard architecture (extended Industry standard architecture, EISA) bus, or the like. The buses may be divided into address buses, data buses, control buses, etc.

In the above embodiments, it may be implemented in whole or in part by software, hardware, firmware, or any combination thereof. When implemented using a software program, it may be wholly or partly implemented in the form of a computer program product. The computer program product includes one or more computer instructions. When the computer instructions are loaded and executed on a computer, the processes or functions in accordance with embodiments of the present application are produced in whole or in part. The computer may be a general purpose computer, a special purpose computer, a computer network, or other programmable apparatus. The computer instructions may be stored in a computer-readable storage medium or transmitted from one computer-readable storage medium to another computer-readable storage medium, for example, the computer instructions may be transmitted from one website, computer, server, or data center to another website, computer, server, or data center by a wired (e.g., coaxial cable, fiber optic, digital subscriber line (digital subscriber line, DSL)) or wireless (e.g., infrared, wireless, microwave, etc.) means. The computer readable storage medium may be any available medium that can be accessed by a computer or a data storage device including one or more servers, data centers, etc. that can be integrated with the available medium. The usable medium may be a magnetic medium (e.g., a floppy disk, a magnetic tape), an optical medium (e.g., a digital video disc (digital video disc, DVD)), or a semiconductor medium (e.g., a Solid State Disk (SSD)), or the like.

From the foregoing description of the embodiments, it will be apparent to those skilled in the art that, for convenience and brevity of description, only the above-described division of functional modules is illustrated, and in practical application, the above-described functional allocation may be implemented by different functional modules according to needs, i.e. the internal structure of the apparatus is divided into different functional modules to implement all or part of the functions described above. The specific working processes of the above-described systems, devices and units may refer to the corresponding processes in the foregoing method embodiments, which are not described herein.

In the several embodiments provided in the present application, it should be understood that the disclosed systems, devices, and methods may be implemented in other manners. For example, the apparatus embodiments described above are merely illustrative, e.g., the division of the modules or units is merely a logical functional division, and there may be additional divisions when actually implemented, e.g., multiple units or components may be combined or integrated into another system, or some features may be omitted, or not performed. Alternatively, the coupling or direct coupling or communication connection shown or discussed with each other may be an indirect coupling or communication connection via some interfaces, devices or units, which may be in electrical, mechanical or other form.

The units described as separate units may or may not be physically separate, and units shown as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in the embodiments of the present application may be integrated in one processing unit, or each unit may exist alone physically, or two or more units may be integrated in one unit. The integrated units may be implemented in hardware or in software functional units.

The integrated units, if implemented in the form of software functional units and sold or used as stand-alone products, may be stored in a computer readable storage medium. Based on this understanding, the technical solution of the present application may be embodied essentially or in a part contributing to the prior art or in whole or in part in the form of a software product stored in a storage medium, comprising several instructions for causing a computer device (which may be a personal computer, a server, a network device, etc.) or a processor to perform all or part of the steps of the method according to the embodiments of the present application. And the aforementioned storage medium includes: flash memory, removable hard disk, read-only memory, random access memory, magnetic or optical disk, and the like.

The foregoing is merely illustrative of specific embodiments of the present application, and the scope of the present application is not limited thereto, but any changes or substitutions within the technical scope of the present application should be covered by the scope of the present application. Therefore, the protection scope of the present application shall be subject to the protection scope of the claims.

Claims

1. A method of message transmission, comprising:

Acquiring a first message from a producer side, wherein the first message is a message corresponding to a first topic and is an associated message corresponding to a second topic, the keyword of the first message is a first keyword, and the first topic comprises one or more topics;

According to a keyword conversion rule, converting keywords of the first message from the first keywords to second keywords, wherein the topics of the message corresponding to the second keywords are the second topics, and the consumer side has subscribed to the second topics;

and distributing the first message to a queue corresponding to the second theme according to the second keyword.

2. The method of claim 1, wherein the assigning the first message to the queue corresponding to the second topic according to the second key comprises:

Determining that the topic of the first message is the second topic according to the second keyword and a keyword matching rule, wherein the keyword matching rule comprises a plurality of groups of corresponding relations between target features and topics;

And distributing the first message to a queue corresponding to the second theme.

3. The method of claim 2, wherein the determining that the topic of the first message is the second topic according to the second keyword and keyword matching rules comprises:

and determining the theme corresponding to the target feature matched with the second keyword in the keyword matching rule as the second theme.

4. A method according to claim 2 or 3, characterized in that the method further comprises:

Determining whether the first theme exists according to the first keyword and the keyword matching rule;

And if the first theme exists, distributing the first message to a queue corresponding to the first theme.

5. The method of claim 4, wherein determining whether the first topic exists based on the first keyword and the keyword matching rule comprises:

If the first keyword is matched with a first target feature in the keyword matching rule, determining that the first topic exists, wherein the first topic is a topic corresponding to the first target feature;

And if the first keyword is not matched with the target feature in the keyword matching rule, determining that the first theme does not exist.

6. The method according to claim 2 to 5, wherein,

The keyword conversion rule is set according to target features in the keyword matching rule.

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

and sending the first message to a consumer end subscribed to the second theme.

8. A message transmission apparatus, comprising: the device comprises an acquisition module, a conversion module and an allocation module;

The acquisition module is used for acquiring a first message from a producer side, wherein the first message is a message corresponding to a first theme and is an associated message corresponding to a second theme, the keyword of the first message is a first keyword, and the first theme comprises one or more themes;

the conversion module is used for converting the keyword of the first message from the first keyword to a second keyword according to a keyword conversion rule, wherein the topic of the message corresponding to the second keyword is the second topic, and the consumer terminal has subscribed to the second topic;

the allocation module is configured to allocate the first message to a queue corresponding to the second topic according to the second keyword.

9. The apparatus of claim 8, wherein the apparatus further comprises a determination module;

The determining module is configured to determine that the topic of the first message is the second topic according to the second keyword and a keyword matching rule, where the keyword matching rule includes correspondence between multiple groups of target features and topics;

The allocation module is specifically configured to allocate the first message to a queue corresponding to the second topic.

10. The apparatus of claim 9, wherein the device comprises a plurality of sensors,

The determining module is specifically configured to determine, as the second topic, a topic corresponding to the target feature matched with the second keyword in the keyword matching rule.

11. The device according to claim 9 or 10, wherein,

The determining module is further configured to determine whether the first topic exists according to the first keyword and the keyword matching rule;

The allocation module is further configured to allocate the first message to a queue corresponding to the first topic when the first topic exists.

12. The apparatus of claim 11, wherein the device comprises a plurality of sensors,

The determining module is specifically configured to determine that the first topic exists when the first keyword is matched with a first target feature in the keyword matching rule, where the first topic is a topic corresponding to the first target feature; and determining that the first theme does not exist under the condition that the first keyword is not matched with the target feature in the keyword matching rule.

13. The device according to any one of claims 9 to 12, wherein,

14. The apparatus according to any one of claims 8 to 13, further comprising a transmission module;

The sending module is configured to send the first message to a consumer end subscribed to the second topic.

15. A message transmission apparatus, comprising: a non-volatile memory and a processor coupled to each other, the processor invoking program code stored in the memory to perform the method of any of claims 1-7.

16. A computer readable storage medium, characterized in that it comprises computer instructions which, when run on a computer, cause a message transmission device to perform the method according to any of claims 1 to 7.