Разработка заглушек бизнес-процесса на языке BPEL на основе Oracle SOA Suite и Weblogic12.10.2016 18:18

1. Запуск установщика.

   
   

   java -jar wls1036_generic.jar

   
   

2. Выбор пути для домашней папки.

   
   

   
   

3. Пропустим регистрацию для обновлений.

   
   

   
   

4. Выберем типичную установку.

   
   

   
   

5. Укажем папку с JDK.

   
   

   
   

6. Далее укажем папку куда поставить сам Weblogic.

   
   

   
   
7. Установка и поздравления.

В установке нет ничего сложного, остановлюсь только на некоторых моментах.
Пропустим минимальные требования и поставим Oracle Database 11g Release 2×32 для Windows, выберем Desktop Class. Нам для разработки хватит.
В интернете, в том числе и на хабре есть много статей по установке. Отмечу только установку под локальным админом и задание переменных окружения. Хотя ошибка с отсутствием ORACLE_UNQNAME не помешала и все завелось.

1. Для запуска установщика надо указать путь к JRE или JDK.

   
   

   ofm_soa_generic_11.1.1.7.0/Disk1/setup.exe -jreLoc c:\Oracle\Middleware\jdk160_24

   
   

2. Пропустим обновление софта.

   
   

   
   

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

   
   

   
   

4. Выбор Middleware Home и название директории для нашего SOA.

   
   

   
   

5. Далее установщик нашел Weblogic в домашней папке.

   
   

   
   
6. Установка и поздравления. Проверим подключение.
   

   sqlplus sys@ORCL as sysdba

7. Или запустим SQL Developer и настроим подключение.
   

   c:\app\admin\product\11.2.0\dbhome_1\sqldeveloper\sqldeveloper.exe

1. Запустим RCU.

   
   

   ofm_rcu_win_11.1.1.7.0_64_disk1_1of1/rcuHome/bin/rcu.bat

   
   

2. Выбираем Create Repository.

   
   

   
   

3. Указываем параметры БД, в нашем случае это localhost, 1521, sys и пароль. Далее идет проверка.

   
   

4. Следом надо указать префикс для имен схем данных (по умолчанию DEV) и выбрать компоненты репозитория, нам нужны Metadata Services и SOA Infrastructure, User Messaging Service выбирается автоматически.

   
   

   
   

5. Укажем пароль для пользователей, владельцев схем с данными для репозитория.

   
   

   
   

6. Потом можно выбрать табличные пространства для схем данных репозитория.

   
   

   
   

7. Запуск создания tablespaces.

   
   

   
   
8. Готово.

   
   

1. Запускаем установку.
   Чтобы его создать запустим файл config.cmd в папке

   
   

   C:\Oracle\Middleware\Oracle_SOA1\common\bin

   
   

   У меня JDK 1.7, поэтому он ругнулся

   
   Мы ее обойдем — меняем javaw на java в файле

   
   

   c:\Oracle\Middleware\wlserver_10.3\common\bin\config.cmd

   
   

   и получаем описание Unrecognized VM option 'UseSpinning'
   Удаляем опцию -XX:+UseSpinning (которой больше нет с 1.6) в файле

   
   

   c:\Oracle\Middleware\wlserver_10.3\common\bin\commEnv.cmd

   
   

   и снова запускаем.

   
   

2. Выбираем создание нового домена.

   
   

   
   

3. Выбираем Oracle SOA Suite, Enterprise Manager. WSM Policy Manager и JRF выберутся автоматически.

   
   

   
   

4. Указываем имя и путь к домену и приложениям.

   
   

   
   

5. Пароль для пользователя weblogic.

   
   

   
   

6. JDK и тип инсталляции. Оставим Development Mode.

   
   

   
   

7. Пропишем пароли к вашим схемам, хост и sid:.

   
   

   
   

8. Проверка.

   
   

   
   

9. Настраивать не будем, оставим пустыми.

   
   

   
   

10. Жмем создать.

    
    

11. Готово. Запустим Admin Server.

    
    

    
    

12. Дождемся сообщения «Server state changed to RUNNING»

    
    
13. Запустим soa_server1.
    

    c:\Oracle\Middleware\user_projects\domains\base_domain\bin\startManagedWebLogic.cmd soa_server1

