JEUS MQ 서버는 서비스 채널(Service Channel)을 통해서 클라이언트와 통신한다. 하나의 JEUS MQ 서버에는 최소한 하나의 서비스 채널이 있어야 하며, 각 서비스 채널마다 서비스 URL 등의 네트워크 설정을 다르게 지정할 수 있다.

서비스 채널이 사용하는 서비스 URL은 <server-address>와 <port>를 같이 사용하거나, 또는 <server-url>을 단독으로 사용하여 설정할 수 있다.

다음은 JMSMain.xml 파일의 서비스 채널을 설정하는 2가지 방법에 대한 예이다. 설정 정보는 <service-config> 태그 안에 설정되며 2가지 방법 중 반드시 한 가지 방법은 사용해야 한다.

다음은 설정 태그에 대한 설명이다.

JEUS MQ 서비스 채널에서 JEUS 엔진 컨테이너의 Base Port를 통해 서비스할 수 있다. 이를 위해서는 2가지 방법으로 설정이 가능하다.

Connection Factory는 JMS 관리 객체로 클라이언트가 JMS 서버에 접속하는 데 필요한 연결 설정 정보와 클라이언트를 위한 기본 정보들을 가지고 있다. JEUS MQ의 경우 JMSMain.xml에 설정되며 JEUS MQ 서버가 기동될 때 생성되어 JEUS JNDI 서비스에 등록된다.

다음은 JMSMain.xml은 <connection-factory> 태그 아래 기본적인 Connection Factory를 설정한 예이다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <connection-factory>
        <type>nonxa</type>
        <name>ConnectionFactory</name>
        <export-name>jms/ConnectionFactory</export-name>
    </connection-factory>

    <connection-factory>
        <type>queue</type>
        <name>QueueConnectionFactory</name>
        <export-name>jms/QueueConnectionFactory</export-name>
    </connection-factory>

    <connection-factory>
        <type>topic</type>
        <name>TopicConnectionFactory</name>
        <export-name>jms/TopicConnectionFactory</export-name>
    </connection-factory>
    . . .
</jms-server>

다음은 설정 태그에 대한 설명이다.

Queue나 Topic과 같은 Destination 역시 JEUS MQ 서버가 기동할 때 JMSMain.xml 파일의 설정을 읽어 JEUS JNDI 서비스에 등록한다.

다음은 Destination 설정한 JMSMain.xml 예로 설정 값은 <destination> 태그 안에 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <destination>
        <type>queue</type>
        <name>ExamplesQueue</name>
        <export-name>jms/ExamplesQueue</export-name>
    </destination>

    <destination>
        <type>topic</type>
        <name>ExamplesTopic</name>
        <export-name>jms/ExamplesTopic</export-name>
    </destination>
    . . .
</jms-server>

다음은 설정 태그에 대한 설명이다.

Persistence Store는 서버가 재기동될 때 메시지나 Subscription, 트랜잭션들의 이전 상태를 복구하기 위해 필요하다. Persistence Store를 설정하지 않으면 클라이언트에서 DeliveryMode.PERSISTENT 방식으로 메시지를 송신한 경우에 서버에서 장애가 발생했을 때 메시지 전달을 보장할 수 없다.

JEUS MQ에서 제공하는 Persistence Store의 종류에는 저널 로그와 데이터베이스가 있다.

저널 로그 방식으로 Persistence Store를 사용할 경우에는 다음과 같이 <persistence-store> 태그 아래 설정한다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <persistence-store>
        <journal>
            <base-dir>/home/jeus/store/jeusmq</base-dir>
            <initial-log-file-count>5</initial-log-file-count>
            <max-log-file-count>10</max-log-file-count>
            <log-file-size>128M</log-file-size>
            <property>
                <key>jeus.store.journal.overflow-factor</key>
                <value>0.2</value>
            </property>
            ...
        </journal>
    </persistence-store>
    . . .
</jms-server>

다음은 설정 태그에 대한 설명이다.

다음은 외부 데이터베이스를 Persistence Store로 설정한 예이다.

현재 호환 가능한 외부 데이터베이스는 다음과 같다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <persistence-store>
        <jdbc>
            <data-source>datasource1</data-source>
            ...
        </jdbc>
    </persistence-store>
    . . .
</jms-server>

