Використання адаптера ресурсів WebSphere MQ з сервером додатків WebSphere Application Server Community Edition

1. Параметри адаптера ресурсів WebSphere MQ
2. Вихідні
3. Лістинг 1. Конфігурація вихідного зв'язку в in ra.xml
4. вхідні
5. Лістинг 2. Конфігурація вхідного зв'язку в in ra.xml
6. керовані об'єкти
7. Лістинг 3. Керовані об'єкти з ra.xml
8. Лістинг 4. План Geronimo
9. Створення плану корпоративного додатка
10. Лістинг 5. План додатки Geronimo
11. Налаштування конфігурації Websphere MQ для роботи з Community Edition
12. Необхідні умови
13. Налаштування конфігурації Community Edition
14. виконання прикладу
15. Вихідна зв'язок
16. Ресурси для скачування

IBM® Сервер додатків WebSphere® Application Server Community Edition (далі Community Edition) надає підтримку обміну повідомленнями за допомогою інтерфейсу ActiveMQ, постачальника служби повідомлень з відкритим вихідним кодом. Додаток J2EE, розгортається в середовищі Community Edition, може використовувати створювані в ActiveMQ черзі і теми, а керований повідомленнями bean-компонент (MDB) може служити кінцевою точкою для вилучення повідомлень з черги або теми. У цій статті показано, як використовувати WebSphere MQ в якості постачальника служби повідомлень для Community Edition. Ми використовуємо підтримку JMS, що надається WebSphere MQ через адаптер ресурсів архітектури коннектора J2EE (JCA). Адаптер ресурсів надає темам і черг вихідний зв'язок, а вхідний зв'язок в якості адаптера ресурсів вибирає повідомлення з черги і пересилає його до bean-компонента повідомлень.

На схемі показані використовувані для інтеграції компоненти Community Edition і WebSphere MQ.

• Черги / теми в WebSphere MQ;
• Адаптер ресурсів WebSphere MQ;
• Прив'язки файлу JNDI для WebSphere MQ;
• Керований повідомленнями bean-компонент для вхідного зв'язку;
• Сервлет для вихідного зв'язку.

Параметри адаптера ресурсів WebSphere MQ

Параметри адаптера ресурсів перераховуються в дескрипторі розгортання (ra.xml). У наступному розділі описуються параметри конфігурації вихідних, вхідних і керованих обєктів, яким для підключення до WebSphere MQ необхідний адаптер ресурсів.

Вихідні

Параметри конфігурації адаптера ресурсів для вихідного зв'язку:

url URL

постачальника JNDI, наприклад: ldap: // test / o = test, c = com, file: / C: / JNDI-Directory icf Первинна фабрика контексту (Initial Context Factory), наприклад: com.sun.jndi.fscontext. RefFSContextFactory name Ім'я фабрики, наприклад: wasceQCF

Лістинг 1. Конфігурація вихідного зв'язку в in ra.xml

<Outbound-resourceadapter> <config-property> <description> JNDI provider url </ description> <config-property-name> url </ config-property-name> <config-property-type> java.lang.String </ config-property-type> </ config-property> <config-property> <description> Initial Context Factory </ description> <config-property-name> icf </ config-property-name> <config-property-type> java.lang.String </ config-property-type> </ config-property> <config-property> <description> Factory Name </ description> <config-property-name> name </ config-property-name> < config-property-type> java.lang.String </ config-property-type> </ config-property> </ outbound-resourceadapter>

вхідні

Параметри конфігурації адаптера ресурсів для вхідного зв'язку:

url URL

постачальника JNDI icf Первинна фабрика контексту (Initial Context Factory) name Ім'я фабрики destination Адресат для пошуку форми повідомлень, наприклад, ім'я черги (Queue Name)

Лістинг 2. Конфігурація вхідного зв'язку в in ra.xml

<Inbound-resourceadapter> <activationspec> <required-config-property> <config-property-name> url </ config-property-name> </ required-config-property> <required-config-property> <config-property -name> icf </ config-property-name> </ required-config-property> <required-config-property> <config-property-name> name </ config-property-name> </ required-config-property > <required-config-property> <config-property-name> destination </ config-property-name> </ required-config-property> </ activationspec> </ inbound-resourceadapter>

керовані об'єкти

Ім'я черзі або теми, створеної в JNDI Geronimo

Лістинг 3. Керовані об'єкти з ra.xml

