Третья часть освоение SOA

Выполнить задания:

• Задачка 1

Сделать композит, который периодически опрашивает (polling) таблицу БД на наличие строк со статусом READY и при их появлении пишет в файловую директорию cvs-файлы.

• Задачка 2

Сделать композит, который периодически опрашивает (polling) файловую директорию на наличие csv-файлов следующей структуры: First name,Last name,ID,E-mail John,Doe,01234567,john.doe@domain.com Alex,Smith,88888888,alex.smith@domain.com … Необходимо записать данные из csv-файлов в таблицу БД (сделать табличку с теми же полями и первичный ключ по всем полям).

• Задачка 3

Сделать композит, который «слушает» очереди JMS и AQ (т.е. две очереди; внутри XML-сообщения) и записывает данные сообщения в таблицу БД через вызов API-процедуры.

• Задачка 4

Добавить в существующий композит (см. задачку 2) дополнительную операцию (интерфейс WS), входная переменная которой получает полный путь к локальному csv-файлу (структура та же).  Необходимо записать данные из указанного файла в таблицу БД.

• Задачка 5

Добавить обработку ошибок в композите (см. задачку 2)  и в случае ошибки вставки в таблицу БД (ошибка по первичному ключу) переводить на администратора (humanIntervention), который может изменить значения полей и завершить выполнение композита

Вторая часть освоения SOA

Требуется изучить:

Выполнить tutorial. Есть следующие полезные книги:

• Getting Started With Oracle SOA Suite 11gR1 (главы 1-10,13-15,17)
• Oracle SOA Suite 11g R1 Developer’s Guide (главы 1-8,11,13-14,18-21)
• WS-BPEL 2.0 for SOA Composite Applications with Oracle SOA Suite 11g (главы 1-7 включительно)

Книги однотипные, главы связанные с BAM (Business Activity Monitorung) и OSB (Oracle Service Bus) пока не рассматриваем. Первые две книги содержат tutorial-ы. Пройдите от начала до конца одину из них (см. указанные главы). Обрати внимание, что оба tutorial-а по немного более старой версии SOA (например по 11.1.1.5), хотя на данный момент чаще всего используется версии 11.1.1.6 и 11.1.1.7 - поэтому скриншоты в книгах могут немного не совпадать.

После завершения tutorial просмотреть остальные книги на непроработанный/незатронутый функционал.

Выполнить задание:

1. Создать две JMS Queue в Weblogic;
2. Создать MDB, который перекладывает сообщения из одной очереди в другую;
3. Развернуть на сервере и протестировать.

Полезные ссылки:

1. Рекомендую использовать официальный developers guide по Oracle SOA, как справочник.
2. Хороший блог по Oracle SOA на русском языке
3. Блоги на английском:
• A-Team Chronicles
• Albin's Blog
• AMIS TECHNOLOGY BLOG
• Antony Reynolds' Blog
• Beyond SOA
• Harvinder Singh's Oracle AIA & SOA ...
• Java / Oracle SOA blog
• Managing Oracle SOA Environment [10g/11g]
• Middleware Magic [Weblogic]
• Middleware Snippets
• Neeraj Sehgal - Experimenting with SOA
• Oracle Middleware Blog
• Oracle SOA / Java blog
• Oracle SOA Best Practice And Troubleshooting
• Oracle SOA Essentials for an engineer
• Oracle SOA Suite - Team Blog
• Oracle Technologies Primer
• OracleFusionMiddleWare 10g,11g and AIA
• Sathyam's SOA Blog
• SOA / BPM on Oracle Fusion Middleware
• SOA Proactive Support
• SOA Thinker
• STEFAN'S SOA & AIA & ENTERPRISE ARCHITECTURE BLOG
• The Real Rach!!!
• The WebLogic Server Blog
• и многие другие

Первая часть освоения SOA

Требуется изучить:

• XML. Основные технологии: основы XML, XSD/XML Schema, XPath, XSL/XSLT, SOAP, WSDL. Полезная информация:
• Вкратце:
• Школа XML
• Школа XSL
• Школа XPath
• Школа XSD
• Школа SOAP
• Школа WSDL (в браузере выбрать кодировку cp1251)
• Видеокурсы от Яндекс:
• XML
• XPath
• XSLT

Книг по XML много, в том числе и на русском. Дополнительно полезно знать XQuery. Нужно понимание функциональности и возможностей XQuery по сравнению с XSL. Рекомендую книгу «W3C XML: Xquery от экспертов. Руководство по языку запросов» или в оригинале «XQuery from the Experts: A Guide to the W3C XML Query Language».

• Weblogic. Требуется разобраться:
• Как минимум, в следующих технологиях:
• JMS (Java Message Service)
• MDB (Message Driven Bean)
• JTA & JTS (Java Transaction API & Java Transaction Service)
• В основах администрирования.

Полезные ссылки:

• Oracle Learning Library
• Документацию по Oracle Fusion Middleware
• Google J

Конфигурирование автоматической миграции JMS-серверов

Описание: WebLogic-кластере приложения и Data Source-ы могут быть распределены на всех узлах кластера, но есть несколько типов singleton-ресурсов, которые должны быть в единственном экземпляре в кластере:

• JMS-сервера и их destinations;
• JMS SAF-агенты;
• Persistance store;
• Менеджер транзакций и его логи;
• Созданные пользователем классы (должен быть имплементирован интерфейс weblogic.cluster.singleton.SingletonService).

Для обеспечения высокой доступности данных ресурсов используются два подхода:

