다운로드 Oracle SOA Suite 10g Oracle JDeveloper 10g Sample code Sample application

태그 middleware, integration, SOA

Enterprise Service Bus를 이용한 Event-Driven Architecture의 구현

간단한 예를 통해 ESB를 이용하여 엔터프라이즈 이벤트를 "배포(publish)"하는 방법을 배워 보십시오.

게시일: 2007년 2월

SOA(Service-Oriented Architecture)에서 가장 중요한 개념의 하나로 Event-Driven Architecture(EDA)를 꼽을 수 있을 것입니다. 프로그램 코드의 트리거 영역을 버튼 클릭, 필드 값 변경, 쿼리 입력 등의 이벤트에 연결(hook in)할 수 있는 JavaScript, 4GL 이벤트 메커니즘과 마찬가지로, EDA는 "서비스"를 "비즈니스 이벤트"에 연결하는 방법을 정의하고 있습니다.

주문 입력, 견적 요청, 직원 채용, 물품 배송과 같은 대부분의 비즈니스 이벤트는 기업 내부적으로 다양한 이벤트를 발생시키는 일종의 트리거로서 작용합니다. 좀 더 세부적으로 들여다 본다면, 프로세스 단계별로 발생하는 이벤트(예: 서비스 호출 실패, 사전정의된 임계치의 초과)가 외부의 다른 이벤트를 유발시킬 수 있습니다.

EDA는 이러한 이벤트들을 중앙의 이벤트-핸들링 백본으로 배포하고 외부에서 확인할 수 있게 하는 메커니즘을 제공하고 있습니다. 이벤트를 발생시키는 프로세스/서비스는 이러한 외부 프로세스/서비스의 존재와 무관하게 동작해야 합니다. 그렇지 않은 경우, 프로세스간의 종속관계로 인해 실행이 제약될 수 있으며 유지보수 작업의 복잡도가 끔찍한 수준으로 높아질 수 있습니다.

본 문서에서는 Oracle ESB를 기반으로 한 간단한 예제를 통해 이벤트를 외부 프로세스/서비스에 배포하기 위한 이벤트-핸들링 백본의 설정 방법을 배워 보겠습니다. (이 튜토리얼의 과정을 따라 하기 귀찮은 분들은 "결론" 섹션의 링크에서 완성된 JDeveloper 애플리케이션을 다운로드하실 수 있습니다.)

배경 정보

Oracle ESB는 몇 가지 핵심적인 기능을 제공하고 있습니다. 첫 번째로, Oracle ESB는 JMS, 웹 서비스 호출, 파일 시스템, 데이터베이스 테이블 등 메시지(이벤트 통보)를 접수하기 위한 다양한 방법을 제공합니다. 또 이벤트 데이터가 저장된 메시지를 추출하여 보다 정격화, 표준화된 엔터프라이즈 모델로 변환하는 기능을 제공합니다.

또 ESB는 하나의 "coarse-grained" 이벤트 메시지를 다수의 "fine-grained" 메시지로 변환하는 기능을 제공하고 있습니다. 예를 들어 고객이 웹 기반 Consumer Ordering 시스템을 통해 최초 주문을 실행했을 때 발생된 메시지로부터 New Customer 이벤트와 New Order 이벤트를 동시에 발생시킬 수 있습니다. 하나의 메시지를 다수의 정격화된 메시지로 변환하는 과정에서, ESB는 컨텐트를 보강하기 위한 기능을 추가로 제공합니다. 예를 들어, 현재 날짜 및 타임스탬프 정보를 추가하거나 레퍼런스 데이터 소스로부터 조회된 정보를 추가하는 것이 가능합니다.

마지막으로, 이벤트의 특성(메시지의 컨텐트)를 기반으로 웹 서비스, JMS, 데이터베이스 프로시저/테이블, 이메일 등의 다양한 출력 경로로 메시지를 변환하는 것이 가능합니다.

(참고: 이벤트 리포터의 대표적인 예로 BPEL 프로세스를 들 수 있습니다. BPEL 프로세스가 실행되는 과정에서 웹 이벤트를 호출하는 방식으로 이벤트를 배포할 수 있는 경우가 자주 있습니다.)

ESB로부터 전달된 메시지를 접수/처리하는 방법에도 여러 가지가 있습니다.

• ESB가 모든 메시지를 JMS 토픽 형태로 전달하고, 각각의 프로세스/서비스가 메시지의 수신/변환 방법을 직접 정의하도록 설정할 수 있습니다.
• 메시지의 확인을 원하는 각 시스템은 ESB로부터, 다시 말해 이벤트를 수신하고 다른 포맷으로 변환한 서비스로부터 직접 호출될 수 있습니다. 이를 위해서는 ESB 서비스가 각각의 서비스/프로세스를 위해 확장될 수 있어야 하며, 또 각 서비스/프로세스별로 추가적인 변환/필터링 규칙을 적용할 수 있어야 합니다.
• ESB는 이벤트의 수신을 위한 서비스, 메시지의 변환을 위한 서비스, 이벤트를 JMS로 배포하기 위한 서비스를 포함하고 있습니다. 또 각각의 서비스/프로세스를 위한 서비스가 별도로 존재합니다. 각 서비스/프로세스를 위한 서비스는 수신 서비스로부터 이벤트 메시지를 직접 수신하거나("coupled" 방식), 또는 JSM로부터 메시지를 읽어온 후("decoupled" 방식), 추가적인 변환 작업을 수행한 후 JMS, 웹 서비스, 데이터베이스 등을 통해 메시지를 전달합니다. 이 시나리오에서 이벤트(메시지)를 수신하는 서비스를 새로 추가하기 위해서는 독립적이고 느슨하게 커플링된(loosely coupled) 서비스를 ESB에 신규로 생성해야 합니다. 하지만 이 과정에서 일부 오버헤드가 수반되며, 이 오버헤드는 외부 JMS 토픽을 통해 복제되는 경향을 보입니다.

대부분의 경우에는 두 번째 접근법이 최선으로 간주됩니다. 이때 ESB 서비스 인스턴스로부터 호출되는 타겟 서비스는 병렬적으로 또는 순차적으로 호출이 가능함을 참고하시기 바랍니다.

Oracle ESB를 이용한 ESB 서비스의 개발

Oracle ESB는 Oracle Fusion Middleware의 웹 서비스 인프라스트럭처에서 ESB 컴포넌트를 담당하고 있습니다. 아래는 Oracle ESB를 이용하여 ESB 서비스를 개발하는 방법을 설명하고 있습니다.

본 문서에서는 신규 직원을 채용하는 상황을 가정하여 비즈니스 이벤트를 구현하고 있습니다. 새로운 이벤트가 계약서에 서명하면 이벤트가 ESB로 배포됩니다. 이벤트 메시지에는 직원의 이름, 나이, 성별, 직책 및 최초 업무 시작일 등의 정보가 포함됩니다. 이 이벤트가 전달되어야 하는 대상이 아래와 같습니다.

• Security 부서는 새로운 직원의 정보를 등록하고 시설 출입을 위한 배지를 발행해야 합니다.
• Finance 부서는 새로운 직원을 위한 급료 및 경비 보고서를 작성해야 합니다.
• Junior Managers Club은 40세 이하의 관리자들을 클럽 회원으로 가입시키고 있습니다. 따라서 이 조건을 만족하는 신규 직원이 채용된 경우, 이벤트가 전달되어야 합니다.

Oracle ESB를 사용하여 비즈니스 이벤트 서비스를 구현하는 방법이 아래와 같습니다.

NewEmployee 비즈니스 이벤트가 HR 부서를 통해 배포됩니다. (HR 부서는 이를 위해 ESB 웹 서비스를 호출합니다.) ESB 서비스는 이벤트를 수신하고 일부 변환 작업을 포함하는 3 가지 라우팅 룰을 실행합니다.

• SendNewEmployeeFileToJuniorManagerClub 타겟 서비스가 호출되어 타겟 디렉토리에 CSV 파일을 작성합니다.
• InformFinanceDepartmentOfNewEmployee 타겟 서비스가 호출되어 Finance 데이터베이스에 새로운 Employee 레코드를 작성합니다.
• NotifySecurityWebService가 호출되어 새로운 직원의 데이터를 포함하는 메시지를 전달합니다. 그리고 BPEL Workflow 프로세스가 시작되고 새로운 직원을 위한 보안 배지를 제작하기 위한 수작업 기반 절차가 진행됩니다.

새로운 Employee Event를 배포하기 위한 NewEmployee ESB 웹 서비스 호출이 발생하는 경우, 2 개 혹은 3 개(40세 이하의 매니저가 신규 채용된 경우)의 타겟 서비스가 실행됩니다. 이 아키텍처에서 핵심은, 이벤트 배포자(event publisher)와 이벤트 소비자(event consumer)간에 완벽한 디커플링(decoupling)이 가능하다는 점입니다. 다시 말해 이벤트 배포자(HR 부서)에 전혀 영향을 미치지 않은 상태에서 새로운 이벤트 소비자를 추가할 수 있습니다. New Employee 이벤트의 변경 사항은 Router Service에 의해 처리되며 따라서 이벤트 소비자에 영향을 미치지 않습니다.

이러한 이벤트를 위한 ESB 서비스를 개발하기 위한 작업 단계가 아래와 같습니다.

• Oracle SOA Suite 10.1.3.1 이후 버전을 다운로드하여 설치합니다.
• Oracle JDeveloper 10.1.3.1 이후 버전을 다운로드하여 설치합니다.
• Oracle SOA Suite를 시작합니다.
• JDeveloper를 실행합니다
• 1 단계 셋업을 수행합니다.

1 단계 셋업

셋업 과정이 아래와 같습니다:

1. 샘플 코드를 다운로드하고 임시 디렉토리에서 압축을 풉니다.
2. employees_table.sql 스크립트를 이용하여 사용자가 선택한 데이터베이스 스키마에 EMPLOYEES 테이블을 생성합니다. 나중에 이 테이블에 새로운 레코드를 INSERT하게 될 것입니다.
3. NewEmployeeEvent_Template.csv 파일을 JDeveloper에서 접근 가능한 디렉토리에 복사합니다. 나중에 File Adapter Wizard에서 이 파일을 ESB 서비스에서 작성하는 파일을 모델링하는 용도로 사용하게 될 것입니다.
4. 현재 디렉토리에 SecurityProcessingNewEmployee.zip 파일의 압축을 풉니다. 이 파일은 간단한 JDeveloper 10.1.3.1 프로젝트와 BPEL 프로세스( SecurityProcessingNewEmployee)를 포함하고 있습니다. 이 프로세스는 Security 부서에서 신규 직원의 배치를 제작하기 위한 BPEL Workflow Service를 호출합니다.
5. JDeveloper 10.1.3.1에서 SecurityProcessingNewEmployee 프로젝트를 로드합니다. 프로젝트를 SOA Suite 인스턴스의 BPEL PM에 적용(deploy)합니다. 나중에 ESB에서 EDA 서비스를 개발하는 과정에서 이 BPEL 프로세스가 필요하게 될 것입니다.

JDeveloper 애플리케이션의 생성

New Gallery로 이동하여 Projects, ESB Project 아이템을 선택합니다.

프로젝트의 이름을 NewEmployeeEventService로 설정합니다.

ESB 다이어그램이 열리면, System 생성을 위해 왼쪽 상단의 작은 아이콘을 클릭합니다.

ESB 서버에 프로젝트를 등록하면, ESB Console에서 생성한 시스템 또는 서비스 그룹을 사용할 수 있게 됩니다. Service는 System 또는 System 내 Group의 한 부분으로서 존재합니다. System과 Group은 서비스의 분류를 위한 방법으로 사용되며, 이 점에서 BPEL 프로세스의 Scope와 다르지 않습니다. System에서 중요한 점은, 서로 다른 System의 Target Service들은 Routing Service에 의해 병렬적으로 호출되는 반면, 동일한 System 내의 Target Service들은 순차적으로 호출된다는 사실입니다.

새로운 System의 이름을 NewEmployeeEventSystem으로 설정합니다.

ESB의 Event Handling service를 시작하기 전에, New Employee 이벤트가 발생했을 때 HR 부서에 어떤 타입의 메시지를 전달할 것인지 설정해 주어야 합니다. 이를 위해 이벤트에서 수신되는 XML 메시지의 구조를 정의하는 XML Schema Document(XSD)를 생성해야 합니다.

New Gallery로 이동하여 General, XML 노드를 선택한 후 아이템 목록에서 XML Schema를 클릭합니다. 새로운 XML Schema Document의 이름을 NewEmployeeEventMessage.xsd로 설정합니다.

이 스키마가 비교적 간단한 메시지 구조를 가지고 있으며, 다섯 가지 타입 엘리먼트를 포함하는 컴플렉스 타입으로 구현되어 있음을 참고하시기 바랍니다.

이제 ESB 탭으로 돌아가 서비스를 생성해 봅시다.

Component Palette에서 Routing Service 를 ESB Service로 드래그-앤-드롭 합니다. Routing Service의 이름을 입력하기 위해 Browse 버튼과 Type Chooser를 누른 뒤, NewEmployeeEventMessage스키마 정의에서 NewEmployeeEvent 스키마 엘리먼트를 선택합니다.

Routing Service에 대한 입력을 정의하는 XSD 엘리먼트를 선택하기 위한 Type Chooser 스크린샷이 아래와 같습니다.

여기서는 콜백을 포함하지 않는 비동기식 서비스를 생성하므로, Reply Message 또는 Fault를 설정할 필요가 없습니다.

외부 프로세스는 웹 서비스 인터페이스를 통해 NewEmployeeEventRS RoutingService를 직접 호출할 수 있도록 허용됩니다. 다른 채널이 이벤트 배포를 위해 사용되는 경우(예: FTP 서버에 Employee 파일을 올리거나, 데이터베이스 테이블 또는 JMS를 통해 신규 지원 정보가 입력되는 경우), ESB Service에 인바운드 Adapter Service를 추가하고, NewEmployeeEventRS로 메시지를 포워딩하도록 설정할 수 있습니다. 여기에서는 HR 부서가 웹 서비스 인터페이스를 사용하는 것으로 가정하기로 합니다.

이제 아웃바운드 어댑터를 설정할 차례입니다. 이 이벤트가 전달되어야 하는 대상은 Security Department, Finance Department, 그리고 Junior Managers Club입니다.

• Security 부서는 웹 서비스 엔드 포인트를 호출합니다. 이 웹 서비스는 수작업(배지 제작) 워크플로우를 포함하는 BPEL 프로세스의 프론트 엔드로서 기능합니다.
• Finance 부서는 데이터베이스 테이블에 저장된 신규 직원의 레코드를 조회하는 방식으로 이벤트를 확인합니다.
• Junior Managers Club은 특정 디렉토리에 저장된 CSV 파일을 통해 새로운 Junior Manager를 확인합니다. 파일의 포맷 확인을 위한 샘플 파일이 제공되고 있습니다.

이제 아웃바운드 서비스를 ESB Service에 추가해 봅시다.

ESB Diagrammer에서 File Adapter를 다이어그램에 드래그-앤-드롭 합니다. SCV 파일을 위한 File Adapter Service의 세부 정보를 정의하기 위한 팝업 윈도우가 표시됩니다.

서비스의 이름을 입력합니다. 그럼 다음 WSDL File 필드 옆에 위치한 Define Adapter Service 아이콘을 클릭합니다.

다음으로 File Adapter Configuration Wizard를 입력합니다. 첫 번째 페이지에서 Service의 이름을 입력합니다. (Create File Adapter 팝업 윈도우에서 정의한 이름을 확인합니다.)

Next 를 클릭하면 Operation 페이지가 표시됩니다. 이곳에서 서비스가 파일에 정보를 기록함을 정의하게 됩니다.

Step 3에서는 출력 디렉토리와 파일 이름의 명명 규칙을 정의합니다. 여기서는 디렉토리의 이름을 하드 코딩 방식으로 정의하기로 합니다(물론 서비스의 이식성을 고려한다면 바람직한 방법은 아닐 것입니다). 파일 이름을 정의하는 과정에서 날짜, 시간, 시퀀스 등의 여러 가지 다이내믹 엘리먼트를 이용할 수 있습니다(단, 동시에 두 가지의 다이내믹 엘리먼트를 사용할 수는 없습니다.)

Step 4에서 파일의 출력 포맷을 정의합니다. 이곳에서 정보를 어떻게 구조화할 것인지 결정해야 합니다. 여기에서는 CSV 파일을 사용하므로, Define Schema for native format 버튼을 누릅니다.

Native Format Builder에서는 File Adapter가 XML 데이터로부터 CSV 파일을 생성하는데 사용할 XSD를 생성합니다. Junior Manager Club이 공개한 샘플 CSV 파일을 이용합니다.

디폴트 값을 승인하고 Next 를 클릭합니다.

다음 페이지에서 파일을 브라우즈하거나 파일 이름/위치를 입력합니다. 그런 다음 Next 를 클릭합니다.

페이지 3의 디폴트 값을 승인하고 Next 를 클릭합니다.

다수의 레코드를 포함하되, 하나의 레코드를 대표하는 엘리먼트들의 이름을 입력합니다. (예: NewJuniorManagers와 NewJuniorManager) 참고: 이 엘리먼트들은 파일 서비스에 대한 매핑을 생성할 때 사용되며, 실제로 작성되는 파일에는 포함되지 않습니다.

페이지 5의 디폴트 값을 승인하고 Next 를 클릭합니다.

페이지 6에서 "Use the first record as the field names" 체크 박스를 체크합니다. 이와 같이 함으로서 XSD의 가독성을 높일 수 있지만, 서비스가 실제로 작성하는 파일의 내용과는 무관합니다.

다음 페이지에서는 File Adapter를 위해 마법사가 생성한 XSD 파일에 대한 개요 정보가 제공됩니다. 내용을 검토하고, Next 를 눌러 승인합니다.

Native Format Builder 마법사의 마지막 페이지가 표시됩니다. Finish 를 클릭합니다.

다음으로 File Adapter Configuration Wizard로 돌아가 Next 를 클릭합니다.

Finish 를 클릭합니다. 이제 Create File Adapter Service 팝업 윈도우로 돌아왔습니다. 다시 Finish 를 클릭합니다.

NewEmployeeEventService를 위한 ESB 다이어그램에 SendNewEmployeeFileToJuniorManagersClub 서비스가 추가되었습니다.

NewEmployeesRS 아이콘을 더블-클릭하고 NewEmployeeEvent 메시지를 타겟 서비스에 전달하기 위한 라우팅 룰을 설정합니다.

초록색 플러스 기호를 클릭하여 새로운 Routing Rule을 생성합니다. Browse Target Service 대화상자가 표시됩니다. 여기서 Routing Rule이 메시지를 어떤 서비스에 전달할 것인지 설정할 수 있습니다.

SendNewEmployeeFileToJuniorManagersClubd의 write 작업을 선택한 후 OK 를 클릭합니다.

두 부분으로 작성된 필터 표현식을 추가합니다. 한 표현식은 새로운 직원의 연령이 40세 이하이어야 함을, 다른 표현식은 직책이 매니저이어야 함을 명시합니다. 실제로 입력할 표현식이 아래와 같습니다:

/inp1:newEmployeeEvent/inp1:age < 40 and contains('MANAGER,PRESIDENT,
VICE PRESIDENT,TECHNOLOGY MANAGER,CFO,CHIEF,SUPERVISOR',/inp1:newEmployeeEvent/inp1:role)

이제 HR 부서로부터 수신한 메시지를 타겟 서비스로 전달하기 위해 변환하는 방법을 설정해야 합니다.

매핑 아이콘을 클릭합니다. 대화 상자에서 Create New Mapper File 옵션을 선택합니다.

OK 를 클릭합니다. Mapper 툴로 이동합니다. 여기서 두 개의 XSD 문서를 연결하고, 소스 XSD를 타겟으로 변환하기 위한 XSLT를 정의합니다.

먼저 NewJuniorManager 위에 newEmployeeEvent 엘리먼트를 드래그-앤-드롭하여 단순한 형태의 매핑을 생성합니다.

Match Elements Considering their Ancestor Names 체크박스의 선택을 해제합니다.

이제 두 번째 매핑을 정의할 차례입니다.

Role 엘리먼트가 아직 Position 필드에 매핑되지 않았습니다. 또 FirstDay 필드를 위한 날짜 포맷을 정의해 주어야 합니다.

role 을 position에 드래그-앤-드롭 합니다. 컴포넌트 팔레트의 format-dateTime Date Function을 firstDayAtWorkDate과 firstDay 간의 연결 위로 드래그-앤-드롭 합니다.

이제 Function 아이템을 더블 클릭하여 변환 방법을 정의합니다:

다음으로, Finance 부서의 요구 사항에 맞게 메시지를 설정해 줍니다.

SQL> desc employees
 Name                          Null?            Type
 ----------------------------  ---------------  ----------------------
 NAME                          NOT NULL         VARCHAR2(50)
 GENDER                                         VARCHAR2(1)
 JOB_TITLE                                      VARCHAR2(50)
 START_DATE                                     DATE

이제 타겟을 위한 어댑터 서비스를 생성해 줍니다. Database Adapter 를 이용하여 NewEmployeeEventRS를 위한 Target Service를 설정합니다. Component Palette의 Adapter Services 섹션에서 Database Adapter를 esb 문서로 드래그-앤-드롭 합니다. 아래와 같이 팝업 창이 표시됩니다.

Adapter Service의 이름을 입력하고 WSDL File 필드 다음의 첫 번째 아이콘을 클릭하여 데이터베이스 어댑터를 설정합니다.

New Database Connection 을 생성하여 FINANCE 스키마를 기업 데이터베이스에 연결합니다. (참고: "1 단계 셋업" 과정에서 EMPLOYEES 테이블을 생성했던 데이터베이스 스키마에 연결을 생성해야 합니다.):

연결의 이름을 설정합니다:

다음으로, FINANCE 스키마의 유저네임/패스워드를 설정합니다:

Next 버튼을 눌러 Connection 세부 정보를 입력합니다:

이 과정에서 호스트네임, 포트, 데이터베이스 SID와 같은 JDBC URL 상세 정보를 입력해 주어야 합니다. 작업이 완료되었다면 Next 를 클릭하여 연결을 테스트합니다.

모든 작업이 성공했다면, Finish 를 클릭합니다. 그렇지 않은 경우 문제를 찾아 해결합니다.

이제 Database Adapter Configuration Wizard로 돌아왔습니다. Next 를 클릭합니다.

서비스가 수행할 작업을 선택합니다: 여기에서는 새로운 레코드를 INSERT하는 작업이 필요합니다.

Next 를 클릭하면 Select Table 페이지가 표시됩니다. Import Tables를 클릭하고 FINANCE 데이터베이스에서 EMPLOYEES 테이블을 선택합니다.

Import Tables 를 클릭합니다. Query 버튼을 클릭합니다. FINANCE 스키마의 모든 테이블 목록이 표시됩니다. EMPLOYEES 테이블을 선택하고 OK를 클릭합니다.

다시 Select Table 마법사가 표시되면 Finish 를 클릭합니다.

이제 Create Database Adapter Service로 돌아왔습니다. OK 를 클릭합니다.

이제 esb 다이어그램으로 돌아왔습니다.

타겟 서비스를 NewEmployeeEventRS로 연결합니다. Router Service 아이콘을 더블 클릭합니다.

초록색 플러스 기호를 클릭하여 Routing Rule을 추가합니다.

InformFinanceDepartmentOfNewEmployeeEven에서 Event 작업을 선택한 후 OK 를 클릭합니다.

Mapping 아이콘을 클릭하여 NewEmployeeEvent로부터 Target Service로의 매핑을 정의합니다.

Create New Mapper File을 선택하고 OK 를 클릭합니다.

newEmployeeEvent 이벤트 엘리먼트를 top:Employees 엘리먼트로 드래그-앤-드롭 합니다.

Match Elements considering their ancestors 체크박스의 체크를 해제합니다.

자동 매핑을 통해 변환 작업의 첫 번째 단계가 수행됩니다:

이제 수작업으로 role 을 jobTitle 에, 그리고 firstDayAtWorkDate 를 startDate 로 매핑해야 합니다. 이를 위해 Source 엘리먼트를 Target 엘리먼트로 드래그-앤-드롭 합니다. 완성된 매핑 결과가 아래와 같습니다:

완성된 매핑 결과가 아래와 같습니다:

Save All 아이콘을 클릭합니다. 이제 거의 끝났습니다. 3 개의 부서 중 2 개의 부서가 NewEmployeeEvent와 연결되었습니다.

The Security Department. Security 부서는 웹 서비스를 통해 NewEmployeeEvent를 수신합니다. 이 웹 서비스는 수작업 기반의 워크플로우를 실행하는 BPEL 프로세스를 포함하고 있습니다.

ESB Service에서 이 BPEL 프로세스를 호출하는 새로운 Adapter Service를 생성하고 Router Service에 연결해야 합니다.

ESB Services Component Palette에서 SOAP Service 엘리먼트를 ESB 다이어그램에 드래그-앤-드롭합니다.

Create Soap Invocation Service 대화상자가 표시됩니다. 서비스의 이름을 입력합니다(예: NotifySecurityWebService). 그런 다음 Service Explorer 아이콘을 클릭합니다.

(기존 BPEL PM 인스턴스에 deploy된) SecurityProcessingNewEmployee 서비스를 선택합니다.

OK 를 클릭합니다.

다시 OK 를 클릭합니다.

Router Service를 더블 클릭합니다. 이제 새로운 Routing Rule을 추가하고 Soap Invocation Service를 Router Service에 연결해야 합니다.

초록색 플러스 기호를 클릭하여 새로운 Routing Rule을 추가합니다.

NotifySecurityWebService 타겟 서비스의 initiate 작업을 선택합니다.

OK 를 클릭합니다.

Mapping 아이콘을 클릭합니다.

Create New Mapper File 을 선택하고 OK를 클릭합니다.

RouterService newEmployeeEvent를 SecurityProcessingNewEmployeeEventRequest 메시지로 매핑합니다.

Save All을 누릅니다.

완성된 ESB 서비스가 아래와 같습니다:

Router Service를 ESB에 등록하기

이제 서비스를 ESB에 등록할 차례입니다. 현재 실행 중인 ESB에 연결되어 있지 않은 상태라면, 아래 섹션("ESB에 연결 생성하기")을 참고하여 연결을 설정합니다.

프로젝트에서 마우스 오른쪽 버튼을 누르고 Register with ESB 와 LocalESB_soasuite_10_1_3_1 연결을 선택합니다.

등록이 성공적으로 완료된 경우 표시되는 내용이 다음과 같습니다:

이제 ESB Console에서 적용된 서비스들을 확인할 수 있습니다.

NewEmployeeEventRS 서비스는 일반 웹 서비스로 호출될 수 있습니다. 또 서비스의 Definition 탭에서 WSDL의 위치를 확인할 수 있습니다:

EDA NewEmployeeEvent Routing Service의 실행

Enterprise Manager를 통해 OC4J 인스턴스에서 사용 가능한 웹 서비스가 무엇인지 확인하고 직접 테스트해 볼 수도 있습니다.

Test Service 버튼을 클릭합니다.

Test Web Service 를 클릭하여 아래 페이지로 이동합니다:

5 가지 필드에 값을 입력하고 Invoke 버튼을 누릅니다. Enterprise Manager 콘솔을 통해 확인할 수 있는 결과는 극히 제한적입니다. ESB Service가 비동기식으로 설정되었을 뿐 아니라 아무런 응답도 반환하지 않기 때문입니다:

ESB 콘솔에서 방금 생성한 웹 서비스 호출을 통해 트리거된 새로운 서비스 인스턴스를 확인할 수 있습니다:

또 3 가지 타겟 서비스가 모두 NewEmployeeEvent를 수신한 시점에 ESB 서비스에 의해 호출되었음을 확인할 수 있습니다.

이는 아래와 같은 사실을 의미합니다:

• Security 부서에 새로운 워크플로우가 대기 중임.
• Junior Managers Club에 새로운 CSV 파일이 전달 되었음.
• Finance 부서의 EMPLOYEES 테이블에 새로운 레코드가 입력되었음.

Worklist Application에서 JSTEIN(배지 제작을 담당하는 보안 책임자)으로 로그인해 봅시다:

아래와 같이 작업이 대기 중임을 확인할 수 있습니다:

또 Junior Managers Club에서 지정한 디렉토리를 확인한 결과가 아래와 같습니다:

이 파일을 열어 봅시다:

SQL> show user
USER is "FINANCE"
SQL> select *
  2  from    employees
  3       /

NAME                                                      G
--------------------------------------------------------- -
JOB_TITLE                                                 START_DAT
--------------------------------------------------------- ----------
Lex Jellema                                               M
MANAGER                                                   16-AUG-20

ESB에 대한 연결의 생성

ESB에 연결하여 새로운 서비스를 등록하기 전에, 애플리케이션 서버에 대한 연결을 설정해야 합니다.

SOA Suite 10.1.3.1에서 애플리케이션 서버 연결을 설정하는 방법이 아래와 같습니다:

New Gallery로 이동하여 Application Server Connection 옵션을 선택합니다.

Connection Type을 Oracle Application Server 10g 10.1.3 으로 선택합니다. 연결의 이름을 입력하고 Next 를 클릭합니다.

애플리케이션 서버 연결에 사용할 유저네임/패스워드를 입력합니다. 로컬 개발 환경의 경우에는 administrator/oc4jadmin을 입력하면 될 것입니다. Next 를 클릭합니다.

다음 화면에서는 연결할 애플리케이션 서버 인스턴스를 선택합니다. \opmn\conf 디렉토리의 opmn.xml 파일을 참조하여 정확한 값을 입력합니다. 이 파일에서 port 엘리먼트의 속성 값을 참조하시기 바랍니다.

정확한 값을 입력한 후 Next 를 클릭합니다.

Test Connection 을 클릭하고 Success! 상태가 표시될 때까지 기다립니다.

Finish 를 클릭합니다. 다시 New Gallery로 이동합니다. 이번에는 Integration Server Connection을 선택합니다. OK를 클릭합니다.

연결의 이름을 입력하고 Next 를 클릭합니다.

방금 생성한 애플리케이션 서버 연결을 선택합니다. 그런 다음 정확한 포트 번호를 입력합니다. (SOA_SUITE_HOME\install\esbsetupinfo.txt 파일에서 정확한 포트 정보를 확인하실 수 있을 것입니다.)

다른 문제가 없다면 Test Connection 버튼을 클릭하면 아래와 같은 결과를 확인할 수 있습니다:

결론

EDA를 이용한 지능형 이벤트 커뮤니케이션 인프라스트럭처를 기반으로, 느슨하게 커플링된(loosely coupled) 비즈니스 서비스 간의 비즈니스 이벤트 트리거 환경을 구현하고 이벤트와 연계된 작업을 수행할 수 있습니다.

이번 튜토리얼에서는 "직원 신규 채용" 비즈니스 이벤트를 Oracle ESB에서 처리하고, 서로 연관되지 않은 3 가지 비즈니스 서비스를 호출하여 각각 서로 다른 메커니즘과 출력 포맷을 적용하는 방법에 대해 알아 보았습니다. ESB는 이에 필요한 모든 라우팅, 필터링, 변환 작업을 수행해 주고 있습니다. 완성된 JDeveloper 애플리케이션은 이곳에서 다운로드할 수 있습니다.

지금까지 확인한 것처럼, 매우 간단한 작업만으로 Oracle JDeveloper와 Oracle ESB를 활용하여 기본적인 EDA 환경을 구현할 수 있습니다. 프로그래밍 기술은 전혀 필요하지 않으며 대부분의 작업을 마법사를 이용해 수행할 수 있습니다.