위 예에서 'datasource1'은 Persistence Store로 사용할 사용할 데이터 소스의 JNDI 이름이다. JEUS에 데이터 소스를 추가하는 방법은 “JEUS Server 안내서”의 “제8장 DB Connection Pool과 JDBC”에 소개되어 있다.

위와 같은 기본 설정을 사용하는 경우 해당 데이터베이스 내의 <BROKER-NAME>_DEST, <BROKER-NAME>_DSUB, <BROKER-NAME>_MESG, <BROKER-NAME>_SMSG, <BROKER-NAME>_TRAN이라는 이름의 테이블을 사용하게 된다.

JEUS MQ에서는 통신 레벨에서의 보안을 위해 서비스 채널에 Secure Socket Layer(이후 SSL)를 사용할 수 있도록 지원하고 있다. JEUS MQ에서는 Blocking, Non-Blocking에서 모두 SSL을 지원하고 있으며 SSL을 사용하기 위해서는 서버뿐만 아니라 클라이언트에도 별도의 설정이 필요하다.

SSL 사용을 위한 서버 설정

다음은 SSL 사용을 위한 서버 설정 방법이다.

SSL 사용을 위한 클라이언트 설정

클라이언트에서는 JVM 옵션으로 SSL 설정을 할 수 있다. 클라이언트는 key-store와 trust-store를 모두 설정해야 한다.

java -Djeus.jms.ssl.protocol=TLS -Djeus.jms.ssl.keystore.type=JKS 
    -Djeus.jms.ssl.keystore.passphrase=changeit 
    -Djeus.jms.ssl.keystore.file=;c:\jeus\jeus\config\keystore 
    -Djeus.jms.ssl.keymanagement.algorithm=SunX509
    -Djeus.jms.ssl.truststore.type=JKS 
    -Djeus.jms.ssl.truststore.passphrase=changeit
    -Djeus.jms.ssl.truststore.file=;c:\jeus\jeus\config\truststore 
    -Djeus.jms.ssl.trustmanagement.algorithm=SunX509 ... 

JEUS MQ 서버가 사용하는 Thread Pool에 대한 정보를 설정한다.

JMS의 비동기적인 특성에 따라 클라이언트와 메시지를 주고받거나 서버 내부에서 메시지를 처리하고 스토리지에 저장하는 등의 작업은 각각 별도의 스레드에 의해 수행된다. JEUS MQ 서버 내에서 동시에 실행 가능한 스레드의 개수는 이 Thread Pool 설정에 의해 결정된다.

서버의 성능에 크게 영향을 미치므로 동시 처리 가능한 클라이언트의 수와 서버에 걸리는 부하 등을 고려한 적절한 설정이 필요하다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <thread-pool>
        <min>5</min>
        <max>300</max>
        <keep-alive-time>120000</keep-alive-time>
    </thread-pool>
    . . .
</jms-server>

일반적으로 Durable Subscriber는 클라이언트가 생성하기 때문에 생성 이전에 Topic에 도착한 메시지는 클라이언트에게 전달되지 않는다. 이런 상황을 피하기 위해 JEUS MQ는 JMSMain.xml 환경 파일에 Durable Subscriber를 설정하여 서버가 실행될 때 미리 Durable Subscriber를 등록해 두었다가 조건에 맞는 클라이언트가 접속했을 때 메시지를 전달하는 기능을 제공한다.

Session.createDurableSubscriber() 메소드를 호출할 때 클라이언트 ID와 Subscription 이름 및 Topic이 필요한 것처럼 JMSMain.xml에 Durable Subscriber를 설정할 때도 클라이언트 ID, Subscription 이름, Topic 이름을 지정해야 한다. 추가로 메시지 셀렉터도 설정할 수 있다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <durable-subscriber>
        <client-id>client_id1</client-id>
        <name>subscription1</name>
        <destination-name>ExamplesTopic</destination-name>
    </durable-subscriber>
    . . .
</jms-server>

Destination에 클라이언트에게 전달되지 않은 메시지가 계속해서 늘어나면 JVM이 OutOfMemoryError를 내면서 서버가 종료될 수 있다. 이를 막기 위해 JMSMain.xml 파일을 통해 JEUS MQ는 Destination별로 메모리 관리 정책을 설정할 수 있는 방법을 제공한다.

