KR101639911B1 - Time period based framework system of steel process middleware - Google Patents

Abstract

The time frame based framework system of the steel process middleware according to an embodiment of the present invention includes an application programming interface (API) for allowing a task to request a middleware service, and an application programming interface A task processor including a task process manager for classifying and initializing, periodically executing, and deleting the processes for the task; And a middleware service handler for assigning the middleware service handler to the service agent executed in response to the middleware service request, and an agent for classifying the processes for the agent for long time and short time and for creating, initializing, periodically executing, and deleting the process for the agent And a service agent unit including a process manager.

Description

{TIME PERIOD BASED FRAMEWORK SYSTEM OF STEEL PROCESS MIDDLEWARE}

The present invention relates to a time period based framework system for steel process middleware.

The role of middleware in the steel process control work is to manage the tasks currently performed by performing tasks such as storing and referencing information related to communication or process control between tasks in response to a task request.

In general, steel process middleware has the feature that the creation and deletion of a large number of tasks are repeatedly performed, and when a new service is added, a new service function added to the middleware is added. Because of this feature, steel process middleware should be able to efficiently allocate task resources according to the dynamic situation, efficiently manage the resources of the system in which middleware is executed, and increase the overall performance of the executed system. In addition, steel process middleware should be easy to add new service functionality in terms of middleware developers.

Since the steel process is a continuous process due to its characteristics, and the required service, responsiveness, system platform, and distributed environment requirements required by each process are varied, the structure of the middleware system capable of accommodating the availability Modularity is required.

In addition, since the steel process middleware has to provide services to a large number of tasks at once, if all of the tasks are integrated into one process, the response time experienced by the user may be deteriorated.

Therefore, there is a need for a framework system for process development and maintenance of steel process middleware, which provides an environment in which common tasks can be processed independently and operated in separate time periods.

Korean Patent Publication No. 10-2010-0076840

In the process development and maintenance of steel process middleware, there is a need for a framework system to independently process common tasks and to provide an environment in which processes can operate in a time period.

The framework system according to an embodiment of the present invention classifies an application programming interface (API) for allowing a task to request a middleware service and a task process for a long time and a short time, A task unit including a task process manager responsible for initialization, periodic execution, and deletion; And a middleware service handler that the server assigns to the corresponding service agent in response to the middleware service request, and a process for classifying the processes for the agent for a long time and a short time and for creating, initializing, periodically executing, and deleting the processes for the agent And a service agent unit including an agent process manager.

The framework system according to the embodiment of the present invention can independently process the common operations and provide an environment in which processes can operate in a time period in the process development and maintenance of the steel process middleware.

1 is a block diagram illustrating a time period based framework system of a steel process middleware according to an embodiment of the present invention.
2 is a block diagram illustrating a process pool for a task in a time period based framework system of a steel process middleware according to an embodiment of the present invention.
3 is a block diagram illustrating an agent process pool and a resource recovery process pool in a time period based framework system of a steel process middleware according to an embodiment of the present invention.
FIG. 4 is a diagram for explaining independent processes of a time period-based framework system of a steel process middleware according to an embodiment of the present invention.

Hereinafter, preferred embodiments of the present invention will be described with reference to the accompanying drawings.

However, the embodiments of the present invention can be modified into various other forms, and the scope of the present invention is not limited to the embodiments described below. Further, the embodiments of the present invention are provided to more fully explain the present invention to those skilled in the art. It should be understood that the various embodiments of the present invention are different, but need not be mutually exclusive. For example, certain features, structures, and characteristics described herein may be implemented in other embodiments without departing from the spirit and scope of the invention in connection with an embodiment.

Also, to "include" an element means that it may include other elements, rather than excluding other elements, unless specifically stated otherwise.

The term '~' or '~ manager' used in the present embodiment means a hardware component such as a software or a field-programmable gate array (FPGA) or an ASIC, and '~' Perform roles. However, '~' or '~ manager' is not meant to be limited to software or hardware. The 'to' or 'manager' may be configured to reside on an addressable storage medium and may be configured to play one or more processors. Thus, by way of example, 'to' or 'to' may refer to components such as software components, object-oriented software components, class components and task components, and processes, Routines, routines, procedures, subroutines, segments of program code, drivers, firmware, microcode, circuitry, data, databases, data structures, tables, arrays, and variables. Or " administrators " may be combined with a smaller number of elements and with " parts " or " Can be further divided into '~ administrators'. In addition, components and 'to' or 'administrators' may be implemented to play one or more CPUs in a device or system.

1 is a block diagram illustrating a time period based framework system of a steel process middleware according to an embodiment of the present invention.

Referring to FIG. 1, a time period based framework system of the steel process middleware according to an embodiment of the present invention may include a task unit 100 and an agent unit 200.

The task unit 100 includes tasks 101-1 to 101-N, an application programming interface (API) 110, a task execution environment manager 120, and a task process manager 130 can do.

In addition, the task unit 100 may include a task process pool 140.

First, the tasks 101-1 to 101-N are application software including a steel process operation logic of a level 2 system for operating a steel process, and each of the tasks 101-1 to 101-N May call the application program interface 110 dedicated to executing the corresponding middleware service in order to receive the service of the agent unit 200. [ Here, the steel process level 2 system is a system that utilizes the tasks 101-1 to 101-N and the steel process middleware, and constitutes a steel process automation system together with steel process level 1 and 3 systems.

The application program interface 110 is a set of programming functions to be called upon the request of the tasks 101-1 to 101-N that are subjects of operation to perform logic using the middleware service, -1 to 101-N may request the middleware service to the agent unit 200 by calling the corresponding application program interface 110.

Accordingly, the tasks 101-1 to 101-N provide middleware services such as message transmission / reception related services, file related services, task registration / termination related services, communication related services, database function related services, and shared memory related services Can receive.

The task execution environment manager 120 is created at the time of execution of the application program interface 110 and may be responsible for initializing the execution environment of the task process manager 130 and creating / deleting the task process manager 130.

The task process manager 130 classifies tasks for a long time and a short time, and is responsible for initializing, periodically executing and deleting the tasks for the task.

In addition, the task process manager 130 includes a first time period based process manager 131, a first minimum management cycle calculator 132, a first process manager 133, and a second process manager 134 .

Here, the first time period based process manager 131 generates the task processes according to the task cycle environment setting 131 - 1, classifies the processes for the task according to the processing time, ) Or to the second process manager 134.

The first process manager 133 is responsible for managing tasks for processes with relatively short processing time, and can be responsible for initializing, periodically executing and deleting processes for each task. The second process manager 134 ) Manages tasks for processes with relatively long processing times, and can be responsible for initializing, periodically executing, and deleting processes for each task.

The first minimum management period calculator 134 analyzes the operation cycle of the task processes managed by the first process manager 133 and the second process manager 134 to check the check cycle in the first process manager 133 133 and the second process manager 134. [

Specifically, the first minimum management period calculator 134 may set the check period by analyzing the operation cycle of the task process to minimize the error between the operation start point and the check point in each operation cycle intended by the task process.

The task process pool 140 may include the processes for the task, and may have a structure capable of adding, deleting, and searching the processes for the task.

The task pool 140 may be interlocked with the first H / W hardware clock counter 150, the task logger 160, and the task information manager 170, Will be described later.

The agent unit 200 may include a middleware service handler 210, a service execution environment manager 220, and an agent process manager 230.

In addition, the agent unit 200 may include a process pool 240 for an agent, and a resource recovery process pool 280.

The middleware service handler 210 may be assigned to a service agent executed by the server in response to a middleware service request of the application programming interface 110 included in the task unit 100. [

The service execution environment manager 220 is created at the time of execution of the service agent and initializes the execution environment of the agent process manager 230 according to the service period environment setting document 220-1 and generates / It is possible to play the role of deletion.

The agent process manager 230 may classify the processes for the agent into a long time and a short time, and take charge of initializing, periodically executing and deleting the processes for the task.

In addition, the agent process manager 230 includes a second time period based process manager 231, a second minimum management cycle calculator 232, a third process manager 233, and a fourth process manager 234 .

Here, the second time period based process manager 231 creates the processes for the agent, classifies the processes for the task according to the processing time, and delegates to the third process manager 233 or the fourth process manager 234 can do.

The first process manager 233 is responsible for managing tasks for processes with relatively short processing times and can be responsible for initializing, periodically executing, and deleting processes for each task. The second process manager 234 ) Manages tasks for processes with relatively long processing times, and can be responsible for initializing, periodically executing, and deleting processes for each task.

The second minimum management period calculator 234 analyzes the operation cycle of the processes for the agent managed by the third process manager 233 and the fourth process manager 234 to check the confirmation period in the third process manager 233, and the fourth process manager 234.

Specifically, the second minimum management period calculator 234 may set an acknowledgment period by analyzing the operation cycle of the agent process to minimize the error between the operation start point and the check point in each operation cycle intended for the agent process.

The process pool 240 for the agent may include processes for the agent and may have a structure capable of adding, deleting, and searching the processes for the agent.

Here, the agent process pool 140 can be interworked with the kernel logger 250, the second H / W clock counter manager 260, the service resource recovery process manager 270, and the resource recovery process pool 280 Which will be described later with reference to FIG.

2 is a block diagram illustrating a process pool for a task in a time period based framework system of a steel process middleware according to an embodiment of the present invention.

Referring to FIG. 2, a task process pool 140 included in a time period-based framework system of a steel process middleware according to an embodiment of the present invention includes a time correction process 141, a heartbeat transmission process 142, And a task memory process 143.

The time correction process 141 may have a confirmation period in accordance with an instruction of the first process manager 133 so that a plurality of the tasks 101-1 to 101-N may perform distributed processing of time correction.

Specifically, the time correction process 141 calculates the H / W clock counter value obtained from the first H / W clock counter manager 150 that manages the H / W clock counter value provided by the CPU counter, The corrected time period value can be obtained by periodically correcting according to the correction period environment setting 141-1.

For example, a counter provided by a CPU of a device equipped with a task unit may have a time error of ms units in one hour due to an error with the CPU operating frequency, so that the time recognized by the operating system and middleware is a time error in ms Lt; / RTI >

The time correction process 141 allows the tasks 101-1 to 101-N to process the periodic correction for the time error in a distributed manner so that when one task is responsible for time correction, It is possible to prevent a problem that may occur in the case where a problem occurs.

The heartbeat transmission process 142 has an acknowledgment period in accordance with an instruction of the first process manager 133 and transmits a heartbeat signal to inform that each of the tasks 101-1 to 101- May be periodically transmitted to the middleware according to the heartbeat cycle environment setting 142-1.

To this end, the task information manager 170 may receive the information of the tasks 101-1 to 101-N from the application program interface 110 (FIG. 1) and transmit the information to the heartbeat transmission process 142.

The task memory process 143 has a check cycle in accordance with an instruction of the second process manager 134 and sends the task results of the tasks 101-1 to 101-N to the task memory cycle environment setting 143-1 And synchronize with the shared memory of the task unit 100 periodically.

That is, the task memory process 143 may periodically store the task results of the tasks 101-1 to 101-N in the shared memory of the task unit 100 to prevent data loss due to a system error.

In addition, the task process pool 140 may be interlocked with the task logger 160.

The task logger 160 may output the task logs of the tasks 101-1 to 101-N to the outside as corrected time values using the corrected time values.

As a result, chaos over time of the developer analyzing the job log can be minimized.

3 is a block diagram illustrating an agent process pool and a resource recovery process pool in a time period based framework system of a steel process middleware according to an embodiment of the present invention.

Referring to FIG. 3, the agent process pool 240 included in the time period based framework system of the steel process middleware according to an embodiment of the present invention includes an agent memory process 241, a file disk process 242, Recovery process 244, a time correction process 244, a resource recovery process 245, and an agent activation / recovery process 246.

The agent memory process 241 has an acknowledgment cycle in accordance with an instruction from the fourth process manager 234 and sends the operation result of the service agent corresponding to the tasks 101-1 to 101- It may be periodically synchronized with the shared memory of the agent unit 200 according to the environment setting document 241-1.

That is, the agent memory process 241 periodically transmits a task result of the service agent corresponding to the tasks 101-1 to 101-N (FIG. 1) to the agent unit 200 in order to prevent data loss due to a system error. In shared memory.

The file disk process 242 has a check cycle according to an instruction of the fourth process manager 234 and periodically writes a file for providing a data input / output service to the file disk Synchronization can be made.

Here, the file is a file used by the service agent in the steel process middleware to provide a data input / output service on a record basis. The service agent corresponding to the tasks 101-1 to 101-N transmits the requested data to the corresponding file And at a certain point of time, the data of the file can be stored in a file disk.

That is, the file disk process 242 periodically accesses the input / output file of the service agent corresponding to the tasks 101-1 to 101-N (FIG. 1) to prevent data loss due to a system error, May be periodically stored in the file disk of the agent unit 200 according to the file name 242-1.

The abnormal unlocking process 243 may have an acknowledgment cycle according to an instruction of the fourth process manager 234 and may determine that the file is unlocked if the file is locked for a predetermined number of times, and release the abnormal lock.

The locking of the file is a function provided to ensure data consistency because the task 101-1 to 101-N (FIG. 1) can simultaneously use a file for providing an input / output service.

The abnormal unlocking process 243 can solve the problem that the abnormal lock is determined and released to release the file from being unlocked when some tasks are abnormally terminated.

The time correction process 244 has a check cycle according to an instruction of the third process manager 233 and includes a CPU counter, a second H / W clock counter manager for managing the H / W clock counter value provided by an external device, 260 can be periodically corrected in accordance with the time correction period setting document 244-1 to obtain a corrected time value.

The resource recovery process 245 periodically confirms the abnormal termination of the task according to the resource recovery period environment setting document 245-1 with an acknowledgment cycle according to the instruction of the third process manager 233, The resource allocated to the task in question can be recovered.

To this end, the resource recovery process 245 uses the service resource recovery process registration information generated by the resource recovery process manager 270 according to the resource recovery setting document 270-1, The recovery process can be executed.

To this end, the resource recovery process manager 270 may generate service resource recovery processes, register them in the resource recovery process pool 280, and provide the service resource recovery process registration information to the resource recovery process 245.

Also, the service resource recovery process may be one of the service resource recovery processes 281, 282, 283, 284, and 285 included in the resource recovery process pool 280.

The agent activation / restoration process 246 has an acknowledgment cycle according to an instruction of the third process manager 233 and determines whether the service agents corresponding to the tasks 101-1 to 101-N (FIG. 1) It is periodically checked according to the startup recovery period setting document 246-1 and a new service agent can be created when it is determined that there is an abnormal service agent.

In addition, the process pool 240 for the agent can cooperate with the kernel logger 250.

The kernel logger 250 can output the service logs of the service agents corresponding to the tasks 101-1 to 101-N using the corrected time value to the outside as a corrected time value.

As a result, chaos over time of the developer analyzing the job log can be minimized.

The resource recovery process pool 280 may include service resource recovery processes and may have a structure capable of adding, deleting, and retrieving the service resource recovery processes.

The resource recovery process pool 280 included in the time period based framework system of the steel process middleware according to one embodiment of the present invention includes a communication adapter manager 281, a message waiting queue manager 282, a timer waiting queue manager 283 ), An inter-task synchronization queue manager 284, and a file manager 285.

The communication adapter manager 281 may create / delete a communication channel adapter for transmission / reception with a programmable logic controller (PLC) and an instrument, and may communicate with the communication channel adapter resources 281-1 through 282, 281-N) of the communication channel.

The message waiting queue manager 282 can create / delete a message-task waiting queue in which messages used for communication between the tasks 101-1 to 101-N are stored and managed, Task queue queuing resources among the message-task queuing resources 282-1 through 282-N according to an instruction.

The timer message waiting queue manager 283 can generate / delete a timer-task waiting queue in which a timer event waiting to be received by the corresponding task among the tasks 101-1 to 101-N is stored and managed, Task waiting queue resources among the managed timer-task waiting queue resources 283-1 through 283-N managed according to the instruction of the process 245. [

The task-to-task synchronization queue manager 284 determines whether or not the corresponding task among the synchronization-task waiting queues 284-1 to 284-N to recover synchronization resources to be acquired by the corresponding task among the tasks 101-1 to 101- Synchronization - Task Waiting Queue resources can be reclaimed and synchronization resources can be transferred to the next task.

The file manager 285 determines whether or not the corresponding one of the file-task waiting queues 285-1 through 285-N to recover the resource for the file lock that the corresponding task is to acquire from among the tasks 101-1 through 101- You can transfer the resources for file locking to the next-in-time task by retrieving the file-to-task queue resources.

FIG. 4 is a diagram for explaining independent processes of a time period-based framework system of a steel process middleware according to an embodiment of the present invention.

4, the task start 411 and the application program interface 412 operate as the first process 410, but the heartbeat transmission process 421 and the task memory process 431, which require a common task, 2 < / RTI > process 420 and the third process 430, respectively.

Accordingly, the time-based framework system of the steel process middleware according to an embodiment of the present invention provides an environment in which processings of common tasks can be independently processed and developed in a separate time period in process development and maintenance .

In addition, provision of an environment in which a process can operate in a time period can solve the phenomenon of response time degradation that may occur during provision of a middleware service

In addition, the development time can be shortened by using an independent process for the common work provided by the framework system, and maintenance can be ensured easily.

It is to be understood that both the foregoing general description and the following detailed description are exemplary and explanatory and are not intended to limit the invention to the particular forms disclosed. It will be understood by those skilled in the art that various changes in form and details may be made therein without departing from the spirit and scope of the invention as defined by the appended claims.

100: Task part
110: Application Interface
120: Task execution environment manager
130: Task Process Manager
140: Process pool for tasks
200: Agent section
210: Middleware service handler
220: Service execution environment manager
230: Agent Process Manager
240: Process Pool for Agent
280: Resource recovery process pool

Claims (11)

An application programming interface (API) for allowing a task to request a middleware service, and processes for tasks are classified into a long time and a short time according to processing time, and according to this classification, A task processor including a task process manager responsible for execution, deletion, and deletion; And
A middleware service handler allocated to a service agent executed in response to the middleware service request, and agents for processes for a long time and a short time according to processing time, and generates, initializes, periodically A service agent unit including an agent process manager responsible for executing,
.
The method of claim 1, wherein the task process manager
A first time period based process manager for creating the tasks for the task, and classifying the tasks according to the processing time and delegating them to the first process manager or the second process manager;
And a first minimum management cycle calculator for analyzing the operation cycle of the task processes and instructing the first process manager and the second process manager a confirmation cycle,
.
The method of claim 1, wherein the agent process manager
A second time period based process manager for creating the processes for the agent, classifying the processes for the processing time, and delegating the processes to the third process manager or the fourth process manager; And
A second minimum management cycle calculator for analyzing the operation cycle of the processes for the agent and instructing the third process manager and the fourth process manager of a confirmation cycle;
.
2. The apparatus of claim 1, wherein the task portion
A process pool for a task including the task processes and having a structure capable of adding,
. ≪ / RTI >
5. The method of claim 4, wherein the task process pool
A framework system comprising a time correction process for causing a plurality of tasks to distribute correction of time.
5. The method of claim 4, wherein the task process pool
And a heartbeat transmission process for periodically notifying middleware of a normal operation of the task.
5. The method of claim 4, wherein the task process pool
And a task memory process for synchronizing a task result of the task with a shared memory of the task unit.
The method of claim 1, wherein the service agent unit
A process pool for the agent including the processes for the agent and having a structure capable of adding, deleting, and searching the processes for the agent
. ≪ / RTI >
9. The method of claim 8,
And an agent memory process for synchronizing the operation result of the service agent with the shared memory of the service agent unit.
9. The method of claim 8,
And an abnormal unlocking process for determining that the file is unlocked when the lock of the file is maintained for a predetermined number of check cycles and releasing it.
9. The method of claim 8,
And a resource collection process for periodically confirming an abnormal end of the task to recall resources allocated to a task in which an event of abnormal end occurs.

Images