> Java > java지도 시간 > Java API 개발에서 JMS 연결을 위해 JNDI 사용

Java API 개발에서 JMS 연결을 위해 JNDI 사용

WBOY
풀어 주다: 2023-06-18 09:21:52
원래의
1287명이 탐색했습니다.

현대 엔터프라이즈 애플리케이션의 개발이 점점 더 분산 시스템에 의존함에 따라 메시지 대기열의 사용이 점점 더 중요해지고 있습니다. JMS(Java Message Service)는 메시징 시스템을 쉽게 구축하는 데 사용할 수 있는 메시지 지향 API입니다. JNDI(Java Naming and Directory Interface)는 이름 지정 및 디렉토리 서비스에 액세스하기 위한 Java의 표준 API입니다. Java API 개발에서 JMS 연결용 JNDI를 사용하면 메시지 대기열을 더 쉽게 관리하고 사용할 수 있습니다.

  1. JNDI 소개

JNDI는 주로 런타임 시 이름 지정 및 디렉터리 서비스에 액세스하는 데 사용되는 Java API입니다. 이는 LDAP(Lightweight Directory Access Protocol), DNS(Domain Name System) 및 CORBA(Common Object Request Broker Architecture)와 같은 다양한 이름 지정 및 디렉터리 서비스에 액세스하는 일반적인 방법을 제공합니다. JNDI는 이름 지정 및 디렉토리 서비스의 세부사항을 배후에 숨기므로 개발자는 서비스에서 제공하는 객체를 얻고 사용하는 방법에만 집중할 수 있습니다.

  1. JMS 소개

JMS는 애플리케이션 간에 메시지를 전달하는 데 사용되는 메시지 지향 API입니다. JMS를 사용하면 큐나 주제에 메시지를 보내고 지정된 시간에 받을 수 있습니다. JMS는 비동기식 메시징 기능을 제공하므로 분산 시스템 간 통신에 이상적인 방법입니다.

  1. JNDI를 사용하여 JMS에 연결

Java API 개발에서는 JNDI를 사용하여 JMS에 연결하는 것이 매우 편리합니다. JMS에 연결하는 기본 단계는 다음과 같습니다.

3.1 JNDI 컨텍스트 만들기

먼저 JNDI 컨텍스트를 만들어야 합니다. JMS에서 컨텍스트는 연결 및 대상 관리를 담당하는 객체입니다. 다음 코드를 사용하여 JNDI 초기 컨텍스트를 생성할 수 있습니다.

Hashtable<String, String> env = new Hashtable<>();
env.put(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
env.put(Context.PROVIDER_URL, "tcp://localhost:61616");
Context context = new InitialContext(env);
로그인 후 복사

3.2 ConnectionFactory 및 Destination 가져오기

다음으로 ConnectionFactory 및 Destination 객체를 가져와야 합니다. ConnectionFactory는 연결을 생성하는 데 사용되는 팩토리 개체이고 Destination은 메시지를 보내고 받는 대상을 나타냅니다. ActiveMQ를 사용하는 경우 다음 코드를 사용하여 이러한 개체를 가져올 수 있습니다.

ConnectionFactory factory = (ConnectionFactory) context.lookup("ConnectionFactory");
Destination destination = (Destination) context.lookup("dynamicQueues/TEST.QUEUE");
로그인 후 복사

3.3 연결 및 세션 만들기

ConnectionFactory 및 대상을 가져온 후 연결 및 세션 개체를 만들 수 있습니다. ConnectionFactory를 사용하여 연결을 생성할 때 사용자 이름과 비밀번호를 지정할 수도 있습니다. 다음 코드는 연결을 만드는 방법을 보여줍니다.

Connection connection = factory.createConnection("username", "password");
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
로그인 후 복사

3.4 생산자와 소비자 만들기

이제 생산자(메시지 전송용)와 소비자(메시지 수신용)를 만들 수 있습니다. 다음 코드는 이러한 개체를 생성하는 방법을 보여줍니다.

MessageProducer producer = session.createProducer(destination);
MessageConsumer consumer = session.createConsumer(destination);
로그인 후 복사

3.5 메시지 보내기 및 받기

마지막으로 Producer를 사용하여 메시지를 보내고 Consumer를 사용하여 메시지를 받을 수 있습니다. 다음 코드는 이러한 작업을 수행하는 방법을 보여줍니다.

TextMessage message = session.createTextMessage("Hello World!");
producer.send(message);

Message receivedMessage = consumer.receive();
if (receivedMessage instanceof TextMessage) {
    TextMessage textMessage = (TextMessage) receivedMessage;
    String text = textMessage.getText();
    System.out.println(text);
}
로그인 후 복사
  1. Summary

일반적으로 Java API 개발에서 JNDI를 사용하여 JMS에 연결하면 메시지 대기열을 더 쉽게 관리하고 사용할 수 있습니다. JNDI를 사용하면 ConnectionFactory와 Destination을 쉽게 얻을 수 있고 Connection, Session, Producer 및 Consumer를 생성할 수 있습니다. 메시지도 쉽게 보내고 받을 수 있습니다. 따라서 JNDI를 사용하여 JMS에 연결하는 것은 JMS를 자주 사용해야 하는 엔터프라이즈 애플리케이션에 적합한 선택입니다.

위 내용은 Java API 개발에서 JMS 연결을 위해 JNDI 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