Destination 설정 내에 <low-mark>, <high-mark>, <limit> 값을 지정하면 메모리 사용량에 따라 JEUS MQ 서버는 다음과 같이 동작한다.

Destination에 도착한 메시지의 내용이 메모리에서 삭제되더라도 메시지가 유실되는 것은 아니다. 메시지는 스토리지에 저장되어 있기 때문에 JEUS MQ 서버는 필요할 때 메시지 내용을 스토리지로부터 읽어서 처리하게 된다. 이 경우 처리 속도는 메시지 내용이 메모리에 있을 때보다 느릴 수 밖에 없다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <destination>
        <type>queue</type>
        <name>ExamplesQueue</name>
        <export-name>jms/ExamplesQueue</export-name>
        <!-- limit = 16MB -->
        <limit>16777216</limit>
        <!-- high-mark = 64MB -->
        <high-mark>67108864</high-mark>
        <!-- low-mark = 32MB -->
        <low-mark>33554432</low-mark>
    </destination>
    . . .
</jms-server>

<limit>는 1GB, <high-mark>는 0.75GB를 기본값으로 지정하고 있지만, <low-mark>의 경우는 기본값이 0이므로 별도로 설정하지 않으면 메시지는 항상 소프트 캐싱된다는 점에 유의한다.

메시지 수신자가 Destination에 Message Listener를 등록한 경우 JEUS MQ 서버는 Destination에 메시지가 도착하면 해당 클라이언트에게 메시지를 전송한다. 그런데 서버가 메시지를 전송하는 속도보다 클라이언트에서 메시지를 처리하는 속도가 느리면 클라이언트 메모리에 메시지가 계속해서 쌓이게 되고, 결국 클라이언트 JVM에서 OutOfMemoryError가 발생할 수 있다.

이와 같은 상황을 방지하기 위해 클라이언트 측에 아직 처리되지 않고 쌓여 있는 메시지의 최대 개수를 설정하여 이 개수를 초과하면 서버가 클라이언트로 잠시 동안 메시지를 전송하지 않도록 할 수 있다.

이 값은 다음의 예제와 같이 JMSMain.xml에 Destination별로 지정 가능하다. 설정 정보는 <destination> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <destination>
        <type>queue</type>
        <name>ExamplesQueue</name>
        <export-name>jms/ExamplesQueue</export-name>
        <max-pending-limit>1000</max-pending-limit>
        <resume-dispatch-factor>0.5</resume-dispatch-factor>
    </destination>
    . . .
</jms-server>

다음은 설정 태그에 대한 설명이다.

Transaction이 Rollback되거나 Client Acknowledge 모드일 때 명시적인 Acknowledge를 하지 않고 Session이나 Connection을 닫아서 메시지가 서버로 되돌아갔다가 다시 서비스가 되는 경우 다음 서비스까지 잠시 지연되도록 설정할 수 있다.

다음은메시지 재전달 지연 설정로 예로 JMSMain.xml에 Destination별로 지정 가능하다. 설정 정보는 <destination> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
  <jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
      . . .
      <destination>
          <type>queue</type>
          <name>ExamplesQueue</name>
          <export-name>jms/ExamplesQueue</export-name>
          <redelivery-delay>10000</redelivery-delay>
      </destination>
      . . .
  </jms-server>

다음은 설정 태그에 대한 설명이다.

메시지 전송을 시도했으나 메시지 수신자에서 여러번 반복해서 오류가 발생하였거나 만료되어 더 이상 전달되어서는 안 되는 메시지 등 미처리된 메시지들을 보관하는 Destination을 별도로 지정할 수 있다.

다음은 미처리된 메시지를 보관하기 위한 Destination 설정의 예로 JMSMain.xml에 Destination별로 지정 가능하다. 설정 정보는 <destination> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
  <jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
      . . .
      <destination>
          <type>queue</type>
          <name>ExamplesQueue</name>
          <export-name>jms/ExamplesQueue</export-name>
          <dead-letter-destination>DeadLetterQueue</dead-letter-destination>
      </destination>
      . . .
  </jms-server>

다음은 설정 태그에 대한 설명이다.