<Adminobject> <adminobject-interface> javax.jms.Queue </ adminobject-interface> <config-property> <config-property-name> PhysicalName </ config-property-name> <config-property-type> java.lang .String </ config-property-type> </ config-property> </ adminobject> <adminobject> <adminobject-interface> javax.jms.Topic </ adminobject-interface> <config-property> <config-property-name > PhysicalName </ config-property-name> <config-property-type> java.lang.String </ config-property-type> </ config-property>

Параметри адаптера ресурсів відображаються в план адаптера ресурсів Community Edition (wasce-mq.xml), який містить параметри рівня екземпляра для вхідних з'єднань і адмініструються об'єктів. У цьому файлі можна вказати значення для параметрів конфігурації вихідного зв'язку адаптера ресурсів і адмініструються об'єктів. приклади:

ldap: // test / o = test, c = com OR file: / C: / JNDI-Directory icf com.sun.jndi.fscontext.RefFSContextFactory name wasceQCF фізичне ім'я черги SYSTEM.DEFAULT.LOCAL.QUEUE фізичне ім'я теми SampleTopic

Лістинг 4. План Geronimo

<Outbound-resourceadapter> <connectiondefinition> <connectiondefinition-instance> <name> MQQueueFactory </ name> <config-property-setting name = "url"> </ config-property-setting> <config-property-setting name = "icf"> </ config-property-setting> <config-property-setting name = "name"> </ config-property-setting> <connectionmanager> </ connection-definition> <adminobject> <adminobject-instance> <message-destination-name> ivtQ </ message-destination-name> <config-property-setting name = "PhysicalName"> SYSTEM.DEFAULT.LOCAL.QUEUE </ config-property-setting> </ adminobject-instance> < / adminobject> <adminobject> <adminobject-instance> <message-destination-name> ivtT </ message-destination-name> <config-property-setting name = "PhysicalName"> SampleTopic </ config-property-setting> </ adminobject-instance> </ adminobject>

Створення плану корпоративного додатка

Для комунікацій з WebSphere MQ можна використовувати такі об'єкти J2EE, як сервлети або сеансу bean-компоненти. У лістингу 5 показаний план корпоративного програми, що складається з Web-модуля і модуля у вигляді bean-компонента для вихідної і вхідного зв'язку з WebSpere MQ. Конфігурація Community Edition включена в файл geronimo-application.xml. Web-модуль містить посилання на ra / MQQueueFactory і ra / MQTopicFactory, а модуль bean-компонент містить посилання на екземпляр адаптера ресурсів MQRA_1. Параметри Activation Spec, необхідні для вхідного зв'язку з адаптером ресурсів, задаються у файлі конфігурації активації bean-компонента повідомлень.

Лістинг 5. План додатки Geronimo

<Application xmlns = "http: // geronimo. Apache.org/xml/ns/j2ee/application" configId = "wasce / mq.ear" parented = "wasce / mq.rar"> <module> <web> WASCEMQWAR. war </ web> <web-app xmlns = "http://geronimo.apache.org/xml/ns/web" xmlns: naming = "http://geronimo.apache.org/xml/ns/naming" configId = "wasce / mq.war" parentId = "wasce / mq.ear"> <context-priority-classloader> false </ context-priority-classloader> <naming: resource-ref xmlns = "http: // geronimo. apache .org / xml / ns / naming "> <naming: ref-name> ra / MQQueueFactory </ naming: ref-name> <naming: resource-link> MQQueueFactory </ naming: resource-link> </ naming: resource- ref> <naming: resource-ref xmlns = "http://geronimo.apache.org/xml/ns/naming"> <naming: ref-name> ra / MQTopicFactory </ naming: ref-name> <naming: resource -link> MQTopicFactory </ naming: resource-link> </ naming: resource-ref> </ web-app> </ module> <module> <ejb> WASCEMQEJB.jar </ ejb> <openejb-jar xmlns = " http://www.openejb.org/xml/ns/openejb-jar "xmlns: naming =" http://geronimo.apache.org/xml/ns/naming "configId =" wasce / mq. ejb "parentId =" wasce / mq.ear "> <enterprise-beans> <message-driven> <ejb-name> MQMDB </ ejb-name> <resource-adapter> <resource-link> MQRA_1 </ resource-link > </ resource-adapter> <activation-config> <activation-config-property> <activation-config-property-name> url </ activation-config-property-name> <activation-config-property-value> file: // C: / JNDI-Directory </ activation-config-property-value> </ activation-config-property> <activation-config-property> <activation-config-property-name> icf </ activation-config-property -name> <activation-config-property-value> com.sun.jndi.fscontext.RefFSContextFactory </ activation-config-property-value> </ activation-config-property> <activation-config-property> <activation-config -property-name> name </ activation-config-property-name> <activation-config-property-value> wasceQCF </ activation-config-property-value> </ activation-config-property> <activation-config-property > <activation-config-property-name> destination </ activation-config-property-name> <activation-confi g-property-value> SYSTEM.DEFAULT.LOCAL.QUEUE </ activation-config-property-value> </ activation-config-property> </ activation-config> </ message-driven> </ enterprise-beans> < / openejb-jar> </ module> <ext-module> <connector> MQRA_1 </ connector> <external-path> mq / rars / wascemq.rar </ external-path> <connector xmlns = "http: // geronimo .apache.org / xml / ns / j2ee / connector "configId =" wasce / mq.rar.1 "parentId =" wasce / mq.ear "> <resourceadapter> <resourceadapter-instance> <resourceadapter-name> MQRA_1 </ resourceadapter-name> <workmanager> <gbean-link> DefaultWorkManager </ gbean-link> </ workmanager> </ resourceadapter-instance> <outbound-resourceadapter> ... (Same as Listing 4) </ connector> <ext- module> </ application>