14. Когда будет просить ввод логина и пароля, вводим от администратора домена. Чтобы больше не просил создадим файл.
    

    c:\Oracle\Middleware\user_projects\domains\base_domain\servers\soa_server1\security\boot.properties

    
    
    

    username=weblogic
    password=welcome1

1. Проверка WebLogic Administration Console: http://localhost:7001/console (если вы использовали порт по умолчанию при установке).

   
   

   
   
2. Проверка Enterprise Manager: http://localhost:7001/em
   В Enterprise Manager должна быть доступна вкладка «SOA» в дереве слева.

1. Необходимо установить JDeveloper что бы создавать композиты. Берем версию 11.1.1.9.0.
   Ставим, используя существующий Middleware Home.

   
   
2. Для работы с композитами, необходимо установить расширение для нашего JDeveloper.

   

   

   
   

1. Импорт MDS архива.

   

   
   

   
   
2. Создание подключения к БД под пользователем схемы MDS. View→Resource palette→New Connection→Database

   
   

3. Создание подключения к MDS. View→Resource palette→New Connection→SOA-MDS

   
   

1. Создание пустого проекта. (File→New).

   

   

   
   

   
   
2. Импорт существующего композита. Композиты также можно выкачать с функционального стенда. Выбираем созданный проект, File→Import.

   

   

   
   

На картинке выше можно видеть в правой части имеется внешняя система и бизнес-процесс ее вызывает методом invoke.
Давайте же уберем это ненужное. Я буду делать это в блокноте. Но можно и в интерфейсе.

1. Краткий экскурс.
   Файл состоит из блоков, вариаций больше, я перечислю некоторые:
   process — корневой тег для процесса
   partnerLinks — партнерские соглашения между сервисами
   variables — декларация переменные
   faultHandlers — обработчики ошибок
   sequence main — бизнес-процесс
   receive — получение запроса от клиента
   assign — блок присвоения переменных
   сopy — копирование данных из одного объекта в другой
   invoke — вызов веб-сервиса
   if, elseif, else — объявление условий
   condition — описание условия
   forEach — объявление цикла
   startCounterValue — начало цикла
   finalCounterValue — конец цикла
   scope — объединение

   
   

2. Убрать часть соглашения, касающееся внешней системы.

   
   
   
   

3. Для простоты обработчик ошибок я тоже удалю. Весь тег faultHandlers.

   
   
   
   
4. Удаляем assign запроса к внешней системе, оставим только копирование данных из запроса для идентификации запроса.
   

   
       $inputVariable.payload/SYSTEM/MSG_ID/@Value
       $outputVariable.payload/SYSTEM/MAIN_ID/@Value
   

5. Удаляем все вызовы внешних систем invoke, кроме последнего в файле, где должен быть ответ нашему клиенту.
   

6. Посмотрим переменную, в которую нужно записать ответ. В нашем случае это outputVariable
7. Берем пример ответа, который наш дружелюбно предоставили разработчики или мы сами вытащили из SOA на функциональном стенде. И прописываем значения в нужные теги. Например
   Метод payload, операция ответа AnsSearchGetCustomerPartyAcc и xpath поставим свои.
   BEGIN[$itr] — элемент в цикле, означает $itr-итый элемент BEGIN внутри родительского.

    
        "0"
        $outputVariable.payload/DATA/AnsSearchGetCustomerPartyAcc/BEGIN_/accClntList/BEGIN_[$itr]/accClnt/BEGIN_/status/BEGIN_/code/@Value
    

1. Удалим импорт wsdl от внешнего сервиса.
   

2. Уберем еще ссылку на внешний сервис.
   

3. И еще соединение wire к удаляемому сервису GetCustomerPartyAccountBS
   

   
   ```GetCustomerPartyAccountsystReqA/GetCustomerPartyAccountBS
       GetCustomerPartyAccountBS
   

1. Убираем ссылку на внешний сервис в этих файлах.
   

2. Пробуем собрать. Right Click на проекте → Make.
   Если все ОК, то деплоим, нет — разбираемся.

1. Пробуем задеплоить.

   
   

   
   

2. Выбор операции.

   
   

   
   

3. Можно создать несколько сервисов с одинаковым именем, но разной версии.
   Вызывать можно все, но по стандартному адресу будет работать только default-ревизии. В Enterprise Manager можно применить default на задеплоенном композите.

   
   

   
   

4. Выбор сервера.

   
   

   
   

5. Добавим локальный сервер. Жмем плюс.

   

   
   

   
   

6. Выбор SOA сервера.

   
   

   
   

7. Summary.

   
   

   
   
8. Лог деплоя.

   
   

Несколько примеров интересных возможностей.

1. Регулярные выражения.
   

   
       sender_bic
       xp20:matches($sender_bic,'(?!044525716|046577413|044030811|043602955|045004751|042007738|040349585|040813827)\d{9}') = true()
   ...

2. Присвоение строки
   
   
   

   
       "0000000001CA3B1"
       $CITResponse/DATA/ReqSyncFinancialTransactionBatch/BEGIN_/documentList/BEGIN_/document/BEGIN_/extId/@Value
                                   

3. Цикл и итератор.

   
   

   
   1
   count($onMessage_ExecuteFinancialTransactionBatch_InputVariable.part1/DATA/ReqExecFinancialTransactionBatch/BEGIN_/documentList/BEGIN_)
   ...

   
   
4. Использование итератора в цикле.
   

   
       "BQ.00000.1415807097.277059967"
       $CITResponse/DATA/ReqSyncFinancialTransactionBatch/BEGIN_/documentList/BEGIN_[$ForEach1CounterInc]/document/BEGIN_/extId/@Value
   

5. Много встроенный функций, например генерация guid.
   

   
       oraext:generate-guid()
       $CITResponse/SYSTEM/MSG_ID/@Value
   

6. Или сравнение.
   

   xp20:compare($sender_bic,$recipient_bic) != 0

7. Вкусное. Можно вставить Java.
   

Есть бизнес-процесс который вызывает внешнюю систему, которая через какое-то время делает запрос в тестируемую систему. Этого в нашем бизнес-процессе нет.
Необходимо настроить партнерские соглашения с новым сервисом, прописать переменные и вставить invoke сервиса запросом ReqSyncFinancialTransactionBatch в наш бизнес-процесс.
Сервис-провайдер, который принимает запрос ReqSyncFinancialTransactionBatch тоже построен на SOA и по хорошему стечению обстоятельств от него есть композит.
Нужно его распаковать и перетащить все, что относится к вызову провайдера в наш композит.

1. Добавляем пространства имен от провайдера и типа запроса в список.

   
   

   xmlns:ns27="urn:syst-ws:ws_soap-provider_ta" 
   xmlns:ns28="http://www.mybank.ru/ApplicationObjectLibrary/syst/Providers/DistributedFinancialTransactionProcessingBatchsystProvA/V1/SyncFinancialTransactionBatch_Request"   

   
   
2. Добавление партнерского соглашения.
   

3. Мне потребовалось еще и импортировать схемы.
   

4. Пропишем переменные.
   

5. Делаем присвоения в новом запросе, там где необходимо в соответствии со схемой.
   

   
       
           "cm.System.syst"
           $CITResponse/DATA/ReqSyncFinancialTransactionBatch/BEGIN_/systemTo/@Value
       
       
           "cm.System.BQ"
           $CITResponse/DATA/ReqSyncFinancialTransactionBatch/BEGIN_/systemFrom/@Value
                                            
       
           $onMessage_ExecuteFinancialTransaction_InputVariable.part2/DATA/ReqExecFinancialTransaction/BEGIN_/document/BEGIN_/id/@Value
           $CITResponse/DATA/ReqSyncFinancialTransactionBatch/BEGIN_/documentList/BEGIN_/document/BEGIN_/id/@Value
        
          

6. Присвоение переменной во входную переменную для вызова сервиса. Смотрим в wsdl провайдера на сообщение, которое он понимает.

   
   
   
   

   
       
           $CITResponse
           $processPutSoapIn.parameters/ns27:REQUESTPUT
       
   

   
   

7. Делаем вызов сервиса invoke, и вычитывание ответа receive, если нужно.
   Если нужно, проставляем необходимые хедеры к запросу с помощью bpelx: toProperties.

   
   

   
   
       
           'null'
       
                              
   
    

   
   

8. Добавим отношение к новому сервису в файл .componentType

   
   

   ...
   
     
         
   

   
   

9. Положим wsdl PROVIDER_TAWrapper.wsdl от сервиса в наш проект

   
   

10. Добавим reference в файл сfgplan

    
    

    
      
         
            
               @@@systDistributedFinancialTransactionProviderTAWSDL@@@
            
            
               @@@systDistributedFinancialTransactionTAWSDL_httpConnTimeout@@@
            
            
               @@@systDistributedFinancialTransactionTAWSDL_httpReadTimeout@@@
            
         
      
      

    
    
11. Добавим импорт wsdl, reference и wire в файл composit.xml
    Обратим внимание на ссылку к wsdl сервиса-провайдера location=«http://k10systwp.mybank.ru:7030/webproxy/WS/PROVIDER_TA? wsdl
    

    
      
      
         WSDLDriven
      
      
         
      
         

   
```DistributedFinancialTransactionProcessingBatchsystReqA/ProviderTAWSImport
      ProviderTAWSImport
     

1. Все, пробуем собрать и деплоить

1. Берем SoapUI, генерируем mosk-сервис, используя wsdl от задеплоенного нами сервиса.
2. Берем пример запроса к нашему сервису, прописываем в настройках в ReplyTo адрес mosk, которого только что создали. В Action прописываем операцию. Картинка кликабельна.

   
   

3. Делаем запрос
4. Смотрим, сервис отработал и прислал ответ. Картинка кликабельна.

   
   

1. Также возьмем SoapUI, генерируем mosk-сервис, используя wsdl от сервис-провайдера.
2. Копируем адрес wsdl и прописываем его в файле composite.xml в нашем сервисе. Таким образом мы указываем куда будет идти внедренный запрос.
   

3. Сохраняем, деплоим с другой версией. Снимаем также галочку в default, чтобы наш дебаг никому не помешал.

   
   

4. Проверим, что все собралось без ошибок и идем в EM. Ищем наш сервис с новой ревизией.

   

   
   

5. Сделаем запрос и проверим что внедренный вызов пришел на наш stub. Картинка кликабельна.

   
   

Потребовалось найти запросы по содержимому, чтобы понять что с ним случилось. Таблица CUBE_INSTANCE в нашей схеме DEV_SOAINFRA содержит всю историю по композитам. Но для просмотра надо ее вытащить из блоба.
Нашел тут функцию, которая это делает

        CREATE OR REPLACE PACKAGE SOA_UTIL AS

           -------------------------------------------------------------------------------------------
           -- Written by   : Gilberto Holms (https://gibaholms.wordpress.com/)
           -- Last update  : 07/11/2014
           -- Version      : 1.1
           -- Description  : Utility code to handle Oracle SOA Suite tables
           -- Release notes:
           --   1.0: Initial release
           --   1.1: Bug fix to work properly on SOA 10g
           -------------------------------------------------------------------------------------------

          FUNCTION GET_AUDIT_TRAIL(P_SCHEMA_NAME VARCHAR2, P_CIKEY NUMBER) RETURN CLOB;

        END SOA_UTIL;

        /

        CREATE OR REPLACE PACKAGE BODY SOA_UTIL AS

           -------------------------------------------------------------------------------------------
           -- Written by   : Gilberto Holms (https://gibaholms.wordpress.com/)
           -- Last update  : 07/11/2014
           -- Version      : 1.1
           -- Description  : Utility code to handle Oracle SOA Suite tables
           -- Release notes:
           --   1.0: Initial release
           --   1.1: Bug fix to work properly on SOA 10g
           -------------------------------------------------------------------------------------------

          FUNCTION GET_AUDIT_TRAIL(P_SCHEMA_NAME VARCHAR2, P_CIKEY NUMBER) RETURN CLOB
          AS
            V_AUDIT_BLOB BLOB;
            V_AUDIT_CLOB CLOB;

            V_CUR_AUDIT SYS_REFCURSOR;

            TYPE TP_AUDIT_RECORD IS RECORD(
              BLOCK NUMBER(38,0),
              LOG BLOB
            );
            TYPE TP_AUDIT_ARRAY IS TABLE OF TP_AUDIT_RECORD;
            V_AUDIT_ARRAY TP_AUDIT_ARRAY;
            V_AUDIT_COMPLETE BLOB;

            V_BUFFER_LENGTH PLS_INTEGER := 32767;
            V_BUFFER VARCHAR2(32767);
            V_READ_START PLS_INTEGER := 1;
        BEGIN

            DBMS_LOB.CREATETEMPORARY(V_AUDIT_BLOB, TRUE);
            DBMS_LOB.CREATETEMPORARY(V_AUDIT_CLOB, TRUE);
            DBMS_LOB.CREATETEMPORARY(V_AUDIT_COMPLETE, TRUE);

            OPEN V_CUR_AUDIT FOR 'SELECT BLOCK, LOG FROM ' || P_SCHEMA_NAME || '.AUDIT_TRAIL WHERE CIKEY = :cikey ORDER BY COUNT_ID' USING P_CIKEY;
            FETCH V_CUR_AUDIT BULK COLLECT INTO V_AUDIT_ARRAY;
            CLOSE V_CUR_AUDIT;

            FOR j IN 1..V_AUDIT_ARRAY.COUNT LOOP
                IF j = 1 THEN
                    DBMS_LOB.APPEND (V_AUDIT_BLOB, V_AUDIT_ARRAY(j).LOG);
                ELSE
                    IF ( V_AUDIT_ARRAY(j).BLOCK = V_AUDIT_ARRAY(j-1).BLOCK ) THEN
                        DBMS_LOB.APPEND (V_AUDIT_BLOB, V_AUDIT_ARRAY(j).LOG);
                    ELSE
                        DBMS_LOB.APPEND (V_AUDIT_COMPLETE, UTL_COMPRESS.LZ_UNCOMPRESS(V_AUDIT_BLOB));
                        DBMS_LOB.CREATETEMPORARY(V_AUDIT_BLOB, TRUE);
                        DBMS_LOB.APPEND (V_AUDIT_BLOB, V_AUDIT_ARRAY(j).LOG);
                    END IF;
                END IF;
            END LOOP;

            DBMS_LOB.APPEND (V_AUDIT_COMPLETE, UTL_COMPRESS.LZ_UNCOMPRESS(V_AUDIT_BLOB));
            V_AUDIT_ARRAY.DELETE;

            FOR i IN 1..CEIL(DBMS_LOB.GETLENGTH(V_AUDIT_COMPLETE) / V_BUFFER_LENGTH) LOOP
                V_BUFFER := UTL_RAW.CAST_TO_VARCHAR2(DBMS_LOB.SUBSTR(V_AUDIT_COMPLETE, V_BUFFER_LENGTH, V_READ_START));
                DBMS_LOB.WRITEAPPEND(V_AUDIT_CLOB, LENGTH(V_BUFFER), V_BUFFER);
                V_READ_START := V_READ_START + V_BUFFER_LENGTH;
            END LOOP;

            RETURN V_AUDIT_CLOB;

        END;

        END SOA_UTIL;

        /

и пример использования

SELECT
  CI.PROCESS_ID AS PROCESS_ID,
  CI.CIKEY AS INSTANCE_ID,
  CI.CREATION_DATE AS CREATION_DATE,
  CI.STATUS AS STEP,
  SOA_UTIL.GET_AUDIT_TRAIL('ORABPEL', CI.CIKEY) AS AUDIT_TRAIL_XML
FROM
  ORABPEL.CUBE_INSTANCE CI
WHERE
  CI.PROCESS_ID = 'MyBPEL'
  AND CI.CREATION_DATE BETWEEN (sysdate - 1) AND (sysdate)
  ORDER BY CI.CREATION_DATE DESC;

Картинки кликабельны.

1. Ищем проблемный запрос. Картинка кликабельна.

   
   

2. Берем его индентификатор ECID
3. Идем в EM и ищем запрос по ECID

   
   

4. Смотрим что случилось и главное за какое мы ответили системе

   

   
   

Тут ничего сложного

1. Для мониторинга системных ресурсов и метрик soa eсть замечательная вкладка Perfomace summary.

   
   

2. Есть свой скрипт, который будет слать soap запросы к заглушке раз в 30 секунд и замеряет время ответа. Можно его прикрутить к чему угодно, Grafana, Zabbix, Sitescope
3. При работах потребовалось увеличить память для heap до 4096, сама машина с 16 gb ram.
4. Так как история запросов растет, соответственно схема soa также пухнет. Требовалось расширять табличное пространство. Код можно найти в интернете, я приведу на всякий случай

ALTER TABLESPACE DEV_SOAINFRA
ADD DATAFILE 'C:\APP\KALISTRATOVKA\ORADATA\ORCL\DEV_SOAINFRA07.DBF' size 20000M
AUTOEXTEND ON
NEXT 100M
MAXSIZE 20000M;

Размер табличного пространства можно смотреть в таблице dba_tablespace_usage_metrics