클라이언트에서 프로그램적으로 설정하는 각종 수치들을 서버에 도착하는 순간 강제로 Override해주는 기능을 제공한다. 이 기능을 통해서 클라이언트 프로그램을 수정하지 않고 서버 설정만을 바꾸어서 클라이언트 프로그램의 동작을 바꿀 수도 있다.

다음은 클라이언트 설정값 강제 Override 기능 설정의 예로 JMSMain.xml에 Destination별로 지정 가능하다. 설정 정보는 <destination> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
  <jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
      . . .
      <destination>
          <type>queue</type>
          <name>ExamplesQueue</name>
          <export-name>jms/ExamplesQueue</export-name>
          <override-client-attributes>
              <expiration-time>500000</expiration-time>
          </override-client-attributes>
      </destination>
      . . .
  </jms-server>

다음은 설정 태그에 대한 설명이다.

JMS Specification 1.1의 항목 3.4.9 JMSExpiration에 따르면 메시지에 expiration time이 설정된 경우 메시지 수신자가 해당 메시지를 받지 않도록 해야한다고만 명시되어있으며 서버에서 정확히 어떤식으로 다루라고 명시하지는 않고 있다. 따라서 JEUS MQ에서는 만료되는 메시지들을 어떻게 다룰지에 대한 다양한 policy를 설정할 수 있도록 지원하고 있다.

다음은 메시지 만료 정책 설정의 예로 JMSMain.xml에 Destination별로 지정 가능하다. 설정 정보는 <destination> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
  <jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
      . . .
      <destination>
          <type>queue</type>
          <name>ExamplesQueue</name>
          <export-name>jms/ExamplesQueue</export-name>
          <expiration-policy>Delete</expiration-policy>
      </destination>
      . . .
  </jms-server>

다음은 설정 태그에 대한 설명이다.

본 절에서는 앞서 “5.3.4. Persistence Store 기본 설정”에서 소개한 간단한 설정에 덧붙여 몇 가지 고급 옵션에 대해 설명한다.

다음은 Persistence Store 설정의 예로 설정 정보는 <persistence-store> 태그 아래 구성한다.

<?xml version="1.0" encoding="UTF-8"?>
<jms-server xmlns="http://www.tmaxsoft.com/xml/ns/jeus">
    . . .
    <persistence-store>
        <jdbc>
            <data-source>datasource1</data-source>
            <destination-table>
                TEST_DEST
            </destination-table>
            <durable-subscriber-table>
                TEST_DSUB
            </durable-subscriber-table>
            <message-table>
                TEST_MESG
            </message-table>
            <subscription-message-table>
                TEST_SMSG
            </subscription-message-table>
            <transaction-table-name>
                TEST_TRAN
            </transaction-table-name>
        </jdbc>
    </persistence-store>
    . . .
</jms-server>

위의 예에서 사용하는 테이블 이름을 지정하는 각 Element들의 용도는 다음과 같다.

이 태그들을 사용하면 운용 중인 서버에서 테스트를 수행하는 경우 별도의 Persistence Store를 설치하지 않고도 사용하는 테이블의 이름만 바꿔서 JEUS MQ 서버를 테스트 하는 것이 가능하다.

jmsadmin은 JEUS MQ 전용 콘솔 툴로, 자체 프롬프트에서 여러 가지 명령어를 실행함으로써 관리 작업을 수행할 수 있게 해준다. 실행 스크립트는 다음의 경로에 위치한다.

JEUS_HOME\bin\

jmsadmin은 다음 명령어들을 제공한다.

JEUS WebAdmin은 웹 브라우저를 통해 JEUS 전체를 설정, 관리 및 모니터링하는 기능을 제공한다.

JEUS MQ 서버는 JEUS의 JMS 엔진이므로(“5.1. 서버 구조” 참고) JEUS WebAdmin을 통한 관리가 가능하다. 특히 WebAdmin은 콘솔 툴에 비해 서로 연관된 복잡한 옵션을 설정하기 쉽고, 다양한 기능을 제공하며 사용 방법 또한 직관적이라는 장점을 갖는다.

다음은 WebAdmin의 사이트 맵 트리의 일부분을 보여준다. WebAdmin에서 아래에 굵게 표시한 트리 노드를 따라가면 JEUS MQ 서버를 설정, 모니터링 및 관리할 수 있는 WebAdmin 페이지가 나타난다.