CN113468221A - System integration method based on kafka message data bus - Google Patents
System integration method based on kafka message data bus Download PDFInfo
- Publication number
- CN113468221A CN113468221A CN202110635495.5A CN202110635495A CN113468221A CN 113468221 A CN113468221 A CN 113468221A CN 202110635495 A CN202110635495 A CN 202110635495A CN 113468221 A CN113468221 A CN 113468221A
- Authority
- CN
- China
- Prior art keywords
- service
- micro
- server
- data
- layer
- 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.)
- Withdrawn
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; 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/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24552—Database cache management
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; 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
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; 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/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/80—Information retrieval; Database structures therefor; File system structures therefor of semi-structured data, e.g. markup language structured data such as SGML, XML or HTML
- G06F16/81—Indexing, e.g. XML tags; Data structures therefor; Storage structures
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
-
- 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/01—Protocols
- H04L67/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Databases & Information Systems (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Software Systems (AREA)
- Computing Systems (AREA)
- Computational Linguistics (AREA)
- Hardware Redundancy (AREA)
Abstract
The embodiment of the invention provides a system integration method based on a kafka message data bus, which comprises the following steps of establishing a system based on the kafka message data bus, wherein the system comprises: the system comprises an access layer, a control layer, a middleware service layer, a micro-service supporting layer and a data storage layer; wherein the access layer is configured to allocate services by the keepalive server according to the dynamically adjusted priorities of the Nginx servers; the control layer processes the request forwarded by the access layer; the middleware server layer is used for managing the micro-services which provide interfaces outwards so as to provide communication among the micro-services; wherein the microservice service support layer is developed by utilizing a SpringCloud microservice architecture; the data storage layer is a distributed database, and each segment node stores different data for distributed computation.
Description
Technical Field
The invention belongs to the technical field of information, and particularly relates to a system integration method based on a kafka message data bus.
Background
With the progress of a plurality of policies in China, the application of artificial intelligence technology to various industries and fields is promoted. Large-scale enterprises in various industries in China build core business systems and comprehensive cooperative office systems such as ERP, CRM, PLM, financial management and control and the like, but the business application systems come from different suppliers respectively, use different customization technologies, and each application system has a database of the application system, so that a plurality of information isolated islands are implemented inside the business application systems. Each "island of information" is for a single purpose and a specific use object, and only part of the functions of an enterprise are automated. When data processing in an enterprise relates to data exchange among a plurality of application systems, resources of the plurality of systems need to be integrated, and a large amount of workload and difficulty are brought to data sharing, system development, management, maintenance and the like. Therefore, there is an urgent need to establish an information integration system in an enterprise. In view of the fact that currently, most of system integration is performed in the form of WebService and the like for direct access of service application systems, the following problems can occur by adopting the method:
1. after large-scale data access, the concurrent transmission capability of the warehousing service can reach the limit;
2. the platform has no function of distributed storage, so that the efficiency is low when data is stored and accessed;
3. the retrieval speed is inefficient due to the large amount of data stored in the single table.
Disclosure of Invention
In order to solve the problems in the prior art, the embodiment of the disclosure provides a system integration method based on a kafka message data bus.
In order to solve the above problem, an embodiment of the present disclosure provides a system integration method based on a kafka message data bus, including:
establishing a kafka message data bus-based system, wherein the system comprises: the system comprises an access layer, a control layer, a middleware service layer, a micro-service supporting layer and a data storage layer;
the access layer comprises a Nginx server cluster used for receiving a request sent by the ERP and CRM systems through a WebService interface; after receiving a user request, the Nginx server reversely proxies the request to a control layer through load balancing; the access layer comprises a Nginx server and a keepalive server, the two servers are respectively provided with the Nginx server and the keepalive server, and the keepalive server is provided with the priority of each Nginx server so as to determine the Nginx server for providing service according to the priority of the Nginx server; each Nginx server is provided with a Nginx _ check.sh script to realize the automatic restart of the Nginx process, wherein the Nginx _ check.sh script automatically tries to restart the Nginx process every preset time; if one server fails to start the Nginx process, all keepalive processes are ended, and the keepalive server is informed to reduce the priority of the Nginx server;
the control layer is based on a Spring Boot development platform, wherein the Spring Boot has a Spring MVC framework; wherein the processing of the request forwarded by the access layer using SpringMVC comprises: reading data from a Redis cache; calling a micro-service interface to execute a service; session sharing is realized by matching with a Redis cache server;
the middleware server layer uses the Zookeeper as a service registration configuration center, and all micro-services providing interfaces outwards can be called by other consumers after being registered on the Zookeeper; when the control layer processes the user request, the consumer serving as the service interface inquires and executes corresponding micro-service on the Zookeeper; managing and monitoring the micro-service by matching Dubbox on the Zookeeper; taking Redis as a cache server to provide session sharing support for a control layer and provide cache service for a distributed system; wherein Kafka acts as a messaging server to provide communication between individual microservices;
wherein the microservice service support layer is developed using a SpringCloud microservice architecture.
The SG-RDB-PG database is a distributed database, a shared-nothing architecture is adopted, each segment node stores different data, distributed computation can be carried out, parallel computation is supported, parallel backup and restoration and parallel query are supported.
In some embodiments, the microservice business support layer includes the following components:
the SpringBootEureka is used for carrying out service treatment components, and comprises a service registration center and the realization of a service registration and discovery mechanism;
the SpringBootConfig is used for dynamically maintaining the configuration file;
the SpringBootHystrix is used for fault-tolerant management components, realizing a breaker mode, helping delay in service dependence and providing strong fault-tolerant capability for faults;
a SpringBootReinbon, a service calling component for client load balancing;
the invention relates to a method for calling a declarative service, in particular to a method for calling a dynamic proxy, which comprises the following steps that SpringBootFeign and a declarative service calling component based on Ribbon and Hystrix, the calling between acquisition micro-service and analysis micro-service is carried out by using an annotation mode, @ FeignClient annotation is defined for a certain interface of the micro-service, the Feign can establish a dynamic proxy aiming at the interface, and the dynamic proxy of the Feign can dynamically construct the address of the service to be requested according to the @ RequestMapping and other annotations on the interface, and initiate a request and analyze a response;
SpringBootZuul: the gateway component provides functions of intelligent routing, access filtering and the like;
and the SpringBootservice is used for providing service logic of each micro service.
In some embodiments, the microservice business support layer includes the following components:
common microservice common service: providing basic service for other micro-services, wherein the service relies on a public third party jar package and integrates Zookeeper, Redis and Kafka;
collecting the micro service Collection service: collecting target data sent to a kafka message queue by core service systems such as ERP, CRM and PLM through a WebService interface, recording the data to a daily indicator table, and supporting report inquiry service by matching with Redis cache;
analyzing the micro-service AnalysiService: processing the data acquired by the acquired microservice, processing the data into business data, main data and metadata required by other systems, and storing the processing result into a database;
distributing the micro-service DistributeService: providing interface micro-service of service data for a MES system and an ERP system of a service system, distributing data of micro-service access data storage layers, providing interfaces for each service system, and sending main data and metadata required by the service system.
In some embodiments, the real-time data of the Kafka message queue is in XML format.
The invention has the beneficial effects that: the technical scheme of the embodiment of the disclosure provides a system integration method based on a kafka message data bus; the micro-service framework provided by the SpringCloud is used for developing micro-services to realize the acquisition, analysis and distribution of data of each business system of an enterprise, thereby realizing the circulation of the data of each business system, realizing the data integration of each business system and further achieving the purpose of business integration. The invention uses Kafka as the message bus to realize the communication among all the microservices, and uses the interface of Kafka data batch processing to transmit the data of all the service systems in batch, thereby reducing the overhead of network transmission and leading the performance of the whole system to be higher.
Drawings
Fig. 1 is a schematic diagram of a kafka message data bus based system of an embodiment of the present disclosure.
DETAILED DESCRIPTION OF EMBODIMENT (S) OF INVENTION
In order to make the objects, technical solutions and advantages of the present invention more apparent, the present invention is further described in detail below with reference to the accompanying drawings. It should be understood that the specific embodiments described herein are merely illustrative of the invention and are not intended to limit the invention.
The method of post-evaluation is further described below with reference to the accompanying drawings and embodiments of the present invention.
The embodiment of the invention provides a system integration method based on a kafka message data bus; the method comprises the following steps:
establishing a kafka message data bus-based system, wherein the system as shown in fig. 1 comprises: the system comprises an access layer, a control layer, a middleware service layer, a micro-service supporting layer and a data storage layer;
the access layer comprises a Nginx server cluster for receiving a request sent by the ERP and CRM systems through a WebService interface; after receiving a user request, the Nginx server reversely proxies the request to a control layer through load balancing; the scheme uses Nginx and keepalived to realize a high-availability server cluster, uses 2 servers, and sets IP addresses 10.10.7.77 and 10.10.7.78 respectively and a virtual IP address 10.10.7.110 provided externally. Installing Nginx and Keepallyd on the two servers respectively, and modifying the configuration file; in setting a configuration file, priority plays a crucial role in keepalived realization, a keepalived server selects a device which is currently provided with service according to priority, 10.10.7.77 sets the priority to be 100, 10.10.7.78 sets the priority to be 90, keepalived checks the priority, finds that 10.10.7.77 the device has high priority, allows the device to provide service to the outside, after 10.10.7.77 the device has nginx hung, since nginx _ check.sh script is executed every two seconds, finds that 10.10.7.77 the node has no nginx process and tries to restart nginx, if restart or not, kills all keepalived processes, and tells 10.10.7.77 that nginx hang of the node and reduces the priority of the node by 20, so that the next time keepalived checks priority to find 10.10.7.78 the node has higher priority than 3590, thus allowing the next time keepalived server to provide priority to 10.10.7.78, similarly, if the node fails, another node can be used for providing service, and high availability is achieved.
A control layer: the control layer uses Spring Boot as a development platform. The Spring Boot provides a Spring mvc framework for out-of-box use, and the processing of a request forwarded by an access layer by using the Spring mvc can be roughly divided into three cases: 1) reading data from a Redis cache; 2) and calling the microservice interface to execute the business. In addition, session sharing needs to be realized in cooperation with a Redis cache server.
Middleware server layer: using Zookeeper as a service registration configuration center, all microservices that provide interfaces to the outside need to be registered on the Zookeeper before they can be invoked by other consumers. When the control layer processes the user request, the consumer serving as the service interface inquires and executes the corresponding micro service on the Zookeeper. The management and monitoring of the microservices are carried out by matching Dubbox on the Zookeeper. Redis is used as a cache server, on one hand, session sharing support is provided for a control layer, on the other hand, cache service is provided for a distributed system, and data query response speed and efficiency are increased. Kafka is used as a message communication server to support communication among various microservices and realize the functions of message collection and transmission.
Microservice business support layer: the microservice service supporting layer uses a SpringCloud microservice architecture for development, and the invention designs the following components:
and constructing a SpringBootEureka for carrying out a service governance component, including the realization of a service registration center and a service registration and discovery mechanism.
And constructing a SpringBootConfig for dynamically maintaining the configuration file.
And constructing a SpringBootHystrix for fault tolerance management components, realizing a breaker mode, helping delay in service dependence and providing strong fault tolerance for faults.
And constructing a SpringBootReibbon and a client load balanced service calling assembly.
The invention builds SpringBootFeign, and based on Ribbon and Hystrix declarative service calling components, the invention uses annotation mode to collect micro service and analyze calling between micro services, defines @ FeignClient annotation for a certain interface of micro service, Feign will create a dynamic proxy aiming at the interface, Feign dynamic proxy will dynamically construct the address of service to be requested, initiate request and analyze response according to @ RequestMapping and other annotations on the interface.
Constructing SpringBootZuul: and the gateway component provides functions of intelligent routing, access filtering and the like.
Constructing a SpringBootservice, which is the service logic of each micro-service and comprises the following micro-services:
common microservice: and providing basic services for other micro-services, wherein the services rely on a public third party jar package and integrate Zookeeper, Redis and Kafka.
Collecting the micro service Collection service: and collecting target data sent to the kafka message queue by core service systems such as ERP, CRM and PLM through a WebService interface, recording the data to a daily indicator table, and supporting report inquiry service by matching with Redis cache. The Kafka message queue can be applied to a plurality of existing message formats, such as XML, JSON and the like, and considering that a service system mostly uses a WebService interface form, a preset format of real-time data conversion is an XML format, and the XML is an extensible language and has the characteristics of completely separating the content and the structure of a document, supporting various codes and unifying specifications.
Analyzing the micro-service Analysisservice: and processing the data acquired by the acquired microservice, processing the data into business data, main data, metadata and the like required by other systems (such as an MES system), and storing the processing result into a database.
Fourthly, distributing the micro-service distribution service: interface micro-service of service data is provided for a service system MES system and an ERP system, data of a micro-service access data storage layer is distributed, an interface is provided for each service system, main data, metadata and the like required by the service system are sent, and therefore data integration of each service system is achieved.
A data storage layer: the SG-RDB-PG database is used for storing data, the database is a distributed database, a shared-nothing architecture is adopted, each segment node stores different data, distributed computation can be carried out, parallel computation is supported, parallel backup reduction and parallel query are supported, complex query on mass data is carried out, the performance is particularly considerable, the performance can be linearly improved along with the increase of the nodes, and the database is used for greatly improving the performance of storage, conversion, loading and transmission of the data of each system.
The invention uses Kafka as a message bus to realize the communication among various microservices. When other business systems such as an ERP system push data to the collection microservices through an access layer, the collection microservices serve as a message pusher (producer), the data are firstly pushed to the Kafka cluster, and the Kafka cluster persists the data in a hard disk in a log file form. Analyzing the micro-service as a consumer (consumer), pulling data from a Kafka message queue for consumption, synchronizing the consumption condition of each message of the consumer to a Zookeeper server cluster, if the consumption of a certain micro-service is stopped abnormally, recording the offset of the last consumed message of the consumer by the Zookeeper, and continuing to consume the message from the offset after the micro-service is recovered to be normal, thereby ensuring that each message is consumed successfully. Therefore, the design of the invention in data transmission has higher reliability. In addition, the invention adopts the interface of data batch processing provided by Kafka, the data of each service system is transmitted to the Kafka cluster in batch, and other micro-services pull the data from the Kafka cluster in batch for analysis and processing, thereby reducing the overhead of network transmission and improving the performance of the whole system.
The technical scheme provides an enterprise system integration processing method, and the micro-service framework provided by spring cloud is used for developing micro-services to realize the acquisition, analysis and distribution of data of each business system of an enterprise, so that the data of each business system is circulated, the data integration of each business system is realized, and the purpose of business integration is further achieved. The invention uses Kafka as the message bus to realize the communication among all the microservices, and uses the interface of Kafka data batch processing to transmit the data of all the service systems in batch, thereby reducing the overhead of network transmission and leading the performance of the whole system to be higher.
While the foregoing is directed to the preferred embodiment of the present invention, it will be understood by those skilled in the art that various changes and modifications may be made without departing from the spirit and scope of the invention as defined in the appended claims.
Claims (4)
1. A system integration method based on kafka message data bus; it is characterized by comprising:
establishing a kafka message data bus-based system, wherein the system comprises: the system comprises an access layer, a control layer, a middleware service layer, a micro-service supporting layer and a data storage layer;
the access layer comprises a Nginx server cluster used for receiving a request sent by the ERP and CRM systems through a WebService interface; after receiving a user request, the Nginx server reversely proxies the request to a control layer through load balancing; the access layer comprises a Nginx server and a keepalive server, the two servers are respectively provided with the Nginx server and the keepalive server, and the keepalive server is provided with the priority of each Nginx server so as to determine the Nginx server for providing service according to the priority of the Nginx server; each Nginx server is provided with a Nginx _ check.sh script to realize the automatic restart of the Nginx process, wherein the Nginx _ check.sh script automatically tries to restart the Nginx process every preset time; if one server fails to start the Nginx process, all keepalive processes are ended, and the keepalive server is informed to reduce the priority of the Nginx server;
the control layer is based on a Spring Boot development platform, wherein the Spring Boot has a Spring MVC framework; wherein the processing of the request forwarded by the access layer using SpringMVC comprises: reading data from a Redis cache; calling a micro-service interface to execute a service; session sharing is realized by matching with a Redis cache server;
the middleware server layer uses the Zookeeper as a service registration configuration center, and all micro-services providing interfaces outwards can be called by other consumers after being registered on the Zookeeper; when the control layer processes the user request, the consumer serving as the service interface inquires and executes corresponding micro-service on the Zookeeper; managing and monitoring the micro-service by matching Dubbox on the Zookeeper; taking Redis as a cache server to provide session sharing support for a control layer and provide cache service for a distributed system; wherein Kafka acts as a messaging server to provide communication between individual microservices;
wherein the microservice service support layer is developed using a SpringCloud microservice architecture.
The SG-RDB-PG database is a distributed database, a shared-nothing architecture is adopted, each segment node stores different data, distributed computation can be carried out, parallel computation is supported, parallel backup and restoration and parallel query are supported.
2. The kafka message data bus-based system integration method of claim 1; wherein the microservice service support layer comprises the following components:
the SpringBootEureka is used for carrying out service treatment components, and comprises a service registration center and the realization of a service registration and discovery mechanism;
the SpringBootConfig is used for dynamically maintaining the configuration file;
the SpringBootHystrix is used for fault-tolerant management components, realizing a breaker mode, helping delay in service dependence and providing strong fault-tolerant capability for faults;
a SpringBootReinbon, a service calling component for client load balancing;
the invention relates to a method for calling a declarative service, in particular to a method for calling a dynamic proxy, which comprises the following steps that SpringBootFeign and a declarative service calling component based on Ribbon and Hystrix, the calling between acquisition micro-service and analysis micro-service is carried out by using an annotation mode, @ FeignClient annotation is defined for a certain interface of the micro-service, the Feign can establish a dynamic proxy aiming at the interface, and the dynamic proxy of the Feign can dynamically construct the address of the service to be requested according to the @ RequestMapping and other annotations on the interface, and initiate a request and analyze a response;
SpringBootZuul: the gateway component provides functions of intelligent routing, access filtering and the like;
and the SpringBootservice is used for providing service logic of each micro service.
3. The kafka message data bus-based system integration method of claim 1; wherein the microservice service support layer comprises the following components:
common microservice common service: providing basic service for other micro-services, wherein the service relies on a public third party jar package and integrates Zookeeper, Redis and Kafka;
collecting the micro service Collection service: collecting target data sent to a kafka message queue by core service systems such as ERP, CRM and PLM through a WebService interface, recording the data to a daily indicator table, and supporting report inquiry service by matching with Redis cache;
analyzing the micro-service AnalysiService: processing the data acquired by the acquired microservice, processing the data into business data, main data and metadata required by other systems, and storing the processing result into a database;
distributing the micro-service DistributeService: providing interface micro-service of service data for a MES system and an ERP system of a service system, distributing data of micro-service access data storage layers, providing interfaces for each service system, and sending main data and metadata required by the service system.
4. The kafka message data bus-based system integration method of claim 1; the Kafka message queue real-time data is in an XML format.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110635495.5A CN113468221A (en) | 2021-06-08 | 2021-06-08 | System integration method based on kafka message data bus |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110635495.5A CN113468221A (en) | 2021-06-08 | 2021-06-08 | System integration method based on kafka message data bus |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN113468221A true CN113468221A (en) | 2021-10-01 |
Family
ID=77868700
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110635495.5A Withdrawn CN113468221A (en) | 2021-06-08 | 2021-06-08 | System integration method based on kafka message data bus |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113468221A (en) |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114979137A (en) * | 2022-04-28 | 2022-08-30 | 中国电力科学研究院有限公司 | Method, system, equipment and medium for high-concurrency processing in power industry |
| CN115063123A (en) * | 2022-08-17 | 2022-09-16 | 歌尔股份有限公司 | Intelligent manufacturing method and system and electronic equipment |
| CN115481151A (en) * | 2022-07-22 | 2022-12-16 | 国网安徽省电力有限公司铜陵供电公司 | Data processing system based on Redis distributed cache |
| CN116401198A (en) * | 2023-06-08 | 2023-07-07 | 成都房联云码科技有限公司 | SM2 algorithm-based interface bus system |
| CN116610532A (en) * | 2023-07-17 | 2023-08-18 | 山东浪潮数字商业科技有限公司 | Redis client monitoring method, system, electronic equipment and storage medium |
| CN118981414A (en) * | 2024-08-06 | 2024-11-19 | 安徽同徽信息技术有限公司 | A data automatic collection system and collection method |
-
2021
- 2021-06-08 CN CN202110635495.5A patent/CN113468221A/en not_active Withdrawn
Cited By (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114979137A (en) * | 2022-04-28 | 2022-08-30 | 中国电力科学研究院有限公司 | Method, system, equipment and medium for high-concurrency processing in power industry |
| CN115481151A (en) * | 2022-07-22 | 2022-12-16 | 国网安徽省电力有限公司铜陵供电公司 | Data processing system based on Redis distributed cache |
| CN115063123A (en) * | 2022-08-17 | 2022-09-16 | 歌尔股份有限公司 | Intelligent manufacturing method and system and electronic equipment |
| CN116401198A (en) * | 2023-06-08 | 2023-07-07 | 成都房联云码科技有限公司 | SM2 algorithm-based interface bus system |
| CN116401198B (en) * | 2023-06-08 | 2023-09-22 | 成都房联云码科技有限公司 | SM2 algorithm-based interface bus system |
| CN116610532A (en) * | 2023-07-17 | 2023-08-18 | 山东浪潮数字商业科技有限公司 | Redis client monitoring method, system, electronic equipment and storage medium |
| CN116610532B (en) * | 2023-07-17 | 2023-10-27 | 山东浪潮数字商业科技有限公司 | Redis client monitoring method, system, electronic equipment and storage medium |
| CN118981414A (en) * | 2024-08-06 | 2024-11-19 | 安徽同徽信息技术有限公司 | A data automatic collection system and collection method |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113468221A (en) | System integration method based on kafka message data bus | |
| CN109327509B (en) | Low-coupling distributed streaming computing system of master/slave architecture | |
| CN101207550B (en) | Load balancing system and method for realizing load balancing of multiple services | |
| Yongguo et al. | Message-oriented middleware: A review | |
| US8146095B2 (en) | Method, apparatus and computer program product for managing persistence in a messaging network | |
| WO2021088641A1 (en) | Data transmission method, data processing method, data reception method and device, and storage medium | |
| CN104639654A (en) | Integrated access system and integrated access method for mass electricity information acquisition terminals | |
| WO2004036344A2 (en) | System and method for the optimization of database | |
| CN111885439A (en) | Optical network integrated management and duty management system | |
| CN114900449B (en) | Resource information management method, system and device | |
| CN113067850A (en) | Cluster arrangement system under multi-cloud scene | |
| CN111209364A (en) | Mass data access processing method and system based on crowdsourcing map updating | |
| CN114866528A (en) | Data communication method based on MQTT and Websocket | |
| CN110297862A (en) | Data bank access method and Database-access Middleware Based | |
| CN113055378A (en) | Protocol conversion platform for industrial internet identification analysis and data docking method | |
| CN104468299A (en) | Enterprise service bus system based on user rule | |
| US9021109B1 (en) | Controlling requests through message headers | |
| CN113326148A (en) | Data interaction system based on micro-service | |
| CN112817539A (en) | Industrial data storage method and system, electronic device and storage medium | |
| CN115378946A (en) | Data processing method, device and system | |
| CN117354400B (en) | Acquisition and analysis service system for Beidou short message | |
| CN108075989B (en) | Extensible protocol-based load balancing network middleware implementation method | |
| CN118488060A (en) | Distributed long connection cluster service system | |
| CN109257435B (en) | Communication system of multi-instance multi-subsystem application based on message middleware | |
| CN114237858A (en) | Task scheduling method and system based on multi-cluster network |
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 | ||
| WW01 | Invention patent application withdrawn after publication | ||
| WW01 | Invention patent application withdrawn after publication |
Application publication date: 20211001 |