KR101416280B1

KR101416280B1 - 이벤트 처리 시스템 및 방법

Info

Publication number: KR101416280B1
Application number: KR20130004638A
Authority: KR
Inventors: 유환기; 김인희; 최영수
Original assignee: 주식회사 엘지씨엔에스
Priority date: 2013-01-15
Filing date: 2013-01-15
Publication date: 2014-07-08
Also published as: US9015731B2; US20140201762A1

Abstract

본 발명은 SOP(Standard Operating Procedure; 표준 작업 절차)를 활용하여 인 메모리 그리드(In Memory Grid) 기반으로 이벤트(Event)를 통합 처리하도록 한 이벤트 처리 시스템 및 방법에 관한 것으로, SOP 엔진에서 디바이스에 수신되는 이벤트 별로 우선 순위에 의거한 SOP를 자동화하고 이벤트를 전달하며, 이벤트 퍼블리셔에서 SOP 엔진으로부터 전달되는 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 것을 특징으로 한다. 이러한 이벤트 처리 시스템 및 방법은 이벤트 처리에 대한 업무 자동화를 지원하고 중요 이벤트에 대한 처리 프로세스의 명확성을 확보할 수 있으며, 지능적인 이벤트 전달 보장성을 향상시킬 수 있으며, 대량의 이벤트를 원활하게 처리할 수 있다.

Description

이벤트 처리 시스템 및 방법{EVENT HANDLING SYSTEM AND METHOD}

본 발명은 이벤트 처리 시스템 및 방법에 관한 것으로, 보다 상세하게는, SOP(Standard Operating Procedure; 표준 작업 절차)를 활용하여 인 메모리 그리드(In Memory Grid) 기반으로 이벤트(Event)를 통합 처리하도록 한 이벤트 처리 시스템 및 방법에 관한 것이다.

일반적으로, 보안 및 관제 시스템은 수집된 중요 이벤트를 다수의 전달 대상까지 안전하게 보내 인지시키고, 대응 판단을 이끌어 내는 기능이 핵심 요소 중 하나이다.

따라서, 다양한 관제 대상 디바이스(Device)로부터 수집된 수많은 이벤트를 거의 실시간에 근접하여 모니터링 및 제어하는 컨버전스 시스템(Convergence System)에서는 이벤트를 자동 처리하는 프로세스 및 전달 대상에 따른 다양한 푸쉬(Push) 방안이 활용되고 있다.

대표적인 구현 방식이 사용자 및 프로세스에 따른 웹(Web) 기반 롱 폴링(Long Polling) 및 TCP/IP 세션 푸쉬(Session Push)와, 모바일(Mobile) 기반 TCP/IP 세션 푸쉬 방식이 있으며, 해당 이벤트를 수집하여 전달 대상에 대한 푸쉬를 단편적으로 처리해 주도록 한다.

즉, 종래의 이벤트 전송 기술은, 폴링(Polling), 롱 폴링(Long Polling), 스트리밍(Streaming) 등과 같은 단편적인 서비스를 익명의 브라우저(Browser)나 다수의 클라이언트(Client)에게 제공하도록 하는 기술이다.

해당 폴링은 브라우저 또는 클라이언트가 요구 메시지(Request Message)를 서버에게 보내면 서버가 이에 대한 응답 메시지(Response Message)를 보내게 되는데, 이때 서버측에 이벤트가 발생되더라도 브라우저 또는 클라이언트로부터 요구 메시지를 수신받지 않는 이상 이벤트를 전송하지 않고 있다가, 브라우저 또는 클라이언트로부터 요구 메시지를 수신받는 경우에 응답 메시지로 이벤트를 전송하게 되는 방식이다.

해당 롱 폴링은 브라우저 또는 클라이언트가 요구 메시지를 서버에게 보내더라도 이벤트가 발생되지 않는 한 응답 메시지를 전송하지 않고 있다가, 이벤트가 발생한 후에 브라우저 또는 클라이언트로부터 요구 메시지를 수신받는 경우에 응답 메시지로 이벤트를 전송하게 되는 방식이다.

해당 스트리밍은 브라우저 또는 클라이언트로부터 요구 메시지를 한 번 수신받은 이후로, 이벤트가 발생할 때마다 매번 응답 메시지를 발생시켜 이벤트를 매번 전송하게 되는 방식이다.

그러나 보편적인 보안 및 관제 디바이스에서 발생되는 이벤트는, 기존 엔터프라이즈(Enterprise) 데이터 처리량에 비해 상대적으로 대량이므로, 그에 맞는 이벤트 전달자 구현이 어렵고, 더불어 웹, 모바일 등의 개별적으로 동작하는 이벤트 전달 방안으로는 해당 전달 대상의 접속 환경 변화가 고려되지 않아 목적지(즉, 전달 대상) 기준 전달 보증을 처리할 수 없는 한계가 있었다.

한편, 한국공개특허 제2001-0060869호는 통신 시스템에서 운용자의 요구에 의한 이벤트 처리 방법에 관한 것으로서, 통신 시스템에서 이벤트 상태 데이터를 관리함으로써 한 디바이스에서 동시에 폴링 모드 또는 인터럽트 모드로 이벤트 검출이 가능하고 폴링 모드로 이벤트를 검출할 때 지속 시간이나 우선 순위 및 이벤트의 발생 수를 참조로 폴링할 수 있는 기술에 대해 개시하였다. 개시된 기술에 따르면, 이벤트 상태 테이블을 구비한 통신 시스템의 이벤트 처리 방법에 있어서, 시스템 운용 중에 운용자로부터 이벤트 정보를 수신하여 상기 이벤트 상태 테이블을 갱신하는 과정과, 상기 이벤트 상태 테이블에서 검출 방식이 폴링 모드인 이벤트들에 대해 폴링 방식으로 이벤트를 검출하는 과정과, 상기 이벤트 상태 테이블에서 검출 방식이 인터럽트 모드인 이벤트들에 대해 인터럽트 방식으로 상기 이벤트를 검출하는 과정을 포함하는 것을 특징으로 함으로써, 여러 개의 이벤트가 존재하는 디바이스에서 운용자의 요구에 의해 운용중에도 이벤트를 유연하게 조정할 수 있다.

그리고 한국등록특허 제10-0489690호는 실시간 장애 제어를 위한 데이터베이스 테이블 모델링 및 이벤트 처리 방법에 관한 것으로, 더욱 상세하게는 네트워크 디바이스로부터 발생하는 장애 및 연관 이벤트를 실시간으로 장애 관리자에게 전달하는 경우, 각각의 클라이언트들과 장애 시퀀스 번호간의 매핑과 이를 뒷받침하는 데이터베이스 모델링과 이벤트 관리 기법을 통하여 보다 효율적으로 이벤트를 처리할 수 있도록 하는 기술에 대해서 개시하고 있다. 이러한 개시된 기술에 의하면, 장애 관리 프로세서와 클라이언트 리스트 테이블과 장애 데이터베이스와 비정상 종료된 클라이언트를 관리하는 데몬 프로세서와 하나의 대기자 테이블 및 복수 개의 장애 관리자들을 구비한 네트워크 장애 관리 시스템에서의 실시간 장애 제어를 위한 데이터베이스 테이블 모델링 및 이벤트 처리 방법에 있어서, 상기 장애 관리 프로세서에서 네트워크 시스템 디바이스로부터 장애 이벤트가 발생하면 그 발생한 장애 정보를 장애 데이터베이스에 저장하는 단계와; 상기 장애 관리자들은 상기 데이터베이스에 저장된 장애 정보를 장애 시퀀스 번호에 대응하여 폴링하고, 폴링이 종료되면 상기 클라이언트 리스트 테이블에 폴링 관련 정보를 저장하는 단계와; 상기 데몬 프로세서에서 상기 대기자 테이블에 축적되는 일정량의 현재 장애 정보를 상기 클라이언트 리스트 테이블의 판독 장애 시퀀스 번호와 매핑하여 상기 대기자 테이블내의 현재 장애 리스트를 관리하고 상기 클라이언트 리스트 테이블의 상태를 최종 폴링 시간과 장애 시퀀스 번호로 파악하여 비정상 종료된 클라이언트를 관리하는 단계를 수행하는 것을 특징으로 한다. 본 발명에 따르면, 데이터베이스 테이블 모델링을 통하여 장애 이벤트를 용이하게 핸들링하도록 도모하며, 장애 정보 처리 속도를 향상시킬 수 있으며, 클라이언트 접속 수의 증가에 반비례적으로 급속히 저하되는 장애 관리자들의 실시간 모니터링 기능의 단점을 해결하는 효과를 갖는다.

그런데, 이러한 종래의 이벤트 처리 기술은, 다수의 이벤트 전달 대상들의 온라인(On-line) 접속 환경에 따른 전송 기술로서, 해당 시점 개별 전달 대상의 실제 접속 환경이 고려되지 않아, 전달 보장성이 떨어지는 단점이 있으며, 더불어 이벤트의 생명 주기를 관리하지 않아, 중요 이벤트에 대한 처리 프로세스의 명확성이 떨어지는 단점을 가지며, 또한 대량의 이벤트 처리에 대한 대비가 되어 있지 않고 재처리에 대한 프로세스도 존재하지 않은 문제점도 있다.

그리고 이러한 종래의 이벤트 처리 기술은, 중요 이벤트를 처리함에 있어 업무 중심의 단일화된 처리 인터페이스를 제공하지 않았으며, 전통적 트랜잭션(Transaction)을 넘어서는 대량의 이벤트 처리도 고려되지 않은 문제점도 가지고 있다.

다시 말해서, 종래의 이벤트 처리 기술은, 전달 대상의 접속 환경 변화에 따른 지능적인 이벤트 전달 보증보다는 이벤트 발생 시점에 일률적인 푸쉬(Push)을 전달할 수 있는 기능에 중점을 두고 있다.

이에, 보안 및 관제 업무 중심의 단일화된 업무 처리 인터페이스를 제공하여 업무 자동화를 지원하고 대용량 데이터 처리를 위한 기반이 고려되어야 할 필요성이 있다고 할 것이며, 또한 전달 대상의 실제 접속 환경이 고려된 다양한 지능형 푸쉬 방안을 제공할 필요성이 있다고 할 것이다.

한국공개특허 제2001-0060869호 한국등록특허 제10-0489690호

본 발명의 일 실시예는 SOP(Standard Operating Procedure; 표준 작업 절차)를 활용하여 인 메모리 그리드(In Memory Grid) 기반으로 이벤트를 통합 처리하도록 한 이벤트 처리 시스템 및 방법을 제공하고자 한다.

본 발명의 일 실시예는 SOP 엔진(Engine)에 의해 이벤트의 생명 주기를 관리하고 이벤트를 처리함에 있어 업무 중심의 단일화된 처리 인터페이스를 제공하도록 한 이벤트 처리 시스템 및 방법을 제공하고자 한다.

본 발명의 일 실시예는 대용량 데이터 처리를 위한 기반 및 재처리에 대한 프로세스를 제공하도록 한 이벤트 처리 시스템 및 방법을 제공하고자 한다.

본 발명의 일 실시예는 인 메모리 그리드 기반으로 저장된 이벤트를 해당 시점에 전달 대상의 접속 환경에 맞추어진 다양한 푸쉬(Push)를 제공하도록 한 이벤트 처리 시스템 및 방법을 제공하고자 한다.

실시예들 중에서, 이벤트 처리 시스템은 이벤트 별 정의된 표준작업절차(SOP: Standard Operating Procedure)를 처리하고 상기 이벤트를 전달하는 SOP 엔진; 및 상기 SOP 엔진으로부터 전달받은 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 이벤트 퍼블리셔를 포함한다.

일 실시예에서, 상기 SOP 엔진은 이벤트 별 공통으로 대응되는 업무처리절차를 우선순위를 기반으로 표준화한 상기 SOP를 자동화할 수 있다.

일 실시예에서, 상기 SOP 엔진은 기본 업무 프로세스를 기반으로 사용자에 의해 정의된 이벤트 별 SOP를 처리하는 SOP 프로세스부; 상기 SOP 프로세스부에서 처리한 SOP로 이벤트의 액션을 진행하는 SOP 태스크부; 및 전달 대상을 지정하여 이벤트를 상기 이벤트 퍼블리셔로 전달하는 이벤트 송신부를 포함할 수 있다.

일 실시예에서, 상기 이벤트 퍼블리셔는 상기 SOP 엔진으로부터 전달되는 이벤트를 키와 밸류 형식으로 등록하는 이벤트 수신부; 상기 이벤트 수신부를 통해 수신된 이벤트를 키와 밸류 값으로 저장하는 이벤트 저장부; 상기 이벤트 저장부의 이벤트 퍼블리셔 레파지토리의 클러스터를 관리하는 클러스터 매니저부; 상기 이벤트 저장부에 저장된 이벤트에 대해 우선 순위 및 전달 대상의 접속 상태를 인지하고, 전달 대상의 상태에 따라 이벤트를 분배하는 이벤트 분배부; 및 상기 이벤트 분배부에 의해 최적된 푸쉬를 적용하여 이벤트를 전달 대상에게 전송하는 전송부를 포함할 수 있다.

일 실시예에서, 상기 전송부는 TCP/IP 세션 및 자바 스크립트 기반 서버 사이드 스크립트를 활용하여 이벤트를 푸쉬하는 웹 전송부, 개별 디바이스와의 TCP/IP 세션을 이용하여 이벤트를 푸쉬하는 모바일 전송부, 스트리밍 AMF와 웹 소켓을 이용하여 이벤트를 푸쉬하는 RIA 전송부, 및 API를 이용하여 이벤트를 푸쉬하는 메시지 전송부 중 적어도 하나를 포함할 수 있다.

일 실시예에서, 상기 이벤트 퍼블리셔는 주기적으로 전달되어야 하는 이벤트를 관리하는 스케쥴러부를 더 포함할 수 있다.

실시예들 중에서, 이벤트 처리 방법은 표준작업절차(SOP: Standard Operating Procedure) 엔진을 통해 이벤트 별 정의된 SOP를 처리하고 상기 이벤트를 전달하는 단계; 및 이벤트 퍼블리셔를 통해 상기 SOP 엔진으로부터 수신된 상기 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 단계를 포함한다.

일 실시예에서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는, 상기 SOP 엔진에 수신되는 이벤트가 SOP이 정의된 이벤트인지를 확인하는 단계; 상기 SOP이 정의된 이벤트인 경우, 이벤트에 대응하는 SOP 프로세스를 자동 호출하여 진행시키는 단계; 상기 SOP 프로세스 하위의 세부 태스크가 존재하는지를 확인하는 단계; 상기 세부 태스크가 존재하는 경우, SOP 태스크를 진행시키는 단계; 및 이벤트 전달 지시 여부를 확인하여 전달 대상을 지정해 이벤트를 상기 이벤트 퍼블리셔로 전달하는 단계를 포함할 수 있다.

일 실시예에서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는, 상기 이벤트 전달 지시가 없는 경우, 상기 SOP 태스크의 진행이 완료되었는지를 확인하는 단계를 더 포함할 수 있다.

일 실시예에서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는, 상기 세부 태스크가 존재하지 않는 경우, 또는 상기 SOP 태스크의 진행이 완료된 경우, 상기 SOP 프로세스의 진행이 완료되었는지를 확인하는 단계를 더 포함할 수 있다.

일 실시예에서, 상기 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 단계는, 상기 SOP 엔진으로부터 수신되는 전달 대상과 전달 이벤트를 등록하는 단계; 상기 이벤트가 등록되는 시점에 이벤트 드리븐(event driven)으로 우선 순위와 전달 대상의 현재 접속 상태를 판단하는 단계; 상기 판단된 우선 순위와 전달 대상의 현재 접속 상태에 따라 이벤트를 분배하는 단계; 및 전달 대상의 접속 상태 및 위치에 맞게 상기 분배된 이벤트를 푸쉬하는 단계를 포함할 수 있다.

일 실시예에서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는, 이벤트 전달 대상이 미리 정의한 자신의 접속 상태 값을 수신하고 해당 수신한 접속 상태 값을 이벤트와 동시에 등록할 수 있다.

일 실시예에서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는, 다수 개의 접속 환경에 동시다발적인 이벤트를 등록할 수 있다.

일 실시예에서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는, 이벤트의 중요도에 따라 우선 순위를 등록할 수 있다.

일 실시예에서, 상기 분배된 이벤트를 푸쉬하는 단계는, 웹 기반 전달 대상을 위한 웹 소켓 및 서버 사이드 자바 스크립트, 디바이스와의 TCP/IP 세션, 스트리밍 AMF와 웹 소켓, 또는 API를 활용하여 상기 분배된 이벤트를 전달 대상으로 전송할 수 있다.

일 실시예에서, 상기 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 단계는, 상기 분배된 이벤트가 전달되었는지를 확인하는 단계; 및 상기 분배된 이벤트의 전달 실패 시에 주기적으로 이벤트를 재 처리할 수 있도록 주기적으로 전달되어야 하는 이벤트를 관리하는 단계를 포함할 수 있다.

본 발명의 일 실시예에 따른 이벤트 처리 시스템 및 방법은, SOP 엔진에 의해 이벤트의 생명 주기를 관리하고 이벤트를 처리함에 있어 업무 중심의 단일화된 처리 인터페이스를 제공함으로써, 이벤트 처리에 대한 업무 자동화를 지원하고 중요 이벤트에 대한 처리 프로세스의 명확성을 확보할 수 있다.

본 발명의 일 실시예에 따른 이벤트 처리 시스템 및 방법은, 인 메모리 그리드 기반으로 저장된 이벤트를 해당 시점에 전달 대상의 실제 접속 환경이 고려된 다양한 지능형 푸쉬를 제공함으로써, 지능적인 이벤트 전달 보장성을 향상시킬 수 있다.

본 발명의 일 실시예에 따른 이벤트 처리 시스템 및 방법은, 대용량 데이터 처리를 위한 기반 및 재처리에 대한 프로세스를 제공함으로써, 대량의 이벤트 처리에 대한 대비를 통해 대량의 이벤트를 원활하게 처리할 수 있다.

도 1은 본 발명의 일 실시예에 따른 이벤트 처리 시스템을 설명하는 블록도이다.
도 2 및 도 3은 본 발명의 일 실시예에 따른 이벤트 처리 방법을 설명하는 순서도이다.

본 발명에 관한 설명은 구조적 내지 기능적 설명을 위한 실시예에 불과하므로, 본 발명의 권리범위는 본문에 설명된 실시예에 의하여 제한되는 것으로 해석되어서는 아니 된다. 즉, 실시예는 다양한 변경이 가능하고 여러 가지 형태를 가질 수 있으므로 본 발명의 권리범위는 기술적 사상을 실현할 수 있는 균등물들을 포함하는 것으로 이해되어야 한다.

한편, 본 발명에서 서술되는 용어의 의미는 다음과 같이 이해되어야 할 것이다.

"제1", "제2" 등의 용어는 하나의 구성요소를 다른 구성요소로부터 구별하기 위한 것으로, 이들 용어들에 의해 권리범위가 한정되어서는 아니 된다. 예를 들어, 제1 구성요소는 제2 구성요소로 명명될 수 있고, 유사하게 제2 구성요소도 제1 구성요소로 명명될 수 있다.

어떤 구성요소가 다른 구성요소에 "연결되어"있다고 언급된 때에는, 그 다른 구성요소에 직접적으로 연결될 수도 있지만, 중간에 다른 구성요소가 존재할 수도 있다고 이해되어야 할 것이다. 반면에, 어떤 구성요소가 다른 구성요소에 "직접 연결되어"있다고 언급된 때에는 중간에 다른 구성요소가 존재하지 않는 것으로 이해되어야 할 것이다. 한편, 구성요소들 간의 관계를 설명하는 다른 표현들, 즉 "~사이에"와 "바로 ~사이에" 또는 "~에 이웃하는"과 "~에 직접 이웃하는" 등도 마찬가지로 해석되어야 한다.

단수의 표현은 문맥상 명백하게 다르게 뜻하지 않는 한 복수의 표현을 포함하는 것으로 이해되어야 하고, "포함하다"또는 "가지다" 등의 용어는 설시된 특징, 숫자, 단계, 동작, 구성요소, 부분품 또는 이들을 조합한 것이 존재함을 지정하려는 것이며, 하나 또는 그 이상의 다른 특징이나 숫자, 단계, 동작, 구성요소, 부분품 또는 이들을 조합한 것들의 존재 또는 부가 가능성을 미리 배제하지 않는 것으로 이해되어야 한다.

각 단계들에 있어 식별부호(예를 들어, a, b, c 등)는 설명의 편의를 위하여 사용되는 것으로 식별부호는 각 단계들의 순서를 설명하는 것이 아니며, 각 단계들은 문맥상 명백하게 특정 순서를 기재하지 않는 이상 명기된 순서와 다르게 일어날 수 있다. 즉, 각 단계들은 명기된 순서와 동일하게 일어날 수도 있고 실질적으로 동시에 수행될 수도 있으며 반대의 순서대로 수행될 수도 있다.

본 발명은 컴퓨터가 읽을 수 있는 기록매체에 컴퓨터가 읽을 수 있는 코드로서 구현될 수 있고, 컴퓨터가 읽을 수 있는 기록 매체는 컴퓨터 시스템에 의하여 읽혀질 수 있는 데이터가 저장되는 모든 종류의 기록 장치를 포함한다. 컴퓨터가 읽을 수 있는 기록 매체의 예로는 ROM, RAM, CD-ROM, 자기 테이프, 플로피 디스크, 광 데이터 저장 장치 등이 있으며, 또한, 캐리어 웨이브(예를 들어 인터넷을 통한 전송)의 형태로 구현되는 것도 포함한다. 또한, 컴퓨터가 읽을 수 있는 기록 매체는 네트워크로 연결된 컴퓨터 시스템에 분산되어, 분산 방식으로 컴퓨터가 읽을 수 있는 코드가 저장되고 실행될 수 있다.

여기서 사용되는 모든 용어들은 다르게 정의되지 않는 한, 본 발명이 속하는 분야에서 통상의 지식을 가진 자에 의해 일반적으로 이해되는 것과 동일한 의미를 가진다. 일반적으로 사용되는 사전에 정의되어 있는 용어들은 관련 기술의 문맥상 가지는 의미와 일치하는 것으로 해석되어야 하며, 본 발명에서 명백하게 정의하지 않는 한 이상적이거나 과도하게 형식적인 의미를 지니는 것으로 해석될 수 없다.

도 1은 본 발명의 일 실시예에 따른 이벤트 처리 시스템을 설명하는 블록도이다.

도 1을 참조하면, 본 발명의 일 실시예에 따른 이벤트 처리 시스템은, 이벤트 처리 프로세스를 단일화된 인터페이스로 통합하여 전달이 발생되는 시점과 이벤트 생명 주기 관리를 명확하게 하며, 대용량 이벤트를 전달받아 처리할 수 있는 기반을 구축하고 있으며, 중요도에 따라 이벤트를 자동 분배한 후에, 전달 대상의 접속 환경 상태를 감지하고 그에 맞게 이벤트를 푸쉬할 수 있는 통합된 전달자들을 제공하여 이벤트를 최종 목적지까지 명확하게 전달하도록 한다.

그리고 본 발명의 일 실시예에 따른 이벤트 처리 시스템은, SOP(Standard Operating Procedure; 표준 작업 절차) 엔진(100) 및 이벤트 퍼블리셔(200)를 포함한다.

SOP 엔진(100)은 이벤트의 흐름에 따른 자동화된 업무 처리 프로세스로서, 디바이스 및 내부 시스템에 수신된 이벤트 별로 우선 순위에 의거한 SOP를 자동화해 주며, 디바이스 및 내부 시스템에 수신된 이벤트를 이벤트 퍼블리셔(200)로 전달하는데, 이때 단일화된 인터페이스를 비즈니스 로직(Business Logic)에 제공하여 업무 처리의 일관성을 제공한다. 즉, SOP 엔진(100)은 이벤트 수신 시에 공통으로 대응되어야 할 SOP를 표준화하여 관리자에게 제공하도록 해 준다.

그리고 SOP 엔진(100)은 SOP 프로세스(Process)부(110), SOP 태스크(Task)부(120), 이벤트 송신부(Event Sender)(130)를 포함할 수 있다.

SOP 프로세스부(110)는 메모리에 미리 설정되어 있는 기본 업무 프로세스를 기반으로 사용자에 의해 정의된 이벤트 별 SOP를 처리하는 역할을 수행한다.

SOP 태스크부(120)는 SOP 프로세스부(110)에서 처리한 이벤트 별 SOP로 진행되는 세부 태스크로, 실제 이벤트의 액션(Action)을 진행하도록 한다.

이벤트 송신부(130)는 전달 대상을 지정하여 이벤트 퍼블리셔(200)로 이벤트 전달을 지시하여 이벤트를 전달하도록 해 준다.

이벤트 퍼블리셔(200)는 대용량 이벤트 처리에 적합하도록 이벤트 드리븐(Event Driven), 인 메모리 그리드, 멀티 채널 전송기(Multi Channel Transmitter) 등의 아키텍처를 이용한 구성을 가지며, SOP 엔진(100)으로부터 전송되는 대용량 이벤트를 처리하도록 하는데, SOP 엔진(100)의 SOP 기반 서비스를 통해 자동 처리되는 업무와 디바이스 이벤트(Device Event)를 해당 전달 대상 목적지의 유형 및 접속 상태에 따라 지능적으로 전달하도록 한다.

그리고 이벤트 퍼블리셔(200)는 이벤트 수신부(Event Receiver)(210), 이벤트 저장부(Event Repository)(220), 클러스터 매니저부(Cluster Manager)(230), 이벤트 분배부(Event Distributor)(240), 전송부(Transmitter)(250)를 포함할 수 있다.

이벤트 수신부(210)는 SOP 기반의 비즈니스 로직에서 전달 대상에게 보내야 할 이벤트의 처리를 위해 호출하는 모듈로, 이벤트를 키(Key)와 밸류(Value) 형식으로 이벤트 저장부(220)에 등록하는 역할을 수행한다.

이벤트 저장부(220)는 임시 저장소로서, 대용량 이벤트 전달을 위해서 전달 대상에게 보내기 전에 메모리상에 키와 밸류 값으로 임시로 등록하여 저장하는 역할을 수행한다. 즉, 이벤트 저장부(220)는 대용량 데이터를 전달받아 저장할 수 있는 키-밸류 기반의 인 메모리 그리드를 활용하여 해당 이벤트를 자동으로 저장한다. 여기서, 해당 인 메모리 그리드는 메모리에 데이터를 분산시켜 저장하는 방식을 말하는데, 데이터를 메인 메모리에 저장하고 확장성(Scalability)을 보장하고 객체 자체를 저장할 수 있도록 한다.

조금 더 자세히 설명하면, 해당 인 메모리 그리드는 메인 메모리의 최대 용량을 넘는 데이터를 처리하고 장애 발생시에 데이터 손실이 없도록 하기 위해서, 키와 밸류 값을 이용하여 데이터를 분산시켜 임시로 저장해 두도록 하는데, 인 메모리 그리드가 제공하는 클라이언트 라이브러리가 있고, 해당 라이브러리를 이용하여 인 메모리 그리드에 접근하도록 한다.

클러스터 매니저부(230)는 대용량 이벤트 전달을 위해서 이벤트 저장부(220)의 이벤트 퍼블리셔 레파지토리의 클러스터 구성을 관리하는 역할을 수행한다.

이벤트 분배부(240)는 이벤트 저장부(220)에 저장된 이벤트를 전달 대상의 현재 접속 상태 및 위치에 맞게 분배해 준다. 즉, 이벤트 수신부(210)로부터 수신되는 이벤트를 개별적으로 우선 순위를 판단하고, 해당 시점에 전달 대상의 접속 상태를 인지하고 전달 대상의 상태에 따른 최적화된 전송부(250)로 분배하는 역할을 수행한다.

전송부(250)는 이벤트 분배부(240)에서 분배되는 실제 이벤트를 전달 대상에게 푸쉬하는 역할을 수행하며, 이벤트 분배부(240)에 의해서 전달 대상에 따라 최적화된 다양한 푸쉬를 적용해 주도록 한다.

또한, 전송부(250)는 웹 전송부(WEB Transmitter)(251), 모바일 전송부(Mobile Transmitter)(252), RIA(Rich Internet Application) 전송부(253), 메시지 전송부(Message Transmitter)(254) 등을 포함할 수 있으며, 또는 이것들 중 적어도 하나 또는 그 이상을 포함할 수도 있다.

웹 전송부(251)는 웹 기반(Web based)로 개발된 애플리케이션(Application)에 이벤트를 푸쉬하기 위해서, TCP/IP 세션 및 자바 스크립트(Java Script) 기반 서버 사이드 스크립트(Server Side Script)를 활용하여 이벤트를 푸쉬하여 전달해 준다.

모바일 전송부(252)는 모바일 애플리케이션(Mobile Application)으로 이벤트를 푸쉬하기 위해서, 개별 디바이스(Device)와의 TCP/IP 세션을 이용하여 이벤트를 전달해 준다.

RIA 전송부(253)는 FLEX, Html5 등의 RIA에게 이벤트를 전달하기 위해 관련된 스트리밍(Streaming) AMF(Action Message Format)와 웹 소켓(Web Socket)으로 구현된 이벤트 전달자로서, 스트리밍 AMF와 웹 소켓을 이용하여 이벤트를 전달해 준다.

메시지 전송부(254)는 메일(Mail), SMS(Short Message Service), SNS(Social Network Service) 등의 다양한 전달 대상을 위해서 API(Application Program Interface)로 구현된 이벤트 전달자로서, API를 이용하여 이벤트를 전달해 준다.

상술된 구성을 가지는 본 발명의 일 실시예에 따른 이벤트 처리 시스템은, SOP로 단일화된 이벤트 처리 인터페이스를 제공하고, 이벤트의 생명 주기를 관리하며, 대용량 데이터를 전달받아 저장할 수 있는 키-밸류 기반의 인 메모리 그리드를 활용하여 해당 이벤트를 자동으로 이벤트 저장부(220)에 저장하고 이벤트 분배부(240)에서 분배하며, 전달 대상의 접속 환경 변화를 인지하여 동작하는 실시간 푸쉬 전달자들(250)을 구성하여 이벤트의 전달 보장성을 향상시켜 줄 수 있다.

일 실시예에서, 이벤트 퍼블리셔(200)는, 스케쥴러부(Scheduler)(260)를 더 포함할 수 있다. 이때, 스케쥴러부(260)는 주기적으로 전달되어야 하는 이벤트를 관리하는 역할을 수행하는데, 주기적으로 이벤트를 재 처리할 수 있도록 하기 위해서 이벤트를 관리하여 이벤트 분배부(240)로 하여금 이벤트를 전달하도록 해 준다.

도 2 및 도 3은 본 발명의 일 실시예에 따른 이벤트 처리 방법을 설명하는 순서도이다. 여기서, 도 2는 도 1에 도시된 SOP 엔진의 동작을 나타낸 예시도이다.

일 실시예에 따른 SOP 기반 SOP 엔진의 작동을 도 2를 참조하면 살펴보면, SOP 엔진(100)은 자동화 시스템으로서, 이벤트가 관제 대상 디바이스 또는 내부의 보안 및 관제 시스템에 수신될 때에, 해당 수신된 이벤트에 대해서 공통으로 대응되어야 할 SOP를 표준화하여 관리자에게 제공하도록 해 준다. 이때, 디바이스 및 내부 시스템에 수신된 이벤트는 그의 중요도를 기반으로 SOP를 사용자에 의해 사전에 정의되어 있다.

이에, 디바이스 및 내부 시스템이 사용자에 의해 사전에 정의된 이벤트를 수신하게 되면, SOP 엔진(100)에서는 해당 이벤트가 수신되었을 때에 해당 수신된 이벤트에 대응하여 사전에 정의된 SOP 프로세스를 자동 호출하여 진행시켜 준다.

다시 말해서, SOP 프로세스부(110)는 수신된 이벤트를 확인하여 사용자에 의해 사전에 SOP이 정의된 이벤트인지(즉, SOP 정의 여부)를 확인하며(S201), 해당 단계 S201에서 사용자에 의해 사전에 SOP이 정의된 이벤트인 경우에 기본 업무 프로세스를 기반으로 사용자에 의해 정의된 이벤트 별 SOP를 처리(즉, SOP 프로세스 진행)하도록 한다(S202).

그리고 SOP 엔진(100)에서는 상술한 단계 S202에서 진행된 SOP 프로세스 하위의 세부 태스크도 실제 모니터링 및 제어하는 표준 업무에 기반하여 동작을 수행하도록 한다.

이때, SOP 태스크부(120)는 SOP 프로세스부(110)에서 처리한 이벤트 별 SOP로 진행되는 세부 태스크가 존재하는지(즉, SOP 태스크 존재 여부)를 확인하며(S203), 해당 단계 S203에서 세부 태스크가 존재하는 경우에 실제 이벤트의 액션(즉, SOP 태스크)을 진행하도록 한다(S204).

그런 다음에, 이벤트 송신부(130)는 전달 대상을 지정하여 이벤트 퍼블리셔(200)로 이벤트 전달을 지시해 주는데, 이때 이벤트 전달 지시가 있는지를 확인하게 된다(S205).

이에, 상술한 단계 S205에서 이벤트 전달 지시가 없는 경우에, SOP 태스크부(120)는 실제 이벤트의 액션(즉, SOP 태스크) 진행이 완료되었는지를 확인하도록 한다(S206). 이때, 해당 단계 S206에서 SOP 태스크 진행이 완료되지 않은 경우에, 상술한 단계 S204로 복귀하여 SOP 태스크부(120)는 SOP 태스크를 계속해서 진행하도록 한다.

반면에, 상술한 단계 S203에서 세부 태스크가 존재하지 않는 경우, 또는 상술한 단계 S206에서 SOP 태스크 진행이 완료된 경우에, SOP 프로세스부(110)는 사용자에 의해 정의된 이벤트 별 SOP를 처리(즉, SOP 프로세스 진행)가 완료되었는지를 확인하도록 한다(S207).

이때, 상술한 단계 S207에서 SOP 프로세스 진행이 완료되지 않은 경우에, 상술한 단계 S202로 복귀하여 SOP 프로세스부(110)는 SOP 프로세스를 계속해서 진행하도록 한다. 반면에, 상술한 단계 S207에서 SOP 프로세스 진행이 완료된 경우에, SOP 프로세스부(110)는 SOP를 종료하도록 한 후에(S208), 상술한 단계 S201로 복귀하여 수신된 이벤트를 확인하여 SOP 정의 여부를 확인하는 동작을 계속해서 수행하도록 한다.

이때, 모든 SOP 프로세스가 종료하게 되면, SOP 프로세스부(110)는 해당 이벤트에 대한 시스템적인 관제 업무 처리가 끝났음을 의미하고 해당 이벤트의 생명 주기를 종료하도록 한다.

상술한 바와 같이, 자동화된 SOP 관리 시스템인 SOP 엔진(100)은 수신된 이벤트의 생명 주기를 도 2에 도시된 바와 같이 시스템적으로 처리하도록 한다. 여기서, SOP는 하나의 이벤트에 등록되는 표준 업무 처리 절차로서, 해당 이벤트 수신 시에 시작되고, SOP 프로세스의 종료는 관리자의 조작 또는 자동화되어 처리되도록 한다. 또한, SOP 태스크 중에는 내부 또는 외부 업무 및 시스템에 효과적으로 이벤트를 전파하는 내용이 포함되며, 이때 해당 이벤트를 효율적으로 전달 대상에게 전파하기 위해 이벤트 퍼블리셔(200)를 이용하게 된다.

즉, 상술한 단계 S201에서 사용자에 의해 사전에 SOP이 정의된 이벤트가 아닌 경우, 또는 상술한 단계 S205에서 이벤트 전달 지시가 있는 경우, 이벤트 송신부(130)는 전달 대상을 지정하여 디바이스 및 내부 시스템에 수신된 이벤트를 이벤트 퍼블리셔(200)로 전달해 준다(S209).

도 3은 도 1에 도시된 이벤트 퍼블리셔의 동작을 나타낸 예시도이다.

일 실시예에 따른 SOP 기반 이벤트 퍼블리셔의 작동을 도 3을 참조하면 살펴보면, 이벤트 수신부(210)는 전달할 이벤트를 SOP 엔진(100)으로부터 수집하는데, SOP 또는 타 애플리케이션으로부터 전달 대상과 전달 이벤트를 수신받고(S301), 해당 수신받은 전달 대상과 전달 이벤트를 이벤트 저장부(220)에 등록해 준다(S302). 여기서, 이벤트 저장부(220)는 이벤트 수신부(210)에서 수집한 이벤트를 임시적으로 저장하는 인 메모리 그리드 이벤트 레파지토리이다.

이때, 이벤트 수신부(210)는 SOP 또는 타 애플리케이션으로부터 수신받은 이벤트를 키와 밸류 형식으로 이벤트 저장부(220)에 등록하는데, 이벤트 전달 대상이 미리 정의한 자신의 접속 상태 값을 수신하여 해당 수신한 접속 상태 값을 이벤트와 동시에 이벤트 저장부(220)에 등록해 준다.

더불어, 이벤트 수신부(210)는 다양한 접속 환경에 동시다발적인 이벤트 전송 등록도 이벤트 저장부(220)에 가능하며, 이벤트의 중요도에 따라 우선 순위 등록도 이벤트 저장부(220)에 가능하다.

그리고 클러스터 매니저부(230)는 대용량 이벤트 전달을 위해서 이벤트 퍼블리셔 레파지토리의 클러스터 구성을 관리하도록 하며, 또한 스케쥴러부(260)는 주기적으로 전달되어야 하는 이벤트를 관리하여 이벤트 분배부(240)로 하여금 이벤트를 전달하도록 해 준다.

이에, 이벤트 분배부(240)는 수신받은 이벤트가 이벤트 저장부(220)에 등록되는 시점에 이벤트 드리븐으로 동작하며, 우선 순위와 해당 전달 대상의 현재 접속 상태를 판단하며(S303), 해당 판단 결과에 맞는 전송부(250)로 이벤트를 분배해 주게 된다(S304).

