런타임 엔진 서버

AnyLink 서비스 플로우 엔진(Service Flow Engine)은 이벤트에 의해 트리거되는 프로세스 실행 엔진이다. 서비스 플로우 엔진이 처리하는 이벤트는 어댑터 등의 다른 컴포넌트가 넘겨주는 메시지이다.

서비스 플로우는 비즈니스 프로세스를 모델링하는 데 사용되는 표준인 BPMN(Business Process Modeling Notation)을 차용한 다이어그램을 통해 프로세스의 흐름을 표현한다. BPMN은 OMG(Object Management Group)에서 정의하고 있는 비즈니스 프로세스를 표현하는 모델링과 표기법 표준으로 비동기적이며 동시성이 필요한 프로세스를 잘 표현할 수 있다.

서비스 플로우는 스튜디오를 통하여 액티비티와 이벤트로 구성된 다이어그램 형태로 정의하며, 프로세스 흐름 외에 변수, 표현식, 매핑, 핸들러, 사용자 액티비티 등의 기능을 추가로 제공한다.

서비스 플로우는 어댑터 등의 컴포넌트로부터 전달된 메시지에 의해 만들어지며, 다른 어댑터 혹은 서비스 플로우를 호출하거나 메시지를 주고 받을 수 있다. 또한 조건 분기, 선택적 실행, 동시 실행 등의 기능을 가지며, 흐름을 제어하기 위한 상태를 저장하는 변수 개념을 가진다.

AnyLink 서비스 플로우 엔진은 비동기적이고 동시성이 필요한 프로세스를 잘 실행할 수 있는 특별한 아키텍처를 가지고 있으며, 엔진에 할당된 스레드 풀을 통해 프로세스를 실행한다.

AnyLink 런타임 엔진 서버에서 어댑터(Adapter)는 AnyLink가 연계해야 하는 각 대상들과의 연계를 쉽게 해주는 역할을 한다. 연계 대상의 프로토콜에 맞추어 입출력 처리를 통한 연계를 하거나, 연계 대상 애플리케이션의 라이브러리를 사용한 연계 등을 실행한다.

AnyLink 어댑터는 입출력의 방향에 따라 크게 인바운드 룰과 아웃바운드 룰 두 가지 룰을 정의할 수 있다.

프로토콜에 따라 인바운드 룰의 요청 메시지와 아웃바운드 룰의 응답 메시지의 구분이 어려운 경우가 있다. 이를 효율적으로 처리하기 위해 AnyLink는 외부 시스템으로부터 들어오는 메시지 파싱 룰(parsing rule)을 통해서 인바운드 룰의 요청 메시지인지 혹은 아웃바운드 룰의 응답 메시지인지 여부를 판단할 수 있게 설계되었다.

멀티바인딩 라우터(Multi-Binding Router)는 서비스 컴포넌트 내부적인 라우팅이 실행 시점에 동적으로 이루어질 수 있는 컴포넌트 간 라우팅 기능을 담당하는 컴포넌트이다.

AnyLink는 내부적으로 컴포넌트 간에 메시지를 주고받는 방식으로 다른 컴포넌트를 트리거링(triggering)한다. 기능의 이름과 특정한 형태의 요청 메시지 자료형과 응답 메시지 자료형, 오류 응답 메시지 자료형 등을 규격화하여 AnyLink에서는 서비스라고 한다.

AnyLink에서는 다음을 내부적으로 서비스로 사용한다.

본 절에서는 런타임 엔진 서버의 시스템 아키텍처에 대해서 설명한다.

런타임 엔진 서비스 컨테이너

런타임 엔진 서비스 컨테이너(RTE Service Container)는 컴포넌트의 라이프사이클을 관리하고 컴포넌트에 필요한 서비스들을 정의하고 제공하는 역할을 한다. 서비스 플로우 엔진, 멀티바인딩 라우터, 어댑터 관리자 등을 실행시켜주는 역할을 한다.

주요 서비스로 내부 통신 채널인 딜리버리 채널(Delivery Channel), 서비스 플로우 엔진과 어댑터 룰 등의 배포와 적재를 관리해주는 리소스 관리자, 스레드 풀과 로깅 등과 같은 시스템 자원을 관리하는 시스템 리소스 관리자, 각종 룰과 플로우에 사용되는 자바 코드들을 로드하기 위한 비즈니스 클래스 로더(Business ClassLoader) 등을 제공한다.

서비스 플로우 엔진 컴포넌트와 멀티바인딩 라우터 컴포넌트는 컨테이너별로 하나만 존재하며 어댑터 컴포넌트는 어댑터 종류별로 여러 개가 존재할 수 있다. 어댑터 컴포넌트는 어댑터 관리자가 기동 및 적재를 담당한다. 멀티바인딩 라우터 컴포넌트는 딜리버리 채널 내부에 존재하는 컴포넌트로 서비스를 라우팅할 때 서비스 ID 외에 다른 방식으로 라우팅을 하기 위한 컴포넌트이다.

엔진 아키텍처

AnyLink 엔진은 효율적으로 대량의 입출력 채널을 관리하는 I/O 구조와 스레드 자원의 낭비를 최소화하는 비동기적 프로세싱 구조를 가지고 있다.

AnyLink 주요 통신 어댑터는 I/O 멀티플렉싱 방식의 입출력 처리를 하며, 특정 I/O 채널의 버퍼링에 다른 채널 처리가 영향받지 않도록 full non-blocking 방식의 처리를 구현하고 있다. 스레드 풀에서 주로 실행되는 서비스 플로우 엔진은 wait 시간을 최소화하도록 최대한 비동기적 특성을 가지도록 구현되어 있어서, 다수의 서비스 플로우가 동시에 실행되더라도 스레드 풀 부족으로 지체되지 않도록 고안되었다.

딜리버리 채널(Delivery Channel)은 미리 정의된 유형의 메시지 패턴을 통해 서비스 컴포넌트들간의 내부 통신을 비동기적인 방식으로 지원하는 서비스이다. 서비스 컴포넌트들 간의 의존성을 줄여주는 핵심 아키텍처이며, 메시징 API에 따라 적절한 스레드 풀을 사용하는 등의 기능을 가지고 있다.

런타임 엔진 서비스 컨테이너는 딜리버리 채널 외에도 런타임 운영에 필요한 서비스들 제공한다.

AnyLink 런타임 엔진 내부의 서비스 컴포넌트 간 통신 채널인 딜리버리 채널에서 하나의 서비스 컴포넌트로 다른 서비스 컴포넌트로 메시지를 전달할 때 발생하는 에러 처리가 있다. 이 부분은 시스템 내부적인 오류이므로 AnyLink 사용자가 고려할 필요는 없지만, 내부적인 동작 방식을 이해하는 데 도움이 될 수 있다.

엔진 내부의 서비스 컴포넌트들 간의 통신을 담당하는 딜리버리 채널은 응답과 에러 응답을 구분하여 보내도록 구성되어 있다. 딜리버리 채널의 에러 응답은 서비스 컴포넌트에서 메시지를 처리하다가 내부적으로 오류가 발생하였을 때 이 에러를 응답으로 보내기 위한 것이다.

딜리버리 채널의 에러 응답은 업무적 관점의 비정상 응답과는 다르다. 업무적 관점의 비정상 응답은 딜리버리 채널에서는 정상 응답과 마찬가지로 응답 메시지를 통해 전달되어야 한다. 즉, 각 서비스 컴포넌트들은 비정상 응답 메시지를 보낼 때에는 딜리버리 채널에서 정상 응답 메시지를 보내는 방식과 동일한 API를 사용하고, 에러를 보낼 때에는 에러를 전달하는 별도의 API를 사용한다.

AnyLink 서비스 플로우 정의는 내부적으로 에러 이벤트와 에러 핸들러, 에러 코드 매퍼를 정의하고 있다 또, 서비스 요청에 대한 비정상 응답을 처리하는 메커니즘도 정의하고 있다.

어댑터는 파싱 룰에서 응답 메시지 외에 비정상 응답 메시지를 정의하고 있으며, 어댑터의 엔드포인트에서 내부 시스템 에러가 발생했을 때 시스템 에러 메시지를 정의할 수 있도록 하고 있다.

어댑터는 파싱 룰과 아웃바운드 룰에서 각각 요청 메시지와 응답 메시지, 비정상 응답 메시지를 정의하게 되어 있다. 또 시스템 에러, 포맷 에러 등 다양한 에러 시나리오에 대한 대응을 지정할 수 있도록 룰이 설계되어 있다. 어댑터의 에러 처리에 대한 상세 내용은 해당 어댑터 안내서를 참고할 수 있다.