• Миграция всего Managed-сервера;
• Миграция сервисов (т.е. данных singleton-ресурсов с одного Managed-сервера на другой в Weblogic-кластере).

В данной статье пойдёт речь об автоматической миграцией JMS-ресурсов в конфигурации из двух физических серверов (с точки зрения операционной системы).

Последовательность шагов:

1. Создадим два Managed-сервера, например jms_server1 и jms_server2:
   
   
2. Создадим кластер, например JMS_Cluster и добавим ранее созданные Managed-сервера:
   
   
3. Создадим две Machine и соотнесём их с каждым Managed-сервером:
   
   
4. Создадим Data Source для целей миграции, например MigrationDS:
   
   
5. Создадим JDBC Persistence Store, например JDBCStore1:
   
   
6. Создадим JMS-сервер, например JMSServer1:
   
   
7. Создадим JMS-модуль, например JMSModule1:
   
   
8. Создадим в JMSModule1 новый Subdeployment, например JMSServer1Sub, и назначим его на JMSServer1:
   
   
9. В JMSModule1 создадим Connection Factory и очередь, например JMSConnectionFactory и TestQueue соответственно, и соотвесём их с SubDeployment - JMSServer1Sub:
   
   
10. Перейти в JMS_Cluster на страницу "Configuration"->"Migration" и выбрать тип механизма контроля миграции, в нашем случае будем использовать Database и выберем созданный (на шаге 4) Data Source - MigrationDS:
    
    
11. Создадим необходимую служебную таблицу для механизма контроля миграции, для этого надо выполнить скрипт лежащий в $MW_HOME/wlserver_10.3/server/db/<СУБД>/leasing.ddl.
12. Затем перейти в "Environment"->"Migratable Targets" выбрать "jms_server1 (migratable)" и изменить Service Migration Policy, например:
    
    
13. Аналогично для "jms_server2 (migratable)":
    
    
14. Перезапустить AdminServer, а после этого запустить jms_server1 и jms_server2:
    
    
15. Тестируем миграцию JMS-сервера. Например с помощью данного консольного клиента.

Простой консольный JMS-клиент для Weblogic Server

Возникла необходимость тестирования миграции JMS-очередей (queue-типа), для этого сделана утилита для:

• отправки текстовых сообщений в очередь;
• получения сообщений из очереди.

Скомпилированный jar-файл здесь, а исходный код здесь.

Как настроить соединение с сервером:
В jar-файле есть текстовый файл connection.properties - параметры соединения хранятся в нём.
Пример содержимого данного файла:

 url=t3://192.168.2.130:7501,192.168.2.96:7502  
 user=weblogic  
 password=welcome1  
 queue=jms/Queue  
 connectionFactory=jms/JMSConnectionFactory  
 textMessage=<elem><val1>#DATE_LONG#</val1><val2>#RND#</val2><val3>#DATE#</val3></elem>    

где textMessage - шаблон сообщения для отправки. Можно использовать следующие подстановочные значения:

• #DATE_LONG# - текущая дата в формате количества милисекунд с 1 января 1970 года;
• #DATE# - текущая дата в формате "ЧАСЫ:МИНУТЫ:СЕКУНДЫ.МИЛИСЕКУНДЫ ДЕНЬ-МЕСЯЦ-ГОД";
• #RND# - произвольное целое число в диапазоне от 0 до 10000.

Как запустить:

• Отправка сообщений в очередь, например:
  

   java -classpath C:\Apps\SimpleClientForJMS.jar;C:\Apps\Oracle\Weblogic\10.3.5\wlserver_10.3\server\lib\weblogic.jar com.blogspot.stan1slav.jms.testing.SimpleJMSClient send 12  
  

  где C:\Apps\Oracle\Weblogic\10.3.5\wlserver_10.3\server\lib\weblogic.jar - путь к weblogic.jar;
        12 - какое кол-во сообщений отправить в очередь.
  
• Забрать сообщения из очереди, например:
  

   java -classpath C:\Apps\SimpleClientForJMS.jar;C:\Apps\Oracle\Weblogic\10.3.5\wlserver_10.3\server\lib\weblogic.jar com.blogspot.stan1slav.jms.testing.SimpleJMSClient receive 10  
  

  где 10 - сколько секунд ожидать получение новых сообщенийю
  

Пример простейшего MDB-компонента

Ниже пример MDB-компонента который слушает очередь (в этом примере jms/TestQueue) и выводит содержимое сообщения в лог-сервера:

 import javax.ejb.ActivationConfigProperty;  
 import javax.ejb.EJBException;  
 import javax.ejb.MessageDriven;  
 import javax.jms.Message;  
 import javax.jms.MessageListener;  
 import javax.jms.TextMessage;  
 @MessageDriven(  
 activationConfig = {  
 @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue") ,  
 @ActivationConfigProperty(propertyName="connectionFactoryJndiName",propertyValue="jms/JMSConnectionFactory"),  
 @ActivationConfigProperty(propertyName="destinationJndiName", propertyValue="jms/TestQueue")  
 }  
 ,mappedName="jms/TestQueue"  
 )  
 public class TestMDBBean implements MessageListener {  
   public void onMessage(Message message) {  
     try {  
       if (message instanceof TextMessage) {  
         TextMessage msg = (TextMessage)message;  
         System.out.println("Message arrived:");  
         System.out.println(msg.getText());  
         System.out.println("\n");  
       }  
     } catch (Exception e) {  
       throw new EJBException(e.toString());  
     }  
   }  
 }