CN113905094B - Industrial Internet integration method, device and system - Google Patents
Industrial Internet integration method, device and system Download PDFInfo
- Publication number
- CN113905094B CN113905094B CN202111483349.1A CN202111483349A CN113905094B CN 113905094 B CN113905094 B CN 113905094B CN 202111483349 A CN202111483349 A CN 202111483349A CN 113905094 B CN113905094 B CN 113905094B
- Authority
- CN
- China
- Prior art keywords
- service
- request
- external
- industrial internet
- integrated
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/02—Details
-
- 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/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Computer And Data Communications (AREA)
Abstract
The embodiment of the application is suitable for the technical field of industrial Internet, and provides an industrial Internet integration method, an industrial Internet integration device and an industrial Internet integration system, wherein the method comprises the following steps: determining a plurality of external request systems to be integrated; deploying a plurality of integrated channels according to the service types corresponding to the services; configuring a requesting system adapter comprising a plurality of adaptation request interfaces; when a service request submitted by an external target request system through an adaptive request interface is received, calling a target integrated channel from a plurality of integrated channels according to service type information carried in the service request; and determining a target server which is currently used for processing the service request in the plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system. By adopting the method, the system integration efficiency can be improved, and the cost required by system integration can be reduced.
Description
Technical Field
The embodiment of the application belongs to the technical field of industrial internet, and particularly relates to an industrial internet integration method, device and system.
Background
The Industrial Internet (Industrial Internet) is a new infrastructure, application mode and Industrial ecology deeply integrated with new-generation information communication technology and Industrial economy, and a brand-new manufacturing and service system covering a whole Industrial chain and a whole value chain is constructed through comprehensive connection of people, machines, objects, systems and the like. The industrial internet provides an implementation approach for the industrial and even industrial digital, networked and intelligent development.
In the field of industrial internet, it is necessary to realize integrated access between various systems. For example, the request system and the application system are integrated together, and data interconnection between the request system and the application system is realized. However, the request system and the application system may belong to different service parties, and the number of the request systems or the number of the application systems provided by the same service party may also include a plurality of request systems, and if a plurality of request systems and a plurality of application systems are directly integrated, not only the operation is very complicated, the efficiency is extremely low, but also the cost spent in the integration process is very large.
Disclosure of Invention
In view of this, the embodiment of the present application provides an industrial internet integration, so as to improve the integration efficiency of the request system and the application system and reduce the integration cost.
A first aspect of an embodiment of the present application provides an industrial internet integration method, which is applied to an industrial internet integration system, and the method includes:
determining a plurality of external request systems to be integrated, wherein any external request system is used for requesting to execute at least one service, and each service has a corresponding service type;
deploying a plurality of integrated paths according to the service types corresponding to the services, wherein any integrated path comprises a plurality of mutually independent servers;
configuring a requesting system adapter comprising a plurality of adaptation request interfaces;
when a service request submitted by an external target request system through the adaptive request interface is received, calling a target integrated channel from the plurality of integrated channels according to the service type information carried in the service request;
and determining a target server which is currently used for processing the service request in the plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system.
A second aspect of embodiments of the present application provides an industrial internet integration apparatus, which is applied to an industrial internet integration system, and the apparatus includes:
the system comprises a determining module, a judging module and a judging module, wherein the determining module is used for determining a plurality of external request systems to be integrated, any one of the external request systems is used for requesting to execute at least one service, and each service has a corresponding service type;
a deployment module, configured to deploy a plurality of integrated paths according to the service types corresponding to the services, where any of the integrated paths includes a plurality of servers that are independent of each other;
a configuration module for configuring a requesting system adapter comprising a plurality of adaptation request interfaces;
the calling module is used for calling a target integrated channel from the plurality of integrated channels according to the service type information carried in the service request when receiving the service request submitted by an external target request system through the adaptive request interface;
and the transmission module is used for determining a target server which is currently used for processing the service request in the plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system.
A third aspect of embodiments of the present application provides an industrial internet integration system, including a memory, a processor, and a computer program stored in the memory and executable on the processor, wherein the processor, when executing the computer program, implements the industrial internet integration method according to the first aspect.
A fourth aspect of embodiments of the present application provides a computer-readable storage medium storing a computer program, which when executed by a processor, implements the industrial internet integration method according to the first aspect.
A fifth aspect of embodiments of the present application provides a computer program product, which when run on a computer, causes the computer to execute the industrial internet integration method of the first aspect.
Compared with the prior art, the embodiment of the application has the following advantages:
in the embodiment of the application, for a plurality of external request systems to be integrated, a plurality of integration paths can be respectively deployed according to the specific type of service requested to be realized by each external request system. Each integrated channel can comprise a plurality of mutually independent servers, so that the reliability of the system can be ensured, and the mutual influence among different external request systems can be reduced. For the case that the system interface specifications used between the external request system and the industrial internet integrated system are different, the embodiment of the application can configure the request system adapter in the industrial internet integrated system to solve the interface difference between the systems. In this way, when an external target requesting system initiates a service request, the service request can be transmitted to the industrial internet integration system via a corresponding adapted request interface in the system adapter. The industrial internet integration system can call a target integration path to process the service request according to a specific service type, and integration between an external target request system and an external target application system is realized. By adopting the method provided by the embodiment of the application, the system integration efficiency can be improved, and the cost required by system integration can be reduced.
Drawings
In order to more clearly illustrate the technical solutions in the embodiments of the present application, the drawings used in the embodiments or the description of the prior art will be briefly described below. It is obvious that the drawings in the following description are only some embodiments of the application, and that for a person skilled in the art, other drawings can be derived from them without inventive effort.
Fig. 1 is a schematic flowchart illustrating steps of an industrial internet integration method according to an embodiment of the present disclosure;
fig. 2 is a schematic diagram illustrating an implementation manner of step S102 in an industrial internet integration method according to an embodiment of the present application;
fig. 3 is a schematic diagram illustrating an implementation manner of step S1021 in an industrial internet integration method according to an embodiment of the present application;
fig. 4 is a schematic diagram illustrating an implementation manner of step S103 in an industrial internet integration method according to an embodiment of the present application;
fig. 5 is a schematic diagram illustrating an implementation manner of an application system adapter configured with multiple adaptive transmission interfaces in an industrial internet integration method according to an embodiment of the present application;
fig. 6 is a schematic diagram illustrating an implementation manner of establishing a security mechanism between an industrial internet integration system and an external request system in an industrial internet integration method according to an embodiment of the present application;
fig. 7 is a schematic diagram of an industrial internet integration device according to an embodiment of the present application;
fig. 8 is a schematic diagram of an industrial internet integration system provided in an embodiment of the present application.
Detailed Description
In the following description, for purposes of explanation and not limitation, specific details are set forth, such as particular system structures, techniques, etc. in order to provide a thorough understanding of the embodiments of the present application. However, it will be apparent to one skilled in the art that the present application may be practiced in other embodiments that depart from these specific details. In other instances, detailed descriptions of well-known systems, devices, circuits, and methods are omitted so as not to obscure the description of the present application with unnecessary detail.
The technical solution of the present application will be described below by way of specific examples.
Referring to fig. 1, a schematic flow chart illustrating steps of an industrial internet integration method provided in an embodiment of the present application is shown, which may specifically include the following steps:
s101, determining a plurality of external request systems to be integrated, wherein any external request system is used for requesting to execute at least one service, and each service has a corresponding service type.
It should be noted that the method can be applied to an industrial internet integration system. The external request system and the external application system can be integrated in the industrial internet integrated system, and data interconnection and intercommunication between the external request system and the external application system are achieved. The external request system and the external application system may be referred to as an external application system with respect to the industrial internet integration system.
In addition, a specific external system may be an external request system or an external application system, depending on the way in which the specific service is implemented. That is, the external request system is the party that initiates the service request, and the external application system is the party that responds to the service request, thereby implementing the corresponding service function. For example, in the process of implementing the first service, the external system a is the party that initiates the service request, and the external system B is the party that responds to and processes the service request. In this case, the external system a is an external request system, and the external system B is an external application system. In another scenario, if the second service is to be implemented, the external system B needs to initiate a corresponding service request, and the external system a needs to respond to and process the service request. In this case, the external system B belongs to the external requesting system, and the external system a is the external application system. The embodiment of the present application distinguishes between the external requesting system and the external application system only to clarify the data flow between the systems in the process of implementing a certain service.
In the embodiment of the present application, for any external request system, it may implement a certain service or services with a specific service type by initiating a service request to the corresponding external application system. That is, for some external request system, it may be used to request that at least one specific service be implemented. The embodiment of the application does not limit the types and the number of the services requested by each external request system.
Taking an industrial enterprise as an example, a plurality of systems in the enterprise need to access other systems of the enterprise or an external provider enterprise, so as to realize the intellectualization and informatization of the enterprise. Thus, the external request system to be integrated can be regarded as a certain information system requiring access to other systems, such as an Enterprise Resource Planning (ERP) system, a Manufacturing Execution System (MES) system, and the like. Therefore, the external request system may be an ERP system of the enterprise, and the corresponding external application system may be an information system of the supplier enterprise.
It should be noted that, for a certain external request system, the number of corresponding external application systems may include a plurality. Each external application system may be used to implement one or more specific services, respectively.
S102, deploying a plurality of integrated paths according to the service types corresponding to the services, wherein any integrated path comprises a plurality of mutually independent servers.
Generally, information transmitted between systems to realize a certain service may be referred to as messages, and an industrial internet integration system may deploy a plurality of integration paths respectively to transmit the messages according to specific service types of each service.
In the embodiment of the present application, the corresponding integrated circuit may be deployed according to the characteristics of the service, the characteristics of the transmitted message, and the like. These integrated circuits may be circuits deployed within an industrial internet integrated system.
In a possible implementation manner of the embodiment of the present application, as shown in fig. 2, deploying a plurality of integrated vias in S102 according to service types corresponding to each service may specifically include the following sub-steps S1021 to S1024:
s1021, determining a plurality of integrated passages to be deployed according to the service types corresponding to the services.
In the embodiment of the present application, it may be determined, first, which integration paths need to be deployed for each service implementing the service type according to a specific service type.
Illustratively, the real-time requirements of the services can be determined according to the service types corresponding to the services. Then, different integrated channels are respectively deployed according to different real-time requirements.
Generally, for a certain service, its real-time requirements may include high real-time requirements or low real-time requirements. Services with high real-time requirements may refer to services that require real-time or near real-time processing, which typically have a high priority for response, and belong to services that have a significant impact on system functionality. Such as bidding services, alarm warning services, and the like. Services with low real-time requirements are those with relatively poor real-time performance relative to services with high real-time requirements, which can be handled during a period of time when the system is relatively idle, and which do not have a significant impact on the system functionality. Such as order data synchronization services, account application and logoff services, etc.
For a service with high real-time requirement, after an external request system initiates a corresponding service request, the corresponding external application system needs to respond and process the service request in time. Therefore, the service with high real-time requirement can be regarded as a key service influencing the performance of the system, and for the service with high real-time requirement, a key service access needs to be deployed in the industrial internet integrated system.
For services with low real-time requirements, these services can be considered non-critical services since they do not significantly affect system performance. For services with low real-time requirements, it may be determined that non-critical service pathways need to be deployed for them in an industrial internet integrated system.
In a possible implementation manner of the embodiment of the present application, as shown in fig. 3, determining, according to the service type corresponding to each service in S1021, a plurality of integrated channels to be deployed may further include the following sub-steps S1211-S1212:
and S1211, counting the data volume of the service with the low real-time requirement.
And S1212, deploying a batch service path for the service with the low real-time requirement and the data volume larger than the preset data volume.
In the embodiment of the application, for services with low real-time requirements, the system can also complete the transmission of messages in a batch processing mode under the condition of the data volume of the messages transmitted in the process of realizing the services. Therefore, for the service with low real-time requirement, the data volume of the message in the implementation process can be counted, if the data volume is larger than the preset data volume, a batch service channel can be determined to be deployed for the service, so that the message can be transmitted in a batch processing mode, the integration cost is reduced, and the influence on the system performance in the service implementation process is reduced.
In another possible implementation manner of the embodiment of the application, for some services, the implementation purpose of the service may not be the same as the implementation purpose of the industrial internet integration system. For such services, it is determined that a proxy service path needs to be deployed in the industrial internet integration system so as to transmit messages of the services in a transparent transmission manner, thereby reducing implementation workload and implementation cost in the system integration process.
S1022, determining configuration information of each integrated channel respectively, wherein the configuration information at least comprises data standards, service components and implementation methods of each service in each integrated channel.
In the embodiment of the present application, after determining each integrated circuit to be deployed, it may be determined, for each integrated circuit, what configuration information is required to implement the circuit, so as to perform uniform configuration development on each integrated circuit.
Generally, a plurality of integrated channels are deployed in an industrial internet integrated system, and configuration information required for each integrated channel at least includes data standards, service components, implementation methods, and the like of each service in the integrated channel. Data standards may include, among other things, management of metadata, data structure and service interface definitions, and routing rules; the service components can be specific unit structures and the like required in the service implementation process; and the implementation method may include functions and the like that need to be called in the service implementation.
S1023, packaging the implementation methods of the services.
S1024, deploying data standards, service components and the packaged implementation method of each service in a plurality of mutually independent servers to obtain a plurality of integrated channels.
In the embodiment of the application, the industrial internet integration system can package each service implementation method realized by each integration channel, so that different services can call the corresponding packaged implementation method. The data standard, service components, and encapsulated implementations described above may then be deployed to a server for building an integrated circuit for the service.
In a possible implementation manner of the embodiment of the present application, each integrated channel may have multiple physical deployments, so as to ensure reliability of the system, support lateral expansion of the system, and reduce mutual influence between different systems. Thus, any one integrated circuit can be implemented based on a plurality of mutually independent servers. Therefore, when each integrated channel is deployed, the data standard, the service components and the encapsulated implementation method can be deployed into a plurality of mutually independent servers.
In the embodiment of the present application, a plurality of mutually independent servers in any integrated channel may form a blade server cluster. The blade server cluster has the advantage of virtualized resource management, so that the utilization rate of resources can be effectively improved; moreover, a new blade is inserted into the blade server cluster, so that the overall performance can be improved, and the system is favorably expanded; in addition, the blade server cluster supports hot plug, hardware resources can be easily replaced, and therefore system maintenance time can be reduced to the minimum.
S103, configuring a request system adapter comprising a plurality of adaptation request interfaces.
In this embodiment, the requesting system adapter may be a component in the industrial internet integrated system for performing format conversion on a message transmitted by an external requesting system, and is responsible for solving interface differences between the external requesting system and the industrial internet system and an external application system. The request system adapter can comprise a plurality of adaptation request interfaces, and each adaptation request interface can be used for converting messages with a specific format so as to enable the messages to conform to the interface specification of the industrial Internet integration system.
In a possible implementation manner of the embodiment of the present application, as shown in fig. 4, configuring a request system adapter including a plurality of adaptation request interfaces in S103 may specifically include the following sub-steps S1031 to S1032:
and S1031, respectively determining system interface specifications of each external request system and the industrial Internet integration system.
S1032, aiming at any external request system, configuring an adaptation request interface corresponding to the external request system according to the external request system and the system interface specification of the industrial Internet integration system to obtain a request system adapter comprising a plurality of adaptation request interfaces.
In the embodiment of the application, for each external request system to be integrated, the system interface specification of the external request system and the current industrial internet integration system can be determined firstly. For those external request systems that differ from the system interface specification used by the industrial internet integration system, the adaptation request interface needs to be configured in accordance with the system interface specification of the industrial internet integration system. For those external request systems that have the same system interface specification as used by the industrial internet integrated system, there is no need to configure an adaptation request interface for them separately.
It should be noted that, when the industrial internet integrated system is constructed, more interface specifications used in the external system can be used as the interface specifications used by the industrial internet integrated system, so that the workload of the configurator of the configuration request system can be greatly reduced.
After the request system adapter is configured, when the adapter receives a service request message submitted by an external request system, the adaptation request interface therein may decapsulate the message according to a system interface specification of the corresponding external request system; and then, encapsulating the decapsulated message into a message which conforms to the system interface specification of the industrial Internet integration system.
In the embodiment of the application, not only the interface difference exists between the external request system and the industrial internet integrated system, but also the interface difference may exist between the external application system and the industrial internet system. Therefore, in order to solve the above problem, after configuring a requesting system adapter including a plurality of adaptation request interfaces, an application system adapter of a plurality of adaptation transmission interfaces may also be configured. The application system adapter can be regarded as a component used for converting the format of the message needing to be transmitted to the external request system in the industrial internet integrated system and is responsible for solving the interface difference between the industrial internet system and the external application system.
In this embodiment, as shown in fig. 5, configuring an application system adapter including a plurality of adaptive transmission interfaces may specifically include the following steps S1033 to S1034:
s1033, system interface specifications of the external application systems are determined respectively.
S1034, configuring an application system adapter comprising a plurality of adaptive transmission interfaces according to the system interface specification of each external application system and the industrial Internet integration system.
Similar to the configuration request system configurator, the system interface specification of each external application system may be determined first, and it may be determined whether the system interface specification of the external application system is the same as the system interface specification currently used by the industrial internet integrated system. For an external application system with the same system interface specification as that currently used by the industrial internet integrated system, an adaptive transmission interface cannot be independently configured for the external application system; for an external application system with a system interface specification different from that currently used by the industrial internet integrated system, a corresponding adaptive transmission interface needs to be configured according to the system interface specifications of the external application system and the industrial internet integrated system. Thus, when the industrial internet integration system transmits the message to the external application system, the adaptive transmission interface corresponding to each external application system can firstly decapsulate the message according to the system interface specification of the industrial internet integration system, and then encapsulate the message into the message meeting the system interface specification of the corresponding external application system, and transmit the message to the external application system for processing by the external application system.
Through the steps of 101-S103, corresponding integrated channels have been constructed in the industrial internet integrated system, and service requests submitted by each external request system can be processed, so as to implement interconnection and intercommunication of data between the external request system and the external application system.
In the embodiment of the application, after the industrial internet integration system integrates a plurality of external systems, complex business processes and a large amount of information and data can be efficiently transferred and shared between the request system and the application system, the standardization and automation of the business processes are realized, the process optimization is promoted, and the system operation efficiency is improved. In this case, any unsafe factors can cause immeasurable losses. Therefore, all messages, data transmission, processing and exchange must be performed in a well secured environment. It is necessary to establish a safe operation mechanism between the industrial internet integration system and the external request system and the external application system.
In a possible implementation manner of the embodiment of the present application, as shown in fig. 6, establishing a security mechanism between the industrial internet integration system and the external request system may specifically include the following steps S601 to S602:
s601, in an off-line state, issuing authentication certificates to the external request systems.
And S602, performing bidirectional authentication on the plurality of external request systems and the industrial Internet integrated system by using the authentication certificate to obtain authentication random numbers respectively stored in the plurality of external request systems and the industrial Internet integrated system, wherein the authentication random numbers are used for generating a symmetric key to encrypt messages transmitted when each service is executed.
In the embodiment of the application, in order to ensure the validity of each external request system integrated to the industrial internet integrated system, a bidirectional identity authentication mode based on an authentication certificate can be adopted between the industrial internet integrated system and the external request system. The authentication certificate may be issued to an external requesting system in an offline state. For example, it is installed in a file format such as PKCS #12 in the external request system. PKCS #12 is an encryption standard that exchanges digital certificates to describe personal identity information. Such as: a user public key, a private key, a certificate, etc.
After the bidirectional identity authentication is completed, the industrial internet integrated system and the external request system can obtain a random number. For example, both parties may get a 64 byte random number. Therefore, the industrial internet integrated system and the external request system can use the random number to generate a symmetric key in the communication process, and encrypt messages transmitted when various services are executed by adopting the symmetric key.
It should be noted that both parties can use the same policy for the selection rule of the symmetric key, and the symmetric key and the public key information of the other party can be stored in the shared memory, so that the symmetric key and the public key information of the other party can be conveniently used during encryption.
For the external application system, the security mechanism between the external application system and the industrial internet integration system can be realized in the same manner as described above. That is, in an off-line state, the industrial internet integrated system issues authentication certificates to the external application systems, and performs bidirectional authentication on the external application systems and the industrial internet integrated system using the authentication certificates to obtain authentication random numbers respectively stored in the external application systems and the industrial internet integrated system, where the authentication random numbers may also be used to generate a symmetric key to encrypt messages transmitted when each service is executed.
S104, when a service request submitted by an external target request system through the adaptive request interface is received, a target integrated channel is called from the integrated channels according to the service type information carried in the service request.
The foregoing S101-S103 describe in detail how to deploy integration paths for various services of different service types in the industrial internet integration system, and S104-S105 will describe a process of implementing a specific service based on an already established integration path.
In an embodiment of the present application, the external target requesting system may be one of a plurality of external requesting systems, which may initiate a corresponding service request for the target service. The service request may be transmitted to the industrial internet integration system via an adapted request interface corresponding to an external target request system. The adaptation request interface can convert the format of the message carrying the service request so as to meet the system interface specification of the industrial Internet integration system.
After receiving the service request, the industrial internet integration system can call a target integration path from the multiple integration paths according to the service type information carried in the service request. The target integrated channel can be a critical service channel or a non-critical service channel, depending on whether the target service requested to be realized by the external target request system belongs to a critical service with high real-time performance or a non-critical service with low real-time performance. For example, if the target service belongs to a service with a high real-time requirement, the target integrated circuit should select a key service circuit; if the target service belongs to the service with lower real-time requirement, the target integrated channel can select a non-key service channel; if the target service has a low real-time requirement and a huge data volume in the process of realizing the service, the target integrated channel can select a batch service channel.
S105, determining a target server which is currently used for processing the service request in the plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server to realize integration of the external target request system and the external target application system.
In the embodiment of the application, because any integrated channel comprises a plurality of mutually independent servers, after a target integrated channel for processing a currently received service request is determined, a target server can be determined from the plurality of servers of the target integrated channel, and the transmission of the service request is realized based on the target server, so that the integration of an external target request system and an external target application system is completed.
The target server may be a server that currently processes a smaller amount of data among the plurality of servers of the target integrated circuit. Thus, the processing efficiency of the service request can be improved, and the large amount of data is prevented from being processed by the same server in the target integrated circuit.
In the embodiment of the present application, for a plurality of external request systems to be integrated, a plurality of integration paths may be respectively deployed according to a specific type of service requested to be implemented by each external request system. Each integrated channel can comprise a plurality of mutually independent servers, so that the reliability of the system can be ensured, and the mutual influence among different external request systems can be reduced. For the case that the system interface specifications used between the external request system and the industrial internet integrated system are different, the embodiment of the application can configure the request system adapter in the industrial internet integrated system to solve the interface difference between the systems. In this way, when an external target requesting system initiates a service request, the service request can be transmitted to the industrial internet integration system via a corresponding adapted request interface in the system adapter. The industrial internet integration system can call a target integration path to process the service request according to a specific service type, and integration between an external target request system and an external target application system is realized. By adopting the method provided by the embodiment of the application, the system integration efficiency can be improved, and the cost required by system integration can be reduced.
It should be noted that, the sequence numbers of the steps in the foregoing embodiments do not mean the execution sequence, and the execution sequence of each process should be determined by the function and the inherent logic of the process, and should not constitute any limitation on the implementation process of the embodiments of the present application.
Referring to fig. 7, a schematic diagram of an industrial internet integrated device provided in an embodiment of the present application is shown, and specifically may include a determining module 701, a deploying module 702, a configuring module 703, a calling module 704, and a transmitting module 705, where:
a determining module 701, configured to determine a plurality of external request systems to be integrated, where any external request system is configured to request to execute at least one service, and each service has a corresponding service type;
a deployment module 702, configured to deploy, according to the service type corresponding to each of the services, a plurality of integrated paths, where any of the integrated paths includes a plurality of mutually independent servers;
a configuration module 703 for configuring a requesting system adapter including a plurality of adaptation request interfaces;
a calling module 704, configured to, when receiving a service request submitted by an external target request system via the adaptation request interface, call a target integrated circuit from the multiple integrated circuits according to information of a service type carried in the service request;
a transmission module 705, configured to determine a target server currently used for processing the service request in the multiple servers of the target integrated circuit, and transmit the service request to an external target application system through the target server, so as to implement integration of the external target request system and the external target application system.
In this embodiment of the present application, the deployment module 702 may specifically be configured to: determining a plurality of integrated passages to be deployed according to the service types corresponding to the services; respectively determining configuration information of each integrated channel, wherein the configuration information at least comprises data standards, service components and implementation methods of each service in each integrated channel; packaging the implementation methods of the services; deploying data standards, service components and the packaged implementation method of each service in a plurality of mutually independent servers to obtain a plurality of integrated channels; wherein a plurality of mutually independent servers in any one of the integrated circuits form a blade server cluster.
In this embodiment of the application, the plurality of integrated channels may include a critical service channel and a non-critical service channel, and the deployment module 702 may further be configured to: determining real-time requirements of the services according to service types corresponding to the services, wherein the real-time requirements comprise high real-time requirements or low real-time requirements; deploying a key service access for the service with high real-time requirement; and deploying a non-critical service path for the service with low real-time requirement.
In this embodiment of the application, the plurality of integration paths may further include a batch service path, and the deployment module 702 may further be configured to: counting a data volume of the service with the low real-time requirement; and deploying a batch service channel for the service with the low real-time requirement and the data volume larger than the preset data volume.
In this embodiment, the configuration module 703 may be specifically configured to: respectively determining system interface specifications of each external request system and the industrial Internet integration system; aiming at any external request system, configuring an adaptation request interface corresponding to the external request system according to the system interface specifications of the external request system and the industrial Internet integration system to obtain a request system adapter comprising a plurality of adaptation request interfaces; the adaptation request interface is used for decapsulating the message according to the system interface specification of the corresponding external request system and then encapsulating the decapsulated message into a message conforming to the system interface specification of the industrial internet integrated system.
In this embodiment of the application, the configuration module 703 may be further configured to: respectively determining the system interface specification of each external application system; configuring an application system adapter comprising a plurality of adaptive transmission interfaces according to the system interface specification of each external application system and the industrial Internet integration system; and any adaptive transmission interface is used for decapsulating the message according to the system interface specification of the industrial Internet integration system and then encapsulating the decapsulated message into a message which conforms to the system interface specification of the corresponding external application system.
In an embodiment of the present application, the apparatus may further include an encryption module. The encryption module may be specifically configured to: in an off-line state, issuing authentication certificates to a plurality of external request systems; and performing bidirectional authentication on the external request systems and the industrial Internet integrated system by adopting the authentication certificate to obtain authentication random numbers which are respectively stored in the external request systems and the industrial Internet integrated system, wherein the authentication random numbers are used for generating a symmetric key to encrypt messages transmitted when various services are executed.
For the apparatus embodiment, since it is substantially similar to the method embodiment, it is described relatively simply, and reference may be made to the description of the method embodiment section for relevant points.
Referring to fig. 8, a schematic diagram of an industrial internet integration system provided by an embodiment of the present application is shown. As shown in fig. 8, the industrial internet integration system 800 of the present embodiment includes: a processor 810, a memory 820, and a computer program 821 stored in the memory 820 and operable on the processor 810. The processor 810, when executing the computer program 821, implements the steps in the various embodiments of the industrial internet integration method described above, such as the steps S101 to S105 shown in fig. 1. Alternatively, the processor 810, when executing the computer program 821, implements the functions of the modules/units in the device embodiments, such as the functions of the modules 701 to 705 shown in fig. 7.
Illustratively, the computer program 821 may be partitioned into one or more modules/units that are stored in the memory 820 and executed by the processor 810 to accomplish the present application. The one or more modules/units may be a series of computer program instruction segments capable of performing specific functions, which may be used for describing the execution process of the computer program 821 in the industrial internet integrated system 800. For example, the computer program 821 may be partitioned into a determination module, a deployment module, a configuration module, a calling module, and a transmission module, wherein:
the system comprises a determining module, a judging module and a judging module, wherein the determining module is used for determining a plurality of external request systems to be integrated, any one of the external request systems is used for requesting to execute at least one service, and each service has a corresponding service type;
a deployment module, configured to deploy a plurality of integrated paths according to the service types corresponding to the services, where any of the integrated paths includes a plurality of servers that are independent of each other;
a configuration module for configuring a requesting system adapter comprising a plurality of adaptation request interfaces;
the calling module is used for calling a target integrated channel from the plurality of integrated channels according to the service type information carried in the service request when receiving the service request submitted by an external target request system through the adaptive request interface;
and the transmission module is used for determining a target server which is currently used for processing the service request in the plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system.
The industrial internet integration system 800 may be formed by a desktop computer, a cloud server, and other computing devices. The industrial internet integration system 800 can include, but is not limited to, a processor 810 and a memory 820. Those skilled in the art will appreciate that fig. 8 is only one example of an industrial internet integrated system 800, and does not constitute a limitation of the industrial internet integrated system 800, and may include more or less components than those shown, or combine certain components, or different components, for example, the industrial internet integrated system 800 may further include input-output devices, network access devices, buses, and the like.
The Processor 810 may be a Central Processing Unit (CPU), other general purpose Processor, a Digital Signal Processor (DSP), an Application Specific Integrated Circuit (ASIC), an off-the-shelf Programmable Gate Array (FPGA) or other Programmable logic device, discrete Gate or transistor logic device, discrete hardware component, or the like. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like.
The storage 820 may be an internal storage unit of the industrial internet integrated system 800, such as a hard disk or a memory of the industrial internet integrated system 800. The memory 820 may also be an external storage device of the industrial internet integrated system 800, such as a plug-in hard disk, a Smart Media Card (SMC), a Secure Digital (SD) Card, a Flash memory Card (Flash Card), and the like, which are provided on the industrial internet integrated system 800. Further, the memory 820 may also include both an internal storage unit and an external storage device of the industrial internet integrated system 800. The memory 820 is used to store the computer program 821 and other programs and data required by the industrial internet integrated system 800. The memory 820 may also be used to temporarily store data that has been output or is to be output.
The embodiment of the application also discloses an industrial internet integration system, which comprises a memory, a processor and a computer program stored in the memory and capable of running on the processor, wherein the processor executes the computer program to realize the industrial internet integration method according to the foregoing embodiments.
The embodiment of the application also discloses a computer readable storage medium, which stores a computer program, and the computer program is executed by a processor to realize the industrial internet integration method according to the foregoing embodiments.
The embodiment of the application also discloses a computer program product, and when the computer program product runs on a computer, the computer is enabled to execute the industrial internet integration method of the previous embodiments.
The above-mentioned embodiments are only used for illustrating the technical solutions of the present application, and not for limiting the same. Although the present application has been described in detail with reference to the foregoing embodiments, it should be understood by those of ordinary skill in the art that: the technical solutions described in the foregoing embodiments may still be modified, or some technical features may be equivalently replaced; such modifications and substitutions do not depart from the spirit and scope of the embodiments of the present application, and they should be construed as being included in the present application.
Claims (6)
1. An industrial internet integration method applied to an industrial internet integration system, the method comprising:
determining a plurality of external request systems to be integrated, wherein any external request system is used for requesting to execute at least one service, each service has a corresponding service type, any external request system has a corresponding external application system, the external request system and the external application system are external systems relative to the industrial internet integration system, the external systems are external request systems in the process of realizing one service and external application systems in the process of realizing another service, the external request systems are parties initiating service requests, and the external application systems are parties responding to the service requests;
determining a plurality of integrated passages to be deployed according to the service types corresponding to the services;
respectively determining configuration information of each integrated channel, wherein the configuration information at least comprises data standards, service components and implementation methods of each service in each integrated channel;
packaging the implementation methods of the services;
deploying data standards, service components and the packaged implementation method of each service in a plurality of mutually independent servers to obtain a plurality of integrated channels, wherein the plurality of mutually independent servers in any integrated channel form a blade server cluster;
respectively determining system interface specifications of each external request system and the industrial internet integrated system, wherein the system interface specifications of the industrial internet integrated system are the same as the system interface specifications used by relatively more external request systems;
aiming at any external request system, configuring an adaptation request interface corresponding to the external request system according to the system interface specifications of the external request system and the industrial Internet integration system to obtain a request system adapter comprising a plurality of adaptation request interfaces; the adaptation request interface is used for decapsulating the message according to the system interface specification of the corresponding external request system and then encapsulating the decapsulated message into a message conforming to the system interface specification of the industrial internet integrated system;
respectively determining the system interface specification of each external application system;
configuring an application system adapter comprising a plurality of adaptive transmission interfaces according to the system interface specification of each external application system and the industrial Internet integration system; any adaptive transmission interface is used for decapsulating the message according to the system interface specification of the industrial internet integrated system and then encapsulating the decapsulated message into a message meeting the system interface specification of the corresponding external application system;
when a service request submitted by an external target request system through the adaptive request interface is received, calling a target integrated channel from the plurality of integrated channels according to the service type information carried in the service request;
determining a target server which is currently used for processing the service request in a plurality of servers of the target integration path, and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system;
the method further comprises the following steps: in an off-line state, issuing authentication certificates to a plurality of external request systems; and performing bidirectional authentication on the external request systems and the industrial Internet integrated system by using the authentication certificate to obtain authentication random numbers which are respectively stored in the external request systems and the industrial Internet integrated system, wherein the authentication random numbers are used for generating a symmetric key to encrypt messages transmitted when each service is executed, and the symmetric key is stored in a shared memory.
2. The method of claim 1, wherein the plurality of integrated circuits includes a critical service circuit and a non-critical service circuit, and wherein determining the plurality of integrated circuits to be deployed according to the service types corresponding to the services comprises:
determining real-time requirements of the services according to service types corresponding to the services, wherein the real-time requirements comprise high real-time requirements or low real-time requirements;
deploying a key service access for the service with high real-time requirement; and the number of the first and second groups,
and deploying a non-critical service access for the service with low real-time requirement.
3. The method of claim 2, wherein the plurality of integrated circuits further includes a batch service circuit, and wherein determining the plurality of integrated circuits to be deployed according to the service types corresponding to the services further comprises:
counting a data volume of the service with the low real-time requirement;
and deploying a batch service channel for the service with the low real-time requirement and the data volume larger than the preset data volume.
4. An industrial internet integration apparatus applied to an industrial internet integration system, the apparatus comprising:
a determining module, configured to determine a plurality of external request systems to be integrated, where any external request system is used to request execution of at least one service, each service has a corresponding service type, any external request system has a corresponding external application system, and both the external request system and the external application system are external systems relative to the industrial internet integration system, and the external systems are external request systems in a process of implementing one service and external application systems in a process of implementing another service, where the external request system is a party initiating a service request, and the external application system is a party responding to the service request;
the deployment module is used for determining a plurality of integrated passages to be deployed according to the service types corresponding to the services; respectively determining configuration information of each integrated channel, wherein the configuration information at least comprises data standards, service components and implementation methods of each service in each integrated channel; packaging the implementation methods of the services; deploying data standards, service components and the packaged implementation method of each service in a plurality of mutually independent servers to obtain a plurality of integrated channels, wherein the plurality of mutually independent servers in any integrated channel form a blade server cluster;
the configuration module is used for respectively determining the system interface specifications of each external request system and the industrial Internet integration system; aiming at any external request system, configuring an adaptation request interface corresponding to the external request system according to the system interface specifications of the external request system and the industrial Internet integration system to obtain a request system adapter comprising a plurality of adaptation request interfaces; respectively determining the system interface specification of each external application system; configuring an application system adapter comprising a plurality of adaptive transmission interfaces according to the system interface specification of each external application system and the industrial Internet integration system; the system interface specification of the industrial Internet integration system is the same as the system interface specifications used by relatively more external request systems, the adaptation request interface is used for decapsulating a message according to the corresponding system interface specification of the external request system and then encapsulating the decapsulated message into a message conforming to the system interface specification of the industrial Internet integration system, and any adaptation transmission interface is used for decapsulating the message according to the system interface specification of the industrial Internet integration system and then encapsulating the decapsulated message into a message conforming to the system interface specification of the corresponding external application system;
the calling module is used for calling a target integrated channel from the plurality of integrated channels according to the service type information carried in the service request when receiving the service request submitted by an external target request system through the adaptive request interface;
the transmission module is used for determining a target server which is currently used for processing the service request in a plurality of servers of the target integration path and transmitting the service request to an external target application system through the target server so as to realize integration of the external target request system and the external target application system;
the encryption module is used for issuing authentication certificates to the external request systems in an off-line state; and performing bidirectional authentication on the external request systems and the industrial Internet integrated system by using the authentication certificate to obtain authentication random numbers which are respectively stored in the external request systems and the industrial Internet integrated system, wherein the authentication random numbers are used for generating a symmetric key to encrypt messages transmitted when each service is executed, and the symmetric key is stored in a shared memory.
5. An industrial internet integration system comprising a memory, a processor, and a computer program stored in the memory and executable on the processor, wherein the processor implements the industrial internet integration method of any one of claims 1 to 3 when executing the computer program.
6. A computer-readable storage medium storing a computer program, wherein the computer program, when executed by a processor, implements the industrial internet integration method according to any one of claims 1 to 3.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111483349.1A CN113905094B (en) | 2021-12-07 | 2021-12-07 | Industrial Internet integration method, device and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111483349.1A CN113905094B (en) | 2021-12-07 | 2021-12-07 | Industrial Internet integration method, device and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113905094A CN113905094A (en) | 2022-01-07 |
| CN113905094B true CN113905094B (en) | 2022-09-20 |
Family
ID=79025620
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111483349.1A Active CN113905094B (en) | 2021-12-07 | 2021-12-07 | Industrial Internet integration method, device and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113905094B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114089711B (en) * | 2022-01-21 | 2022-05-17 | 深圳艾灵网络有限公司 | Industrial equipment control management method, electronic equipment and storage medium |
| CN114489700A (en) * | 2022-01-26 | 2022-05-13 | 山东浪潮通软信息科技有限公司 | Distributed integration method and system between heterogeneous systems |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102056333A (en) * | 2009-11-05 | 2011-05-11 | 中国移动通信集团河南有限公司 | WAP (wireless application protocol) gateway, service processing method thereof and WAP proxy server |
| CN108494811A (en) * | 2018-06-27 | 2018-09-04 | 深圳市思迪信息技术股份有限公司 | data transmission security authentication method and device |
Family Cites Families (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| RU2636112C1 (en) * | 2014-02-26 | 2017-11-20 | Хуавэй Текнолоджиз Ко., Лтд. | Object of interface management service, function service object and method of control of elements |
| US11470168B2 (en) * | 2017-10-12 | 2022-10-11 | Convida Wireless, Llc | Interworking service for the restful internet of things |
| CN110189229A (en) * | 2018-05-16 | 2019-08-30 | 杜鹏飞 | Insure core business system in internet |
| CN109743392A (en) * | 2019-01-07 | 2019-05-10 | 北京字节跳动网络技术有限公司 | A kind of load-balancing method, device, electronic equipment and storage medium |
| CN112751761A (en) * | 2020-12-28 | 2021-05-04 | 中国农业银行股份有限公司 | Transaction routing switching method, intermediate system and service processing system |
-
2021
- 2021-12-07 CN CN202111483349.1A patent/CN113905094B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102056333A (en) * | 2009-11-05 | 2011-05-11 | 中国移动通信集团河南有限公司 | WAP (wireless application protocol) gateway, service processing method thereof and WAP proxy server |
| CN108494811A (en) * | 2018-06-27 | 2018-09-04 | 深圳市思迪信息技术股份有限公司 | data transmission security authentication method and device |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113905094A (en) | 2022-01-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US20230396669A1 (en) | Technologies for transparent function as a service arbitration for edge systems | |
| EP3716107B1 (en) | Technologies for accelerated orchestration and attestation with edge device trust chains | |
| CN109067728B (en) | Access control method and device for application program interface, server and storage medium | |
| WO2020057163A1 (en) | Mec platform deployment method and device | |
| WO2020186807A1 (en) | System and method for power data linking based on blockchain technology | |
| US20220239496A1 (en) | Blockchain consensus method, device and system | |
| US11140137B2 (en) | Method and industrial computing apparatus for performing a secure communication | |
| US12153386B2 (en) | Intelligent operation control apparatus and system | |
| CN113905094B (en) | Industrial Internet integration method, device and system | |
| CN112235193B (en) | Data transmission method, device, equipment and medium based on cross-network multi-level routing | |
| US10678906B1 (en) | Multi-service and multi-protocol credential provider | |
| CN114268667B (en) | Data forwarding method, device, computer equipment and storage medium | |
| CN113886794A (en) | Computing cluster system, security authentication method, node device and storage medium | |
| CN114338682A (en) | Flow identity mark transmission method and device, electronic equipment and storage medium | |
| CN110875945A (en) | Method, apparatus and medium for task processing on a generic service entity | |
| CN115988078A (en) | Communication method, system, electronic device and storage medium | |
| KR102307973B1 (en) | Block chain-based Data Sharing Method for Improving Reliability of Distributed Systems | |
| CN116781764A (en) | Long-connection task execution method and device and related equipment | |
| CN112165529A (en) | Method, device, equipment and medium for low-cost cross-network data exchange | |
| CN115883200B (en) | Log security management method, device, platform and medium | |
| US20240330939A1 (en) | Transaction uploading method, associated apparatus, and medium | |
| CN117201112B (en) | Data access processing method and system based on all-node zero-trust gateway | |
| CN111240867A (en) | Information communication system and method | |
| CN116032494B (en) | Data interaction method, blockchain predictor, device and medium | |
| CN221531503U (en) | Cross-network service data exchange system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |