Amazon MQ 브로커에 Java 애플리케이션 연결

Amazon MQ 콘솔에 로그인합니다.

브로커 목록에서 브로커의 이름(예: MyBroker)을 선택합니다.

에서 MyBroker 페이지의 연결 섹션에서 브로커의 웹 콘솔 및 와이어 수준 프로토콜의 주소URL와 포트를 기록해 둡니다.

세부 정보 섹션의 보안 및 네트워크에서 보안 그룹의 이름 또는 을 선택합니다.

EC2 대시보드의 보안 그룹 페이지가 표시됩니다.

보안 그룹 목록에서 보안 그룹을 선택합니다.

페이지 하단에서 인바운드를 선택한 후 편집을 선택합니다.

인바운드 규칙 편집 대화 상자에서 공개적으로 액세스하려는 모든 URL 또는 엔드포인트에 대한 규칙을 추가합니다(다음 예제에서는 브로커 웹 콘솔에 대해 이 작업을 수행하는 방법을 보여줍니다).

1. 규칙 추가(Add Rule)를 선택합니다.

2. 유형 에서 사용자 지정 을 TCP선택합니다.

3. Port Range(포트 범위)에 웹 콘솔 포트(8162)를 입력합니다.

4. Source(소스)에서 Custom(사용자 지정)을 선택한 상태에서 웹 콘솔에 액세스하는 데 사용할 시스템의 IP 주소(예: 192.0.2.1)를 입력합니다.

5. 저장(Save)을 선택합니다.

   이제 브로커가 인바운드 연결을 허용할 수 있습니다.

브로커의 엔드포인트를 사용하여 메시지 프로듀서의 JMS 풀링된 연결 팩토리를 생성한 다음, 이 createConnection 메서드를 팩토리에 대해 호출합니다.

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Create a pooled connection factory.
final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(connectionFactory);
pooledConnectionFactory.setMaxConnections(10);

// Establish a connection for the producer.
final Connection producerConnection = pooledConnectionFactory.createConnection();
producerConnection.start(); 

// Close all connections in the pool.
pooledConnectionFactory.clear();

세션, MyQueue라는 이름의 대기열, 그리고 메시지 생산자를 생성합니다.

// Create a session.
final Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// Create a queue named "MyQueue".
final Destination producerDestination = producerSession.createQueue("MyQueue");

// Create a producer from the session to the queue.
final MessageProducer producer = producerSession.createProducer(producerDestination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

문자열 "Hello from Amazon MQ!"를 생성한 다음 메시지를 전송합니다.

// Create a message.
final String text = "Hello from Amazon MQ!";
TextMessage producerMessage = producerSession.createTextMessage(text);

// Send the message.
producer.send(producerMessage);
System.out.println("Message sent.");

생산자를 정리합니다.

producer.close();
producerSession.close();
producerConnection.close();

브로커의 엔드포인트를 사용하여 메시지 프로듀서의 JMS 연결 팩토리를 생성한 다음 createConnection 해당 팩토리에 메서드를 호출합니다.

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Establish a connection for the consumer.
final Connection consumerConnection = connectionFactory.createConnection();
consumerConnection.start();

세션, MyQueue라는 이름의 대기열, 그리고 메시지 소비자를 생성합니다.

// Create a session.
final Session consumerSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// Create a queue named "MyQueue".
final Destination consumerDestination = consumerSession.createQueue("MyQueue");

// Create a message consumer from the session to the queue.
final MessageConsumer consumer = consumerSession.createConsumer(consumerDestination);

메시지가 오기를 기다리다가 메시지가 도착하면 이를 수신합니다.

// Begin to wait for messages.
final Message consumerMessage = consumer.receive(1000);

// Receive the message when it arrives.
final TextMessage consumerTextMessage = (TextMessage) consumerMessage;
System.out.println("Message received: " + consumerTextMessage.getText());

소비자, 세션 및 연결을 종료합니다.

consumer.close();
consumerSession.close();
consumerConnection.close();