다이내믹 BPEL 프로세스의 구현
Sean Carey

런타임에 엔드포인트 레퍼런스(endpoint reference)를 조작하여 다이내믹 바인딩 환경을 구현하는 방법을 설명합니다.

전체 BPEL Cookbook 목록 보기

아티클 관련 다운로드: Oracle BPEL Process Managera 및 Designer

웹 서비스와 SOA(service-oriented architecture)는 서로 다른 비즈니스 프로세스 및 애플리케이션 간의 상호연동을 통해 비즈니스 프로세스를 수비게 확장할 수 있게 해 줍니다. BPEL 프로세스는 이러한 상호연동 과정을 파트너 링크(partner link)를 통해 정의합니다. 파트너 링크는 인터페이스(메시지 및 수행 작업), 전송 프로토콜, 그리고 사용 가능한 서비스의 위치 등에 대한 정의를 포함하고 있습니다.

기초적인 프로세스 설계 과정에서는 파트너 링크를 정적(static)으로 정의하는 것이 일반적입니다. 각 파트너 링크는 개발자가 디자인 타임에 지정한 단일 외부 프로세스를 참조합니다. 하지만 대규모 시스템에서는 비즈니스 프로세스가 보다 복잡한 구성을 갖습니다. 다수의 외부 서비스와 다수의 파트너 링크가 서로 연동하기도 하고, 파트너 링크들 중 일부는 디자인 타임에 정의되지 않을 수도 있습니다. 이와 같은 경우 파트너 링크의 선택에 관련한 로직은 비즈니스 프로세스 내부에 구현되어야 하며, 이로 인해 프로세스가 불필요하게 복잡해질 수 있습니다. 또 파트너 링크가 계속적으로 추가되면서 프로세스의 규모가 감당할 수 없는 수준으로 커질 수 있으며, 파트너 링크에 대해 변경 작업을 수행할 때마다 전체 비즈니스 프로세스를 수정해야 하는 문제가 생깁니다.

다행스러운 것은, BPEL 언어가 파트너 링크의 다이내믹 바인딩(dynamic binding)을 지원한다는 사실입니다. 다이내믹 바인딩은 개발자가 설정 파일을 통해, 또는 런타임 입력을 통해 새로운 서비스를 추가할 수 있게 합니다. 이러한 방법으로 전체 부모-자식 관계(parent-child relationship)을 디자인 단계에 예측하고 관리해야 할 필요성을 제거할 수 있습니다.

BPEL Cookbook 시리즈의 이번 연재에서는, 시스템이 파트너 링크를 런타임에 다이내믹하게 관리하도록 함으로써, 부모 프로세스와 서브 프로세스 간의 관계에 발생하는 변경 사항으로부터 BPEL 프로세스를 효과적으로 격리하는 방안에 대해 설명하기로 합니다. 또 다수의 BPEL 프로세스를 순차적 또는 병렬적인 방식으로 다이내믹하게 호출하는 방법에 대해서도 소개하겠습니다.

다이내믹 바인딩 개요

• 기능적인 컴포넌트를 개별 작업 단위로 분할함으로써, 팀 지향적인(team-oriented) 개발 환경을 지원합니다.
  
• 부모 프로세스(parent process)를 수정하고 다시 deploy하는 과정을 거치지 않고도 추가적인 서브프로세스 컴포넌트를 생성하고 deploy할 수 있게 합니다.
  
• 개별적인 중복 프로세스(overlapping process)들을 사용, 관리, 개선할 필요성이 줄어듭니다.
  
• 부모 프로세스는 서브프로세스의 변경 및 개선사항을 자동으로 액세스할 수 있습니다.

다이내믹 BPEL 프로세스의 구현

그림 1 portTypes의 실행 과정

DynamicPartnerLink 샘플의 이해

<partnerLink name="LoanService" partnerLinkType="services:LoanService" 
  myRole="LoanServiceRequester" partnerRole="LoanServiceProvider"/>

