CN111198915A - Data distribution system and method based on public information model - Google Patents
Data distribution system and method based on public information model Download PDFInfo
- Publication number
- CN111198915A CN111198915A CN201911365162.4A CN201911365162A CN111198915A CN 111198915 A CN111198915 A CN 111198915A CN 201911365162 A CN201911365162 A CN 201911365162A CN 111198915 A CN111198915 A CN 111198915A
- Authority
- CN
- China
- Prior art keywords
- application system
- data distribution
- information model
- public information
- interface
- 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
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/25—Integrating or interfacing systems involving database management systems
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention relates to the field of data processing, in particular to a data distribution system and a method based on a public information model, which comprises the following steps: the application system management module is used for acquiring interface information of the application system; the public information model base is used for storing public information models; the adaptive system management module is used for creating a corresponding adaptive system according to the interface information of the application system and matching an adaptive system access address corresponding to the application system for the adaptive system; the adaptation system is used for customizing an interface according to the interface information of the application system so as to realize data transmission with the application system; the subscription management module is used for subscribing the attribute of the public information model object and triggering a subscription event when the attribute changes; and the information management module is used for realizing data distribution facing the common information model object to the application system through the adaptation system according to the sequence. The invention ensures the availability of the data distribution channel and greatly expands the processing range of engineering services.
Description
Technical Field
The invention relates to the field of data processing, in particular to a data distribution system and a data distribution method based on a public information model.
Background
Under the promotion of the explosive increase of the integration requirement of the enterprise information system, the information transmission and engineering business logic between heterogeneous systems become key technologies of information planning step by step. However, because the interfaces of different systems are different, data distribution is limited to single data, and the requirements of the business field cannot be supported, which brings great difficulty to the integration of enterprise systems and the realization of specific engineering business requirements.
In the aspect of system interface standardization of enterprise informatization planning, the existing application system lacks a standardized and interoperable access interface, so that the information transmission path among systems is deficient, the heterogeneous system management is complex, and the coordination work among the systems is difficult. In the aspect of engineering requirements, a single data distribution cannot comprehensively focus on the attribute values of the whole object, and cannot meet most of actual engineering requirements.
Disclosure of Invention
In order to solve the above problems, the present invention provides a data distribution system and method based on a common information model.
A common information model-based data distribution system, comprising:
the system comprises an application system management module, a registration information database and a data distribution module, wherein the application system management module is used for acquiring interface information of an application system and storing the interface information in the registration information database, and the interface information is used as an access path for data distribution;
the public information model library is used for storing a public information model, and the public information model is used as a template for data storage;
the adaptive system management module is used for creating a corresponding adaptive system according to the interface information of the application system, receiving a data distribution request of the application system and matching an adaptive system access address corresponding to the application system for the data distribution request;
the adaptation system is used for customizing an interface according to the interface information of the application system so as to realize data transmission with the application system;
the subscription management module is used for subscribing the attribute of the public information model object and triggering a subscription event when the attribute changes;
and the information management module is used for realizing data distribution facing the public information model object to the application system through the adaptation system according to the sequence when the subscription event is triggered.
Preferably, the interface information includes: the application system comprises an application system identification, an application system name, an application system host address, an application system access port, an application system interface function and an application system function access path.
Preferably, the adaptation system management module is further configured to:
after receiving a data distribution request of an application system, disassembling the data distribution request, carrying out format verification on a message header and a message body, and identifying a service processing requirement, a subscription event and a service processing event in the message body after the verification is correct.
Preferably, the adaptation system management module is further configured to:
adding time series codes for the received data distribution requests, classifying according to source application systems of the data distribution requests, and compiling step numbers for the data distribution requests from the same application system according to the time series codes.
Preferably, the adaptation system management module is further configured to:
and setting corresponding priority levels for the application systems, and performing priority data distribution on the data distribution requests with high priority levels.
A data distribution method based on a common information model comprises the following steps:
acquiring interface information of an application system and storing the interface information in a registration information database;
generating a public information model object by taking the public information as a template for data storage;
establishing a corresponding adaptation system according to interface information of the application system, receiving a data distribution request of the application system, and matching an adaptation system access address corresponding to the application system for the data distribution request;
customizing an interface according to interface information of the application system to realize data transmission with the application system;
subscribing the attribute of the common information model object, and triggering a subscription event when the attribute changes;
and when a subscription event is triggered, realizing data distribution facing to the common information model object to the application system through the adaptation system according to the sequence.
Preferably, the interface information includes: the application system comprises an application system identification, an application system name, an application system host address, an application system access port, an application system interface function and an application system function access path.
Preferably, after receiving the data distribution request of the application system, the method further includes: disassembling the data distribution request, performing format check on the message header and the message body, and identifying the service processing requirement, the subscription event and the service processing event in the message body after the check is correct
Preferably, the implementing data distribution facing to the common information model object to the application system through the adaptation system according to the sequence includes:
adding time series codes for the received data distribution requests, classifying according to source application systems of the data distribution requests, and compiling step numbers for the data distribution requests from the same application system according to the time series codes.
Preferably, the implementing data distribution facing to the common information model object to the application system through the adaptation system according to the sequence further includes:
and setting corresponding priority levels for the application systems, and performing priority data distribution on the data distribution requests with high priority levels.
By using the present invention, the following effects can be achieved:
1. the method ensures that the nonstandard interface can complete data distribution service by means of the standardized interface of the adaptation system, and ensures the channel availability of data distribution for realizing the communication cooperation path of the interoperation between the integrated systems.
2. The common information model is used for formally describing shared information among the systems, and the model is instantiated according to the actual needs of the system, so that a normalized definition model and an object instance are provided for the system, and the processing range of engineering services is greatly expanded.
3. And setting a service logic triggered by a subscription event according to the actual service requirement by subscribing the attribute of the common information model object, thereby realizing the high-standard and high-cooperation service requirement of the engineering system.
4. A message queue management mechanism is established for the system, and meanwhile, transmission requirements such as data distribution sequence and the like can be controlled, so that the data distribution process can be accurately and orderly executed.
Drawings
The present invention will be described in further detail with reference to the accompanying drawings and specific embodiments.
FIG. 1 is a schematic block diagram of a data distribution system based on a common information model according to an embodiment of the present invention;
FIG. 2 is a schematic flow chart diagram of a data distribution method based on a common information model according to an embodiment of the present invention;
fig. 3 is an overall flowchart of a data distribution method based on a common information model according to an embodiment of the present invention.
Detailed Description
The technical solutions of the present invention will be further described below with reference to the accompanying drawings, but the present invention is not limited to these embodiments.
The basic idea of the invention is to fully consider the interface information of the application system, provide the adaptation of the non-standard interface of the heterogeneous system, especially support the subscription/release event and the service logic processing of the model-oriented object, and establish an ordered message queue, ensure the preparation, ordered and reliable execution of the transmission process, and improve the flexibility and reliability of the cooperative work among the heterogeneous systems.
Based on the above inventive concept, the present embodiment proposes a data distribution system based on a common information model, as shown in fig. 1, including: the system comprises an application system management module, a registration information database and a data distribution module, wherein the application system management module is used for acquiring interface information of an application system and storing the interface information in the registration information database, and the interface information is used as an access path for data distribution; the public information model library is used for storing a public information model, and the public information model is used as a template for data storage; the adaptive system management module is used for creating a corresponding adaptive system according to the interface information of the application system, receiving a data distribution request of the application system and matching an adaptive system access address corresponding to the application system for the data distribution request; the adaptation system is used for customizing an interface according to the interface information of the application system so as to realize data transmission with the application system; the subscription management module is used for subscribing the attribute of the public information model object and triggering a subscription event when the attribute changes; and the information management module is used for realizing data distribution facing the public information model object to the application system through the adaptation system according to the sequence when the subscription event is triggered.
Because the third-party application systems involved in the system data distribution process have different interface information, the part of the interface information can be used as an access path for data distribution, and the interface information is stored in the registration information database as registration information.
Specifically, the interface information includes: an application system identification app (id), wherein id represents a unique identification of the application system, and the information is used for identifying the application system; application System name Appid(name), wherein the name represents a system name of the application system, the name also being usable to identify the application system, typically in english characters; application system host address Appid(host), wherein the host represents a network domain name for identifying the host address of the application system; application system access port Appid(port), wherein a port represents an access interface of an application system; application system interface function Appid(serviceId), wherein serviceId represents an interface function identification of the application system; application system function access path Appid,serviceId(path), wherein the path represents an access path under the application system specified function.
The information interaction in the system needs a plurality of kinds of shared information, which are called public information. The public information comprises resource data such as personnel, materials, equipment and physical assets, and business data such as plan information and performance information, models are respectively established for the information, the models are used as unified definition templates of the information and stored in a Common Information Model (CIM) library, and a MySQL library can be used for storing the information. The establishment of a common information model for the type data is the basis for realizing the integrated definition of the system, and can provide shared grammar and semantics for the system. Therefore, in this embodiment, a modeling method is used to construct a common information model for shared data used in the system, and the common information model is stored in a common information model library as a uniform template. And instantiating the model in the public information model library according to the actual requirement of the system, and storing the specific public information model object into the public information model object library.
According to the definition of a plan model in the public information model, an object instance obj _ a is created in a public information model object library, the attribute value of the actual object is stored, the state attribute state of the plan object obj _ a is included, and read-write access authority is provided for other systems.
Because different application systems are heterogeneous systems generally, and interfaces do not meet the transmission requirements of a standard system, customizing an interface adaptation system for the application systems is the basis for realizing information transmission between the systems. The adaptive system management module formulates a special interface according to the interface information so as to realize data interaction.
In one embodiment, the adaptation system management module is further configured to: after receiving a data distribution request of an application system, disassembling the data distribution request, carrying out format verification on a message header and a message body, and identifying a service processing requirement, a subscription event and a service processing event in the message body after the verification is correct.
The subscription event is as follows: the state attribute state value of the subscribed common information model object obj _ a triggers a business process event when the attribute value becomes "public". The business processing events are as follows: and when the subscription event is triggered, publishing the message body in the message body to another application system.
In one embodiment, the adaptation system management module is further configured to: the method comprises the steps of adding time sequence codes to received data distribution requests, classifying according to source application systems of the data distribution requests, compiling step numbers to the data distribution requests from the same application system according to the time sequence codes, controlling transmission requirements such as data distribution sequences and the like, and ensuring that a data distribution process can be accurately and orderly executed.
When P is presentf(t)≥Pf(t-1)When, Seqf(t)＝Seqf(t-1)+ 1; wherein, f (t) is the time sequence code of the request message; p is the priority of the request message, and the smaller the priority value is, the higher the priority is; seq is the number of the execution step of the request message, and the execution is performed from small to large according to the step number.
In one embodiment, the adaptation system management module is further configured to: and setting corresponding priority levels for all application systems, and performing priority data distribution on the data distribution requests with high priority levels so as to realize the distribution of the data according to the priority levels.
When P is presentf(t)<Pf(t-1)Then, the judgment is continued until Pf(t)≥Pf(t-n)Then Seqf(t)＝Seqf(t-n)+1；
Wherein, (t-n) is not less than 1, and f (t) is a time sequence code of the request message; p is the priority of the request message, and the smaller the priority value is, the higher the priority is; seq is the execution step number of the request message.
And the subscription/publication interaction is realized in the subscription management module. The application system subscribes to the state attribute state of the common information model object obj _ a through the adaptation system, and when the value of the attribute state becomes "public" (published), a subscription event is triggered, that is, when obj. Value indicates that the value of the attribute a of the common information model object obj has changed.
The subscription and publishing mechanism facing the common information model object is a key technology for realizing an information transmission mode facing a business field model, supports a system service interface to subscribe one or more object attributes of the common information model object, and sets business logic triggered by a subscription event according to actual business requirements, thereby realizing high-standard and highly-collaborative business requirements of an engineering system.
The information management module receives the data distribution request and sends the data distribution requestNumbering: setting the current request event sequence as f (t), reading the priority P of the requestf(t)Comparing the priority levels to find Pf(t)≥Pf(t-1)Then set the number of the current message as Seqf(t)＝Seqf(t-1)+1 and put in the message queue. And according to the content of the data distribution request, the message body data in the message body is published to the corresponding interface information customization interface, and the data distribution facing to the common information model object is completed.
Correspondingly, the present embodiment further provides a data distribution method based on a common information model, as shown in fig. 2 to 3, including the following steps:
s1: acquiring interface information of an application system and storing the interface information in a registration information database;
s2: generating a public information model object by taking the public information as a template for data storage;
s3: establishing a corresponding adaptation system according to interface information of the application system, receiving a data distribution request of the application system, and matching an adaptation system access address corresponding to the application system for the data distribution request;
s4: customizing an interface according to interface information of the application system to realize data transmission with the application system;
s5: subscribing the attribute of the common information model object, and triggering a subscription event when the attribute changes;
s6: and when a subscription event is triggered, realizing data distribution facing to the common information model object to the application system through the adaptation system according to the sequence.
The method ensures that the nonstandard interface can complete data distribution service by means of the standardized interface of the adaptation system, and ensures the channel availability of data distribution for realizing the communication cooperation path of the interoperation between the integrated systems. The common information model is used for formally describing shared information among the systems, and the model is instantiated according to the actual needs of the system, so that a normalized definition model and an object instance are provided for the system, and the processing range of engineering services is greatly expanded. And setting a service logic triggered by a subscription event according to the actual service requirement by subscribing the attribute of the common information model object, thereby realizing the high-standard and high-cooperation service requirement of the engineering system. A message queue management mechanism is established for the system, and meanwhile, transmission requirements such as data distribution sequence and the like can be controlled, so that the data distribution process can be accurately and orderly executed.
In one embodiment, the interface information includes: the application system comprises an application system identification, an application system name, an application system host address, an application system access port, an application system interface function and an application system function access path.
In an embodiment, after receiving the data distribution request of the application system, the method further includes: disassembling the data distribution request, performing format check on the message header and the message body, and identifying the service processing requirement, the subscription event and the service processing event in the message body after the check is correct
In an embodiment, the implementing, by an adaptation system in sequence, data distribution to an application system for a common information model object includes: adding time series codes for the received data distribution requests, classifying according to source application systems of the data distribution requests, and compiling step numbers for the data distribution requests from the same application system according to the time series codes.
In an embodiment, the implementing, by an adaptation system, data distribution to an application system oriented to a common information model object in sequence further includes: and setting corresponding priority levels for the application systems, and performing priority data distribution on the data distribution requests with high priority levels.
The specific implementation scheme based on the embodiment of the method has been described in detail in the embodiment of the system, and thus is not described in detail.
Various modifications or additions may be made to the described embodiments or alternatives may be employed by those skilled in the art without departing from the spirit or ambit of the invention as defined in the appended claims.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911365162.4A CN111198915A (en) | 2019-12-26 | 2019-12-26 | Data distribution system and method based on public information model |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911365162.4A CN111198915A (en) | 2019-12-26 | 2019-12-26 | Data distribution system and method based on public information model |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111198915A true CN111198915A (en) | 2020-05-26 |
Family
ID=70744431
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201911365162.4A Pending CN111198915A (en) | 2019-12-26 | 2019-12-26 | Data distribution system and method based on public information model |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111198915A (en) |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112019615A (en) * | 2020-08-26 | 2020-12-01 | 德鲁动力科技(海南)有限公司 | Data distribution system |
| CN115189918A (en) * | 2022-06-17 | 2022-10-14 | 江苏电力信息技术有限公司 | Information distribution method based on personalized adaptation |
| CN117891780A (en) * | 2024-03-14 | 2024-04-16 | 中国西安卫星测控中心 | Data subscription, retrieval and distribution method |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102340734A (en) * | 2010-07-16 | 2012-02-01 | 中国电信股份有限公司 | Positioning application management method and device |
| WO2012131429A1 (en) * | 2011-03-29 | 2012-10-04 | Yogesh Chunilal Rathod | A method and system for dynamically publishing, sharing, communication and subscribing |
| CN102932279A (en) * | 2012-10-30 | 2013-02-13 | 北京邮电大学 | Multidimensional resource scheduling system and method for cloud environment data center |
| CN103139251A (en) * | 2011-11-29 | 2013-06-05 | 神州数码信息系统有限公司 | Method of city-level data sharing exchange platform technology |
| CN107688607A (en) * | 2017-07-26 | 2018-02-13 | 努比亚技术有限公司 | The method and mobile terminal of a kind of database access, computer-readable recording medium |
| CN107844378A (en) * | 2016-09-21 | 2018-03-27 | 北京航天长峰科技工业集团有限公司 | A kind of Distributed Heterogeneous Data resources integration and management system |
| CN108876445A (en) * | 2018-05-31 | 2018-11-23 | 华北电力大学 | A kind of data interoperation application based on battalion's distribution end-equipment common information model |
-
2019
- 2019-12-26 CN CN201911365162.4A patent/CN111198915A/en active Pending
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102340734A (en) * | 2010-07-16 | 2012-02-01 | 中国电信股份有限公司 | Positioning application management method and device |
| WO2012131429A1 (en) * | 2011-03-29 | 2012-10-04 | Yogesh Chunilal Rathod | A method and system for dynamically publishing, sharing, communication and subscribing |
| CN103139251A (en) * | 2011-11-29 | 2013-06-05 | 神州数码信息系统有限公司 | Method of city-level data sharing exchange platform technology |
| CN102932279A (en) * | 2012-10-30 | 2013-02-13 | 北京邮电大学 | Multidimensional resource scheduling system and method for cloud environment data center |
| CN107844378A (en) * | 2016-09-21 | 2018-03-27 | 北京航天长峰科技工业集团有限公司 | A kind of Distributed Heterogeneous Data resources integration and management system |
| CN107688607A (en) * | 2017-07-26 | 2018-02-13 | 努比亚技术有限公司 | The method and mobile terminal of a kind of database access, computer-readable recording medium |
| CN108876445A (en) * | 2018-05-31 | 2018-11-23 | 华北电力大学 | A kind of data interoperation application based on battalion's distribution end-equipment common information model |
Non-Patent Citations (4)
| Title |
|---|
| 史会丽: "基于DDS规范的数据发布/订阅模型应用研究", no. 15, pages 253 - 256 * |
| 毛鹏等: "公共信息平台的数据访问服务设计", vol. 30, no. 30, pages 121 - 125 * |
| 熊志刚;李晶;苏振扬;彭卫平: "一种DDS与ESB通信转换的适配器模型", no. 02, pages 76 - 81 * |
| 陈汇远: "基于SOA的城轨信息共享平台模型的研究", no. 04, pages 11 - 15 * |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112019615A (en) * | 2020-08-26 | 2020-12-01 | 德鲁动力科技(海南)有限公司 | Data distribution system |
| CN115189918A (en) * | 2022-06-17 | 2022-10-14 | 江苏电力信息技术有限公司 | Information distribution method based on personalized adaptation |
| CN117891780A (en) * | 2024-03-14 | 2024-04-16 | 中国西安卫星测控中心 | Data subscription, retrieval and distribution method |
| CN117891780B (en) * | 2024-03-14 | 2024-05-17 | 中国西安卫星测控中心 | Data subscription, retrieval and distribution method |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11150634B2 (en) | Methods and systems for implementing distributed ledger manufacturing history | |
| US9589250B2 (en) | System and method for asset registration workflows utilizing an eventing infrastructure in a metadata repository | |
| CN107015853B (en) | Method and device for realizing multi-stage task | |
| CN108874558B (en) | Message subscription method of distributed transaction, electronic device and readable storage medium | |
| CN102542382A (en) | Method and device for managing business rule | |
| CN113919821B (en) | Business circulation method, device, computer equipment and storage medium | |
| CN112380219A (en) | Method for defining block chain cochain data service stipulation and application service stipulation | |
| US9262241B2 (en) | Computer system, computer-implemented method and computer program product for sequencing incoming messages for processing at an application | |
| CN111198915A (en) | Data distribution system and method based on public information model | |
| JP2009217327A (en) | Client environment generation system, client environment generation method, client environment generation program and storage medium | |
| CN108008950B (en) | Method and device for realizing user interface updating | |
| CN110321207A (en) | Method for scheduling task, device, equipment and computer readable storage medium | |
| JP2025541538A (en) | Inter-system digital workflow integration system, workflow management method and system | |
| CN101046746B (en) | Code Management in Distributed Software Development Environment | |
| CN117971401A (en) | A distributed transaction processing method, device, electronic device and storage medium | |
| CN107277146A (en) | A kind of distributed storage service traffics model generating method and system | |
| CN110515611B (en) | Document number generation method | |
| CN113407262A (en) | Information processing method and device, electronic equipment and computer readable medium | |
| CN114416131B (en) | Application upgrade method, application upgrade platform, electronic device and storage medium | |
| US20200134068A1 (en) | Action set translation | |
| CN115525445A (en) | Message intelligent distribution processing method, system, device, equipment and medium | |
| JP2024541858A (en) | Data analysis model management method, electronic device and storage medium | |
| CN115033590A (en) | Multi-domain data fusion method, device and storage medium | |
| CN116805920A (en) | Information processing method, device, network equipment and storage medium | |
| CN116346631A (en) | NFV arrangement method, device, equipment and storage medium |
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 |
Application publication date: 20200526 |
|
| RJ01 | Rejection of invention patent application after publication |