이에 따라, 전송부(250)는 각 개별 전송부(251 ~ 254)에서 전달 대상의 접속상태 및 위치에 맞게 효과적으로 이벤트를 푸쉬하도록 하는데, 즉 이벤트 분배부(240)에서 분배되는 실제 이벤트를 전달 대상에 따라 다양하게 푸쉬하도록 한다(S305).

이때, 이벤트 전달자의 종류로는, 웹 기반 전달 대상을 위한 웹 소켓 및 서버 사이드 자바 스크립트를 이용하는 웹 전송부(251), 디바이스와의 TCP/IP 세션을 활용하는 모바일 전송부(252), Flex, Html5 등의 RIA 클라이언트(Client) 등에 스트리밍 AMF와 웹 소켓을 활용하는 RIA 전송부(253), SMS, 메일, SNS 등에 이벤트를 전파하기 위해 정의된 API를 활용하는 메시지 전송부(254) 등이 있다. 해당 전송부(251 ~ 254)를 활용하여 인지된 전달 대상의 접속 상태에 최적화된 방안으로 이벤트를 푸쉬하는 서비스를 제공하게 된다.

그런 다음에, 스케쥴러부(260)는 상술한 단계 S305에서 정상적으로 이벤트가 전달되었는지(즉, 전달 성공 여부)를 확인하며(S306), 이때 해당 단계 S306에서 이벤트가 전달되지 않았다면, 즉 전달 실패 시에 스케쥴러부(260)는 주기적으로 이벤트를 재 처리할 수 있도록 하기 위해서 주기적으로 전달되어야 하는 이벤트를 관리하여(S307) 이벤트 분배부(240)로 하여금 이벤트를 전달하도록 한 다음에, 상술한 단계 S303을 수행하도록 해 준다.

반면에, 상술한 단계 S306에서 이벤트가 전달되었다면, 수집되어 SOP 기반으로 처리되던 이벤트를 전달 대상의 상태에 최적화시켜 전달 완료하게 된다. 이때, 최종 개별 전송부(251 ~ 254)는 수집된 이벤트를 전달 대상의 상태에 최적화된 이벤트 푸쉬 서비스를 수행하게 되는 것이다.

상술된 과정을 가지는 본 발명의 일 실시예에 따른 이벤트 처리 방법은, 단편적인 자동 처리 업무 절차를 제공하고 이벤트 전송이 별도의 프로세스와 단편적인 전달자들로 구성되어 있어 대용량 이벤트의 전달에도 적합하지 않는 종래의 기술과는 다르게, 이벤트 별 우선 순위에 의거한 SOP를 자동화하며, SOP 태스크 이벤트 전파 시에 이벤트 퍼블리셔(200)를 통해 전달 대상의 접속 상태를 파악한 후, 그에 맞는 전송부(251 ~ 254) 를 선택하고, 대용량 이벤트 처리를 위한 이벤트 드리븐, 인 메모리 그리드 레포지토리, 멀티채널 전송기의 기반이 제공되며, 전달 대상의 접속 상태에 최적화된 다양한 이벤트 푸쉬 전송부(250)를 활용함으로써, 이벤트에 대한 자동화된 생명 주기 관리 및 전달 보장성을 향상시킬 수 있다.

상술한 바와 같이, 본 발명의 일 실시예에 따른 이벤트 처리 시스템 및 방법은, 롱 폴링(Long Polling), 스트림(Streaming), TCP/IP 세션(Session) 기반의 데이터 푸쉬 방안 및 SOP를 활용한 관제 프로세스 자동화에 있어서, SOP 엔진에 의해 자동으로 진행되는 이벤트 처리 방안을 제공하며, 대량의 이벤트를 원활하게 처리할 수 있는 기반 구성과 그 처리 방안을 제공하며, 인 메모리 그리드 기반으로 저장된 이벤트를 해당 시점 전달 대상의 접속 환경에 맞춰진 다양한 푸쉬 방안을 제공하는 기술에 대해서 설명하였다.

다시 말해서, 본 발명은 SOP에 기반한 인 메모리 그리드 통합 이벤트 퍼블리셔(Event Publisher)로, 관제 및 모니터링 업무 처리 시에 다수의 전달 대상에게 중요 이벤트를 정확하게 보낼 수 있도록, SOP를 기반으로 전달해야 할 이벤트를 수집 및 처리하고, 이벤트를 인 메모리 그리드 기반으로 저장하고, 해당 시점에 전달 대상의 접속 상태를 인지하여 해당 인지 결과에 따라 다양한 푸쉬 형태의 기술로 분배 및 전달하는 자동 처리 프로세스에 대해서 설명하였다.

상기에서는 본 발명의 바람직한 실시예를 참조하여 설명하였지만, 해당 기술 분야의 숙련된 당업자는 하기의 특허 청구의 범위에 기재된 본 발명의 사상 및 영역으로부터 벗어나지 않는 범위 내에서 본 발명을 다양하게 수정 및 변경시킬 수 있음을 이해할 수 있을 것이다.

100: SOP 엔진
110: SOP 프로세스부
120: SOP 태스크부
130: 이벤트 송신부
200: 이벤트 퍼블리셔
210: 이벤트 수신부
220: 이벤트 저장부
230: 클러스터 매니저부
240: 이벤트 분배부
250: 전송부
251: 웹 전송부
252: 모바일 전송부
253: RIA 전송부
254: 메시지 전송부

Claims