<partnerLinkBinding name="LoanService">
  <property name="wsdlLocation">LoanService.wsdl</property>
</partnerLinkBinding>

<service name="StarLoan">
 <port name="LoanServicePort" binding="tns:LoanServiceBinding">
  <soap:address location="http://localhost:9700/orabpel/default/StarLoan"/>
 </port>
</service>
  
<service name="UnitedLoan">
 <port name="LoanServicePort" binding="tns:LoanServiceBinding">
  <soap:address location="http://localhost:9700/orabpel/default/UnitedLoan"/>
 </port>
</service>  
  
<service name="AmericanLoan">
 <port name="LoanServicePort" binding="tns:LoanServiceBinding">
  <soap:address location="http://localhost:9700/orabpel/default/AmericanLoan"/>
 </port>
</service>  

<variable name="partnerReference" element="wsa:EndpointReference"/>

xmlns:wsa="http://schemas.xmlsoap.org/ws/2003/03/addressing"

DynamicPartnerLink 프로세스는 기본적으로 “switch” 구문으로 구성되어 있습니다. 이 프로세스는 호출자에 의해 전달된 “provider” 문자열을 점검한 뒤, 요청 서비스에 관련된 정보를 저장하기 위한 partnerReference 변수에 EndpointReference xml 데이터 구조를 할당합니다. “switch” 구문이 실행되고 나면, partnerReference 변수가 LoanService 파트너 링크에 할당되고 파트너 링크가 호출됩니다.

"united" 가 입력 문자열로 사용된 경우의 작업 실행 과정이 아래와 같습니다:

<assign>
 <copy>
  <from>
   <EndpointReference xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing">
   <Address>http://localhost:9700/orabpel/default/UnitedLoan</Address>
   <ServiceName 
     xmlns:ns1="http://services.otn.com">ns1:UnitedLoan</ServiceName>
   </EndpointReference>
  </from>
  <to variable="partnerReference"/>
 </copy>
</assign>

다이내믹 BPEL 프로세스의 생성

다이내믹 BPEL 프로세스를 생성하는 방법을 처음부터 설명해 보기로 하겠습니다.

1. 새로운 BPEL 프로젝트의 생성.
JDeveloper에서 asynchronous BPEL Process Project를 생성하고 이름을 “MyDL”로 설정합니다.

3. loan service 파트너 링크 템플릿의 생성.
마우스 오른쪽 버튼을 클릭한 다음 Create Partner Link....를 선택합니다. 그림 2와 같이 대화상자에 입력합니다. WSDL 파일의 위치를 지정하기 위해 (플래시라이트 버튼 왼쪽에 있는) Browse WSDL Files from Local File System 버튼을 클릭하고, MyDL 프로젝트 디렉토리에서 LoanService.wsdl 파일을 선택합니다. 입력이 완료되면 OK를 클릭하여 파트너 링크를 생성합니다.

그림 2 "Create Partner Link" 대화상자

5. loanInput 변수에 입력할 데이터 설정
사용자로부터의 loan input 데이터를 얻기 위해서는 일반적으로 MyDL.wsdl 파일을 수정하는 방법이 사용됩니다. 여기에서는 작업 편의상 loanInput 변수에 입력할 데이터를 하드코딩하는 방법을 사용하기로 하겠습니다. receiveInput 액션에 assign을 생성하고, 아래와 같이 loanInput의 SSN 엘리먼트에 "123456789"의 값(숫자가 아닌 문자열이므로 인용 기호를 반드시 붙여야 합니다)을 입력하는 copy rule을 생성합니다:

<assign name="PopulateSSN">
 <copy>
  <from expression="'123456789'"/>
  <to variable="loanInput" part="payload" query="/ns2:loanApplication/ns2:SSN"/>
 </copy>
</assign>

그림 3 "Variables" 트리의 확장

