CN106603711B - Communication method, system and message server - Google Patents
Communication method, system and message serverDownload PDFInfo
- Publication number
- CN106603711B CN106603711BCN201611259386.3ACN201611259386ACN106603711BCN 106603711 BCN106603711 BCN 106603711BCN 201611259386 ACN201611259386 ACN 201611259386ACN 106603711 BCN106603711 BCN 106603711B
- Authority
- CN
- China
- Prior art keywords
- message
- subscriber
- subject area
- receipt
- area
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 230000006854communicationEffects0.000titleclaimsabstractdescription74
- 238000004891communicationMethods0.000titleclaimsabstractdescription73
- 238000000034methodMethods0.000titleclaimsabstractdescription25
- 230000004044responseEffects0.000claimsdescription25
- 230000001360synchronised effectEffects0.000abstractdescription24
- 238000010586diagramMethods0.000description6
- 238000012545processingMethods0.000description6
- 238000012827research and developmentMethods0.000description4
- 238000011161developmentMethods0.000description2
- 230000009286beneficial effectEffects0.000description1
- 238000005516engineering processMethods0.000description1
- 238000012986modificationMethods0.000description1
- 230000004048modificationEffects0.000description1
- 230000003287optical effectEffects0.000description1
- 230000001502supplementing effectEffects0.000description1
Images
Classifications
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
- H04L67/146—Markers for unambiguous identification of a particular session, e.g. session cookie or URL-encoding
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/51—Discovery or management thereof, e.g. service location protocol [SLP] or web services
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Mobile Radio Communication Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
Description
Technical Field
The present invention relates to the field of communications technologies, and in particular, to a communication method, a communication system, and a message server.
Background
In order to improve the communication efficiency of the two communication parties, an asynchronous communication mode is generally adopted between some service application systems. However, in the actual application process, some new services may be added, and due to service requirements, synchronous communication sometimes needs to be realized. In order to meet the requirement of synchronous communication of newly added services, an independent synchronous communication subsystem is correspondingly added in the existing application system for synchronous communication.
However, the above-mentioned method of performing synchronous communication by using an independent synchronous communication system needs to re-develop a new service application system, which needs to consume a lot of manpower and material resources, and has a long development period and a high cost.
Disclosure of Invention
The invention solves the technical problem of how to realize synchronous communication while considering the cost.
To solve the foregoing technical problem, an embodiment of the present invention provides a communication method, including: receiving a request message issued by a message issuer, the request message comprising: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area; storing the request message in a first received message topic area corresponding to the message subscriber according to the identification information of the received message topic area of the message subscriber, so that the message subscriber can obtain the request message from the received message topic area; receiving a receipt message published by the message subscriber, wherein the receipt message is generated by the message subscriber according to the request message and comprises identification information of a returned subject area; and storing the receipt message in a corresponding return subject area according to the identification information of the return subject area so as to enable the message publisher to obtain the receipt message.
Optionally, the message subscriber comprises a plurality of individuals, and the request message is adapted to be obtained by any one of the plurality of individuals and is obtained only once.
Optionally, the message subscriber establishes a cluster for one individual or for a plurality of individuals.
Optionally, after storing the request message in the first received message subject area corresponding to the subscriber, further performing any one of the following operations: when the request message is detected to be acquired by a certain entity in the message subscriber, the state of the request message is marked as acquired; and removing the request message from the received message subject area after detecting that the request message is acquired by a certain person in the message subscriber.
Optionally, the method further comprises: receiving a directed message issued by the message issuer, wherein the directed message comprises: a message subscriber receives identification information of a directional message subject area; according to the identification information of a targeted message topic area received by the message subscriber, storing the targeted message in a corresponding second received message topic area so that the message subscriber can acquire the targeted message from the second received message topic area, wherein the first received message topic area is a common received message topic area of the message subscriber, and when the message subscriber comprises a plurality of individuals, each individual can acquire a request message from the first received message topic area; the second message receiving subject area is an exclusive message receiving subject area of an individual, and the corresponding individual can obtain the stored directional message.
Optionally, the directed message further comprises: the receipt message returns an identifier and identifier information of the returned subject area; the communication method further comprises: receiving a receipt message published by the message subscriber, wherein the receipt message comprises identification information of a returned subject area; and storing the receipt message in a corresponding return subject area according to the identification information of the return subject area so as to enable the message publisher to obtain the receipt message.
Optionally, the method further comprises: when the message publisher is detected to be started, establishing a return subject area corresponding to the message publisher; and when the message subscriber is detected to be started, establishing a first received message subject area corresponding to the message subscriber.
An embodiment of the present invention further provides a message server, including: first receiving unit, first memory cell, second receiving unit and second memory cell, wherein: the first receiving unit is adapted to receive a request message issued by a message issuer, where the request message includes: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area; the first storage unit is suitable for storing the request message in a first received message topic area corresponding to a subscriber according to the identification information of the received message topic area of the information subscriber, so that the information subscriber can obtain the request message from the received message topic area; the second receiving unit is suitable for receiving a response piece message published by the message subscriber, wherein the response piece message comprises identification information of a return subject area; the second storage unit is suitable for storing the receipt message in the corresponding return subject area according to the identification information of the return subject area, so that the message publisher can obtain the receipt message.
An embodiment of the present invention further provides a communication system, including: the message server comprises a message publishing party, a message subscribing party and the message server, wherein: the message publisher is adapted to publish a request message to the message server, the request message including: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area; and obtaining the receipt message published by the message subscriber from the return topic area of the message server; the message subscriber is suitable for acquiring the request message from a first received message subject area of the message server, generating the receipt message according to the request message and publishing the receipt message to the message server, wherein the receipt message comprises identification information of a returned subject area; the message server is suitable for receiving the request message published by the message publisher, storing the request message in a first message topic receiving area corresponding to the message subscriber according to the identification information of the message topic receiving area of the message subscriber, receiving the receipt message published by the message subscriber, and storing the receipt message in a corresponding topic returning area according to the identification information of the topic returning area.
Optionally, the message subscriber comprises a plurality of individuals, and the request message is adapted to be obtained by any one of the plurality of individuals and is obtained only once.
Optionally, the message subscriber establishes a cluster for one individual or a plurality of individuals.
Optionally, after storing the request message in the first received message subject area corresponding to the subscriber, the message server is further adapted to perform any one of the following operations: when the request message is detected to be acquired by a certain entity in the message subscriber, the state of the request message is marked as acquired; and removing the request message from the received message subject area after detecting that the request message is acquired by a certain person in the message subscriber.
Optionally, the message publisher is further adapted to generate a directed message and send the directed message to the message server, where the directed message includes: a message subscriber receives identification information of a directional message subject area; the message server is also suitable for receiving the oriented message published by the message publishing party and storing the oriented message in a corresponding second received message subject area according to the identification information of the oriented message subject area received by the message subscribing party; the message subscriber is further adapted to obtain the targeted message from the second received message topic area, the first received message topic area is a common received message topic area of the message subscriber, and when the message subscriber includes a plurality of individuals, each individual can obtain a request message from the first received message topic area; the second message receiving subject area is an exclusive message receiving subject area of an individual, and the corresponding individual can obtain the stored directional message.
Optionally, the directed message further comprises: returning identification and identification information of the returned subject area by the return receipt message; the message subscriber is also suitable for generating a receipt message according to the oriented message and sending the receipt message to the message server, wherein the receipt message comprises identification information of a returned subject area; the message server is also suitable for receiving the receipt message sent by the message subscriber and storing the receipt message in a corresponding return subject area according to the identification information of the return subject; the message publisher is further adapted to retrieve the response piece message from a return subject area of the message server.
Optionally, the message server is further adapted to establish a return subject area corresponding to the message publisher when detecting that the message publisher is started; and when the message subscriber is detected to be started, establishing a message receiving subject area corresponding to the message subscriber.
Optionally, the message server is kafka message middleware.
Compared with the prior art, the technical scheme of the embodiment of the invention has the following beneficial effects:
the request message generated by the message publisher comprises the identification information of the message topic area received by the message subscriber, the return receipt message return identification and the identification information of the return topic area, so that the message subscriber can return the return receipt message to the corresponding return topic area according to the identification information of the return topic given in the request message after receiving the request message. The message publisher can obtain the receipt message from the return subject area, thereby realizing synchronous communication without adding an independent synchronous communication subsystem, and saving research and development cost.
Further, the message subscriber may include a plurality of individuals, and the request message may be acquired by any one of the plurality of individuals and acquired only once. When some individuals in the message subscriber can not obtain the request message, other individuals can obtain the request message, the message subscriber is transversely expanded into a plurality of individuals, and any individual can process the request message by supplementing the other individuals in the message subscriber, so that the reliability in the communication process can be improved.
Further, when it is detected that the request message is acquired by one of the message subscribers, the status of the request message is marked as acquired or the request message is removed from the received message topic, so that the request message is prevented from being acquired repeatedly, system processing resources are saved, and system processing efficiency and stability are improved.
Drawings
FIG. 1 is a flow chart of a method of communication in an embodiment of the invention;
FIG. 2 is a schematic structural diagram of a message server according to an embodiment of the present invention;
fig. 3 is a schematic structural diagram of a communication system according to an embodiment of the present invention;
fig. 4 is a schematic structural diagram of another communication system in the embodiment of the present invention.
Detailed Description
In the prior art, when some services requiring synchronous communication are added between some application systems adopting asynchronous communication modes, in order to meet the requirement of synchronous communication of the newly added services, an independent synchronous communication subsystem is correspondingly added in the existing application systems for synchronous communication. However, the above-mentioned method of performing synchronous communication by using an independent synchronous communication system usually needs to re-develop a new service application system, which needs to consume a lot of manpower and material resources, and has a long development period and a high cost.
In order to solve the above problem, in the embodiment of the present invention, the request message generated by the message publisher includes the identification information of the message topic area received by the message subscriber, the receipt message return identification, and the identification information of the return topic area, so that after the message subscriber receives the request message, the receipt message is returned to the corresponding return topic area according to the identification information of the return topic given in the request message. The message publisher can obtain the receipt message from the return subject area, thereby realizing synchronous communication without adding an independent synchronous communication subsystem, and saving research and development cost.
In order to make the aforementioned objects, features and advantages of the present invention comprehensible, embodiments accompanied with figures are described in detail below.
Referring to fig. 1, a flow chart of a communication method in an embodiment of the present invention is shown. The details are described below with reference to specific steps.
In a specific implementation, a message publisher publishes a request message, a message subscriber receives the request message, and the message publisher and the message subscriber have relativity.
Andstep 11, receiving a request message issued by a message issuing party.
In particular implementations, a message server may be employed to receive request messages issued by the message issuers. Wherein the request message may include: and the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area.
In a specific implementation, the message server may have multiple types according to different communication protocols adopted by two communication parties, namely, a message publisher and a message subscriber. For example, the message server may be kafka message middleware, RabbitMQ message middleware, and rocktmmq message middleware. It is understood that in practical applications, other types of servers or messaging middleware are also possible.
Andstep 12, storing the request message in a first received message topic area corresponding to the message subscriber according to the identification information of the received message topic area of the message subscriber.
In a specific implementation, after receiving the request message, the message server may store the request message in a first received message topic area corresponding to a message subscriber according to identification information of the received message topic area of the message subscriber in the request message.
In a specific implementation, the message subscriber may consume the request message from the corresponding first received message topic area, that is, obtain the request message from the first received message topic area.
In particular implementations, the message subscriber can consume the request message from the first received message topic area periodically, or in real-time.
In a specific implementation, the message server may establish a corresponding first received message topic area for the message subscriber when detecting that the message subscriber is started. The message server may also establish a return subject area corresponding to the message publisher for the message publisher when detecting that the message publisher is started.
Andstep 13, receiving the response piece message published by the message subscriber.
In a specific implementation, after the message subscriber receives the request message, the message subscriber may parse the request message to obtain a return identifier of the receipt message and identifier information of the return subject area in the request message. And when the receipt message return identifier represents that the request message needs to be fed back, the message subscriber generates a receipt message corresponding to the request message and publishes the generated receipt message to the message server.
In particular implementations, the message server can receive response piece messages published by the message subscribers.
Andstep 14, storing the receipt message in the corresponding return subject area according to the identification information of the return subject area, so that the message publisher can obtain the receipt message.
In a specific implementation, after receiving the receipt message, the message server stores the receipt message in a corresponding return subject area according to the identification information of the return subject area in the receipt message.
In particular implementations, the message publisher can consume the response piece message from within the return topic area.
When the message publisher consumes the receipt message from the message server, a synchronous communication is also completed.
As can be seen from the above, the request message generated by the message publisher includes the identification information of the message topic area received by the message subscriber, the receipt message return identification, and the identification information of the return topic area, so that after the message subscriber receives the request message, the receipt message is returned to the corresponding return topic area according to the identification information of the return topic given in the request message. The message publisher can obtain the receipt message from the return subject area, thereby realizing synchronous communication without adding an independent synchronous communication subsystem, and saving research and development cost.
In a specific implementation, the message subscriber may be one individual or multiple individuals, and the request message may be consumed by any one of the message subscribers and may be consumed only once.
In a specific implementation, the message subscriber may be a cluster established for one individual, or may be a cluster established for a plurality of individuals.
In a specific implementation, in order to avoid that the same request message is consumed multiple times, after the completion ofstep 12, the status of the request message may be marked as acquired after detecting that the request message is acquired by a certain entity in the message subscriber; or after detecting that the request message is acquired by a certain person in the message subscriber, removing the request message from the message receiving subject area, thereby saving system processing resources and improving system processing efficiency and stability. .
In particular implementations, when the message subscribers include multiple individuals, there is an application need to send a particular message to one of the designated message subscribers. In order to enable a specific message to be sent to a corresponding individual, in an embodiment of the present invention, a targeted message issued by the message issuer is received, where the targeted message includes: a message subscriber receives identification information of a directional message subject area; and storing the directional message in a corresponding second received message subject area according to the identification information of the directional message subject area received by the message subscriber, so that the message subscriber can acquire the directional message from the second received message subject area.
In a specific implementation, the first received message topic area is a public received message topic area of the message subscriber, and when the message subscriber includes a plurality of individuals, each individual can obtain a request message from the first received message topic area; the second message receiving subject area is an exclusive message receiving subject area of an individual and is only used for the individual to obtain the stored request message.
In particular implementations, sometimes directed messages published by a message publisher require a response from a message subscriber. Accordingly, the directed message may further include: and returning the identification and the identification information of the returned subject area by the receipt message. The message server can also receive a receipt message published by the message subscriber, wherein the receipt message comprises identification information of a return subject area, and the receipt message is stored in the corresponding return subject area according to the identification information of the return subject so as to be acquired by the message publisher.
In order to facilitate better understanding and implementation of the present invention for those skilled in the art, a message server is further provided in the embodiment of the present invention. The message server is described in detail below with reference to the accompanying drawings.
Referring to fig. 2, a schematic structural diagram of a message server in the embodiment of the present invention is shown. Themessage server 20 may include: afirst receiving unit 21, afirst storage unit 22, asecond receiving unit 23, and asecond storage unit 24, wherein:
thefirst receiving unit 21 is adapted to receive a request message issued by a message issuer, where the request message includes: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area;
thefirst storage unit 22 is adapted to store the request message in a first received message topic area corresponding to the subscriber according to the identification information of the received message topic area of the information subscriber, so that the information subscriber can obtain the request message from the received message topic area;
thesecond receiving unit 23 is adapted to receive a response piece message published by the message subscriber, where the response piece message includes identification information of a return topic area;
thesecond storage unit 24 is adapted to store the receipt message in the corresponding return subject area according to the identification information of the return subject area, so that the message publisher can obtain the receipt message.
In a specific implementation, the working principle and the working flow of themessage server 20 may be described in the communication method provided in the above embodiment of the present invention, and are not described herein again.
Referring to fig. 3, a schematic structural diagram of a communication system according to an embodiment of the present invention is shown. The communication system may include: a message publisher a31, a message subscriber B32, and amessage server 33, wherein:
the message publisher a31, adapted to publish a request message to themessage server 33, the request message comprising: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area; and obtaining the response piece message published by the message subscriber B32 from the return topic area of themessage server 33;
the message subscriber B32 is adapted to obtain the request message from the first received message topic area of themessage server 33, generate the response piece message according to the request message, and publish the response piece message to themessage server 33, where the response piece message includes the identification information of the return topic area;
themessage server 33 is adapted to receive the request message published by the message publisher a31, store the request message in a first received message Topic area corresponding to the message subscriber B32, that is, in a Topic area, according to the identification information of the received message Topic area of the message subscriber, receive the receipt message published by the message subscriber B32, and store the receipt message in a corresponding returned Topic area, which is B Topic, according to the identification information of the returned Topic area.
In particular implementations, themessage server 33 may exist in a variety of types. For example, the message middleware may be kafka message middleware, RabbitMQ message middleware, and rocktmmq message middleware. It is understood that in practical applications, other types of servers or messaging middleware are also possible.
As can be seen from the above, the request message generated by the message publisher includes the identification information of the message topic area received by the message subscriber, the receipt message return identification, and the identification information of the return topic area, so that after the message subscriber receives the request message, the receipt message is returned to the return topic area in the message server according to the identification information of the return topic given in the request message. The message publisher can obtain the receipt message from the return subject area in the message server, so that synchronous communication can be realized while asynchronous communication is realized by adopting the existing message server in the asynchronous communication system, and an independent synchronous communication subsystem is not required to be added, so that the research and development cost can be saved.
In a specific implementation, themessage server 33 may establish a corresponding return topic area for the message publisher when detecting that the message publisher is started. And when the message subscriber is detected to be started, establishing a corresponding message receiving subject area for the message subscriber.
In a specific implementation, the message subscriber may be one individual or a cluster formed by a plurality of individuals, and referring to fig. 4, a schematic structural diagram of another communication system in the embodiment of the present invention is given.
During uplink service, the message subscriber is a cluster formed by a plurality of individuals, including B1, B2, … … and Bn, where n is a positive integer. The message issuers are A1, A2, … … and Am, and m is a positive integer.
During downlink service, the message subscriber is a cluster formed by a plurality of individuals, wherein A1, A2, … … and Am are positive integers. The message issuers are B1, B2, … … and Bn, and n is a positive integer.
In particular implementations, the request message may be consumed by any one of the individuals of the message subscribers, and may be consumed only once.
With continued reference to fig. 3, in order to avoid multiple consumption of the same request message, system processing resources are saved, and system processing efficiency and stability are improved. In an embodiment of the present invention, when themessage server 33 detects that the request message is acquired by a certain entity in the message subscriber, the status of the request message is marked as acquired; the request message may also be removed from the received message subject area upon detecting that the request message is obtained by an individual of the message subscribers.
In particular implementations, the message publisher a31 may also publish the targeted message to themessage server 33. The oriented message comprises identification information of an oriented message subject area of the oriented message received by a message subscriber. Themessage server 33 stores the targeted message in the second received message subject area according to the identification information of the targeted message subject area of the targeted message. The message subscriber B32 may consume the targeted message from within the second received message topic area.
In a specific implementation, the first received message topic area is a common received message topic area of the message subscriber B32, and when the message subscriber includes a plurality of individuals, each individual may obtain a request message from the first received message topic area. The second message receiving subject area is an exclusive message receiving subject area of an individual and is only used for the individual to obtain the directional message. That is, the first received message subject area is a group Topic, and any individual in the message subscriber can consume the message from within the group Topic. The second received message subject area is private Topic, and messages within the private Topic are only for consumption of stored messages by the owner of the private Topic.
In a specific implementation, when the targeted message received by the message subscriber includes a receipt message return identifier and identifier information of a return subject area, it is characterized that the message subscriber needs to feed back the receipt message after receiving the targeted message. The message subscriber B32 is adapted to generate a response piece message after receiving the directed message, and send the response piece message to themessage server 33. After receiving the receipt message, themessage server 33 stores the receipt message in the corresponding return subject area according to the identification information of the return subject in the receipt message. The message publisher a31 may retrieve the response piece message from the return topic area.
In specific implementation, the scheme provided by the embodiment of the invention can be suitable for communication between a remote server and a service server in a vehicle remote control system, can also be suitable for communication between a communication server and the service server in a cloud platform, and can also be suitable for transverse communication between background subsystems in a navigation system. It can be understood that in some large-scale systems, the communication between subsystems can adopt the scheme provided in the embodiments of the present invention, so as to realize synchronous communication while considering asynchronous communication.
The communication system according to the embodiment of the present invention will be described in detail with reference to fig. 4.
For convenience of illustration, in the uplink service, the message publisher is a1, a2, … …, Am, and the message subscriber B is a cluster (Group) of B1, B2, … …, Bn. When the message server detects that the message publisher A1, A2, … …, Am and the message subscriber B are started, an A1Topic is automatically established for the message publisher A1 for receiving the response piece message of the message publisher A1, wherein the response piece message deposited in the A1Topic is only consumed by A1. Correspondingly, the message server automatically establishes corresponding A2Topic, … … and Am Topic for the message publishers A2, … … and Am, respectively. The message server establishes BTomic for the message subscriber B, and each individual B1, B2, … … and Bn in the message subscriber B can consume the stored request message from B Topic.
When the message publisher Ai sends the request message M sent to the message subscriber B to the message server, the message server stores the request message M in B Topic according to the identification information of B Topic included in the request message M, and each individual in the message subscriber B continuously consumes messages from B Topic, and when the request message M is consumed by the individual B1 in the message subscriber B, the message server can mark the request message M as consumed.
When the request message M is consumed by the B1, the request message M is analyzed, the return identifier of the receipt message in the request message M is obtained to be 1, and the identifier information of the returned subject area is Ai Topic, so that the request message M is a request message which needs to be responded. B1 generates a response piece message corresponding to the request message M and publishes the response piece message to the message server.
In a specific implementation, if the return identifier of the receipt message in the request message is 0, the request message is characterized as an asynchronous message. It is understood that the return identification of the receipt message may be set as required, or may be characterized by other identifications, for example, 2 is used to characterize the request message and the return receipt message needs to be fed back.
And after receiving the receipt message issued by the B1, the message server stores the receipt message in Ai Topic according to the identification information of the return subject area in the receipt message. Ai may consume receipt messages from Ai Topic on a non-stop basis.
In specific implementation, in the downlink service, the message publisher is a cluster of B1, B2, … …, and Bn, and the message subscriber is a cluster of a1, a2, … …, and Am. When the message server detects that the message publisher B1, B2, … …, Bn and the message subscriber A start, corresponding B1Topic, B2Topic, … …, Bn Topic and A Topic are automatically established for each party respectively. A1, a2, … …, Am in the message subscriber a may all consume the request message from a Topic.
In a specific implementation, the two communication parties may also issue a directed message, for example, B1 issues the directed message to a message server, and the message server stores the directed message in Am Topic according to the identification information of the directed message subject area including Am in the directed message, where Am may message the directed message from Am Topic. When Am consumes the directional message and needs to feed back the receipt message, the receipt message can be issued to the message server, and the message server stores the receipt message in B1Topic according to the identification information of the return subject area in the receipt message. B1 may consume the response piece message from B1 Topic.
In a specific implementation, there may be a directed message, there may also be a receipt message, and there may also be a request message in Am Topic. When Am consumes the message from Am Topic, the consumed message can be compared with the message in the request queue to judge which time request message is, and when the message is the request message, response is carried out and a receipt message is fed back.
Those skilled in the art will appreciate that all or part of the steps in the methods of the above embodiments may be implemented by associated hardware instructed by a program, which may be stored in a computer-readable storage medium, and the storage medium may include: ROM, RAM, magnetic or optical disks, and the like.
Although the present invention is disclosed above, the present invention is not limited thereto. Various changes and modifications may be effected therein by one skilled in the art without departing from the spirit and scope of the invention as defined in the appended claims.
Claims (16)
1. A method of communication, comprising:
receiving a request message issued by a message issuer, the request message comprising: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area;
storing the request message in a first received message topic area corresponding to the message subscriber according to the identification information of the received message topic area of the message subscriber, so that the message subscriber can obtain the request message from the received message topic area;
receiving a receipt message published by the message subscriber, wherein the receipt message is generated by the message subscriber according to the request message and comprises identification information of a returned subject area;
and storing the receipt message in a corresponding return subject area according to the identification information of the return subject area so as to enable the message publisher to obtain the receipt message.
2. The communication method according to claim 1, wherein the message subscriber comprises a plurality of individuals, and the request message is adapted to be acquired by any one of the plurality of individuals and acquired only once.
3. The communication method according to claim 2, wherein the message subscriber establishes a cluster for one individual or for a plurality of individuals.
4. The communication method according to claim 3, wherein storing the request message after the first received message subject area corresponding to the subscriber further comprises performing any one of the following operations: when the request message is detected to be acquired by a certain entity in the message subscriber, the state of the request message is marked as acquired;
and removing the request message from the received message subject area after detecting that the request message is acquired by a certain person in the message subscriber.
5. The communication method according to claim 1, further comprising:
receiving a directed message issued by the message issuer, wherein the directed message comprises: a message subscriber receives identification information of a directional message subject area;
according to the identification information of a targeted message topic area received by the message subscriber, storing the targeted message in a corresponding second received message topic area so that the message subscriber can acquire the targeted message from the second received message topic area, wherein the first received message topic area is a common received message topic area of the message subscriber, and when the message subscriber comprises a plurality of individuals, each individual can acquire a request message from the first received message topic area; the second message receiving subject area is an exclusive message receiving subject area of an individual, and the corresponding individual can obtain the stored directional message.
6. The communication method of claim 5, wherein the directed message further comprises: the receipt message returns an identifier and identifier information of the returned subject area; the communication method further comprises:
receiving a receipt message published by the message subscriber, wherein the receipt message comprises identification information of a returned subject area;
and storing the receipt message in a corresponding return subject area according to the identification information of the return subject area so as to enable the message publisher to obtain the receipt message.
7. The communication method according to claim 1, further comprising:
when the message publisher is detected to be started, establishing a return subject area corresponding to the message publisher;
and when the message subscriber is detected to be started, establishing a first received message subject area corresponding to the message subscriber.
8. A message server, comprising: first receiving unit, first memory cell, second receiving unit and second memory cell, wherein:
the first receiving unit is adapted to receive a request message issued by a message issuer, where the request message includes: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area;
the first storage unit is adapted to store the request message in a first received message topic area corresponding to a subscriber according to the identification information of the received message topic area of the message subscriber, so that the message subscriber can obtain the request message from the received message topic area;
the second receiving unit is suitable for receiving a response piece message published by the message subscriber, wherein the response piece message comprises identification information of a return subject area;
the second storage unit is suitable for storing the receipt message in the corresponding return subject area according to the identification information of the return subject area, so that the message publisher can obtain the receipt message.
9. A communication system, comprising: a message publisher, a message subscriber and a message server according to claim 8, wherein:
the message publisher is adapted to publish a request message to the message server, the request message including: the message subscriber receives the identification information of the message subject area, the return receipt message return identification and the identification information of the return subject area; and obtaining the receipt message published by the message subscriber from the return topic area of the message server;
the message subscriber is suitable for acquiring the request message from a first received message subject area of the message server, generating the receipt message according to the request message and publishing the receipt message to the message server, wherein the receipt message comprises identification information of a returned subject area;
the message server is suitable for receiving the request message published by the message publisher, storing the request message in a first message topic receiving area corresponding to the message subscriber according to the identification information of the message topic receiving area of the message subscriber, receiving the receipt message published by the message subscriber, and storing the receipt message in a corresponding topic returning area according to the identification information of the topic returning area.
10. The communication system according to claim 9, wherein the message subscriber comprises a plurality of individuals, and the request message is adapted to be obtained by any one of the plurality of individuals and only once.
11. The communication system of claim 10, wherein the message subscriber establishes a cluster for one or more individuals.
12. The communication system according to claim 11, wherein the message server is further adapted to perform any one of the following operations after storing the request message in the first received message subject area corresponding to the subscriber:
when the request message is detected to be acquired by a certain entity in the message subscriber, the state of the request message is marked as acquired;
and removing the request message from the received message subject area after detecting that the request message is acquired by a certain person in the message subscriber.
13. The communication system of claim 9, wherein the message publisher is further adapted to generate and send a directed message to the message server, the directed message comprising: a message subscriber receives identification information of a directional message subject area;
the message server is also suitable for receiving the oriented message published by the message publishing party and storing the oriented message in a corresponding second received message subject area according to the identification information of the oriented message subject area received by the message subscribing party;
the message subscriber is further adapted to obtain the targeted message from the second received message topic area, the first received message topic area is a common received message topic area of the message subscriber, and when the message subscriber includes a plurality of individuals, each individual can obtain a request message from the first received message topic area; the second message receiving subject area is an exclusive message receiving subject area of an individual, and the corresponding individual can obtain the stored directional message.
14. The communication system of claim 13, wherein the directed message further comprises: the receipt message returns an identifier and identifier information of the returned subject area;
the message subscriber is also suitable for generating a receipt message according to the oriented message and sending the receipt message to the message server, wherein the receipt message comprises identification information of a returned subject area;
the message server is also suitable for receiving the receipt message sent by the message subscriber and storing the receipt message in a corresponding return subject area according to the identification information of the return subject;
the message publisher is further adapted to retrieve the response piece message from a return subject area of the message server.
15. The communication system according to claim 9, wherein the message server is further adapted to establish a return subject area corresponding to the message publisher when detecting that the message publisher is started; and when the message subscriber is detected to be started, establishing a message receiving subject area corresponding to the message subscriber.
16. The communication system of claim 9, wherein the message server is kafka message middleware.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201611259386.3ACN106603711B (en) | 2016-12-30 | 2016-12-30 | Communication method, system and message server |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201611259386.3ACN106603711B (en) | 2016-12-30 | 2016-12-30 | Communication method, system and message server |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN106603711A CN106603711A (en) | 2017-04-26 |
| CN106603711Btrue CN106603711B (en) | 2020-01-03 |
Family
ID=58581511
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201611259386.3AActiveCN106603711B (en) | 2016-12-30 | 2016-12-30 | Communication method, system and message server |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN106603711B (en) |
Families Citing this family (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107026917A (en)* | 2017-06-16 | 2017-08-08 | 智者四海（北京）技术有限公司 | The method and system pushed for message |
| CN107678866B (en)* | 2017-09-22 | 2020-02-21 | 北京东土科技股份有限公司 | A kind of partition communication method and device based on embedded operating system |
| CN108880985A (en)* | 2018-06-01 | 2018-11-23 | 安徽八千里科技发展股份有限公司 | One kind is based on wisdom endowment system under electronic information mode |
| CN109451072A (en)* | 2018-12-29 | 2019-03-08 | 广东电网有限责任公司 | A kind of message caching system and method based on Kafka |
| CN111027966B (en)* | 2019-11-07 | 2023-08-22 | 中国建设银行股份有限公司 | Service processing method and system |
| CN111405021A (en)* | 2020-03-10 | 2020-07-10 | 中国建设银行股份有限公司 | Data transmission method, device, equipment and storage medium of peer-to-peer node |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1374598A (en)* | 2001-03-12 | 2002-10-16 | 李英元 | Interactive advertizing method and system |
| CN106161216A (en)* | 2016-08-31 | 2016-11-23 | 深圳市精准分众传媒有限公司 | Promotion message shares tracking and system |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8725807B2 (en)* | 2010-08-04 | 2014-05-13 | International Business Machines Corporation | Decentralized data casting in an interest aware peer network |
| US10992772B2 (en)* | 2015-05-01 | 2021-04-27 | Microsoft Technology Licensing, Llc | Automatically relating content to people |
- 2016
- 2016-12-30CNCN201611259386.3Apatent/CN106603711B/enactiveActive
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1374598A (en)* | 2001-03-12 | 2002-10-16 | 李英元 | Interactive advertizing method and system |
| CN106161216A (en)* | 2016-08-31 | 2016-11-23 | 深圳市精准分众传媒有限公司 | Promotion message shares tracking and system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN106603711A (en) | 2017-04-26 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN106603711B (en) | Communication method, system and message server | |
| CN108897854B (en) | Monitoring method and device for overtime task | |
| CN105915612A (en) | Push message acquisition method, message push method and device | |
| CN111917687B (en) | Method and device for circularly pushing reminding message | |
| CN102685018B (en) | A kind of method of network instant communication information processing, system and instant communication device | |
| CN108712457A (en) | Back-end server dynamic load method of adjustment and device based on Nginx reverse proxys | |
| CN112099864B (en) | Asynchronous data processing method and device | |
| CN102185801A (en) | Information processing method in instant messaging and instant messaging tool | |
| CN104657841A (en) | Express item delivery method, delivery processing method, express cabinet terminal and service system | |
| CN111726417B (en) | Delay control method, device, server and storage medium | |
| CN103024085A (en) | System and method for processing P2P (peer-to-peer) node request | |
| CN114024972A (en) | Long connection communication method, system, device, equipment and storage medium | |
| CN107562803B (en) | Data supply system and method and terminal | |
| CN113296976A (en) | Message processing method, message processing device, electronic equipment, storage medium and program product | |
| CN113064740B (en) | A message processing method and device | |
| US10268532B2 (en) | Application message processing system, method, and application device | |
| CN114827171B (en) | Information synchronization method, apparatus, computer device and storage medium | |
| CN105656769B (en) | Business data processing method, device and system | |
| CN102546734B (en) | Data information processing system and method | |
| CN112671636B (en) | Group message pushing method and device, computer equipment and storage medium | |
| CN106790354B (en) | Communication method and device for preventing data congestion | |
| CN105025042A (en) | A method and system for determining data information, and proxy server | |
| CN110839061A (en) | Data distribution method, device and storage medium | |
| CN108268607B (en) | Data circulation system and method, storage medium, and terminal | |
| CN107493201B (en) | Synchronization method and device for configuration messages |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |