[go: up one dir, main page]

CN108140008A - Steel handles the Event Service method and frame system of middleware - Google Patents

Steel handles the Event Service method and frame system of middleware Download PDF

Info

Publication number
CN108140008A
CN108140008A CN201680062015.8A CN201680062015A CN108140008A CN 108140008 A CN108140008 A CN 108140008A CN 201680062015 A CN201680062015 A CN 201680062015A CN 108140008 A CN108140008 A CN 108140008A
Authority
CN
China
Prior art keywords
event
subscription
service
task
information
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.)
Granted
Application number
CN201680062015.8A
Other languages
Chinese (zh)
Other versions
CN108140008B (en
Inventor
金度薰
朴永福
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Posco Holdings Co ltd
Posco Holdings Inc
Original Assignee
Posco Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Posco Co Ltd filed Critical Posco Co Ltd
Priority claimed from PCT/KR2016/011586 external-priority patent/WO2017069468A1/en
Publication of CN108140008A publication Critical patent/CN108140008A/en
Application granted granted Critical
Publication of CN108140008B publication Critical patent/CN108140008B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F15/00Digital computers in general; Data processing equipment in general
    • G06F15/16Combinations of two or more digital computers each having at least an arithmetic unit, a program unit and a register, e.g. for a simultaneous processing of several programs
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F15/00Digital computers in general; Data processing equipment in general
    • G06F15/76Architectures of general purpose stored program computers
    • G06F15/82Architectures of general purpose stored program computers data or demand driven
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/48Program initiating; Program switching, e.g. by interrupt
    • G06F9/4806Task transfer initiation or dispatching
    • G06F9/4843Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
    • G06F9/4881Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46Multiprogramming arrangements
    • G06F9/54Interprogram communication
    • G06F9/542Event management; Broadcasting; Multicasting; Notifications
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06QINFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q50/00Information and communication technology [ICT] specially adapted for implementation of business processes of specific business sectors, e.g. utilities or tourism
    • G06Q50/04Manufacturing
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02PCLIMATE CHANGE MITIGATION TECHNOLOGIES IN THE PRODUCTION OR PROCESSING OF GOODS
    • Y02P90/00Enabling technologies with a potential contribution to greenhouse gas [GHG] emissions mitigation
    • Y02P90/30Computing systems specially adapted for manufacturing

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Software Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • Computer Hardware Design (AREA)
  • Business, Economics & Management (AREA)
  • Economics (AREA)
  • Health & Medical Sciences (AREA)
  • Manufacturing & Machinery (AREA)
  • General Health & Medical Sciences (AREA)
  • Human Resources & Organizations (AREA)
  • Marketing (AREA)
  • Primary Health Care (AREA)
  • Strategic Management (AREA)
  • Tourism & Hospitality (AREA)
  • General Business, Economics & Management (AREA)
  • Multimedia (AREA)
  • Stored Programmes (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

The Event Service method of steel processing middleware according to the embodiment of the present invention is the Event Service method of the steel processing middleware by mission application software and Events Frame execution, the mission application software includes allowing Application Programming Interface (API) library of task requests Event Service, wherein, this method includes the following steps:Service processor responds Event Service request;Information is defined based on the event for defining event id and size of data to generate event;And if information and the information match of subscription event that pulls subscription about the event generated, the event generated is sent to the subscription task for being mapped to subscription event according to the mapping data of task manager as subscription event.

Description

钢处理中间件的事件服务方法和框架系统Event Service Method and Framework System of Steel Processing Middleware

技术领域technical field

本公开内容涉及钢处理中间件的事件服务方法和框架系统。The disclosure relates to an event service method and a framework system of steel processing middleware.

背景技术Background technique

中间件在钢处理控制中的功能是响应于由任务发出的请求来执行诸如存储和参考关于任务之间的通信的信息或关于处理控制的信息的处理并且管理当前正在运行的任务。The function of middleware in steel processing control is to perform processing such as storing and referring to information on communication between tasks or information on processing control in response to requests issued by tasks and to manage currently running tasks.

这样的任务可以是应用软件,其独立排他地负责分段的工厂控制功能,以提高系统的性能和稳定性。Such tasks may be application software that is solely and exclusively responsible for segmented plant control functions to improve system performance and stability.

另外,为了协作,任务可以指示中间件创建事件并且可以接收由另一任务创建的事件。Additionally, for collaboration, a task can instruct middleware to create events and can receive events created by another task.

通过以一对一的通信方式发送和接收消息来处理相关技术的钢处理中间件的事件服务,因此,当任务必须向多个任务发送事件时,可能需要延长的处理时间。The event service of the steel processing middleware of the related art is processed by sending and receiving messages in a one-to-one communication manner, therefore, when a task has to send an event to a plurality of tasks, an extended processing time may be required.

此外,钢处理中间件反复地创建/删除多项任务,并且在添加新的协作系统时,必须将新的协作系统的事件服务功能添加到钢处理中间件中。In addition, the steel processing middleware repeatedly creates/deletes multiple tasks, and when a new collaboration system is added, the event service function of the new collaboration system must be added to the steel processing middleware.

因此,需要框架系统为钢处理中间件的开发者提供用于开发事件服务方法和处理并且根据新的协作系统进行维护的环境。Therefore, there is a need for a framework system to provide developers of steel processing middleware with an environment for developing event service methods and processing and maintaining them according to new collaboration systems.

发明内容Contents of the invention

技术问题technical problem

本公开内容的一方面可以提供一种框架系统,该框架系统被配置成提高钢处理中间件的事件服务的处理速度并且优化处理开发和管理环境。An aspect of the present disclosure may provide a framework system configured to increase processing speed of event services of steel processing middleware and optimize processing development and management environments.

另外,当通过发送和接收消息来处理事件服务时,可以保持兼容性。Additionally, compatibility is maintained when event services are handled by sending and receiving messages.

技术方案Technical solutions

根据本公开内容的一方面,可以提供由任务应用软件和事件框架执行的钢处理中间件的事件服务方法,该任务应用软件包括允许任务发出事件服务请求的应用编程接口(API)库。事件服务方法可以包括:服务处理器对事件服务请求做出响应;基于定义事件ID和数据大小的事件定义信息来创建事件;以及如果关于所创建的事件的信息与关于所请求的订阅事件的信息一致,则根据事件管理器的映射数据将所创建的事件作为所请求的订阅事件发送至映射到所请求的订阅事件的订阅任务。According to an aspect of the present disclosure, an event servicing method of steel processing middleware executed by a task application software including an application programming interface (API) library allowing tasks to issue event service requests and an event framework may be provided. The event service method may include: a service handler responding to the event service request; creating an event based on event definition information defining an event ID and a data size; and if the information about the created event is consistent with the information about the requested subscription event If they are consistent, the created event is sent as the requested subscription event to the subscription task mapped to the requested subscription event according to the mapping data of the event manager.

根据本公开内容的另一方面,可以提供一种钢处理中间件的事件服务框架系统,该事件服务框架系统由至少一个处理器实现并且包括任务应用软件和事件框架,该任务应用软件包括允许任务请求包括事件订阅的事件服务的API库。事件框架可以包括:服务处理器,其被配置成对事件服务请求做出响应;事件管理器,其被配置成管理定义事件ID和数据大小的事件定义信息并且管理其中所请求的订阅事件被映射到对应的订阅任务的映射数据;以及事件调度接口,其中,如果关于由服务处理器基于事件定义信息创建的事件的信息与关于所请求的订阅事件的信息一致,则事件调度接口可以将所创建的事件作为所请求的订阅事件发送至订阅任务。According to another aspect of the present disclosure, an event service framework system of steel processing middleware may be provided, the event service framework system is implemented by at least one processor and includes task application software and an event framework, and the task application software includes tasks that allow tasks API library for requesting event services including event subscriptions. The event framework may include: a service handler configured to respond to event service requests; an event manager configured to manage event definition information defining event IDs and data sizes and to manage events in which requested subscription events are mapped mapping data to corresponding subscription tasks; and an event dispatch interface, wherein if the information about the event created by the service processor based on the event definition information is consistent with the information about the requested subscription event, the event dispatch interface can send the created The events for are sent to the subscription task as requested subscription events.

有益效果Beneficial effect

根据本公开内容的实施方式,事件服务方法和框架系统可以提高钢处理中间件的事件服务的处理速度并且提供高效的处理开发和管理环境。According to the embodiments of the present disclosure, the event service method and the framework system can improve the processing speed of the event service of the steel processing middleware and provide an efficient processing development and management environment.

附图说明Description of drawings

图1(a)是示出处理钢处理中间件的事件服务的示例的示意图。FIG. 1( a ) is a schematic diagram showing an example of an event service of the processing steel processing middleware.

图1(b)是示出根据本公开内容的实施方式的使用钢处理中间件的事件服务框架系统的事件服务处理过程的示意图。FIG. 1( b ) is a schematic diagram illustrating an event service processing process of an event service framework system using steel processing middleware according to an embodiment of the present disclosure.

图2是示出根据本公开内容的实施方式的钢处理中间件的事件服务框架系统的框图。FIG. 2 is a block diagram illustrating an event service framework system of a steel processing middleware according to an embodiment of the present disclosure.

图3是示出根据本公开内容的实施方式的钢处理中间件的事件服务框架系统的应用编程接口(API)库的表格。3 is a table illustrating an application programming interface (API) library of the event service framework system of steel processing middleware according to an embodiment of the present disclosure.

图4是具体示出根据本公开内容的实施方式的在钢处理中间件的事件服务框架系统中包括的事件框架的框图。FIG. 4 is a block diagram specifically illustrating an event framework included in an event service framework system of steel processing middleware according to an embodiment of the present disclosure.

图5是示出根据本公开内容的另一实施方式的钢处理中间件的事件服务框架系统的框图。FIG. 5 is a block diagram illustrating an event service framework system of steel processing middleware according to another embodiment of the present disclosure.

图6是示出由图5所示的框架系统处理的存储器互通服务的框图。FIG. 6 is a block diagram illustrating memory interworking services handled by the framework system shown in FIG. 5 .

图7是示出图6中示出的存储器互通服务的流程图。FIG. 7 is a flowchart illustrating the memory intercommunication service illustrated in FIG. 6 .

图8是示出根据本公开内容的实施方式的用于在事件服务框架系统中处理事件创建请求的处理的时序图。FIG. 8 is a sequence diagram illustrating a process for handling an event creation request in an event service framework system according to an embodiment of the present disclosure.

图9是示出根据本公开内容的实施方式的用于在事件服务框架系统中处理事件接收请求的处理的时序图。FIG. 9 is a sequence diagram illustrating a process for processing an event reception request in an event service framework system according to an embodiment of the present disclosure.

具体实施方式Detailed ways

现在将参照附图详细描述本公开内容的示例性实施方式。Exemplary embodiments of the present disclosure will now be described in detail with reference to the accompanying drawings.

然而,本公开内容可以以许多不同形式进行例示,并且本公开内容不应被解释为限于本文中阐述的具体实施方式。This disclosure may, however, be illustrated in many different forms and should not be construed as limited to the specific embodiments set forth herein.

将进一步理解的是,本文中使用的术语“包括”和/或“包含”表明存在所陈述的特征或组件,但不排除存在或者添加了一个或更多个其他特征或组件。It will be further understood that the terms "comprising" and/or "comprising" as used herein indicate the presence of stated features or components, but do not exclude the presence or addition of one or more other features or components.

在以下实施方式中,后缀“-er”或“-or”用于指示执行某些任务的软件或硬件组件例如现场可编程门阵列(FPGA)或专用集成电路(ASIC)。然而,后缀“-er”或者“-or”不限于软件或硬件组件。这种具有后缀“-er”或“-or”的组件可以被配置成驻留在可寻址存储介质上或者被配置成执行一个或更多个处理器。因此,这种具有后缀“-er”或“-or”的组件的示例可以包括软件组件、面向对象的软件组件、诸如类组件和任务组件的组件、处理、函数、属性、过程、子例程、程序代码段、驱动器、固件、微代码、电路系统、数据、数据库、数据结构、表格、数组和变量。在具有后缀“-er”或“-or”的组件以及其他组件中提供的功能可以组合成更少的组件或者进一步划分成附加的组件。另外,具有后缀“-er”或“-or”的组件以及其他组件可以被实现为使得这些组件可以执行设备或系统中的一个或更多个CPU。In the following embodiments, the suffix "-er" or "-or" is used to indicate a software or hardware component such as a Field Programmable Gate Array (FPGA) or an Application Specific Integrated Circuit (ASIC) that performs certain tasks. However, the suffix "-er" or "-or" is not limited to software or hardware components. Such components with the suffix "-er" or "-or" may be configured to reside on the addressable storage medium or configured to execute on one or more processors. Thus, examples of such components having the suffix "-er" or "-or" may include software components, object-oriented software components, components such as class components and task components, processes, functions, properties, procedures, subroutines , program code segments, drivers, firmware, microcode, circuitry, data, databases, data structures, tables, arrays, and variables. Functionality provided in components with suffix "-er" or "-or" as well as other components may be combined into fewer components or further divided into additional components. In addition, components having a suffix of "-er" or "-or" and other components may be implemented such that the components may execute one or more CPUs in a device or system.

图1(a)是示出钢处理中间件的事件服务处理过程的示例的示意图,图1(b)是示出根据本公开内容的实施方式的使用钢处理中间件的事件服务框架系统的事件服务处理过程的示意图。FIG. 1( a ) is a schematic diagram showing an example of an event service processing process of a steel processing middleware, and FIG. 1( b ) is an event showing an event service framework system using a steel processing middleware according to an embodiment of the present disclosure. Schematic diagram of service processing.

参照图1(a),钢处理中间件可以通过一对一的通信方法来处理事件服务。Referring to Figure 1(a), steel processing middleware can process event services through a one-to-one communication method.

详细地,当任务(A)将事件发送至多个任务B1至BN时,中间件响应于来自任务A的事件创建指令而创建事件并且将事件发送至任务B1,然后响应于来自任务A的事件创建指令再次创建事件并且将事件发送至任务B2。可以重复该处理,直到中间件将事件发送至任务BN为止。In detail, when a task (A) sends an event to a plurality of tasks B1 to BN, the middleware creates an event in response to an event creation instruction from task A and sends the event to task B1, and then creates an event in response to the event from task A The instruction creates the event again and sends the event to task B2. This process can be repeated until the middleware sends the event to task BN.

相反地,参照1(b),在根据本公开内容的实施方式的使用钢处理中间件的事件服务框架系统的事件处理过程中,任务A仅一次生成事件创建指令,然后中间件可以批量处理对于任务A的所有调度工作。On the contrary, referring to 1(b), in the event processing process of the event service framework system using steel processing middleware according to the embodiment of the present disclosure, task A generates event creation instructions only once, and then the middleware can batch process for All scheduled jobs for Task A.

因此,采用本公开内容的实施方式的事件服务框架系统的钢处理中间件可以具有提高的事件服务处理速度。Therefore, steel processing middleware employing the event service framework system of the embodiments of the present disclosure may have improved event service processing speed.

图2是示出根据本公开内容的实施方式的钢处理中间件的事件服务框架系统的框图。FIG. 2 is a block diagram illustrating an event service framework system of a steel processing middleware according to an embodiment of the present disclosure.

参照图2,本实施方式的钢处理中间件可以包括任务应用软件10和事件框架20。任务应用软件10可以包括多个任务11至1N以及应用编程接口(API)库100。事件框架20可以包括多个服务处理器21至2N、事件管理器200和事件调度接口300。Referring to FIG. 2 , the steel processing middleware of this embodiment may include task application software 10 and event framework 20 . The task application software 10 may include a plurality of tasks 11 to 1N and an application programming interface (API) library 100 . The event framework 20 may include a plurality of service processors 21 to 2N, an event manager 200 and an event scheduling interface 300 .

另外,根据设计,事件框架20可以包括以下中的至少一个:已发送事件队列池400、事件服务监测器500、框架管理器600和存储设备30。In addition, according to the design, the event framework 20 may include at least one of the following: a sent event queue pool 400 , an event service monitor 500 , a framework manager 600 and a storage device 30 .

多个任务11至1N可以是包括用于操作钢处理的2级系统的钢处理操作逻辑的多个应用软件,并且任务11至1N中的每一个可以调用专用于事件框架20的事件服务的API以接收事件服务。此处,用于钢处理的2级系统利用任务11至1N、钢处理中间件,并且1级、2级和3级系统组成钢处理自动化系统。The plurality of tasks 11 to 1N may be a plurality of application software including steel processing operation logic for operating a level 2 system of steel processing, and each of the tasks 11 to 1N may call an API dedicated to an event service of the event framework 20 to receive event services. Here, the level 2 system for steel processing utilizes tasks 11 to 1N, steel processing middleware, and the level 1, 2 and 3 systems constitute the steel processing automation system.

用于钢处理的1级系统在连接到钢厂的生产处理的低级别处执行单元设备控制、顺序控制和PID控制。为此,用于钢处理的1级系统可以包括编程逻辑控制器(PLC)、分布式控制系统(DSC)、数字直接控制器(DDC)、传感器等。A level 1 system for steel processing performs unit equipment control, sequence control, and PID control at a low level connected to the production process of the steel plant. To this end, a Level 1 system for steel processing may include a Programmable Logic Controller (PLC), Distributed Control System (DSC), Digital Direct Controller (DDC), sensors, etc.

此外,用于钢处理的3级系统可以是用于合同/订单管理、生产/处理管理和质量设计的业务系统,并且可以包括企业资源计划(ERP)系统和制造执行系统(MES)。Furthermore, Level 3 systems for steel processing may be business systems for contract/order management, production/processing management, and quality design, and may include enterprise resource planning (ERP) systems and manufacturing execution systems (MES).

API库100是根据作为使用中间件服务来执行逻辑处理的主代理的任务的请求而被调用的一组编程函数,并且每个任务可以调用对应的API以向事件框架20请求包括事件服务的各种服务。The API library 100 is a set of programming functions that are called according to the request of the tasks that are the main agents that use the middleware service to perform logic processing, and each task can call the corresponding API to request the event framework 20 for each function including the event service. kind of service.

API库100可以包括API,任务可以通过API向事件框架20请求包括事件定义、事件订阅、事件订阅取消、事件创建、事件接收和事件定义删除的事件服务。稍后将参照图3根据实施方式描述API库100可以包括的特定API。The API library 100 may include an API through which a task may request event services from the event framework 20 including event definition, event subscription, event subscription cancellation, event creation, event reception, and event definition deletion. Specific APIs that the API library 100 may include will be described later according to an embodiment with reference to FIG. 3 .

响应于任务应用软件10的API的事件服务请求,可以分配多个服务处理器21至2N。A plurality of service processors 21 to 2N may be assigned in response to an event service request of the API of the task application software 10 .

事件管理器200可以管理事件定义信息并且可以管理关于请求的订阅事件和对应的订阅任务之间的映射的数据。本文中,表述“管理某事物”是指创建、删除和改变该事物。此处,事件定义信息包括事件标识(ID)以及关于可以从任务发送至用于处理事件服务的事件框架20(请参见图2)的变量数据的数据信息。此处,数据信息可以指示变量数据的大小。另外,事件管理器200可以响应于服务处理器21至2N的请求来提供事件定义信息和映射数据。The event manager 200 may manage event definition information and may manage data regarding mapping between requested subscription events and corresponding subscription tasks. Herein, the expression "manage something" refers to creating, deleting, and changing that thing. Here, the event definition information includes an event identification (ID) and data information on variable data that can be sent from a task to the event framework 20 (see FIG. 2 ) for processing the event service. Here, the data information may indicate the size of variable data. In addition, the event manager 200 may provide event definition information and mapping data in response to requests from the service processors 21 to 2N.

如果创建了订阅事件,则事件调度接口300可以根据映射数据将订阅事件发送至对应的订阅任务。If a subscription event is created, the event scheduling interface 300 can send the subscription event to a corresponding subscription task according to the mapping data.

已发送事件队列池400可以包括多个已发送事件队列,所述多个已发送事件队列等待直到订阅任务接收到由事件调度接口300发送的订阅事件为止。The sent event queue pool 400 may include a plurality of sent event queues that wait until a subscription task receives a subscription event sent by the event dispatch interface 300 .

事件服务监测器500可以监测事件管理器200、事件调度接口300和已发送事件队列池400,以将与订阅事件的状态有关的信息发送至任务应用软件10。The event service monitor 500 can monitor the event manager 200 , the event dispatch interface 300 and the sent event queue pool 400 to send information about the status of subscribed events to the task application software 10 .

当事件框架20工作时,首先创建框架管理器600,并且框架管理器600可以在初始化处理之后创建事件框架20的所有组件,并且当事件框架20停止工作时,框架管理器600可以收集分配给事件框架20的组件的资源。When the event framework 20 is working, the framework manager 600 is created first, and the framework manager 600 can create all components of the event framework 20 after initialization processing, and when the event framework 20 stops working, the framework manager 600 can collect the A resource for framework 20 components.

存储设备30可以存储设置数据列表31,该设置数据列表31是包含用于控制事件框架20的组件的处理的设置值的文件数据。另外,设置数据列表31可以包括包含关于订阅事件和订阅任务的事件设置值和映射数据的事件系统信息。The storage device 30 can store a setting data list 31 which is file data containing setting values for controlling processing of components of the event framework 20 . In addition, the setting data list 31 may include event system information including event setting values and mapping data about subscribed events and subscribed tasks.

后面将参照图4描述事件管理器200、事件调度接口300和已发送事件队列池400的具体示例。Specific examples of the event manager 200 , the event scheduling interface 300 and the sent event queue pool 400 will be described later with reference to FIG. 4 .

图3是示出根据本公开内容的实施方式的钢处理中间件的事件服务框架系统的API库的表格。FIG. 3 is a table showing an API library of an event service framework system of steel processing middleware according to an embodiment of the present disclosure.

参照图3,API库可以包括可以请求事件服务的API,所述事件服务包括:事件定义、事件订阅、事件订阅取消、事件创建、事件接收、事件定义删除、已发送但尚未接收的事件的特定于任务的数目、已发送但尚未接收的事件的特定于任务的列表、订阅事件的特定于任务的列表、订阅任务的特定于事件的列表、已发送事件队列的初始化、事件设置的添加、事件设置的删除、事件订阅任务设置的添加、事件订阅任务设置的删除以及事件系统设置。Referring to FIG. 3 , the API library may include APIs that can request event services, including: event definition, event subscription, event subscription cancellation, event creation, event reception, event definition deletion, specific events for events that have been sent but not yet received number of tasks, task-specific list of events sent but not yet received, task-specific list of subscribed events, event-specific list of subscribed tasks, initialization of sent event queue, addition of event settings, event Deletion of settings, addition of event subscription task settings, deletion of event subscription task settings, and event system settings.

在下文中,将逐一描述API的功能。事件定义可以命令事件管理器(请参见图2中的附图标记200)在用于确定任务之间的协作的事件框架(请参见图2中的附图标记20)中创建事件定义信息。此处,事件定义信息包括事件ID以及关于可以从任务发送至用于处理事件服务的事件框架(请参见图2中的附图标记20)的变量数据的数据信息。此处,数据信息可以指示变量数据的大小。Hereinafter, the functions of the API will be described one by one. The event definition may instruct the event manager (see reference numeral 200 in FIG. 2 ) to create event definition information in an event frame (see reference numeral 20 in FIG. 2 ) for determining collaboration between tasks. Here, the event definition information includes the event ID and data information on variable data that can be sent from the task to the event frame (see reference numeral 20 in FIG. 2 ) for processing the event service. Here, the data information may indicate the size of variable data.

事件订阅可以命令事件框架创建关于订阅任务所请求的订阅事件的信息。如果关于创建的事件的信息与关于订阅事件的信息一致,则事件框架可以将订阅事件发送至订阅任务。Event subscriptions can instruct the event framework to create information about the subscription events requested by the subscription task. If the information about the created event matches the information about the subscription event, the event framework can send the subscription event to the subscription task.

事件订阅取消可以命令事件框架取消对于执行逻辑处理的任务不是必需的订阅事件的订阅。Event Subscription Cancellation can instruct the event framework to cancel subscriptions to subscription events that are not necessary for the task to perform logic processing.

事件创建可以命令事件框架基于事件定义信息来创建事件,并且将事件ID和相关的变量数据发送至订阅任务。事件创建使用由事件定义在事件框架中定义的事件定义信息。也就是说,由事件创建所创建的每个事件与事件框架中创建的多条事件定义信息中的一条事件定义信息一致,从而具有事件ID和对应的数据大小。Event creation can instruct the event framework to create an event based on the event definition information, and send the event ID and related variable data to the subscribing task. Event creation uses the event definition information defined in the event frame by the event definition. That is to say, each event created by the event creation is consistent with one piece of event definition information among the multiple pieces of event definition information created in the event frame, and thus has an event ID and a corresponding data size.

事件接收可以向事件框架通知订阅任务处于用于接收订阅事件的待命模式。Event receiving may notify the event framework that a subscribing task is in standby mode for receiving subscription events.

事件定义删除可以命令事件框架删除事件框架管理的订阅事件信息和事件定义信息。Event definition deletion can instruct the event framework to delete the subscription event information and event definition information managed by the event framework.

已发送但尚未接收的事件的特定于任务的数目可以请求事件框架针对订阅任务发送存储在已发送事件队列池(请参见图2中的附图标记400)中的事件的数目。Task-specific number of events sent but not yet received The event framework may be requested to send the number of events stored in the sent event queue pool (see reference numeral 400 in FIG. 2 ) for subscribing tasks.

已发送但尚未接收的事件的特定于任务的列表可以请求事件框架针对订阅任务发送关于存储在已发送事件队列池中的事件的信息。A task-specific list of events that have been sent but not yet received can request that the event framework send information about events stored in the sent event queue pool for subscribing tasks.

订阅事件的特定于任务的列表可以请求事件框架发送关于订阅任务已经确定要订阅的订阅事件的信息。A task-specific list of subscription events may request the event framework to send information about subscription events that a subscription task has determined to subscribe to.

订阅任务的特定于事件的列表可以请求事件框架发送关于与订阅事件对应的订阅任务的信息。An event-specific list of subscription tasks may request the event framework to send information about the subscription tasks corresponding to the subscription events.

已发送事件队列的初始化可以命令事件框架通过删除已发送事件队列池的所有已发送事件队列来初始化已发送事件队列池。Initialization of the sent event queue may instruct the event framework to initialize the sent event queue pool by deleting all sent event queues for the sent event queue pool.

事件设置的添加和事件设置的删除可以命令事件框架向存储设备(请参见图2中的附图标记30)中存储的设置数据列表(请参见图2中的附图标记31)中添加事件设置值或者从所述设置数据列表中删除事件设置值。The addition of event settings and the deletion of event settings can command the event framework to add event settings to the setting data list (see reference number 31 in FIG. 2 ) stored in the storage device (see reference number 30 in FIG. 2 ). value or delete the event setting value from the setting data list.

事件订阅任务设置的添加和事件订阅任务设置的删除可以命令事件框架修改关于在存储设备中存储的设置数据列表中包括的订阅事件和订阅任务的映射数据。Addition of event subscription task settings and deletion of event subscription task settings may instruct the event framework to modify mapping data on subscription events and subscription tasks included in the setting data list stored in the storage device.

事件系统设置可以命令事件框架的事件管理器(请参见图2中的附图标记200)重建事件的系统。The event system sets the system that can instruct the event manager (see reference numeral 200 in FIG. 2 ) of the event framework to rebuild events.

包括这些API的API库可以为钢处理中间件的开发者提供高效的处理开发和维护环境。An API library including these APIs can provide an efficient processing development and maintenance environment for developers of steel processing middleware.

图4是具体示出根据本公开内容的实施方式的在钢处理中间件的事件服务框架系统中包括的事件框架的框图。FIG. 4 is a block diagram specifically illustrating an event framework included in an event service framework system of steel processing middleware according to an embodiment of the present disclosure.

参照图4,示出了根据本公开内容的实施方式的在钢处理中间件的事件服务框架系统中包括的事件管理器200、事件调度接口300和已发送事件队列池400的具体示例。Referring to FIG. 4 , it shows a specific example of an event manager 200 , an event scheduling interface 300 and a sent event queue pool 400 included in the steel processing middleware event service framework system according to an embodiment of the present disclosure.

事件管理器200可以包括事件系统访问调整器210、事件设置数据管理器220、事件定义管理器230、订阅任务-事件映射器240和事件-订阅任务映射器250。The event manager 200 may include an event system access regulator 210 , an event setting data manager 220 , an event definition manager 230 , a subscription task-event mapper 240 and an event-subscription task mapper 250 .

事件调度接口300可以包括临时待命队列管理器310、多个临时待命队列访问调整器311、312和313、多个临时待命队列321、322和323、事件发送器管理器330、多个事件发送器331、332和333以及临时待命队列选择器340。The event scheduling interface 300 may include a temporary standby queue manager 310, a plurality of temporary standby queue access regulators 311, 312 and 313, a plurality of temporary standby queues 321, 322 and 323, an event sender manager 330, a plurality of event sender 331, 332 and 333 and temporary standby queue selector 340.

已发送事件队列池400可以包括多个已发送事件队列管理器410、420和430、多个已发送事件队列访问调整器411、421和431以及多个已发送事件队列412、422和432。The sent event queue pool 400 may include a plurality of sent event queue managers 410 , 420 and 430 , a plurality of sent event queue access regulators 411 , 421 and 431 , and a plurality of sent event queues 412 , 422 and 432 .

在图4中,每组多个组件被示出为具有三个组件。然而,这是用于描述的示例,而不应被认为出于限制的目的。例如,组件的数目可以随着事件框架20的事件服务处理过程而变化。每个组中的多个组件可以执行相同的功能,并且因此可以在假设每个组中存在单个组件的情况下进行描述。In FIG. 4, each set of multiple components is shown as having three components. However, this is an example for description and should not be considered for purposes of limitation. For example, the number of components may vary with event framework 20's event service processing. Multiple components within each group may perform the same function, and thus may be described assuming the presence of a single component within each group.

为了保证事件定义信息和其中订阅事件被映射到对应的订阅任务的映射数据的完整性,当服务处理器21至2N添加/删除/搜索事件定义信息和映射数据时,事件系统访问调整器210可以授权服务处理器21至2N访问事件定义信息和映射数据。In order to ensure the integrity of event definition information and mapping data in which subscription events are mapped to corresponding subscription tasks, when service processors 21 to 2N add/delete/search event definition information and mapping data, the event system access regulator 210 may The service processors 21 to 2N are authorized to access event definition information and mapping data.

事件设置数据管理器220可以获取或者修改关于订阅事件和订阅任务的事件设置值和映射数据。The event setting data manager 220 may obtain or modify event setting values and mapping data about subscribed events and subscribed tasks.

事件定义管理器230可以通过接收由事件设置数据管理器220获取的事件设置值来创建事件定义信息,或者可以响应于来自任务应用软件10的API的请求来创建或者删除事件定义信息。The event definition manager 230 may create event definition information by receiving event setting values acquired by the event setting data manager 220 , or may create or delete event definition information in response to a request from the API of the task application software 10 .

订阅任务-事件映射器240可以管理其中任务数据具有优先级的映射数据。也就是说,订阅任务-事件映射器240可以管理映射数据,使得还可以搜索映射到要搜索的订阅任务的订阅事件。The subscription task-event mapper 240 may manage map data in which task data has priority. That is, the subscription task-event mapper 240 can manage mapping data such that subscription events mapped to the subscription task to be searched can also be searched.

事件-订阅任务映射器250可以管理其中事件数据具有优先级的映射数据。也就是说,事件-订阅任务映射器250可以管理映射数据,使得还可以搜索映射到要搜索的订阅事件的订阅任务。The event-subscription task mapper 250 may manage mapping data in which event data has priority. That is, the event-subscription task mapper 250 can manage mapping data such that a subscription task mapped to a subscription event to be searched can also be searched.

临时待命队列管理器310可以创建/删除临时存储事件的临时待命队列321,并且可以管理关于临时待命队列321的状态的信息。The temporary standby queue manager 310 may create/delete a temporary standby queue 321 temporarily storing events, and may manage information on a state of the temporary standby queue 321 .

临时待命队列访问调整器311可以调整访问权限以防止临时待命队列管理器310和事件发送器331同时访问临时待命队列321,并且因此维护存储在临时待命队列321中的订阅事件的完整性。Temporary standby queue access regulator 311 may adjust access rights to prevent temporary standby queue manager 310 and event sender 331 from concurrently accessing temporary standby queue 321 , and thus maintain the integrity of subscribed events stored in temporary standby queue 321 .

临时待命队列321可以被创建为对应于事件发送器331并且可以临时存储订阅事件。事件发送器331可以将订阅事件发送至对应的订阅任务。A temporary standby queue 321 may be created corresponding to the event sender 331 and may temporarily store subscription events. The event sender 331 can send the subscription event to the corresponding subscription task.

事件发送器管理器330可以创建/删除事件发送器331并且可以管理关于事件发送器331的状态的信息。The event transmitter manager 330 may create/delete event transmitters 331 and may manage information on the status of the event transmitters 331 .

临时待命队列选择器340从临时待命队列管理器310获取关于临时待命队列321的状态的信息,并且将事件发送器331确定为发送订阅事件的事件发送器。之后,服务处理器21至2N可以将订阅事件存储在临时待命队列321中,并且然后可以请求事件发送器管理器330执行发送处理。The temporary standby queue selector 340 acquires information on the status of the temporary standby queue 321 from the temporary standby queue manager 310, and determines the event sender 331 as the event sender that sends the subscription event. Afterwards, the service processors 21 to 2N can store the subscription event in the temporary standby queue 321, and then can request the event transmitter manager 330 to perform transmission processing.

已发送事件队列管理器410可以管理关于已发送事件队列412的状态的信息。已发送事件队列访问调整器411可以调整访问权限以防止从服务处理器和事件发送器301同时访问,并且因此维护存储在已发送事件队列412中的订阅事件的完整性。Sent event queue manager 410 may manage information about the status of sent event queue 412 . Sent event queue access regulator 411 may regulate access rights to prevent simultaneous access from service processors and event senders 301 , and thus maintain the integrity of subscription events stored in sent event queue 412 .

已发送事件队列412可以存储由事件调度接口300发送的订阅事件,使得订阅事件可以等待,直到订阅任务接收订阅事件为止。The sent event queue 412 can store the subscription events sent by the event scheduling interface 300, so that the subscription events can wait until the subscription task receives the subscription events.

另外,这样的订阅事件可以是包括事件ID和变量数据的变量事件消息40。Additionally, such subscribed events may be variable event messages 40 including event IDs and variable data.

图5是示出根据本公开内容的另一实施方式的钢处理中间件的事件服务框架系统的框图。FIG. 5 is a block diagram illustrating an event service framework system of steel processing middleware according to another embodiment of the present disclosure.

当与图2所示的框架系统相比时,图5所示的框架系统还包括用于发送和接收消息的API、互通接口700、消息管理器800和存储器管理器900。When compared with the framework system shown in FIG. 2 , the framework system shown in FIG. 5 also includes an API for sending and receiving messages, an interworking interface 700 , a message manager 800 and a memory manager 900 .

框架系统的其他结构可以从参照图2提供的框架系统的描述中理解,因此将省略对其重复的描述。Other structures of the frame system can be understood from the description of the frame system provided with reference to FIG. 2 , and thus repeated descriptions thereof will be omitted.

如图5所示,API库100可以具有下述API,所述API具有消息发送功能和消息接收功能,使得任务可以向其他对象(例如,事件框架20)发送消息并且可以从其他对象接收消息。As shown in FIG. 5 , the API library 100 may have an API having a message sending function and a message receiving function so that tasks can send messages to and receive messages from other objects (eg, the event frame 20 ).

另外,可以响应于任务应用软件10的API的事件服务请求来分配多个服务处理器21至2N。此处,可以通过诸如事件订阅或创建之类的API或者通过消息发送或接收来进行事件服务请求。In addition, a plurality of service processors 21 to 2N may be allocated in response to an event service request of the API of the task application software 10 . Here, event service requests can be made through APIs such as event subscription or creation, or through message sending or receiving.

详细地,当从任务11至1N接收到消息时,服务处理器21至2N对消息做出响应,然后事件框架20可以创建事件并且发送订阅事件。In detail, when a message is received from a task 11 to 1N, the service processor 21 to 2N responds to the message, and then the event framework 20 can create an event and send a subscription event.

另外,事件调度接口300可以通过将订阅事件转换成消息并且将该消息发送至订阅任务来发送订阅事件。In addition, the event dispatch interface 300 can send subscription events by converting the subscription events into messages and sending the messages to the subscribing tasks.

也就是说,当任务11至1N请求事件创建时,服务处理器21至2N可以对该请求做出响应,然后事件框架20可以将所创建的事件转换成消息,并且可以将该消息发送至订阅任务。That is, when a task 11 to 1N requests event creation, the service processor 21 to 2N can respond to the request, and then the event framework 20 can convert the created event into a message, and can send the message to the subscribed Task.

为此,互通接口700将服务处理器21至2N、事件管理器200,消息管理器800和存储器管理器900彼此连接,使得包括消息的发送和接收、事件的创建和订阅事件的发送在内的事件服务可以以交互方式处理。另外,消息管理器800可以根据互通接口700的指令来控制消息的发送和接收。To this end, the interworking interface 700 connects the service processors 21 to 2N, the event manager 200, the message manager 800, and the storage manager 900 to each other, so that the processes including sending and receiving of messages, creation of events, and sending of subscribed events Event services can be handled interactively. In addition, the message manager 800 can control the sending and receiving of messages according to the instruction of the intercommunication interface 700 .

存储器管理器900是由事件框架20提供的用于存储器互通服务的组件,并且将在下面参照图6进行描述。The memory manager 900 is a component provided by the event framework 20 for a memory interworking service, and will be described below with reference to FIG. 6 .

图6是示出由图5所示的框架系统处理的存储器互通服务的框图。FIG. 6 is a block diagram illustrating memory interworking services handled by the framework system shown in FIG. 5 .

参照图6,用于单元设备控制的PLC是包括在钢处理1级系统中的组件,并且PLC的存储器可以由任务应用软件监测。任务应用软件可以根据事件服务请求运行,并且在这种情况下,PLC存储器的信息可以被API库100包括在消息中,然后被发送至事件框架20。另外,该消息可以包括任务ID。Referring to FIG. 6, a PLC for unit equipment control is a component included in the steel processing level 1 system, and the memory of the PLC can be monitored by task application software. Task application software can be run upon event service requests, and in this case, information from PLC memory can be included in messages by the API library 100 and then sent to the event framework 20 . Additionally, the message may include a task ID.

服务处理器21可以对存储器信息中包括的服务请求做出响应。The service processor 21 may respond to service requests included in the memory information.

由于存储器信息以消息的形式发送至事件框架20,因此互通接口700将存储器信息发送至消息管理器800以执行存储器互通服务,并且消息管理器800可以将存储器信息递送至存储器管理器900。Since the memory information is sent to the event framework 20 in the form of a message, the interworking interface 700 sends the memory information to the message manager 800 to perform the memory interworking service, and the message manager 800 can deliver the memory information to the memory manager 900 .

存储器管理器900可以存储PLC的存储器信息。如果新的存储器信息920从消息管理器800被发送至存储器管理器900,则存储器管理器900可以将新的存储器信息920与先前存储的存储器信息910进行比较以确定是否满足事件标准。另外,如果满足事件标准,则存储器管理器900可以将关于要创建的事件的信息递送至服务处理器,并且可以命令创建事件。此后,已接收到关于事件的信息的服务处理器可以创建事件。The memory manager 900 may store memory information of the PLC. If new memory information 920 is sent from message manager 800 to memory manager 900, memory manager 900 may compare new memory information 920 with previously stored memory information 910 to determine whether event criteria are met. In addition, if the event criteria are met, the memory manager 900 may deliver information on the event to be created to the service processor, and may order the event to be created. Thereafter, a service processor that has received information about an event can create an event.

图7是示出图6中示出的存储器互通服务的流程图。FIG. 7 is a flowchart illustrating the memory intercommunication service illustrated in FIG. 6 .

首先,任务应用软件可以检测PLC的存储器区域中的变化(S710),并且可以通过API库100向事件框架20发送服务请求。通过将包括关于存储器区域中的变化的存储器信息的消息发送到事件框架20来进行服务请求(S720)。之后,服务处理器对服务请求做出响应(S730)。First, the task application software may detect a change in the memory area of the PLC ( S710 ), and may send a service request to the event framework 20 through the API library 100 . A service request is made by sending a message including memory information about a change in a memory area to the event framework 20 (S720). Afterwards, the service processor responds to the service request (S730).

接下来,确定服务请求是否为存储器互通请求(S740),如果服务请求是存储器互通请求,则将存储器信息与先前存储的存储器信息进行比较(S750)。如果比较结果不满足事件标准,则更新存储器信息(S754),如果比较结果满足事件标准,则将它确定为事件服务(S760)。Next, it is determined whether the service request is a memory intercommunication request (S740), and if the service request is a memory intercommunication request, the memory information is compared with previously stored memory information (S750). If the comparison result does not meet the event standard, the memory information is updated (S754), and if the comparison result meets the event standard, it is determined as an event service (S760).

如果它被确定为事件服务,则可以进行事件创建请求以发送订阅事件(S770),如果它未被确定为事件服务,则可以执行消息处理以发送消息(S780)。If it is determined as an event service, an event creation request may be made to send a subscription event (S770), and if it is not determined to be an event service, message processing may be performed to send a message (S780).

图8是示出根据本公开内容的实施方式的用于在事件服务框架系统中处理事件创建请求的处理的时序图。图8中所示的处理是非限制性示例。FIG. 8 is a sequence diagram illustrating a process for handling an event creation request in an event service framework system according to an embodiment of the present disclosure. The processing shown in Figure 8 is a non-limiting example.

参照图8,如果任务请求用于事件服务的服务处理器创建事件(S510),则服务处理器可以请求事件定义管理器发送事件定义信息(S531),并且可以接收对事件定义信息请求的响应(S532)。替选地,为了保证事件定义信息的数据完整性,服务处理器可以在请求事件定义信息之前向事件系统访问调整器请求访问事件定义信息(S521),并且可以获得对访问事件定义信息的许可(S522)。Referring to FIG. 8, if a task requests a service handler for an event service to create an event (S510), the service handler may request the event definition manager to send event definition information (S531), and may receive a response to the event definition information request (S531). S532). Alternatively, in order to ensure the data integrity of the event definition information, the service processor may request access to the event definition information from the event system access regulator before requesting the event definition information (S521), and may obtain permission to access the event definition information (S521). S522).

服务处理器使用事件定义信息来创建具有与事件定义信息中的一条一致的信息的事件。The service processor uses the event definition information to create an event with information consistent with one of the event definition information.

另外,服务处理器请求临时待命队列选择器分配待命队列(S541)。然后,临时待命队列选择器可以向临时待命队列管理器请求待命队列信息(S542),并且可以接收对待命队列信息请求的响应(S543)。临时待命队列选择器可以从对待命队列信息请求的响应中获取关于临时待命队列的状态信息,并且可以确定将发送订阅事件的事件发送器。之后,临时待命队列选择器可以向服务处理器回复已经分配了待命队列(S544)。In addition, the service processor requests the temporary standby queue selector to allocate a standby queue (S541). Then, the temporary standby queue selector may request standby queue information from the temporary standby queue manager (S542), and may receive a response to the standby queue information request (S543). The temporary standby queue selector may obtain status information about the temporary standby queue from a response to the pending queue information request, and may determine an event sender that will send subscribed events. Afterwards, the temporary standby queue selector may reply to the service processor that the standby queue has been allocated (S544).

在接收到报告完成待命队列分配的回复之后,服务处理器可以将请求创建的事件作为订阅事件存储在临时待命队列中。之后,服务处理器可以请求事件发送器管理器处理订阅事件(S561)并且可以接收订阅事件处理响应(S562)。另外,由于服务处理器和事件发送器可以同时访问临时待命队列,因此,为了保证临时待命队列的数据完整性,服务处理器可以在将请求创建的事件作为订阅事件存储在临时待命队列中之前向临时待命队列访问管理器请求访问临时待命队列(S551),并且可以获得对访问临时待命队列的许可(S552)。After receiving a reply reporting completion of the standby queue allocation, the service processor may store the requested created event as a subscribed event in the temporary standby queue. Afterwards, the service processor may request the event sender manager to process the subscription event (S561) and may receive a subscription event processing response (S562). In addition, since the service processor and the event sender can access the temporary standby queue at the same time, in order to ensure the data integrity of the temporary standby queue, the service processor can send the requested event to the The temporary standby queue access manager requests access to the temporary standby queue (S551), and may obtain permission to access the temporary standby queue (S552).

在接收到订阅事件处理响应之后,服务处理器可以向任务回复已经创建了事件(S570)。After receiving the subscription event processing response, the service processor may reply to the task that the event has been created (S570).

另外,在订阅事件处理响应之后,事件发送器管理器可以请求事件发送器执行发送处理(S580)。In addition, after subscribing to the event processing response, the event sender manager may request the event sender to perform sending processing (S580).

因此,根据本公开内容的实施方式,事件服务框架系统可以存储可以响应于一次进行的事件创建请求来批量发送的订阅事件,并且可以回复已经创建了事件。因此,可以减少在请求事件创建之后任务等待事件创建完成的响应等待时间。Therefore, according to an embodiment of the present disclosure, the event service framework system can store subscription events that can be sent in batches in response to a one-off event creation request, and can reply that an event has been created. Therefore, it is possible to reduce the response waiting time in which the task waits for the event creation to be completed after the event creation is requested.

图9是示出根据本公开内容的实施方式的用于在事件服务框架系统中处理事件接收请求的处理的时序图。图9中所示的处理是非限制性示例。FIG. 9 is a sequence diagram illustrating a process for processing an event reception request in an event service framework system according to an embodiment of the present disclosure. The processing shown in Figure 9 is a non-limiting example.

参照图9,如果任务向服务处理器请求事件服务以接收事件(S610),则服务处理器可以请求已发送事件队列访问调整器检查订阅事件(S621)并且可以接收订阅事件响应。如果没有对应的订阅事件,即,如果事件发送器等待调度请求,则已发送事件队列访问调整器可以向订阅事件检查请求回复没有订阅事件(S622)。Referring to FIG. 9, if a task requests an event service to a service handler to receive an event (S610), the service handler may request the sent event queue access regulator to check a subscription event (S621) and may receive a subscription event response. If there is no corresponding subscription event, that is, if the event sender is waiting for a scheduling request, the sent event queue access regulator may reply to the subscription event check request that there is no subscription event (S622).

如参照图8所述,如果事件发送器管理器请求事件发送器执行发送处理(S580),则事件发送器可以采用存储在临时待命队列中的订阅事件。这可以通过复制关于订阅事件的信息和数据来执行。另外,为了保证临时待命队列的数据完整性,服务处理器可以在采用订阅事件之前向临时待命队列访问调整器请求访问临时待命队列(S631),并且可以获得对访问临时待命队列的许可(S632)。As described with reference to FIG. 8, if the event sender manager requests the event sender to perform a send process (S580), the event sender may adopt a subscription event stored in a temporary standby queue. This can be performed by replicating information and data about subscription events. In addition, in order to ensure the data integrity of the temporary standby queue, the service processor can request access to the temporary standby queue from the temporary standby queue access adjuster (S631) before adopting the subscription event, and can obtain permission to access the temporary standby queue (S632) .

接下来,事件发送器可以向已发送事件队列访问调整器请求访问已发送事件队列(S641),并且可以获得对访问已发送事件队列的许可(S642)。Next, the event sender may request access to the sent event queue from the sent event queue access regulator (S641), and may obtain permission to access the sent event queue (S642).

之后,事件发送器可以将订阅事件存储在已发送事件队列中,并且可以将存储的订阅事件的状态发送至已发送事件队列访问调整器(S650)。Afterwards, the event sender may store the subscription event in the sent event queue, and may send the status of the stored subscription event to the sent event queue access regulator (S650).

在订阅事件被存储在已发送事件队列中之后,已发送事件队列访问调整器可以向服务处理器通知订阅事件(S660)。After the subscription event is stored in the sent event queue, the sent event queue access regulator may notify the service processor of the subscription event (S660).

另外,如果服务处理器请求已发送事件队列访问调整器检查订阅事件(S621'),则已发送事件队列访问调整器可以肯定地回复服务处理器(S670)。Also, if the service processor requests the sent event queue access regulator to check the subscribed events (S621'), the sent event queue access regulator may reply affirmatively to the service processor (S670).

接下来,服务处理器可以对于事件接收请求发送事件接收回复(S680)。也就是说,请求了事件接收的任务可以接收订阅任务。Next, the service processor may transmit an event reception reply to the event reception request (S680). That is, tasks that have requested event reception can receive subscribed tasks.

尽管以上参照附图示出和描述了本公开内容的实施方式,但是本发明的范围不限于此,并且对于本领域技术人员来说明显的是,可以在不脱离由所附权利要求书限定的本发明的范围的情况下进行修改和变化。While embodiments of the present disclosure have been shown and described above with reference to the accompanying drawings, the scope of the invention is not limited thereto and it will be apparent to those skilled in the art that the invention may be implemented without departing from the scope of the appended claims. Modifications and changes are made within the scope of the present invention.

Claims (14)

1. a kind of Event Service method of steel processing middleware, the Event Service method is by mission application software and Events Frame It performs, the mission application software includes Application Programming Interface (API) library that permission task sends out Event Service request, the thing Part method of servicing includes:
Service processor responds Event Service request;
Information is defined based on the event for defining event id and size of data to create event;And
If the information about the event created is consistent with the information about requested subscription event, by reference to event The event created as requested subscription event is sent to and is mapped to requested subscription thing by the mapping data of manager The subscription task of part.
2. Event Service method according to claim 1, wherein, the establishment of event includes:
If the Event Service request includes memorizer information, memory manager is by the memorizer information with previously depositing The memorizer information of storage is compared, to determine whether to meet event criteria;And
If meeting the event criteria, the service processor is determined based on the event for defining event id and size of data Adopted information creates event.
3. Event Service method according to claim 1, wherein, using the event created as requested subscription event Be sent to the subscription task be by via event scheduling interface send requested subscription event be performed or Requested subscription event is converted into what is performed after message.
4. Event Service method according to claim 3, wherein, the event scheduling interface includes:
Event transmitter is configured to the subscription event being sent to subscription task corresponding with the subscription event;With And
The interim queue of awaiting orders accordingly created with the event transmitter, the interim queue of awaiting orders is for described in interim storage Subscription event.
5. Event Service method according to claim 1, wherein, the task manager includes:
Event defines manager, is configured to create and deletes the event and defines information;
Subscription task-Event mapper, being configured to management wherein task data has the mapping data of priority;And
Event-subscription task mapper, being configured to management wherein event data has the mapping data of priority.
6. a kind of Event Service frame system of steel processing middleware, the Event Service frame system is by least one processor It realizes and including mission application software and Events Frame, the mission application software sends out Event Service including permission task please The API library asked, the Events Frame include:
Service processor is configured to respond Event Service request;
Task manager, the event for being configured to management definition event id and size of data define information, and manage wherein Information about requested subscription event is mapped to the mapping data of corresponding subscription task;And
Event scheduling interface, wherein, if about the event for defining information creating based on the event by the service processor Information it is consistent with the information about requested subscription event, then the event scheduling interface is using the event created as institute The subscription event of request is sent to subscription task.
7. Event Service frame system according to claim 6, further includes memory manager, wherein, if the thing Part service request includes memorizer information, then the memory manager is by the memorizer information and previously stored memory Information is compared, to determine whether to meet event criteria and order establishment event.
8. Event Service frame system according to claim 6, further include message manager, the message manager by with It is set to and the subscription event is converted into message described in information and sending.
9. Event Service frame system according to claim 6, wherein, the API library provides API, and task passes through described API request Event Service, the Event Service include:For creating the event definition, event subscription, event that event defines information Event establishment, event reception and the event definition for subscribe to cancellation, information being defined based on event are deleted.
10. Event Service frame system according to claim 6, wherein, the task manager includes:
Event defines manager, is configured to create and deletes the event and defines information;
Subscription task-Event mapper, being configured to management wherein task data has the mapping data of priority;And
Event-subscription task mapper, being configured to management wherein event data has the mapping data of priority.
11. Event Service frame system according to claim 6, wherein, the Events Frame further includes the event of transmission Queue pond, the event queue pond that sent have sent event queue including multiple, have been ordered by what the event scheduling interface was sent Read event it is described sent wait until that subscription task receives the subscription event in event queue until.
12. Event Service frame system according to claim 11, wherein, the Events Frame further includes Event Service prison Survey device, the Event Service monitor is configured to monitor the task manager, the event scheduling interface and described has sent out Event queue pond is sent, the mission application software will be sent to about the information of the state of the subscription event.
13. Event Service frame system according to claim 6, wherein, the event scheduling interface includes:
Event transmitter is configured to the subscription event being sent to subscription task corresponding with the subscription event;With And
The interim queue of awaiting orders accordingly created with the event transmitter, the interim queue of awaiting orders is for described in interim storage Subscription event.
14. Event Service frame system according to claim 13, wherein, the event scheduling interface further includes to be treated temporarily Queue selector is ordered, the interim queue selector of awaiting orders is configured to the event transmitter that selection sends the subscription event.
CN201680062015.8A 2015-10-21 2016-10-14 Event service method and framework system for steel processing middleware Active CN108140008B (en)

