Azure Service Bus JMS 2.0 개발자 가이드

이 가이드에는 JMS(Java Message Service) 2.0 API를 사용하여 Azure Service Bus와 통신하는 데 도움이 되는 자세한 정보가 포함되어 있습니다.

Java 개발자로서 Azure Service Bus를 접하는 경우 다음 문서를 읽어 보세요.

JMS(Java Message Service) 프로그래밍 모델

Java Message Service API 프로그래밍 모델은 다음 섹션에 나와 있습니다.

JMS - 빌딩 블록

아래 구성 요소는 JMS 애플리케이션과 통신할 수 있습니다.

연결 팩터리

연결 팩터리 개체는 클라이언트에서 JMS 공급자와 연결하는 데 사용됩니다. 연결 팩터리는 관리자가 정의한 연결 구성 매개 변수 집합을 캡슐화합니다.

각 연결 팩터리는 , QueueConnectionFactory또는 TopicConnectionFactory 인터페이스의 ConnectionFactory인스턴스입니다.

Azure Service Bus와의 연결을 간소화하기 위해 이러한 인터페이스는 각각을 통해 ServiceBusJmsConnectionFactoryServiceBusJmsQueueConnectionFactory구현 ServiceBusJmsTopicConnectionFactory 됩니다.

TokenCredential tokenCredential = new DefaultAzureCredentialBuilder().build();

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

TokenCredential tokenCredential = new DefaultAzureCredentialBuilder()
                                                .managedIdentityClientId("<clientIDOfUserAssignedIdentity>")
                                                .build();

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

TokenCredential tokenCredential = new ClientSecretCredentialBuilder()
                .tenantId("")
                .clientId("")
                .clientSecret("")
                .build();;

String host = "<YourNamespaceName>.servicebus.windows.net";
ConnectionFactory factory = new ServiceBusJmsConnectionFactory(tokenCredential, host, null); 

ConnectionFactory factory = new ServiceBusJmsConnectionFactory(SERVICE_BUS_CONNECTION_STRING, null);

JMS 대상

대상은 클라이언트에서 생성하는 메시지의 대상과 클라이언트에서 소비하는 메시지의 원본을 지정하는 데 사용하는 개체입니다.

대상은 Azure Service Bus의 엔터티- 큐(지점 및 지점 시나리오) 및 토픽(pub-sub 시나리오)에 매핑됩니다.

연결

연결은 JMS 공급자와의 가상 연결을 캡슐화합니다. Azure Service Bus를 사용하면 AMQP를 통해 애플리케이션과 Azure Service Bus 간의 상태 저장 연결을 나타냅니다.

다음 예제와 같이 연결 팩터리에서 연결이 만들어집니다.

Connection connection = factory.createConnection();

세션

세션은 메시지를 생성하고 사용하는 단일 스레드 컨텍스트입니다. 메시지, 메시지 생산자 및 소비자를 만드는 데 사용할 수 있지만, 전송 및 수신을 작업의 원자 단위로 그룹화하도록 허용하는 트랜잭션 컨텍스트도 제공합니다.

다음 예제와 같이 연결 개체에서 세션을 만들 수 있습니다.

Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

세션 모드

아래 모드를 사용하여 세션을 만들 수 있습니다.

세션 모드를 지정하지 않으면 기본적으로 Session.AUTO_ACKNOWLEDGE가 선택됩니다.

JMSContext

JMSContext는 연결 및 세션 개체에서 제공하는 기능을 결합합니다. 연결 팩터리 개체에서 만들 수 있습니다.

JMSContext context = connectionFactory.createContext();

JMSContext 모드

Session 개체와 마찬가지로 JMSContext는 세션 모드에서 멘션 동일한 승인 모드로 만들 수 있습니다.

JMSContext context = connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE);

모드를 지정하지 않으면 기본적으로 JMSContext.AUTO_ACKNOWLEDGE가 선택됩니다.

JMS 메시지 생산자

메시지 생산자는 JMSContext 또는 Session을 사용하여 만들어지고 대상에 메시지를 보내는 데 사용되는 개체입니다.

다음 예제와 같이 독립 실행형 개체로 만들 수 있습니다.

JMSProducer producer = context.createProducer();

또는 메시지를 보내야 할 때 런타임에 생성됩니다.

context.createProducer().send(destination, message);

JMS 메시지 소비자

