소개

세션은 Tmax와의 연결이 존재하는 상태에서 생성해야 하며 하나의 애플리케이션 안에서 다수의 세션을 생성할 수도 있다. 세션을 생성하기 위해서는 대상 HMS의 이름이 필요하고 생성될 경우 세션의 여러 가지 속성을 부여할 수 있다.

다음은 세션의 기본적인 속성이다.

Transacted 세션은 생성될 때 Transacted 속성을 부여받아 생성된 세션이다. 주로 로컬 트랜잭션을 사용하기 위해 사용한다. Transacted 세션에서는 메시지 송수신의 결과가 HMS로 즉시 반영되지 않는다. hms_commit(), hms_rollback() API를 통해 반영 여부를 결정한다.

예를 들어 Transacted 세션으로 생성된 생산자가 다수의 메시지를 송신하고 hms_rollback()을 했다면 송신했던 메시지는 Destination에 들어가지 않고 무시된다. 메시지를 수신할 때 결과 반영 여부를 hms_commit(), hms_rollback()으로 결정하게 된다. Transacted 세션에서는 AUTO_ACK만 허용한다.

XA 세션은 HMS와 다른 RM과의 2PC를 수행하기 위해 존재한다. 트랜잭션으로 묶을 구간의 시작과 끝에 Tmax의 트랜잭션 관련 API(tx_beggin(), tx_commit(), tx_rollback())를 이용하여 명시한다.

트랜잭션이 시작되지 않은 상태에서는 일반 세션처럼 동작한다.

HMS는 메시지에 대한 요청 이후 메시지가 송신되는 동기적인 방법뿐만 아니라 메시지에 대한 요청 없이도 메시지를 수신할 수 있는 비동기 세션을 지원한다. 비동기 세션으로 소비자(Consumer)를 생성할 경우 메시지가 도착할 때 불릴 서비스명(Listener)을 넘겨주면, 메시지가 도착할 때마다 지정한 Tmax 서비스가 호출된다.

Publish-and-Subscribe 메시징에서 사용되는 Destination이다. 1개의 메시지는 송신된 시점에 가입되어 있는 구독자(Subscriber)에게 모두 전달된다. 그 시점에 가입된 구독자가 존재하지 않을 경우에는 송신된 메시지는 버려진다.

Point-to-Point 메시징에서 사용되는 Destination이다. 하나의 메시지는 하나의 수신자(Receiver)에게 전달된다. 송신자가 송신한 메시지는 수신자가 메시지를 꺼내갈 때까지 Destination에 존재한다.

대상 Destination의 종류에 따른 Topic에 대한 소비자를 구독자라고 한다.

소비자 중에 영속적인 속성을 갖는 구독자를 영속적 구독자(Durable Subscriber)라고 한다. 영속적 구독자는 생성된 이후에 구독해제(unsubscribe)할 때까지 Destination으로 전달된 모든 메시지를 받을 수 있다. 영속적 구독자가 Tmax와의 연결에서 해제되어도 추후에 재접속하면 이전 메시지에 이어서 수신이 가능하다는 의미이다. HMS가 영속적 구독자를 구분하는 기준은 구독자의 이름이다. 따라서 영속적 구독자를 생성할 때에는 반드시 고유한 이름을 부여해야 한다.

Queue에 대한 소비자를 수신자라고 한다.

수신자를 생성할 때에 Message Selector를 설정할 수 있다. Message Selector는 사용자가 일정한 조건을 설정하고 해당 조건을 충족하는 메시지만을 수신할 수 있도록 해준다. Message Selector 구문은 SQL 조건문과 동일하다.

예를 들어 메시지에 Type과 Month라는 프로퍼티가 존재한다면, 다음과 같은 Message Selector를 설정한 소비자는 '4월 이후의 뉴스' 메시지만 수신한다.

Message Selector에 대한 자세한 내용은 Message Selector 사용법을 참고한다.

CARRAY 타입으로 설정한다.

프로퍼티는 필드 버퍼에서 지원하는 HMS_CHAR, HMS_SHORT, HMS_INT, HMS_LONG, HMS_FLOAT, HMS_DOUBLE, HMS_STRING, HMS_CARRAY의 8가지 데이터 타입으로 설정한다. 프로퍼티는 이름과 함께 값을 설정하게 되며, 프로퍼티 이름은 메시지에서 유일해야 한다. 같은 이름으로 프로퍼티를 재설정할 경우 이전 값이 수정된다.

메시지를 생성하려면 세션을 이용해야 하며, 각 프로퍼티는 데이터 부분뿐만 아니라 이름을 나타내는 공간도 필요하므로 많은 프로퍼티를 설정할 경우 메시지의 크기를 고려하여 넉넉하게 할당해야 한다.

다음은 HMS에서 기본적으로 정의한 예약 프로퍼티이다. 사용자는 이와 같은 이름으로 프로퍼티를 재설정할 수 없다(이외의 다른 예약된 프로퍼티가 있으나 현재 지원하지 않는다).

HMSPORT를 반드시 설정해주어야 하며, Queue를 클러스터링하기 위해서는 추가적으로 GQINT를 설정해 주어야 한다.

클러스터링할 Destination의 이름은 동일하게 설정하고, GLOBAL=Y로 설정해야 한다.

Global Topic으로 송신된 메시지는 나머지 다른 노드의 Global Topic으로 전달된다.

예를 들어 노드 A, B, C에 Topic01이라는 같은 이름을 갖는 Topic에 모두 'GLOBAL=Y’로 설정을 했다면, 노드 A의 Topic01에 도착한 메시지는 노드 B, C의 Topic01에도 전달된다.

설정된 모든 노드에 복사본이 전달되는 Global Topic과는 달리 Global Queue에서는 메시지는 1개만이 존재하고 소비될 수 있으므로 클러스터링에 있어서 다른 방법을 사용한다.

각 HMS는 Global Queue에 대한 정보를 일정 시간(HMSGQINT)을 주기로 계속 주고받는다. 이 정보에는 현재 노드의 각 Queue에 존재하는 메시지의 개수, 연결된 클라이언트 수 등이 포함된다.

각 Queue에는 원활한 메시지 전달을 위해 버퍼링을 하는데, 그 크기는 현재 Queue에 연결되어 있는 소비자의 수에 사용자가 설정한 상수값(GQTHR)을 곱해서 구한다.

Queue의 메시지 수가 계산된 버퍼의 크기보다 작을 경우에는 다른 노드의 Queue로부터 메시지를 요청한다. 한 번의 요청으로 가져올 수 있는 메시지의 수(GQMAXREQ) 또한 설정할 수 있다. 이 값이 클 경우 적은 요청으로 필요한 메시지를 채울 수 있으나, 너무 클 경우에는 노드 간의 불필요한 메시지의 이동이 발생할 수 있다.

버퍼의 크기 말고도 Queue의 길이가 불균형적으로 크게 차이나는 현상을 방지하기 위하여 메시지가 일정 수 이상(GQFULL)이 되면 메시지의 요청이 없어도 Queue의 길이를 균형적으로 맞춰주는 기능도 제공한다.