Weblogic. JMS. Отправка и прием сообщения на topic из клиента.

При работе с JMS хочется проверить работу своего кода, а для этого нам может пригодится простой консольный клиент, который будет соединяться с сервером приложений, в данном случае с Weblogic, класть сообщение в топик и тут же вычитывать его. Так мы сможем протестировать работу publisher/subscriber в одном месте. Для этого создадим класс, пошагово объясняя каждую строчку. 

Сперва разберем весь код в деталях, а в конце приведем пример полного класса. 

Перед работой, желательно сразу подключить библиотеки weblogic.jar, wlclient.jar и wljmsclient.jar. Найти их можно в папка вебложика. 

Сперва нам необходимо задать системные свойства для контекста инициализации, которые должны содержать адрес провайдера и фабрику контекста инициализации:

Для Weblogic данные будут следующие:

Context.PROVIDER_URL, "t3://your_server_name:7290" Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"

t3://your_server_name:7290 - адрес сервера и порт, на котором крутится Ваш сервер. 

"weblogic.jndi.WLInitialContextFactory" - константное значение в случае использования weblogic, но разная для всех серверов приложений j2ee.

1. Создаем контекст инициализации, который будет находить для нас объекты по JNDI.

initialContext = new InitialContext();

2. Получаем через контекст фабрику соединений для топика. Она уже должна быть создана у Вас на сервере. 

topicConnectionFactory = (TopicConnectionFactory) initialContext .lookup("your/topic/factory/name");

3. Создаем соединение для топика:

topicConnection = topicConnectionFactory.createTopicConnection();

4. Создаем сразу две сессии - через одну будем отсылать сообщения, через другую - принимать. 

 TopicSession session = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); TopicSession pub = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

5. Находим наш топик, в который будем отсылать по имени JNDI через контекст инициализации:

Topic topic = (Topic) initialContext .lookup("your/topic/name");

6. Дальше - все просто. Создаем паблишера, сообщение, задаем текст сообщения и публикуемся:

TopicPublisher publisher = session.createPublisher(topic); TextMessage message = session.createTextMessage(); message.setText("Sample message"); publisher.publish(message);

Если все пошло хорошо - мессага улетела на топик.

Прием сообщений. 

1. Подписываемся на топик:

TopicSubscriber topicSubscriber = pub.createSubscriber(topic);

2.  Начинаем:

topicConnection.start();

3. В цикле принимаем сообщений. Реализация убогая, но для теста пойдет:

while (true) { Message receiveMsg = topicSubscriber.receive(); if (receiveMsg != null) { if (receiveMsg instanceof TextMessage) { TextMessage textMessage = (TextMessage) receiveMsg; System.out.println(textMessage.getText()); break; } } }

4. Задаем нашему классу, что он имплементит MessageListener интерфейс и задаем метод onMessage(), который слушает топик:

public void onMessage(Message message) { try { TextMessage textMessage = (TextMessage) message; String text = textMessage.getText(); System.out.println(text); } catch (Exception jmse) { jmse.printStackTrace(); } }

Ну и в конце пример полноценного класса, готового к запуску:

import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicConnectionFactory; import javax.jms.TopicPublisher; import javax.jms.TopicSession; import javax.jms.TopicSubscriber; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; public class JmsTest { public static void main(String[] args) { new JMSImpl(); } } class JMSImpl implements MessageListener { private Context initialContext; private TopicConnectionFactory topicConnectionFactory; private TopicConnection topicConnection = null; public JMSImpl() { System.setProperty(Context.PROVIDER_URL, "t3://your_server_name:7290"); System.setProperty(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"); process(); } private void process() { try { initialContext = new InitialContext(); // get the topic factory topicConnectionFactory = (TopicConnectionFactory) initialContext .lookup("topic/connection/factory"); // create a topic connection and session topicConnection = topicConnectionFactory.createTopicConnection(); TopicSession session = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); TopicSession pub = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); // finds the topic and build a publisher: Topic topic = (Topic) initialContext .lookup("your/topic/name"); TopicPublisher publisher = session.createPublisher(topic); TextMessage message = session.createTextMessage(); message.setText("Sample message"); publisher.publish(message); TopicSubscriber topicSubscriber = pub.createSubscriber(topic); topicConnection.start(); while (true) { Message receiveMsg = topicSubscriber.receive(); if (receiveMsg != null) { if (receiveMsg instanceof TextMessage) { TextMessage textMessage = (TextMessage) receiveMsg; System.out.println(textMessage.getText()); break; } } } } catch (NamingException e) { e.printStackTrace(); } catch (JMSException e) { e.printStackTrace(); } finally { if (topicConnection != null) try { topicConnection.close(); System.out.println("Connection closed."); } catch (JMSException e) { e.printStackTrace(); } } } public void onMessage(Message message) { try { TextMessage textMessage = (TextMessage) message; String text = textMessage.getText(); System.out.println(text); } catch (Exception jmse) { jmse.printStackTrace(); } } }