410013796724260
• Webmoney
R335386147728
Z369087728698
Отправка и чтение JMS сообщенийВ предыдущей статье был рассмотрен пример отправки и получения JMS сообщений в WEB приложении с контейнером JBoss. В качестве провайдера обслуживания очередей javax.jms.Queue был использован HornetQ, интегрированный в контейнер. Данная статья продолжает рассмотрение вопроса отправки и получения JMS сообщений из Java приложения; в качестве провайдера очередей MQ (Message Queue) будет использоваться Websphere MQ. Websphere MQ не является предметом описания статьи. Данное программное обеспечение играет вспомогательную роль и ему будет отведено минимальное внимание. Если Вы не знакомы с Websphere MQ, но желаете освоить данное ПО или работу с JMS сообщениями, то можете установить пробную 90-дневную trial версию с официального сайта IBM. Данного времени вполне достаточно для освоения технологии работы с JMS-сообщениями. Для работы с JMS сообщениями создадим три класса :
Отличия двух последних классов JmsBrowser и JmsConsumer связаны с тем, что если первый будет только читать сообщения из очереди, то второй класс будет читать сообщения вместе с их удалением из очереди. В классы включим методы main, чтобы можно было бы не на словах, а на деле увидеть отправку и получение JMS сообщений. Кроме этого, JMS сообщение будет выведено в консоль, чтобы наглядно представить значимые атрибуты класса javax.jms.Message. При разработке классов упростим себе жизнь и используем один из основных принципов ООП наследование. Для этого разработаем базовый класс JmsBase, в котором определим настройки канала подключения javax.jms.Connection, а классы издателя и просмоторщиков будут наследовать JmsBase. В результате бизнес-логика будет разделена на две части : родитель будет отвечать за подключение к провайдеру JMS очередей, а наследники будут реализовывать определенные им функции. Листинг базового модуля JmsBaseБазовый класс JmsBase, как было отмечено выше, отвечает за подключение к провайдеру Websphere MQ. Создадим в JmsBase метод подключения createConnection и абстрактный класс doAction, обязательный для определения в наследниках. В качестве параметров подключения используются наименование и порт компьютера (host, port), наименования менеджера очередей (queueManagerName) и очередь (queueName). Подключение javax.jms.Connection настраивается на менеджера очередей 'host1/qm1' и очередь 'queue1'. В конструкторе класса создается подключение javax.jms.Connection и вызывается метод doAction. Таким образом, в наследниках потребуется только соответствующим образом реализовать предначертанные им функции. На скриншоте представлен фрагмент интерфейса приложения MQExplorer с открытым окном просмотра сообщений очереди. MQExplorer включен в дистрибутив Websphere MQ.
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.Connection;
import javax.jms.JMSException;
import com.ibm.msg.client.wmq.WMQConstants;
import com.ibm.msg.client.jms.JmsFactoryFactory;
import com.ibm.msg.client.jms.JmsConnectionFactory;
public abstract class JmsBase
{
private String host = "localhost" ;
private int port = 1414 ;
private String channel = "SYSTEM.DEF.SVRCONN";
private String queueManagerName = "host1/qm1" ;
private String queueName = "queue1" ;
private boolean clientTransport = false ;
protected Session session = null;
protected Queue destination = null;
protected Connection connection = null;
// статус выполнения приложения
protected static int status = 1;
protected abstract void doAction();
//---------------------------------------------------------------
private void createConnection()
{
JmsFactoryFactory ff;
JmsConnectionFactory cf;
try {
ff = JmsFactoryFactory.getInstance(
WMQConstants.WMQ_PROVIDER);
cf = ff.createConnectionFactory();
// Set the properties
cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, host );
cf.setIntProperty (WMQConstants.WMQ_PORT , port );
cf.setStringProperty(WMQConstants.WMQ_CHANNEL , channel);
if (clientTransport) {
cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE,
WMQConstants.WMQ_CM_CLIENT);
} else {
cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE,
WMQConstants.WMQ_CM_BINDINGS);
}
cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER,
queueManagerName);
connection = cf.createConnection();
} catch (JMSException jmsex) {
recordFailure(jmsex);
}
}
//---------------------------------------------------------------
public JmsBase()
{
try {
createConnection();
session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue(queueName);
// Старт подключения
connection.start();
// Выполнение действий
doAction();
}
catch (JMSException jmsex) {
recordFailure(jmsex);
} finally {
try {
if (session != null)
session.close();
if (connection != null)
connection.close();
} catch (JMSException jmsex) {
System.err.println("" + jmsex.getMessage());
recordFailure(jmsex);
}
}
}
//---------------------------------------------------------------
protected void recordFailure(Exception ex)
{
// ...
}
//---------------------------------------------------------------
protected void processJMSException(JMSException jmse)
{
// ...
}
}
Код процедур обработки исключений на странице не приводится. Желающие могут скачать рабочие примеры. Листинг издателя сообщений JmsProducerКласс издателя JMS сообщений наследует все свойства родителя JmsBase и определяет процедуру doAction(), в которой выполняется отправка сообщений провайдеру Websphere MQ. В конструкторе класса выполняется подключение к провайдеру MQ, после чего в процедуре doAction() формируется список сообщений messages и создается издатель сообщений producer типа MessageProducer. Для создания MessageProducer используется метод createProducer объекта сессии javax.jms.Session с параметром очереди destination (javax.jms.Queue). Если издатель создан, т.е. имеется канал связи и исключений не было, то в цикле вызывается метод send (TextMessage) для отправки двух сообщений.
import javax.jms.TextMessage;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
public class JmsProducer extends JmsBase
{
private MessageProducer producer = null;
public JmsProducer()
{
super();
try {
if (producer != null)
producer.close();
} catch (JMSException jmse) {
recordFailure(jmse);
}
}
@Override
protected void doAction()
{
// Создание текстовых сообщений
String[] messages = new String[2];
messages[0] = "Good day";
messages[1] = "Hello, world!";
String TEMPL = "Cообщение #%d отправлено";
try {
producer = session.createProducer(destination);
System.out.println("Отправка JMS сообщений\n");
TextMessage message = null;
for (int i = 0; i < messages.length; i++) {
message = session.createTextMessage(messages[i]);
producer.send(message);
System.out.println(String.format(TEMPL, (i + 1)));
}
} catch (JMSException e) {
status = -2;
recordFailure(e);
}
}
public static void main(String[] args)
{
new JmsProducer();
System.exit(status);
}
}
Класс издателя сообщений JmsProducer включает метод main, позволяющий протестировать отправку JMS сообщений. В результате работы класса в консоль будет выведена следующая информация об отправке сообщений. Отправка JMS сообщений Cообщение #1 отправлено Cообщение #2 отправлено На следующем скриншоте представлено окно просмотра сообщений в приложении MQExplorer : в дереве объектов слева выделены Очереди менеджера 'host1/qm1', в панели данных справа выделена очередь 'queue1'. Их перекрывает окно Просмотра сообщений в очереди, в котором отображены отправленные сообщения. 
Листинг просмоторщика сообщений JmsBrowserКласс просмоторщика JMS сообщений JmsBrowser наследует все свойства родителя JmsBase и определяет процедуру doAction(). В конструкторе класса выполняется подключение к провайдеру MQ, после чего в процедуре doAction() создается объект просмотра сообщений browser типа QueueBrowser и выполняется чтение сообщений messages. Сообщения выводятся в консоль и выполнение процедуры завершается. Все тривиально просто и прозрачно.
import javax.jms.Message;
import javax.jms.JMSException;
import javax.jms.QueueBrowser;
import java.util.Enumeration;
public class JmsBrowser extends JmsBase
{
private QueueBrowser browser = null;
public JmsBrowser()
{
super();
try {
if (browser != null)
browser.close();
} catch (JMSException jmsex) {
recordFailure(jmsex);
}
}
@Override
protected void doAction()
{
try {
browser = session.createBrowser(destination);
// Чтение сообщений
Enumeration<?> messages = browser.getEnumeration();
int count = 0;
Message message;
// Просмотр сообщений
System.out.println("Просмотр JMS сообщений : ");
while (messages.hasMoreElements()) {
message = (Message) messages.nextElement();
System.out.println("\nСообщение " + (++count) + " :");
System.out.println(message);
}
System.out.println("\nПросмотр JMS сообщений завершен\n");
} catch (JMSException e) {
e.printStackTrace();
}
}
public static void main(String[] args)
{
new JmsBrowser ();
System.exit(status);
}
}
Класс включает метод main, позволяющий протестировать чтение JMS сообщений. В результате выполнения класса в консоль будут выведены два сообщения, отправленные из JmsProducer. Вы можете оценить количество атрибутов JMS сообщения. В последней строке представлен текст сообщения.
Просмотр JMS сообщений :
Сообщение 1 :
JMSMessage class: jms_text
JMSType: null
JMSDeliveryMode: 1
JMSDeliveryDelay: 0
JMSDeliveryTime: 0
JMSExpiration: 0
JMSPriority: 0
JMSMessageID: ID:414d5120686f7374312f716d31202020cf428c5922ed5a02
JMSTimestamp: 1502364406670
JMSCorrelationID: null
JMSDestination: null
JMSReplyTo: null
JMSRedelivered: false
JMSXAppID: \IBM\MQ\bin64\MQExplorer.exe
JMSXDeliveryCount: 1
JMSXUserID: Serg
JMS_IBM_Character_Set: UTF-8
JMS_IBM_Encoding: 546
JMS_IBM_Format: MQSTR
JMS_IBM_MsgType: 8
JMS_IBM_PutApplType: 11
JMS_IBM_PutDate: 20170810
JMS_IBM_PutTime: 11264667
Good day
Сообщение 2 :
JMSMessage class: jms_text
JMSType: null
JMSDeliveryMode: 1
JMSDeliveryDelay: 0
JMSDeliveryTime: 0
JMSExpiration: 0
JMSPriority: 0
JMSMessageID: ID:414d5120686f7374312f716d31202020cf428c5922ed5b02
JMSTimestamp: 1502364423160
JMSCorrelationID: null
JMSDestination: null
JMSReplyTo: null
JMSRedelivered: false
JMSXAppID: \IBM\MQ\bin64\MQExplorer.exe
JMSXDeliveryCount: 1
JMSXUserID: Serg
JMS_IBM_Character_Set: UTF-8
JMS_IBM_Encoding: 546
JMS_IBM_Format: MQSTR
JMS_IBM_MsgType: 8
JMS_IBM_PutApplType: 11
JMS_IBM_PutDate: 20170810
JMS_IBM_PutTime: 11270316
Hello, world!
Просмотр JMS сообщений завершен
Листинг просмоторщика сообщений JmsConsumerКласс просмоторщика JMS сообщений JmsConsumer также, как и предыдущие классы, наследует все свойства родителя JmsBase и определяет процедуру doAction(). В конструкторе класса также выполняется подключение к провайдеру MQ, после чего в процедуре doAction() создается объект чтения сообщений consumer типа MessageConsumer. Для чтения сообщений используется метод receive, который читает сообщение из очереди с удалением. В качестве параметра методу передается время ожидания в милисекундах. Сообщения выводятся в консоль и выполнение процедуры завершается по истечении установленного в timeout времени.
import javax.jms.Message;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
public class JmsConsumer extends JmsBase
{
private final int timeout = 30000;
private MessageConsumer consumer = null;
@Override
protected void doAction()
{
Message message;
try {
consumer = session.createConsumer(destination);
do {
message = consumer.receive(timeout);
if (message != null)
System.out.println("\nСообщение :\n" + message);
} while (message != null);
} catch (JMSException e) {
e.printStackTrace();
}
System.out.println("\nПросмотр JMS сообщений завершен\n");
}
public JmsConsumer()
{
super();
try {
if (consumer != null)
consumer.close();
} catch (JMSException jmsex) {
recordFailure(jmsex);
}
}
public static void main(String[] args)
{
new JmsConsumer();
System.exit(status);
}
}
В результате выполнения JmsConsumer в консоли будут также представлены JMS сообщения, как и в предыдущем JmsBrowser. Если Вы имеете доступ к провайдеру JMS очередей, то можете убедиться, что сообщения из очереди удалены. Скачать примерыИсходные коды рассмотренных классов в виде проекта Eclipse можно скачать здесь (7.42 Мб). Дистрибутив рабочий и включает весь необходимый набор библиотек. Пример WEB-приложения отправки и чтения JMS-сообщений из контейнера JBoss представлен здесь. |