CN111800519A - Communication system, method and device - Google Patents
Communication system, method and device Download PDFInfo
- Publication number
- CN111800519A CN111800519A CN202010926962.5A CN202010926962A CN111800519A CN 111800519 A CN111800519 A CN 111800519A CN 202010926962 A CN202010926962 A CN 202010926962A CN 111800519 A CN111800519 A CN 111800519A
- Authority
- CN
- China
- Prior art keywords
- terminal
- database
- request
- message queue
- data
- 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.)
- Pending
Links
- 230000006854 communication Effects 0.000 title claims abstract description 81
- 238000004891 communication Methods 0.000 title claims abstract description 77
- 238000000034 method Methods 0.000 title claims abstract description 56
- 238000002955 isolation Methods 0.000 claims description 38
- 238000012545 processing Methods 0.000 claims description 20
- 230000005540 biological transmission Effects 0.000 claims description 8
- 238000013508 migration Methods 0.000 claims description 5
- 230000005012 migration Effects 0.000 claims description 5
- 230000008569 process Effects 0.000 abstract description 18
- 230000008878 coupling Effects 0.000 abstract description 5
- 238000010168 coupling process Methods 0.000 abstract description 5
- 238000005859 coupling reaction Methods 0.000 abstract description 5
- 230000006870 function Effects 0.000 description 9
- 238000010586 diagram Methods 0.000 description 7
- 238000013461 design Methods 0.000 description 5
- 230000008901 benefit Effects 0.000 description 4
- 238000001514 detection method Methods 0.000 description 4
- 230000007246 mechanism Effects 0.000 description 4
- 230000009471 action Effects 0.000 description 3
- 230000010354 integration Effects 0.000 description 3
- 238000013459 approach Methods 0.000 description 2
- 238000011161 development Methods 0.000 description 2
- 238000005516 engineering process Methods 0.000 description 2
- 238000012423 maintenance Methods 0.000 description 2
- 239000011800 void material Substances 0.000 description 2
- 230000007175 bidirectional communication Effects 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000004806 packaging method and process Methods 0.000 description 1
- 230000002265 prevention Effects 0.000 description 1
- 230000000750 progressive effect Effects 0.000 description 1
- 238000000926 separation method Methods 0.000 description 1
- 238000012360 testing method Methods 0.000 description 1
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/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/562—Brokering proxy services
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/25—Integrating or interfacing systems involving database management systems
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L63/00—Network architectures or network communication protocols for network security
- H04L63/02—Network architectures or network communication protocols for network security for separating internal from external traffic, e.g. firewalls
- H04L63/0281—Proxies
Landscapes
- Engineering & Computer Science (AREA)
- General Engineering & Computer Science (AREA)
- Signal Processing (AREA)
- Databases & Information Systems (AREA)
- Computer Networks & Wireless Communication (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer Hardware Design (AREA)
- Computer Security & Cryptography (AREA)
- Computing Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention discloses a communication system, a method and a device, wherein the system comprises: the system comprises a first terminal, a first message queue, a database, a second terminal and a second message queue, wherein the first terminal sends a first request of the first terminal, and the first request comprises: a read or write request; a first message queue receives a first request of a first terminal and processes the first request; the database stores data sent by the first terminal and the second terminal; the second terminal sends a second request of the second terminal, wherein the second request comprises: a read or write request; the second message queue receives a second request of the second terminal and processes the second request. In the system, the database is not interacted with the first terminal and the second terminal any more, the message queue is added between the database and the terminal, even if the database is changed, the message queue only needs to be simply adjusted, the terminal does not need to be adjusted, the coupling degree of the terminal and the database is reduced, and the system is stable.
Description
Technical Field
The present invention relates to the field of communications technologies, and in particular, to a communication system, method, and apparatus.
Background
In the traditional internal and external network communication, the application of the internal network terminal calls an internal network database and writes related information into an internal network MySQL database. And the application of the external network terminal accesses the internal network database through strong isolation to acquire information data generated by the internal network application.
In the communication process, the application of the intranet terminal and the application of the extranet terminal are both based on the database, the intranet terminal and the extranet terminal are required to be configured with relevant information of the database, once the database is changed, the terminal needs to be increased, the normal operation of the system application is influenced, the coupling degree of the system is greatly increased, and the later-stage system maintenance is not easy to realize.
Disclosure of Invention
In view of the above, the present invention provides a communication system, method and device, so as to solve the problems that in the existing communication process, both the application of an intranet terminal and the application of an extranet terminal depend on a database, both the intranet terminal and the extranet terminal need to configure relevant information of the database, once the database is changed, the terminal needs to be increased, and the normal operation of the system application is necessarily affected, so that the coupling degree of the system is greatly increased, and the later-stage system maintenance is not easy, and the specific scheme is as follows:
a communication system, comprising: a first terminal, a first message queue, a database, a second terminal, and a second message queue, wherein,
the first terminal is configured to send a first request of the first terminal, where the first request includes: a read or write request;
the first message queue is used for receiving a first request of the first terminal and processing the first request;
the database is used for storing data sent by the first terminal and the second terminal;
the second terminal is configured to send a second request of the second terminal, where the second request includes: a read or write request;
and the second message queue is used for receiving a second request of the second terminal and processing the second request.
The above system, optionally, further includes: a strong isolation device, wherein,
the strong isolation device is used for isolating a first network from a second network, wherein the first network comprises: the first terminal, the first message queue and the database, the second network comprising: the second terminal and the second message queue;
in the above system, optionally, the first message queue includes: a first service center module and a first service agent module, wherein,
the first service center module is used for forwarding the first request;
the first service agent module is used for processing the first request.
In the above system, optionally, the second message queue includes: a second service center module and a second service agent module, wherein,
the second service center module is used for forwarding the second request;
and the second service agent module is used for processing the second request.
The above system, optionally, further includes: a migration module, wherein,
and the migration module is used for migrating the consumed information in the database to a preset storage position for storage at preset time intervals.
Optionally, in the system, the database is a relational database supporting asynchronous transmission of pictures.
A communication method, applied to the process of writing data into a first terminal and reading data from a second terminal in the communication system, the communication method comprising:
the first terminal writes first data into a database through a first message queue;
and the second message queue accesses the database through a strong isolation device, acquires the first data, and sends the first data to the second terminal through the strong isolation device.
A communication method, applied to the process of reading data by a first terminal and writing data by a second terminal in the communication system, the communication method comprising:
the second terminal writes second data into a database through a second message queue and a strong isolation device;
and the first message queue accesses the database, acquires the second data and sends the second data to the first terminal.
A communication device, which is applied to the communication system described above, in the process of writing data into a first terminal and reading data from a second terminal, the communication device comprising:
the first writing module is used for the first terminal to write first data into a database through a first message queue;
and the first acquisition and sending module is used for accessing the database by the second message queue through a strong isolation device, acquiring the first data and sending the first data to the second terminal through the strong isolation device.
A communication device, which is applied to the communication system in the process of reading data by a first terminal and writing data by a second terminal, the communication device comprising:
the second writing module is used for writing second data into the database by the second terminal through a second message queue and a strong isolation device;
and the second reading and sending module is used for accessing the database by the first message queue, acquiring the second data and sending the second data to the first terminal.
Compared with the prior art, the invention has the following advantages:
the invention discloses a communication system, a method and a device, wherein the system comprises: the system comprises a first terminal, a first message queue, a database, a second terminal and a second message queue, wherein the first terminal is used for sending a first request of the first terminal, and the first request comprises: a read or write request; the first message queue is used for receiving a first request of the first terminal and processing the first request; the database is used for storing data sent by the first terminal and the second terminal; the second terminal is configured to send a second request of the second terminal, where the second request includes: a read or write request; and the second message queue is used for receiving a second request of the second terminal and processing the second request. In the system, the database is not interacted with the first terminal and the second terminal any more, the message queue is added between the database and the terminal, even if the database is changed, the message queue only needs to be simply adjusted, the terminal does not need to be adjusted, the coupling degree of the terminal and the database is reduced, and the system is stable.
Of course, it is not necessary for any product in which the invention is practiced to achieve all of the above-described advantages at the same time.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the drawings without creative efforts.
Fig. 1 is a block diagram of a communication system according to an embodiment of the present disclosure;
fig. 2 is a flowchart of a communication method disclosed in the present embodiment;
fig. 3 is another flowchart of a communication method according to an embodiment of the present disclosure;
fig. 4 is a block diagram of a communication device according to an embodiment of the present disclosure;
fig. 5 is a block diagram of another structure of a communication device according to an embodiment of the present disclosure.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
The previous description of the disclosed embodiments is provided to enable any person skilled in the art to make or use the present invention. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be applied to other embodiments without departing from the spirit or scope of the invention. Thus, the present invention is not intended to be limited to the embodiments shown herein but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.
The invention discloses a communication system, a method and a device, wherein the communication process is the communication of two terminals, the two terminals can be in the same network or different networks, preferably, the two terminals are in different networks in the embodiment of the invention for explanation, in the prior art, the terminals in different networks are directly connected and strongly isolated with a database and can only transmit through SQL, thereby greatly consuming the database resources, having high system redundancy, requiring integral cluster deployment for the communication between different terminals, having serious resource consumption and large mutual influence of all the functions fused together, in the embodiment of the invention, the system adopts the design idea of splitting the modularized function, each module is in work division and cooperation, thereby realizing that each module carries out independent cluster deployment, not only improves the overall performance of the system, but also saves resources. The system further encapsulates the communication process, and the message producer and the consumer do not need to be concerned with the message transmission process.
A block diagram of the communication system is shown in fig. 1, and the communication system includes: a first terminal, a first message queue, a database, a second terminal, and a second message queue, wherein,
the first terminal is configured to send a first request of the first terminal, where the first request includes: a read or write request;
in this embodiment of the present invention, the first terminal is connected to the port of the first message queue exposed to the outside through the first message queue, and the first terminal sends the first request to the first message queue, where the first request includes a read request or a request.
The first message queue is used for receiving a first request of the first terminal and processing the first request;
in this embodiment of the present invention, the first message queue is connected to the database, and the first message queue includes: a first service center module (a first namersv) and a first service broker module (a first broker), wherein the first service center module is configured to receive the first request and forward the first request, the first service center module externally includes a port for external invocation, updating and discovering a first broker service, the first broker module is a message host server and is configured to receive the first request and process the first request, the processing procedure includes obtaining a to-be-processed message included in the first request and correspondingly processing the to-be-processed message according to a type of the request, and the processing manner includes: and storing the data to be processed into the database or reading the data to be processed from the database.
The database is used for storing data sent by the first terminal and the second terminal;
in the embodiment of the present invention, the database is a relational database, preferably, the database is a Mysql database, and the database stores information written by the first terminal and the second terminal.
The second terminal is configured to send a second request of the second terminal, where the second request includes: a read or write request;
in this embodiment of the present invention, the second terminal is connected to the second message queue, and the second terminal sends the second request to the second message queue, where the second request includes a read or write request.
And the second message queue is used for receiving a second request of the second terminal and processing the second request.
In this embodiment of the present invention, the second message pair is connected to the database, and the second message queue includes: a second service center module (second namersv) and a second service broker module (second broker), wherein the second service center module is configured to receive the second request and forward the second request, the second service center module includes an external port for external invocation, updating and discovering a second broker service, the second broker module is a message host server and is configured to receive the second request and process the second request, the processing procedure includes obtaining a to-be-processed message included in the second request, and performing corresponding processing on the to-be-processed message according to a type of the request, and the processing manner includes: and storing the data to be processed into the database or reading the data to be processed from the database.
The invention discloses a communication system, comprising: the system comprises a first terminal, a first message queue, a database, a second terminal and a second message queue, wherein the first terminal is used for sending a first request of the first terminal, and the first request comprises: a read or write request; the first message queue is used for receiving a first request of the first terminal and processing the first request; the database is used for storing data sent by the first terminal and the second terminal; the second terminal is configured to send a second request of the second terminal, where the second request includes: a read or write request; and the second message queue is used for receiving a second request of the second terminal and processing the second request. In the system, the database is not interacted with the first terminal and the second terminal any more, the message queue is added between the database and the terminal, even if the database is changed, the message queue only needs to be simply adjusted, the terminal does not need to be adjusted, the coupling degree of the terminal and the database is reduced, and the system is stable.
In an embodiment of the present invention, the communication system further includes: a strong isolation device to isolate a first network from a second network, wherein the first network comprises: the first terminal, the first message queue and the database, the second network comprising: the second terminal and the second message queue;
in the embodiment of the present invention, the first network is an intranet, the second network is an extranet, and the intranet and the extranet are isolated by a strong isolation device, preferably, the strong isolation device is configured to isolate a trusted information intranet from an untrusted information extranet, so that it is necessary to ensure that SQL communication between the information intranet and the information extranet is performed by the strong isolation device, and at the same time, it is necessary to ensure security of the system.
In intranet and extranet communication, the key point is strong isolation, and the key point of strong isolation is the use of a database. Therefore, the intranet and extranet communication message queue is a self-developed message queue middleware realized based on the existing technical means of strong isolation devices, databases and message queues, and has the basic functions of the message queue. It is a product under the environment of specific network requirements, and is only suitable for data transmission between internal and external networks. The implementation of the indbmq enables the message queue technology commonly used by the internet to be widely applied, and some common queue use scenes can also be applied. The system can process the communication of the internal and external networks with high efficiency, low delay, high concurrency and high stability, thereby providing technical support for the communication of the internal and external networks.
According to the requirements of internal and external network communication, a strong isolation device and a relational database must be used. Therefore, the intranet and extranet communication message queue system (hereinafter referred to as indbmq) adopts the design concept that an intranet and an extranet are respectively provided with one set of system, and the two sets of systems serve as data interaction centers through the mysql database. And deploying an indbmq system in the intranet environment, wherein the system is directly connected with an intranet mysql database. And (3) deploying an indbmq system in the external network environment, and connecting the system to the mysql database address exposed to the external network through a strong isolation device. Therefore, the requirement for internal and external network communication is met, and the function of internet message queue is realized.
The function of the indbmq system is as follows:
(1) the method realizes the basic message queue function, supports the dynamic creation of the theme, supports the basic receiving and sending of the message, supports the push-pull mode and ensures the accurate consumption of the message.
(2) The performance is fast and the original efficiency is high, and the performance is improved by times independently from the original performance. The stability aspect is also superior to the original implementation mode alone.
(3) The method is developed quickly and provides simple SDK packaging implementation. Developers are only concerned with the message queue middleware itself. There is no need to pay attention to the internal and external network problems.
(4) Distributed is supported, as are other distributed message queues supporting distributed cluster deployment. Through the distributed mode, alleviate single-point pressure, solve the performance bottleneck problem. For late stage development and high concurrency of indbmq. The system is designed in a multi-subsystem architecture. I.e. indbmq consists of two parts: namesrv and brooker. The design has the advantage that if the access pressure of the indbmq is continuously increased, a multi-browser node deployment mode can be adopted, and a plurality of browser nodes are in long connection with the namesrv through the listening ports, so that the access pressure can be dispersed to each browser node, and the access pressure of a single browser is relieved. When the system calling pressure is increased, the namesrv can be clustered and deployed, and the calling pressure is reduced. Aiming at the later development of the indbmq, other subsystems can be additionally arranged for cooperative operation.
(5) When a timing task is set in the system, the consumed message data can be backed up to a corresponding history table after one hour. The backup and traceability of the message data are realized. A timed task mechanism is added to the indbmq, and at intervals, the indbmq will migrate consumed messages elsewhere. Therefore, the pressure of the database is relieved, and the consumed messages can be subjected to tracing query. This is very important in some application scenarios.
(6) The product supports asynchronous transmission of pictures between an internal network and an external network. The traditional MQ product can only produce and consume character data. And the design of the indbmq is not only the same, but also the system can support the asynchronous transmission of pictures and can meet more application scenes. And asynchronous transmission of pictures between the internal network and the external network is supported. The transmission type of the message is enriched. And the Indbmq stores the picture information sent by the producer into the mysql database according to the storage characteristics of the mysql database, and acquires the picture from the database when the consumer consumes the message.
Further, when using indbmq, a message queue may be used like rocktmq. Therefore, the learning cost can be saved, and the operation is faster.
Further, the conventional MQ products store message data in files, and only store the message data in a database according to the requirements of the network. Thus, file storage needs to be converted into database storage. Then follows the problem of database typing, and the mainstream database in the market at present has two types of oracle and mysql. Because the use environment of the system is complex, multi-scenario deployment and absolute separation of data are possible, a light weight of data is needed. The advantages of mysql are now more apparent. Mysql is therefore selected as a storage carrier for the message data.
Based on the foregoing communication system, an embodiment of the present invention provides a communication method, where in a process of writing data in a first terminal and reading data from a second terminal in the communication system, an execution flow of the communication method is shown in fig. 2, and the method includes:
s101, the first terminal writes first data into a database through a first message queue;
in the embodiment of the present invention, when the first message queue receives a write request sent by the first terminal, first data included in the write request is acquired, and the first data is written into the database.
S102, the second message queue accesses the database through a strong isolation device, obtains the first data, and sends the first data to the second terminal through the strong isolation device.
In the embodiment of the present invention, the second message queue continuously accesses the database through the strong isolation device in a polling manner, and when it is detected that the first data is stored in the database, the detection manner may be continuously searching at a specified position of the database or receiving a preset instruction or other detection manners.
Based on the communication system, an embodiment of the present invention provides a communication method, which is applied to a process of a first terminal reading data and a second terminal writing data in the communication system, and an execution flow of the communication method is shown in fig. 3, where the method includes:
s201, the second terminal writes second data into a database through a second message queue and a strong isolation device;
in the embodiment of the present invention, when the second message queue receives a write request sent by the second terminal, second data included in the write request is acquired, and the second data is written into the database.
S202, the first message queue accesses the database, the second data are obtained, and the second data are sent to the first terminal.
In the embodiment of the present invention, the first message queue continuously accesses the database through the strong isolation device in a polling manner, and when it is detected that the second data is stored in the database, the detection manner may be continuously searching at a designated position of the database or receiving a preset instruction or other detection manners.
In the embodiment of the invention, the communication method is described by taking the use process of an intranet and extranet communication message queue as an example, an indbmq system is respectively deployed in an intranet server and an extranet server, the indbmq of the intranet is directly connected with a database, and the extranet indbmq is directly connected with a strong isolation access database. Because indbmq has the function of both inserting data into and retrieving data from the database. So that the bidirectional communication of the internal network and the external network is realized. When the internal network generates messages and the external network consumes: the intranet indbmq stores the messages produced by the producer in a database, and the extranet indbmq takes out the message data from the database through strong isolation and sends the message data to the consumer for consumption. When the outer net produces messages and the inner net consumes: the extranet indbmq stores the message produced by the producer into the database through strong isolation, and the intranet indbmq takes out the message information from the database and sends the message information to the consumer for consumption. The implementation process of the spring boot application integration indbmq mode is as follows:
(1) message producer integration approach
Adding relevant dependencies in a pom file
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>spring-boot-starter-rocketmq</artifactId>
<version>1.0.1</version>
</dependency>
Adding corresponding configuration information in the configuration file:
pring:
rocketmq:
nameServer: 127.0.0.1:8764;127.0.0.1:8765
producer:
group: producer-group
the RockMQTemplate object may then be used to send a message to indbmq
@Resource
private RocketMQTemplate rocketMQTemplate;
public void send(String msg) {
this.rocketMQTemplate.convertAndSend(topic,"Hello, World!" + msg);
}
(2) Message consumer integration approach
Adding relevant dependencies in a pom file
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>spring-boot-starter-rocketmq</artifactId>
<version>1.0.1</version>
</dependency>
Adding corresponding configuration information in configuration file
spring:
rocketmq:
nameServer: 127.0.0.1:8764;127.0.0.1:8765
producer:
group: producer-group
The RockMQListener listening can then be used to retrieve the messages within indbmq
@Service
@RocketMQMessageListener(topic = "tooapi-test", consumerGroup = "topic-consumer-group")
public class ConsumerRocketMQListener implements RocketMQListener<String>{
public void onMessage(String message) {
System.out.println("veceived message: " + message);
}
}
Further, aiming at the implementation process, the two sets of indbmq use the same message storage pool, so that the message sharing problem is realized. Indbmq adopts the design of double addresses of the same database. That is, the intranet indbmq is directly connected with the intranet database, and the intranet database exposes another connection address through the strong isolation device for connection of the extranet indbmq. The two databases are actually operated by the same database. Therefore, two sets of indbmq are connected with the same database, and data sharing is guaranteed.
When the mysql database is used for storing the messages, the problems of repeated consumption prevention of the messages and retrieval pressure of the database are also considered. Therefore, the indbmq makes full use of the transaction characteristics of the database, and ensures the unique consumption of the message at the transaction level of the database. When indbmq is run for a period of time, it is followed by database retrieval pressure issues. Since the amount of data in the data pool gradually increases with time, the database search pressure also gradually increases. So indbmq employs a timed migration mechanism. I.e., migrating consumed message data out of the message pool at intervals. This greatly eases the pressure on database retrieval.
In certain scenarios, a message traceable mechanism is also necessary. For example, when the payment system sends a payment message, the message is consumed normally. After several months the service personnel find this payment message problematic and need a full link lookup for traceability. In this case, the message traceability mechanism is important. Indbmq can quickly find the consumed message in the consumed message pool, so that the safety of the service is ensured.
The indbmq may be used only in an extranet environment or an intranet environment. Indbmq not only realizes the two-way communication between the internal network and the external network, but also supports the communication between the internal network and between the external network and the external network. Thus, the application scenes of the indbmq are wider. The indbmq can be used in any scenario where the database is used as a message carrier.
Based on the communication method described in fig. 2, an embodiment of the present invention further provides a communication device, where the communication device is applied in a communication system, and a structural block diagram of the communication device is shown in fig. 4, where the communication device includes:
a first writing module 301 and a first retrieving and sending module 302.
The first writing module 301 is configured to write first data into a database through a first message queue by the first terminal;
the first obtaining and sending module 302 is configured to access the database through a strong isolation device in the second message queue, obtain the first data, and send the first data to the second terminal through the strong isolation device.
Based on the communication method shown in fig. 3, an embodiment of the present invention further provides a communication device, which is applied to the communication system in the process of reading data by a first terminal and writing data by a second terminal, and a structural block diagram of the communication device is shown in fig. 5, where the structural block diagram includes:
a second write module 401 and a second read and transmit module 402.
Wherein,
the second writing module 401 is configured to write, by the second terminal, second data into the database through a second message queue via a strong isolation device;
the second reading and sending module 402 is configured to access the database through the first message queue, acquire the second data, and send the second data to the first terminal.
It should be noted that, in the present specification, the embodiments are all described in a progressive manner, each embodiment focuses on differences from other embodiments, and the same and similar parts among the embodiments may be referred to each other. For the device-like embodiment, since it is basically similar to the method embodiment, the description is simple, and for the relevant points, reference may be made to the partial description of the method embodiment.
Finally, it should also be noted that, herein, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
For convenience of description, the above devices are described as being divided into various units by function, and are described separately. Of course, the functions of the units may be implemented in the same software and/or hardware or in a plurality of software and/or hardware when implementing the invention.
From the above description of the embodiments, it is clear to those skilled in the art that the present invention can be implemented by software plus necessary general hardware platform. Based on such understanding, the technical solutions of the present invention may be embodied in the form of a software product, which may be stored in a storage medium, such as ROM/RAM, magnetic disk, optical disk, etc., and includes instructions for causing a computer device (which may be a personal computer, a server, or a network device, etc.) to execute the method according to the embodiments or some parts of the embodiments.
The above detailed description of the communication system, method and apparatus provided by the present invention has been made, and the principle and implementation of the present invention are explained by applying specific examples, and the above description of the embodiments is only used to help understanding the method and core idea of the present invention; meanwhile, for a person skilled in the art, according to the idea of the present invention, there may be variations in the specific embodiments and the application scope, and in summary, the content of the present specification should not be construed as a limitation to the present invention.
Claims (10)
1. A communication system, comprising: a first terminal, a first message queue, a database, a second terminal, and a second message queue, wherein,
the first terminal is configured to send a first request of the first terminal, where the first request includes: a read or write request;
the first message queue is used for receiving a first request of the first terminal and processing the first request;
the database is used for storing data sent by the first terminal and the second terminal;
the second terminal is configured to send a second request of the second terminal, where the second request includes: a read or write request;
and the second message queue is used for receiving a second request of the second terminal and processing the second request.
2. The system of claim 1, further comprising: a strong isolation device, wherein,
the strong isolation device is used for isolating a first network from a second network, wherein the first network comprises: the first terminal, the first message queue and the database, the second network comprising: the second terminal and the second message queue.
3. The system of claim 1, wherein the first message queue comprises: a first service center module and a first service agent module, wherein,
the first service center module is used for forwarding the first request;
the first service agent module is used for processing the first request.
4. The system of claim 1, wherein the second message queue comprises: a second service center module and a second service agent module, wherein,
the second service center module is used for forwarding the second request;
and the second service agent module is used for processing the second request.
5. The system of claim 1, further comprising: a migration module, wherein,
and the migration module is used for migrating the consumed information in the database to a preset storage position for storage at preset time intervals.
6. The system of claim 1, wherein the database is a relational database that supports asynchronous transmission of pictures.
7. A communication method applied to the communication system according to any one of claims 1 to 6, wherein the communication method comprises:
the first terminal writes first data into a database through a first message queue;
and the second message queue accesses the database through a strong isolation device, acquires the first data, and sends the first data to the second terminal through the strong isolation device.
8. A communication method applied to the communication system according to any one of claims 1 to 6, wherein the communication method comprises:
the second terminal writes second data into a database through a second message queue and a strong isolation device;
and the first message queue accesses the database, acquires the second data and sends the second data to the first terminal.
9. A communication device, for use in a communication system according to any one of claims 1 to 6, wherein the communication device comprises:
the first writing module is used for the first terminal to write first data into a database through a first message queue;
and the first acquisition and sending module is used for accessing the database by the second message queue through a strong isolation device, acquiring the first data and sending the first data to the second terminal through the strong isolation device.
10. A communication device, for use in a communication system according to any one of claims 1 to 6, wherein the communication device comprises:
the second writing module is used for writing second data into the database by the second terminal through a second message queue and a strong isolation device;
and the second reading and sending module is used for accessing the database by the first message queue, acquiring the second data and sending the second data to the first terminal.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010926962.5A CN111800519A (en) | 2020-09-07 | 2020-09-07 | Communication system, method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010926962.5A CN111800519A (en) | 2020-09-07 | 2020-09-07 | Communication system, method and device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111800519A true CN111800519A (en) | 2020-10-20 |
Family
ID=72834206
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010926962.5A Pending CN111800519A (en) | 2020-09-07 | 2020-09-07 | Communication system, method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111800519A (en) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113687958A (en) * | 2021-07-29 | 2021-11-23 | 上海浦东发展银行股份有限公司 | Data processing method, system, computer device and storage medium |
| CN113726820A (en) * | 2021-11-02 | 2021-11-30 | 苏州浪潮智能科技有限公司 | Data transmission system |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20140282936A1 (en) * | 2013-03-14 | 2014-09-18 | Amazon Technologies, Inc. | Providing devices as a service |
| CN109150702A (en) * | 2018-08-16 | 2019-01-04 | 南京南瑞信息通信科技有限公司 | A kind of the high-performance mobile access gateway and its method of communication information intranet and extranet |
-
2020
- 2020-09-07 CN CN202010926962.5A patent/CN111800519A/en active Pending
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20140282936A1 (en) * | 2013-03-14 | 2014-09-18 | Amazon Technologies, Inc. | Providing devices as a service |
| CN109150702A (en) * | 2018-08-16 | 2019-01-04 | 南京南瑞信息通信科技有限公司 | A kind of the high-performance mobile access gateway and its method of communication information intranet and extranet |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113687958A (en) * | 2021-07-29 | 2021-11-23 | 上海浦东发展银行股份有限公司 | Data processing method, system, computer device and storage medium |
| CN113726820A (en) * | 2021-11-02 | 2021-11-30 | 苏州浪潮智能科技有限公司 | Data transmission system |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111078504A (en) | Distributed call chain tracking method and device, computer equipment and storage medium | |
| US9749445B2 (en) | System and method for updating service information for across-domain messaging in a transactional middleware machine environment | |
| US11068555B2 (en) | System and method of sensing and responding to service discoveries | |
| CN108011768A (en) | A kind of aop intercept types HBase data store micro services framework construction method | |
| US10574724B2 (en) | Automatic discovery of management nodes and generation of CLI using HA module | |
| CN103761141A (en) | Method and device for realizing message queue | |
| US20210042174A1 (en) | Distributed queueing over a redis cluster | |
| US10838977B2 (en) | Key-value replication with consensus protocol | |
| CN109213498A (en) | A kind of configuration method and server of internet web front-end | |
| CN104468150A (en) | Method for realizing fault migration through virtual host and virtual host service device | |
| CN111800519A (en) | Communication system, method and device | |
| CN113467970B (en) | Cross-security-area resource access method in cloud computing system and electronic equipment | |
| CN111510330A (en) | Interface management apparatus, method and storage medium | |
| CN115811546B (en) | System and method for realizing network collaborative distributed processing by scientific and technological service | |
| CN116303309A (en) | File mounting method and device and electronic equipment | |
| US10877994B2 (en) | Identifier based data replication | |
| US11645211B2 (en) | Augmenting storage functionality using emulation of storage characteristics | |
| US9503351B1 (en) | Deployment feedback for system updates to resources in private networks | |
| CN112202862B (en) | Method and device for synchronizing cluster data and files based on kafka | |
| US20080065679A1 (en) | Method for rules-based drag and drop processing in a network environment | |
| CN115604344B (en) | Micro-service current limiting method and device | |
| CN112487097A (en) | Method, system and equipment for synchronizing distributed field data | |
| CN111800511A (en) | Processing method, system, equipment and readable storage medium for synchronous login state | |
| CN106790521B (en) | System and method for distributed networking by using node equipment based on FTP | |
| CN113179332B (en) | Method, electronic device and storage medium for acquiring configuration information |
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 | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20201020 |