Налаштування конфігурації Websphere MQ для роботи з Community Edition

У попередньому розділі описувалися плани додатки і адаптера ресурсів для адаптера ресурсів і додатків J2EE. У наступному розділі пояснюється, як налаштувати конфігурацію WebSphere MQ і Community Edition; пояснення супроводжується прикладом.

Необхідні умови

• WebSphere MQ версії 6.0;
• WebSphere Application Server Community Edition версії 1.0.

Налаштування конфігурації WebSphere MQ

Для настройки конфігурації WebSphere MQ:

1. Створіть менеджер черги (Queue Manager) (WASCE_Q) для черг (Queues). При цьому створюється локальна чергу за замовчуванням з ім'ям SYSTEM.DEFAULT.LOCAL.QUEUE;
2. Якщо ви не створили і не запустили слухач (Listener), який буде слухати на порту 1414, при створенні менеджера черги, то зробіть це зараз;
3. Створіть і запустіть канал з'єднання з сервером (Sever Connection Channel) CHANNEL1;
4. Створіть менеджер черги (WASCE_T) для тих і запустіть його з Services як брокер;
5. Створіть і запустіть для цього менеджера черги (QueueManager) слухач на порту 1 434;
6. Створіть і запустіть канал з'єднання з сервером (Sever Connection Channel) CHANNEL1;
7. Виконайте команду MQSC за допомогою файлу MQJMS_PSQ.mqsc, який містить рядок: runmqsc WASCE_T <MQJMS_PSQ.mqsc.
8. Створіть прив'язки JNDI for QueueConnectionFactory і TopicConnectionFactory за допомогою інструменту JMSAdmin. Налаштуйте JMSAdmin.config на використання файлового контексту JNDI і вкажіть шлях C: / JNDI-Directory. Запустіть інструмент JMSAdmin і створіть прив'язки

QueueConnectionfactory DEFINE QCF (wasceQCF) HOST (localhost) PORT (1414) CHANNEL (CHANNEL1) QMGR (WASCE_Q) TRAN (client) TopicConnectionFactory DEFINE TCF (wasceTCF) HOST (localhost) PORT (1434) CHANNEL (CHANNEL1) qmgr (WASCE_T) TRAN ( client) Subscriber DEFINE T (wasceTopic) TOPIC (SampleTopic)

Налаштування конфігурації Community Edition

Для настройки конфігурації Community Edition:

1. Створіть зазначену нижче структуру папок в каталозі Community Edition і скопіюйте наступні JAR- і -RAR файли WebSphere MQ. JAR-файли MQ знаходяться в WebSphere MQ каталозі home / java / lib:
2. Запустіть сервер за допомогою Java: <community edition home> / bin / java -jar server.jar. Не використовуйте ярликом Windows;
3. Розгорніть адаптер ресурсів з областю сервера на сервері за допомогою командного рядка або консолі. Тепер додатки можуть створювати екземпляри цього адаптера ресурсів і використовувати його в своїй області дії: <CE HOME> / bin / deploy deploy wasce-mq.xml <path> /wascemq.rar;
4. Розгорніть EAR, який містить bean-компонент MDB для вхідного зв'язку від WebSphere MQ, WAR для вихідного зв'язку з чергою / темою, і примірник адаптера ресурсів, розгорнутий на кроці 2:

