Изучаем Java EE 7 - [202]
| Методами send() или publish() | ||
| JMSPriority | JMS имеет десятиуровневую шкалу приоритета, где 0 — минимальное значение, а 9 — максимальное | Методами send() или publish() |
Свойства
Помимо полей заголовка, интерфейс javax.jms.Message поддерживает значения свойств, которые похожи на заголовки, но явно создаются конкретным приложением, вместо того чтобы быть стандартным для всех сообщений. Это обеспечивает механизм добавления дополнительных полей заголовка сообщения, которые клиент получит либо не получит с помощью селекторов. Значения свойств могут иметь тип boolean, byte, short, int, long, float, double и String. Код для установки и получения значения свойств выглядит следующим образом:
>message.setFloatProperty("orderAmount", 1245.5f);
>message.getFloatProperty("orderAmount");
Тело сообщения
Тело сообщения не является обязательным и включает данные, которые следует отправить или получить. В зависимости от используемого интерфейса оно может содержать различные форматы данных, как показано в табл. 13.3.
| Интерфейс | Описание |
|---|---|
| StreamMessage | Сообщение, тело которого содержит поток примитивных значений Java. Заполняется и считывается последовательно |
| MapMessage | Сообщение, тело которого содержит набор пар «имя/значение», чьи имена имеют тип String, а значения — примитивные значения Java |
| TextMessage | Сообщение, тело которого содержит строку (например, XML) |
| ObjectMessage | Сообщение, которое содержит сериализуемый объект или коллекцию сериализуемых объектов |
| BytesMessage | Сообщение, которое содержит поток байтов |
Можно создать собственный формат сообщения, если вы создадите класс, наследующийся от интерфейса javax.jms.Message. Следует отметить, что при получении сообщения его тело доступно только для чтения. В зависимости от типа сообщения существуют различные методы, позволяющие получить доступ к его содержимому. Текстовое сообщение будет иметь методы getText() и setText(), сообщение-объект — методы getObject() и setObject() и т. д.:
>textMessage.setText("This is a text message");
>textMessage.getText();
>bytesMessage.readByte();
>objectMessage.getObject();
С появлением версии JMS 2.0 новый метод
Отправка и получение сообщений с помощью классического API
Рассмотрим простой пример, чтобы получить представление о том, как нужно использовать классический JMS API для отправки и получения сообщений. JMS работает с производителями, потребителями и местами назначения. Производитель посылает сообщение по месту назначения, где потребитель ждет прибытия сообщения. Места назначения могут быть двух видов: очередь (для связи «от точки к точке») и тема (для связи «публикация-подписка»). В листинге 13.2 производитель посылает текстовое сообщение в очередь, которую слушает потребитель.
>public class Producer {
>··public static void main(String[] args) {
>·····try {
>······// Получает контекст JNDI
>······Context jndiContext = new InitialContext();
>······// Выполняет поиск администрируемых объектов
>······ConnectionFactory connectionFactory = (ConnectionFactory)
>························jndiContext.lookup("jms/javaee7/ConnectionFactory");
>······Destination queue = (Destination) jndiContext.lookup("jms/javaee7/Queue");
>······//Создает необходимые артефакты для соединения с очередью
>······Connection connection = connectionFactory.createConnection();
>······Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>······MessageProducer producer = session.createProducer(queue);
>······// Отправляет текстовое сообщение в очередь
>······TextMessage message = session.createTextMessage("Сообщение отправлено " + new Date());
>······producer.send(message);
>······connection.close();
>····}··catch (NamingException | JMSException e) {
>······e.printStackTrace();
>····}
>··}
>}
Данный код представляет класс Producer, который имеет только метод main(). Первое, что происходит в этом методе, — создается контекст JNDI и затем используется для получения объектов типа ConnectionFactory и Destination.
Фабрики соединений и места назначения (очереди и темы) являются администрируемыми объектами и должны быть созданы и объявлены в поставщике сообщений (в нашем случае в OpenMQ GlassFish). Они оба имеют имя JNDI (например, очередь называется jms/javaee7/Queue); их следует искать в дереве JNDI.
Когда получены два администрируемых объекта, класс Producer использует класс ConnectionFactory, чтобы создать объект типа Connection, из которого будет получен объект типа Session. С помощью этого сеанса в очереди по месту назначения создаются объект типа MessageProducer и сообщение (session.createProducer(queue)). Производитель посылает это сообщение (текстового типа). Обратите внимание, что класс main ловит исключение JNDI NamingException, а также JMSException.
К счастью, код получения сообщения выглядит примерно так же, как и код для его отправки. Действительно, первые строки класса Consumer в листинге 13.3 точно такие же: создается контекст JNDI, выполняется поиск фабрики соединений и места назначения, затем осуществляется подключение. Различия заключаются в том, что вместо MessageProducer используется MessageConsumer и приемник входит в бесконечный цикл, чтобы слушать очередь (вы позже увидите, что зацикливания можно избежать, если использовать более стандартный слушатель сообщений). Когда приходит сообщение, оно потребляется и отображается его содержимое.
