JNDI 서비스를 이용하는 방법

JEUS MQ 서버의 클러스터링 여부와 상관없이 “2.2.2. Connection Factory”에서 설명한 것과 같은 방법으로 사용할 수 있다. 단, 클라이언트가 매번 JNDI 서비스를 사용해서 Connection Factory를 다시 Lookup하는지 또는 이미 얻어온 Connection Factory를 재활용하여 커넥션 생성만 다시 하는지에 따라서 동작의 주체가 약간 다르다. 또한 동작의 주체에 따라서 JEUS MQ 서버를 선택하는 정책도 달라지게 된다.

JEUS MQ 전용 API를 사용하여 Connection Factory를 직접 생성하는 방법

이 경우에는 JEUS MQ 서버가 클러스터링 되어있다면 “2.2.2. Connection Factory”에서 설명한 방법에 외에 추가적인 작업이 필요하다.

다음은 JeusConnectionFactoryCreator.addBrokerAddress() 메소드를 이용하여 클러스터링에 참여하고 있는 모든 서버들의 정보를 추가하는 방법이다.

jeus.jms.client.util.JeusConnectionFactoryCreator connectionFactoryCreator =
        new jeus.jms.client.util.JeusConnectionFactoryCreator();

connectionFactoryCreator.setFactoryName("ConnectionFactory");
connectionFactoryCreator.addBrokerAddress("192.168.1.2", 9741);
connectionFactoryCreator.addBrokerAddress("192.168.1.3", 9741);
connectionFactoryCreator.addBrokerAddress("192.168.1.4", 9741);

ConnectionFactory connectionFactory =
        (ConnectionFactory) connectionFactoryCreator.createConnectionFactory();

만약 JEUS MQ 클러스터링과 함께 JEUS MQ 장애 극복 기능을 사용하고 있다면 다음의 예와 같이 Standby 서버들의 정보도 추가해야 한다. 자세한 내용은 “제3장 JEUS MQ 장애 극복”을 참고한다.

jeus.jms.client.util.JeusConnectionFactoryCreator connectionFactoryCreator =
        new jeus.jms.client.util.JeusConnectionFactoryCreator();

connectionFactoryCreator.setFactoryName("ConnectionFactory");
connectionFactoryCreator.addBrokerAddress("192.168.1.2", 9741, "192.168.1.5", 9741);
connectionFactoryCreator.addBrokerAddress("192.168.1.3", 9741, "192.168.1.6", 9741);
connectionFactoryCreator.addBrokerAddress("192.168.1.4", 9741, "192.168.1.7", 9741);

ConnectionFactory connectionFactory =
        (ConnectionFactory) connectionFactoryCreator.createConnectionFactory();

메시지 유무 확인 주기 설정

- Djeus.jms.server.cluster.demand-period

큐나 Durable Subscriber에서 메시지를 수신할 때 해당 JEUS MQ 서버에 메시지가 없을 경우 클러스터링된 다른 서버에 메시지가 있는지 확인하고 혹시 있다면 메시지를 요청해서 받아온다.

이때 메시지가 있는지 확인하는 주기를 설정할 수 있다. (기본값: 10000, 단위: ms)

한번에 이동시킬 메시지의 개수 설정

-Djeus.jms.server.cluster.messages-per-request

서버 간의 메시지를 이동할 때 한 번에 이동시키는 메시지의 수를 설정할 수 있다. (기본값: 5)

GMS 프레임워크에서 사용하는 멤버 그룹명 설정

-Djeus.jms.server.cluster.group-name

GMS 프레임워크에서 사용하는 멤버 그룹의 이름을 설정할 수 있다. 클러스터링이나 장애 극복 기능으로 묶이게 되는 서버들 간에는 모두 같은 그룹 이름을 사용해야 한다. 특별한 경우를 제외하고는 설정해 줄 필요는 없으나 같은 서브넷 내에서 여러 단위의 클러스터를 설정할 필요가 있다면 다른 클러스터 간에는 각자 다른 그룹 이름을 설정해 주어야 한다. (기본값: GMSCluster)