Variables를 마우스 오른쪽 버튼으로 클릭하고 Create Variable....를 선택합니다. 변수의 이름을 "partnerReference"로, 타입을 "Element." 로 설정합니다. Element 박스 옆에 위치한 flashlight 아이콘을 클릭하여 Type Chooser를 엽니다. Project WSDL Files → LoanService.wsdl → Inline Schemas → schema에서 "EndpointReference" 타입을 선택합니다 (그림 4 참고).

그림 4 "EndpointReference"의 선택

<EndpointReference xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing" 
  xmlns:ns1="http://services.otn.com">
     <Address/>
     <ServiceName/>
</EndpointReference>

<assign name="SetupPartnerlink">
  <copy>
    <from>
      <EndpointReference 
        xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing" 
         xmlns:ns1="http://services.otn.com">    
        <Address/>    
        <ServiceName/>
      </EndpointReference>
    </from>
    <to variable="partnerReference"/>
  </copy>
  <copy>
    <from expression="'ns1:UnitedLoan'"/>
    <to variable="partnerReference" query="/ns3:EndpointReference/ns3:ServiceName"/>
  </copy>
  <copy>
    <from expression="'http://localhost:9700/orabpel/default/UnitedLoan'"/>
    <to variable="partnerReference" query="/ns3:EndpointReference/ns3:Address"/>
  </copy>
</assign>

8. partnerReference 변수를 DynamicLoanService 파트너 링크에 복사
SetupPartnerlink 액션과 DynamicLoanService의 <invoke> 사이에 새로운 <assign>을 생성합니다. 새로운 copy rule을 생성하고 그림 5와 같이 설정합니다.

그림 5 새로운 copy rule의 생성

이 과정이 완료되고 나면, 다이내믹 BPEL 프로세스가 생성됩니다. 프로세스는 하드코딩된 어드레스 정보를 포함하고 있습니다. 7번째 단계에서 생성한 두 가지 copy rule을 런타임에 수집된 정보로 대체함으로써 완전한 다이내믹 BPEL 프로세스로 변경할 수 있습니다. BPEL 프로세스 다이어그램이 그림 6과 같습니다.

그림 6 새로운 BPEL 프로세스

다이내믹 프로세스의 효율성 개선

런타임의 주소 종속성(address dependency) 제거. 서비스 주소(service address)는 자주 변경될 가능성이 높습니다. 런타임의 다이내믹 프로세스가 주소에 종속되지 않도록 구현하는 것이 가능합니다. 서비스 주소를 제외한 서비스 네임만을 할당하고, 서비스 주소는 WSDL에서 가져오는 방법을 사용하면 됩니다. 이 방법을 실습해 보기 위해, 템플릿 copy rule의 XML 구문에서 주소와 관련된 부분(<Address/>)을 삭제합니다. 이전 설정을 뒷부분에서 다시 복원해야 하므로, 이 작업을 수행하기 전에 MyDL.bpel 파일을 백업해 두도록 합니다. 또, SetupPartnerLink <assign> 구문에서 주소에 관련된 copy rule을 삭제합니다. 변경된 SetupPartnerlink <assign>이 아래와 같습니다:

<assign name="SetupPartnerlink">
  <copy>
    <from>
      <EndpointReference xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing" 
           xmlns:ns1="http://services.otn.com">    
        <ServiceName/>
      </EndpointReference>
    </from>
    <to variable="partnerReference"/>
  </copy>
  <copy>
    <from expression="'ns1:UnitedLoan'"/>
    <to variable="partnerReference" query="/ns3:EndpointReference/ns3:ServiceName"/>
  </copy>
</assign>

서비스의 WSDL 종속성 제거. 관리해야 하는 서비스의 수가 많은 상황에서 서비스 주소가 매우 빈번하게 변경되는 경우, WSDL 파일을 자주 업데이트해야 하는 것이 문제가 될 수 있습니다. 프로세스가 런타임에 엔드포인트 레퍼런스의 주소를 명시하도록 함으로써 이러한 문제를 해결할 수 있습니다.