메시지 소비자는 JMSContext 또는 Session에서 만들어지고 대상으로 전송된 메시지를 수신하는 데 사용되는 개체입니다. 이 예제와 같이 만들 수 있습니다.

JMSConsumer consumer = context.createConsumer(dest);

receive() 메서드를 통해 동기 수신

메시지 소비자는 메서드를 통해 receive() 대상에서 메시지를 수신하는 동기 방법을 제공합니다.

인수/시간 제한을 지정하지 않거나 '0'의 시간 제한을 지정하면 메시지가 도착하거나 연결이 끊어지지 않는 한 소비자는 무기한 차단됩니다(이전 중 어느 것이든지).

Message m = consumer.receive();
Message m = consumer.receive(0);

0이 아닌 긍정 인수를 제공하면 타이머가 만료될 때까지 소비자가 차단됩니다.

Message m = consumer.receive(1000); // time out after one second.

JMS 메시지 수신기를 사용하여 비동기 수신

메시지 수신기는 대상에서 메시지를 비동기식으로 처리하는 데 사용되는 개체입니다. 특정 비즈니스 논리가 MessageListener 있어야 하는 메서드를 onMessage 포함하는 인터페이스를 구현합니다.

메서드를 사용하여 setMessageListener 특정 메시지 소비자에 대해 메시지 수신기 개체를 인스턴스화하고 등록해야 합니다.

Listener myListener = new Listener();
consumer.setMessageListener(myListener);

토픽에서 소비

JMS 메시지 소비자는 큐 또는 토픽일 수 있는 대상에 대해 만들어집니다.

큐의 소비자는 클라이언트 애플리케이션과 Azure Service Bus 간 Session(및 Connection)의 컨텍스트에 상주하는 클라이언트 쪽 개체일 뿐입니다.

그러나 토픽에 대한 소비자는 2개의 부분으로 구성됩니다.

• Session(또는 JMSContext)의 컨텍스트에 상주하는 클라이언트 쪽 개체 및
• Azure Service Bus의 엔터티인 구독.

구독은 여기에 설명되어 있으며 다음 중 하나일 수 있습니다.

• 공유되는 지속형 구독
• 공유되는 비지속형 구독
• 공유되지 않는 지속형 구독
• 공유되지 않는 비지속형 구독

JMS 큐 브라우저

JMS API는 애플리케이션이 큐의 메시지를 찾아보고 각 메시지에 대한 헤더 값을 표시할 수 있는 개체를 제공합니다 QueueBrowser .

다음 예제와 같이 JMSContext를 사용하여 큐 브라우저를 만들 수 있습니다.

QueueBrowser browser = context.createBrowser(queue);

JMS 메시지 선택기

수신된 메시지를 필터링하기 위해 애플리케이션을 수신하여 메시지 선택기를 사용할 수 있습니다. 메시지 선택기를 사용하여 수신 애플리케이션은 해당 책임 자체를 수행하는 대신 JMS 공급자(이 경우 Azure Service Bus)에 메시지를 필터링하는 작업을 오프로드합니다.

아래 소비자를 만들 때 선택기를 사용할 수 있습니다.

• 공유 지속성 구독
• 공유되지 않는 지속성 구독
• 공유 비지속성 구독
• 공유되지 않는 비지속성 구독
• 큐 브라우저

AMQP 처리 및 Service Bus 작업 매핑

다음은 AMQP 처리가 Service Bus 작업으로 변환되는 방법입니다.

ACCEPTED = 1; -> Complete()
REJECTED = 2; -> DeadLetter()
RELEASED = 3; (just unlock the message in service bus, will then get redelivered)
MODIFIED_FAILED = 4; -> Abandon() which increases delivery count
MODIFIED_FAILED_UNDELIVERABLE = 5; -> Defer()

요약

이 개발자 가이드에서는 JMS(Java Message Service)를 사용하는 Java 클라이언트 애플리케이션이 Azure Service Bus와 연결하는 방법을 보여 줍니다.

다음 단계

Azure Service Bus에 대한 자세한 내용과 JMS(Java Message Service) 엔터티에 대한 자세한 내용은 다음 문서를 검사.

• Service Bus - 큐, 토픽 및 구독
• Service Bus - Java Message Service 엔터티
• Azure Service Bus의 AMQP 1.0 지원
• Service Bus AMQP 1.0 개발자 가이드
• Service Bus 큐 시작
• Java Message Service API(외부 Oracle 문서)
• ActiveMQ에서 Service Bus로의 마이그레이션 방법 알아보기