виконання прикладу

Щоб виконати приклад, щоб переглянути вхідну і вихідну зв'язок з WebSphere MQ:

Вихідна зв'язок

1. Використовуйте розгорнутий WAR для перевірки вихідного зв'язку з темою або чергою:
2. Перейдіть до http: // localhost: 8080 / mq:
3. Введіть повідомлення і натисніть кнопку Queue або Topic;
4. Це повідомлення надіслано в чергу QUEUE: SYSTEM.DEFAULT.LOCAL.QUEUE in WASCE_Q;
5. Для теми повідомлення надіслано в SampleTopic:
6. Запустіть передплатника, який додається в якості прикладу, щоб перевірити, чи отримали повідомлення. У WebSphere MQ входить проста програма, яка називається JMSPubSub.java, її можна використовувати для запуску передплатника в Sample Topic. Вона знаходиться в каталозі <MQ-DIR> /Tools/Java/jms/PubSub.java; Після запуску передплатника ви можете побачити повідомлення, надіслане в тему:

Вхідний зв'язок

1. Пошліть пробне повідомлення в чергу в WebSphere MQ (SYSTEM.DEFAULT.LOCAL.QUEUE);
2. Повинен запуститися метод onMessage компонента MDB, і нижче в консолі Community Edition ви побачите це повідомлення. Воно може бути послано і в тему, якщо додати ще один ActivationSpec для тем.

висновок

У цій статті було показано, як налаштувати програму WebSphere MQ для роботи з WebSphere Application Server Community Edition. Можна додати транзакції XA в адаптер ресурсів для підтримки розподілених транзакцій в Community Edition з WebSphere MQ.

Ресурси для скачування

Схожі теми

• оригінал статті Using WebSphere MQ with WebSphere Application Server Community Edition ;
• Сайт developerWorks Розділ WebSphere Application Server Community Edition zone
  Для розробників: доступ до навчальних статей, завантажуваних програм, навчальним посібникам, освітнім матеріалами, інформацією про програмні продукти, інформацією служби підтримки і т. П;
• Як почати працювати з WebSphere Application Server Community Варіант
  Community Edition - це сервер додатків Java c відкритим вихідним кодом на базі коду Apache Geronimo. У цій статті наводиться опис програмного продукту і рекомендації по отриманню та швидкому запуску, включаючи інструкції з вибору потрібного архіву для завантаження, налаштування середовища і розгортання програми;
• Проект Apache Geronimo
  Сайт проекту з відкритим вихідним кодом сервера додатків J2EE від компанії Apache Software Foundation;
• Сторінка програми WebSphere MQ
  Опис продукту, новини про продукт, інформація про навчання, підтримки та багато іншого;
• Бібліотека документації WebSphere MQ
  Керівництва по WebSphere MQ в форматі PDF;
• Центр інформації WebSphere MQ версії 6
  Простий Web-інтерфейс на базі Eclipse для користування усією документацією щодо WebSphere MQ версії 6;
• Розробка автономних Java-додатків для WebSphere MQ
  Показує, як розробити Java-додаток, яке відправляє і отримує повідомлення за допомогою WebSphere MQ, використовуючи стандартні API JMS і JNDI;
• Сайт developerWorks Розділ бізнес-інтеграції WebSphere Business Integration zone
  Для розробників: доступ до навчальних статей, завантажуваних програм, навчальним посібникам, освітнім матеріалами, інформацією про програмні продукти, інформацією служби підтримки і т. П .;
• Продукти інтеграції з бізнесом WebSphere Business Integration products сторінка
  Для бізнес-користувачів і техніків, зручний огляд всіх продуктів WebSpere для інтеграції з бізнесом;
• Завантажте пробні версії програмних продуктів IBM
  Безкоштовне завантаження обраних продуктів IBM® DB2®, Lotus®, Rational®, Tivoli®і WebSphere®;
• Найпопулярніші пробні завантаження WebSphere
  Безкоштовні пробні завантаження основних продуктів WebSphere;
• Книжкова полиця Safari: електронна бібліотека, створена для розробників
  Розширений пошук і доступ до завантаження тисяч технічних книг після одноразової оплати підписки. Пробна безкоштовне завантаження для нових передплатників;

Підпишіть мене на повідомлення до коментарів