MyDL.bpel 파일을 다시 (주소 관련 copy rule을 포함하는) 원래 버전으로 복구합니다. 이번에는 주소 정보를 제거하는 대신, 템플릿의 XML과 ServiceName copy rule로부터 서비스 정보를 제거합니다. 수정된 <assign>이 아래와 같습니다:

<assign name="SetupPartnerlink">
  <copy>
    <from>
      <EndpointReference xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing" 
          xmlns:ns1="http://services.otn.com">
        <Address/>
      </EndpointReference>
    </from>
    <to variable="partnerReference"/>
  </copy>
  <copy>
    <from expression="'http://localhost:9700/orabpel/default/UnitedLoan'"/>
    <to variable="partnerReference" query="/ns3:EndpointReference/ns3:Address"/>
  </copy>
</assign>

<dbOutput>
 <part xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" name="response-
   headers">null</part> 
 <part xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
   name="DynamiclinksCollection">
 <n:DynamiclinksCollection
    xmlns:n=http://xmlns.oracle.com/pcbpel/adapter/db/top/MyDynamicLink
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <Dynamiclinks>
   <address>http://localhost:9700/orabpel/default/UnitedLoan</address> 
   <day>monday</day> 
   <uid>1</uid> 
  </Dynamiclinks>
  <Dynamiclinks>
   <address>http://localhost:9700/orabpel/default/StarLoan</address> 
   <day>united</day> 
   <uid>4</uid> 
 </Dynamiclinks>
</n:DynamiclinksCollection>
</part>
</dbOutput>

<!-- first setup the counter variable "i" -->
<assign name="CounterReset">
  <copy>
    <from expression="1"/>
    <to variable="i"/>
  </copy>
</assign>

<!-- while loop goes until all link collection notes are done -->
<while name="LoanLoop" condition="bpws:getVariableData('i') <=
      count(bpws:getVariableData('dbOutput','DynamiclinksCollection',
        '/ns3:Dynamiclin ksCollection/Dynamiclinks'))">
    <sequence name="Sequence_1">

<!-- reset the endpoint with the usual xml fragment -->
    <assign name="ClearEndpoint">
      <copy>
        <from>
          <EndpointReference 
             xmlns="http://schemas.xmlsoap.org/ws/2003/03/addressing" 
             xmlns:ns1="http://services.otn.com">
            <Address/>
          </EndpointReference>
        </from>
        <to variable="partnerReference"/>
      </copy>
    </assign>

<!-- set the address in the endpoint variable 
	based on the current node -->
    <assign name="SetEndpoint">
      <copy>
        <from variable="dbOutput" part="DynamiclinksCollection"
		     query="/ns3:DynamiclinksCollection/Dynamiclinks
             [number(bpws:getVariableData('i'))]/address"/>
        <to variable="partnerReference"
          query="/wsa:EndpointReference/wsa:Address"/>
      </copy>
    </assign>

<!-- copy the endpoint variable into the partner link -->
    <assign name="DoPartnerlink">
      <copy>
        <from variable="partnerReference"/>
        <to partnerLink="LoanService"/>
      </copy>
    </assign>
<!-- invoke the partner link -->
    <invoke name="Invoke_2" partnerLink="LoanService" 
       portType="ns2:LoanService" operation="initiate" 
       inputVariable="loanInput"/>

<!-- be sure to increment your counter or you have an infinite loop -->
    <assign name="CounterIncrement">
      <copy>
        <from expression="bpws:getVariableData('i')+1"/>
        <to variable="i"/>
      </copy>
    </assign>
  </sequence>
</while>

모든 비동기식 응답이 수신되기 전에 <receive> while 루프에서 빠져나가는 것은 권장되지 않습니다.

결론