Оглавление

Введение

Концепция

Демонстрационный пример

Код демонстрационной программы Z_PRFC_EXAMPLE

Код функционального модуля Z_TEST_RFC

Практическое применение

Введение

Возникают задачи, в которых требуется выполнить большое количество однотипных операций. При этом, тело операций инкапсулировано, а порядок их выполнения не влияет на конечный результат. Суммарное время выполнения операций может достигать нескольких часов. Примерами таких действий может быть: массовое выполнение BAPI или пакетного ввода. Ускорить такие программы можно через параллельное программирование (pRFC).

Данная статья предназначена для тех, кто понимает принципы работы RFC, умеет работать с синхронными (sRFC), асинхронными (aRFC) и транзакционными RFC (tRFC) и хочет научиться работать с параллельными RFC (pRFC).

Если вы сталкиваетесь с RFC впервые или хотите освежить знания, рекомендую предварительно ознакомиться с материалами:

• Статья о видах RFC с примерами их работы
• Справка SAP по синхронным RFC (sRFC)
• Справка SAP по асинхронным RFC (aRFC)
• Справка SAP по транзакционным RFC (tRFC)

Концепция

Параллельный RFC работает схожим с aRFC образом, и вызывается с помощью дополнения DESTINATION IN GROUP <имя_группы_серверов>. Группы серверов pRFC определяют максимально возможные ресурсы для выполнения параллельных задач. Группы настраиваются в RZ12 (Рис. 1). Если в качестве имени группы указать DEFAULT или SPACE, то вызов будет происходить на любой из определенных групп, в зависимости от их загруженности.

Рис. 1 – Интерфейс настройки группы серверов в RZ12

Для параллельной обработки в SAP реализован набор функциональных моделей, определенных в группе функций SPBT.

Перед распараллеливанием задач необходимо инициализировать группу серверов, в которой будет выполняться параллельная обработка. Группу можно инициализировать через SPBT_INITIALIZE и только один раз. При повторном вызове SPBT_INITIALIZE будет исключение PBT_ENV_ALREADY_INITIALIZED, если группа уже была инициализирована, или CANT_INIT_DIFFERENT_PBT_GROUPS, если ранее была инициализирована другая группа.

Для определения доступности ресурсов определенной группы можно воспользоваться SPBT_INITIALIZE или SPBT_UPDATE_SRV_RESOURCE_INFO. При успешном выполнении ФМ вернут значения MAX_PBT_WPS и FREE_PBT_WPS, в которых содержатся число максимально доступных и свободных процессов на сервере.

Для определения сервера, на котором будет выполняться задача pRFC, необходимо вызывать SPBT_GET_PP_DESTINATION сразу же после запуска pRFC.

Чтобы исключить конкретный сервер из дальнейшего использования для задач параллельной обработки (например, при исключении COMMUNICATION_FAILURE), необходимо использовать ФМ SPBT_DO_NOT_USE_SERVER.

На Рис.2. представлена диаграмма активности pRFC.

Рис 2. UML диаграмма активности pRFC

Демонстрационный пример

Для демонстрации сделаем тестовую программу и функциональный модуль Z_TEST_RFC. Функциональный модуль будет выполнять какую-нибудь длительную задачу, которую мы будем запускать в параллельном режиме. Пусть это будет возведение числа в квадрат, а для имитации длительной работы сделаем задержку от 3 до 5 секунд.

Допустим, нам нужно выполнить 20 раз данную операцию и возвести первых 20 натуральных чисел в квадрат. На Рис. 3. представлен результат выполнения данной операции при 9-ти свободных процессах. При последовательной обработке на эту же операцию потребовалось бы 80 секунд.

Рис. 3 – Результат работы параллельной обработки

Код демонстрационной программы Z_PRFC_EXAMPLE

 

REPORT z_prfc_example.
TYPES:
  BEGIN OF gts_task,
    task   TYPE c LENGTH 5,
    input  TYPE i,
    result TYPE i,
  END OF gts_task.
DATA gv_tasks TYPE i.
DATA gt_tasks TYPE TABLE OF gts_task.

START-OF-SELECTION.
  PERFORM main.

FORM main.
  DATA lv_time_start TYPE i.
  DATA lv_time_end TYPE i.
  DATA lv_time TYPE i.
  DATA lv_total TYPE i.
  DATA lv_free TYPE i.
  FIELD-SYMBOLS <ls_tasks> TYPE gts_task.

  CALL FUNCTION