메모리에 미리 설정되어 있는 기본 업무 프로세스를 기반으로 사용자에 의해 이벤트 별로 미리 정의된 표준작업절차(SOP: Standard Operating Procedure)를 처리하고 상기 이벤트를 전달하는 SOP 엔진; 및
상기 SOP 엔진으로부터 전달받은 이벤트에 대한 우선순위를 판단하고 전달 대상의 유형 및 접속 상태를 인지하여, 상기 전달 대상의 상태에 따라 최적화된 푸쉬를 적용하여 상기 이벤트를 전송하는 이벤트 퍼블리셔를 포함하는 이벤트 처리 시스템.
제1항에 있어서, 상기 SOP 엔진은
상기 이벤트에 대한 우선순위를 판단하여 상기 우선순위를 기초로 이벤트 별로 대응되는 업무처리절차를 표준화한 상기 SOP를 자동화하는 것을 특징으로 하는 이벤트 처리 시스템.
제1항에 있어서, 상기 SOP 엔진은
기본 업무 프로세스를 기반으로 사용자에 의해 정의된 이벤트 별 SOP를 처리하는 SOP 프로세스부;
상기 SOP 프로세스부에서 처리한 SOP로 이벤트의 액션을 진행하는 SOP 태스크부; 및
전달 대상을 지정하여 이벤트를 상기 이벤트 퍼블리셔로 전달하는 이벤트 송신부를 포함하는 것을 특징으로 하는 이벤트 처리 시스템.
제1항에 있어서, 상기 이벤트 퍼블리셔는
상기 SOP 엔진으로부터 전달되는 이벤트를 키와 밸류 형식으로 등록하는 이벤트 수신부;
상기 이벤트 수신부를 통해 수신된 이벤트를 키와 밸류 값으로 저장하는 이벤트 저장부;
상기 이벤트 저장부의 이벤트 퍼블리셔 레파지토리의 클러스터를 관리하는 클러스터 매니저부;
상기 이벤트 저장부에 저장된 이벤트에 대해 우선 순위 및 전달 대상의 접속 상태를 인지하고, 전달 대상의 상태에 따라 이벤트를 분배하는 이벤트 분배부; 및
상기 이벤트 분배부에 의해 최적화된 푸쉬를 적용하여 이벤트를 전달 대상에게 전송하는 전송부를 포함하는 것을 특징으로 하는 이벤트 처리 시스템.
제4항에 있어서, 상기 전송부는
TCP/IP 세션 및 자바 스크립트 기반 서버 사이드 스크립트를 활용하여 이벤트를 푸쉬하는 웹 전송부,
개별 디바이스와의 TCP/IP 세션을 이용하여 이벤트를 푸쉬하는 모바일 전송부,
스트리밍 AMF와 웹 소켓을 이용하여 이벤트를 푸쉬하는 RIA 전송부, 및
API를 이용하여 이벤트를 푸쉬하는 메시지 전송부 중 적어도 하나를 포함하는 것을 특징으로 하는 이벤트 처리 시스템.
제4항에 있어서, 상기 이벤트 퍼블리셔는
주기적으로 전달되어야 하는 이벤트를 관리하는 스케쥴러부를 더 포함하는 것을 특징으로 하는 이벤트 처리 시스템.
표준작업절차(SOP: Standard Operating Procedure) 엔진을 통해 메모리에 미리 설정되어 있는 기본 업무 프로세스를 기반으로 사용자에 의해 이벤트 별로 미리 정의된 표준작업절차(SOP: Standard Operating Procedure)를 처리하고 상기 이벤트를 전달하는 단계; 및
이벤트 퍼블리셔를 통해 상기 SOP 엔진으로부터 전달받은 이벤트에 대한 우선순위를 판단하고 전달 대상의 유형 및 접속 상태를 인지하여, 상기 전달 대상의 상태에 따라 최적화된 푸쉬를 적용하여 상기 이벤트를 전송하는 단계를 포함하는 이벤트 처리 방법.
제7항에 있어서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는
상기 SOP 엔진에 수신되는 이벤트가 SOP이 정의된 이벤트인지를 확인하는 단계;
상기 SOP이 정의된 이벤트인 경우, 이벤트에 대응하는 SOP 프로세스를 자동 호출하여 진행시키는 단계;
상기 SOP 프로세스 하위의 세부 태스크가 존재하는지를 확인하는 단계;
상기 세부 태스크가 존재하는 경우, SOP 태스크를 진행시키는 단계; 및
이벤트 전달 지시 여부를 확인하여 전달 대상을 지정해 이벤트를 상기 이벤트 퍼블리셔로 전달하는 단계를 포함하는 것을 특징으로 하는 이벤트 처리 방법.
제8항에 있어서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는
상기 이벤트 전달 지시가 없는 경우, 상기 SOP 태스크의 진행이 완료되었는지를 확인하는 단계를 더 포함하는 것을 특징으로 하는 이벤트 처리 방법.
제9항에 있어서, 상기 SOP를 자동화하고 이벤트를 전달하는 단계는
상기 세부 태스크가 존재하지 않는 경우, 또는 상기 SOP 태스크의 진행이 완료된 경우, 상기 SOP 프로세스의 진행이 완료되었는지를 확인하는 단계를 더 포함하는 것을 특징으로 하는 이벤트 처리 방법.
제7항에 있어서, 상기 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 단계는
상기 SOP 엔진으로부터 수신되는 전달 대상과 전달 이벤트를 등록하는 단계;
상기 이벤트가 등록되는 시점에 이벤트 드리븐(event driven)으로 우선 순위와 전달 대상의 현재 접속 상태를 판단하는 단계;
상기 판단된 우선 순위와 전달 대상의 현재 접속 상태에 따라 이벤트를 분배하는 단계; 및
전달 대상의 접속 상태 및 위치에 맞게 상기 분배된 이벤트를 푸쉬하는 단계를 포함하는 것을 특징으로 하는 이벤트 처리 방법.
제11항에 있어서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는
이벤트 전달 대상이 미리 정의한 자신의 접속 상태 값을 수신하고 해당 수신한 접속 상태 값을 이벤트와 동시에 등록하는 것을 특징으로 하는 이벤트 처리 방법.
제11항에 있어서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는
다수 개의 접속 환경에 동시다발적인 이벤트를 등록하는 것을 특징으로 하는 이벤트 처리 방법.
제11항에 있어서, 상기 전달 대상과 전달 이벤트를 등록하는 단계는
이벤트의 중요도에 따라 우선 순위를 등록하는 것을 특징으로 하는 이벤트 처리 방법.
제11항에 있어서, 상기 분배된 이벤트를 푸쉬하는 단계는
웹 기반 전달 대상을 위한 웹 소켓 및 서버 사이드 자바 스크립트, 디바이스와의 TCP/IP 세션, 스트리밍 AMF와 웹 소켓, 또는 API를 활용하여 상기 분배된 이벤트를 전달 대상으로 전송하는 것을 특징으로 하는 이벤트 처리 방법.
제11항에 있어서, 상기 이벤트를 전달 대상의 유형 및 접속 상태에 따라 전송하는 단계는
상기 분배된 이벤트가 전달되었는지를 확인하는 단계; 및
상기 분배된 이벤트의 전달 실패 시에 주기적으로 이벤트를 재 처리할 수 있도록 주기적으로 전달되어야 하는 이벤트를 관리하는 단계를 포함하는 것을 특징으로 하는 이벤트 처리 방법.