Applications Claiming Priority (5)

Application Number Priority Date Filing Date Title
KR10-2015-0146725 2015-10-21
KR20150146725 2015-10-21
KR1020160132929A KR101889159B1 (en) 2015-10-21 2016-10-13 Mthoed and framework system for evnet service of steel process middleware
KR10-2016-0132929 2016-10-13
PCT/KR2016/011586 WO2017069468A1 (en) 2015-10-21 2016-10-14 Event service method of steel process middleware, and framework system

Publications (2)

Publication Number Publication Date
CN108140008A true CN108140008A (en) 2018-06-08
CN108140008B CN108140008B (en) 2022-08-23

Family

ID=58743398

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201680062015.8A Active CN108140008B (en) 2015-10-21 2016-10-14 Event service method and framework system for steel processing middleware

Country Status (2)

Country Link
KR (1) KR101889159B1 (en)
CN (1) CN108140008B (en)

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
KR102509402B1 (en) * 2020-12-09 2023-03-13 주식회사 에이앤에이 A method for processing the event on the platform

Citations (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6549956B1 (en) * 1998-11-30 2003-04-15 Hewlett Packard Company Mechanism for connecting disparate publication and subscribe domains via the internet
US20070011266A1 (en) * 2005-07-05 2007-01-11 Microsoft Corporation Automatic create, update and delete event publishing
US20070067409A1 (en) * 2005-08-26 2007-03-22 At&T Corp. System and method for event driven publish-subscribe communications
KR20100076840A (en) * 2008-12-26 2010-07-06 주식회사 포스코 Middleware for controling steel process and method for providing service in the middleware
US20120110077A1 (en) * 2010-07-30 2012-05-03 The Mcgraw-Hill Companies, Inc. System and Method Using A Simplified XML Format for Real-Time Content Publication
US20130067024A1 (en) * 2011-09-12 2013-03-14 Microsoft Corporation Distributing multi-source push notifications to multiple targets
CN103927218A (en) * 2014-04-30 2014-07-16 广州唯品会网络技术有限公司 Event dispatching method and system
CN103944924A (en) * 2014-05-15 2014-07-23 重庆邮电大学 Ubiquitous network publish-subscribe middleware model based on RESTful
WO2014171130A1 (en) * 2013-04-17 2014-10-23 日本電気株式会社 Information processing system, deployment method, processing device, and deployment device
CN104618432A (en) * 2014-12-30 2015-05-13 北京红马传媒文化发展有限公司 Event sending and receiving handling method and system
US20150142501A1 (en) * 2013-11-18 2015-05-21 Nuwafin Holdings Ltd System and method for executing business services and enhancing business performance through a business process modeling notation

Patent Citations (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6549956B1 (en) * 1998-11-30 2003-04-15 Hewlett Packard Company Mechanism for connecting disparate publication and subscribe domains via the internet
US20070011266A1 (en) * 2005-07-05 2007-01-11 Microsoft Corporation Automatic create, update and delete event publishing
US20070067409A1 (en) * 2005-08-26 2007-03-22 At&T Corp. System and method for event driven publish-subscribe communications
KR20100076840A (en) * 2008-12-26 2010-07-06 주식회사 포스코 Middleware for controling steel process and method for providing service in the middleware
US20120110077A1 (en) * 2010-07-30 2012-05-03 The Mcgraw-Hill Companies, Inc. System and Method Using A Simplified XML Format for Real-Time Content Publication
US20130067024A1 (en) * 2011-09-12 2013-03-14 Microsoft Corporation Distributing multi-source push notifications to multiple targets
WO2014171130A1 (en) * 2013-04-17 2014-10-23 日本電気株式会社 Information processing system, deployment method, processing device, and deployment device
US20150142501A1 (en) * 2013-11-18 2015-05-21 Nuwafin Holdings Ltd System and method for executing business services and enhancing business performance through a business process modeling notation
CN103927218A (en) * 2014-04-30 2014-07-16 广州唯品会网络技术有限公司 Event dispatching method and system
CN103944924A (en) * 2014-05-15 2014-07-23 重庆邮电大学 Ubiquitous network publish-subscribe middleware model based on RESTful
CN104618432A (en) * 2014-12-30 2015-05-13 北京红马传媒文化发展有限公司 Event sending and receiving handling method and system

Non-Patent Citations (3)

* Cited by examiner, † Cited by third party
Title
廖小平等: "基于XML和发布/订阅机制的主动服务系统", 《计算机应用与软件》 *
潘国伟等: "消息中间件在电力调度自动化系统中的应用", 《电气应用》 *
王稳军等: "可扩展发布/订阅中间件技术研究", 《指挥信息系统与技术》 *

Also Published As

Publication number Publication date
KR20170047169A (en) 2017-05-04
CN108140008B (en) 2022-08-23
KR101889159B1 (en) 2018-08-17

Similar Documents

Publication Publication Date Title
US11922236B2 (en) Producer-side prioritization of message processing
US10505791B2 (en) System and method to handle events using historical data in serverless systems
US10083048B2 (en) System and method for fully configurable real time processing
US10133797B1 (en) Distributed heterogeneous system for data warehouse management
US9075659B2 (en) Task allocation in a computer network
US11687373B2 (en) Flexible computing
CN106371894B (en) Configuration method and device and data processing server
AU2018201052B2 (en) System for optimising distribution of processing an automated process
US20200174844A1 (en) System and method for resource partitioning in distributed computing
US20180183862A1 (en) Apparatus and method for logically grouping client nodes in an iot environment using client identifiers
US12293236B2 (en) Scaling processing systems based on database accessibility state
US10080233B2 (en) Method for providing M2M data
CN112256423A (en) System, device and process for dynamic tenant structure adjustment in distributed resource management system
US9424096B2 (en) Task allocation in a computer network
US20220229695A1 (en) System and method for scheduling in a computing system
US20180052712A1 (en) System and method supporting single software code base using actor/director model separation
US10871987B1 (en) Distributed execution of tasks on client devices
WO2011010711A1 (en) Event processing system and method, distribution control device and method, and program storage medium
WO2023151503A1 (en) Handle management or communication method, electronic device, storage medium and program product
US11474868B1 (en) Sharded polling system
CN108140008A (en) Steel handles the Event Service method and frame system of middleware
EP3655896A1 (en) Method to set up and tear down cloud environments based on a schedule obtained from one or more hosted calendars
US12346775B2 (en) Migrating quantum services based on temperature thresholds
US11366687B2 (en) Task allocations based on color-coded representations
US20230196175A1 (en) CENTRALIZING PROVISION OF QUANTUM CORE SERVICES (QCSs)

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
CP03 Change of name, title or address

Address after: Seoul City, Korea

Patentee after: POSCO Holdings Co.,Ltd.

Address before: Gyeongbuk, South Korea

Patentee before: Style Society POSCO

CP03 Change of name, title or address
TR01 Transfer of patent right

Effective date of registration: 20230612

Address after: Gyeongbuk, South Korea

Patentee after: POSCO Co.,Ltd.

Address before: Seoul City, Korea

Patentee before: POSCO Holdings Co.,Ltd.

TR01 Transfer of patent right
TG01 Patent term adjustment
TG01 Patent term adjustment