Шлюзы в InterSystems IRIS это механизм взаимодействия между ядром InterSystems IRIS и прикладным кодом на языках Java/.Net. С помощью шлюзов вы можете работать как с объектами Java/.NET из ObjectScript так и с объектами ObjectScript и глобалами из Java/.NET. Шлюзы могут быть запущены где угодно - локально, на удаленном сервере, в докере.
В этой статье я покажу, как можно легко разработать и контейнеризовать интеграционную продукцию с .Net/Java кодом. А для взаимодействия с кодом на языках Java/.Net будем использовать PEX, предоставляющий возможность реализовать любой элемент интеграционной продукции на языках Java/.Net.
Для нашего примера мы разработаем интеграцию с Apache Kafka.
Архитектура
Apache Kafka популярный брокер сообщений. В Kafka есть тема (topic) сообщения в которую издатели (publisher) пишут сообщения и есть подписчики (consumer) на темы, которые читают эти сообщения.
Сначала мы напишем Java бизнес-операцию которая будет пубиковать сообщения в Apache Kafka. Затем добавим бизнес-службу на языке C# которая будет сообщения читать, сохранять и передавать для дальнейшей обработки в InterSystems IRIS.
Наше решение будеть работать в докере и выглядит следующим образом:
Java Gateway
Прежде всего, разработаем Бизнес-Операцию на Java для отправки сообщений в Apache Kafka. Код может быть написан в любой Java IDE и выглядеть так:
-
Для разработки новой PEX бизнес-операции необходимо реализовать абстрактный класс
com.intersystems.enslib.pex.BusinessOperation. -
Публичные свойства класса это настройки нашего бизнес-хоста
-
Метод
OnInitиспользуется для установления соединения с Apache Kafka и получения указателя на InterSystems IRIS -
OnTearDownиспользуется для отключения от Apache Kafka (при остановке процесса). -
OnMessageполучает сообщение dc.KafkaRequest и отправляет его в Apache Kafka.
Теперь упакуем нашу бизнес-операцию в Docker контейнер.
Вот наш докер-файл:
FROM openjdk:8 AS builderARG APP_HOME=/tmp/appCOPY src $APP_HOME/srcCOPY --from=intersystemscommunity/jgw:latest /jgw/*.jar $APP_HOME/jgw/WORKDIR $APP_HOME/jar/ADD https://repo1.maven.org/maven2/org/apache/kafka/kafka-clients/2.5.0/kafka-clients-2.5.0.jar .ADD https://repo1.maven.org/maven2/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar .ADD https://repo1.maven.org/maven2/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3.jar .ADD https://repo1.maven.org/maven2/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30.jar .WORKDIR $APP_HOME/srcRUN javac -classpath $APP_HOME/jar/*:$APP_HOME/jgw/* dc/rmq/KafkaOperation.java && \ jar -cvf $APP_HOME/jar/KafkaOperation.jar dc/rmq/KafkaOperation.classFROM intersystemscommunity/jgw:latestCOPY --from=builder /tmp/app/jar/*.jar $GWDIR/
Посмотрим, что здесь происходит (я предполагаю, что вы знакомы с многоступенчатыми докер сборками):
FROM openjdk:8 AS builder
JDK8 это базовый образ, в котором мы будем компилировать наше приложение.
ARG APP_HOME=/tmp/appCOPY src $APP_HOME/src
Копируем исходный код из папки /src в
/tmp/app.
COPY --from=intersystemscommunity/jgw:latest /jgw/*.jar $APP_HOME/jgw/
Копируем библиотеки Java Gateway в папку
/tmp/app/jgw.
WORKDIR $APP_HOME/jar/ADD https://repo1.maven.org/maven2/org/apache/kafka/kafka-clients/2.5.0/kafka-clients-2.5.0.jar .ADD https://repo1.maven.org/maven2/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar .ADD https://repo1.maven.org/maven2/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3.jar .ADD https://repo1.maven.org/maven2/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30.jar .WORKDIR $APP_HOME/srcRUN javac -classpath $APP_HOME/jar/*:$APP_HOME/jgw/* dc/rmq/KafkaOperation.java && \ jar -cvf $APP_HOME/jar/KafkaOperation.jar dc/rmq/KafkaOperation.class
Все зависимости скачаны - вызываем javac/jar для
компиляции jar файла. Для реальных проектов рекомендуется
использовать полноценную систему сборки maven или gradle.
FROM intersystemscommunity/jgw:latestCOPY --from=builder /tmp/app/jar/*.jar $GWDIR/
И, наконец, jar файлы копируются в базовый образ Java шлюза, который содержит все необходимые зависимости и обеспечивает запуск Java шлюза.
.Net Gateway
Далее разработаем службу .Net, которая будет получать сообщения от Apache Kafka. Код может быть написан в любой .Net IDE и выглядеть так.
Особенности:
-
Для разработки новой PEX бизнес-службы необходимо реализовать абстрактный класс
InterSystems.EnsLib.PEX.BusinessService. -
Публичные свойства класса это настройки нашего бизнес-хоста
-
Метод
OnInitиспользуется для установления соединения с Apache Kafka, подписки на темы Apache Kafka и получения указателя на InterSystems IRIS -
OnTearDownиспользуется для отключения от Apache Kafka (при остановке процесса) -
OnMessageполучает сообщения из Apache Kafka и отправляет сообщение классаEns.StringContainerв целевые бизнес-хосты продукции
Теперь упакуем нашу бизнес-операцию в Docker контейнер.
Вот наш докер-файл:
FROM mcr.microsoft.com/dotnet/core/sdk:2.1 AS buildENV ISC_PACKAGE_INSTALLDIR /usr/irissysENV GWLIBDIR libENV ISC_LIBDIR ${ISC_PACKAGE_INSTALLDIR}/dev/dotnet/bin/Core21WORKDIR /sourceCOPY --from=store/intersystems/iris-community:2020.2.0.211.0 $ISC_LIBDIR/*.nupkg $GWLIBDIR/# copy csproj and restore as distinct layersCOPY *.csproj ./RUN dotnet restore# copy and publish app and librariesCOPY . .RUN dotnet publish -c release -o /app# final stage/imageFROM mcr.microsoft.com/dotnet/core/runtime:2.1WORKDIR /appCOPY --from=build /app ./# Configs to start the Gateway ServerRUN cp KafkaConsumer.runtimeconfig.json IRISGatewayCore21.runtimeconfig.json && \ cp KafkaConsumer.deps.json IRISGatewayCore21.deps.jsonENV PORT 55556CMD dotnet IRISGatewayCore21.dll $PORT 0.0.0.0
Посмотрим, что здесь происходит:
FROM mcr.microsoft.com/dotnet/core/sdk:2.1 AS build
Используем образ .Net Core 2.1 SDK для сборки нашего приложения.
ENV ISC_PACKAGE_INSTALLDIR /usr/irissysENV GWLIBDIR libENV ISC_LIBDIR ${ISC_PACKAGE_INSTALLDIR}/dev/dotnet/bin/Core21WORKDIR /sourceCOPY --from=store/intersystems/iris-community:2020.2.0.211.0 $ISC_LIBDIR/*.nupkg $GWLIBDIR/
Копируем библиотеки .Net Gateway из официального образа InterSystems IRIS:
# copy csproj and restore as distinct layersCOPY *.csproj ./RUN dotnet restore# copy and publish app and librariesCOPY . .RUN dotnet publish -c release -o /app
Компилируем нашу бизнес-операцию.
FROM mcr.microsoft.com/dotnet/core/runtime:2.1WORKDIR /appCOPY --from=build /app ./
Копируем библиотеки в финальный контейнер.
RUN cp KafkaConsumer.runtimeconfig.json IRISGatewayCore21.runtimeconfig.json && \ cp KafkaConsumer.deps.json IRISGatewayCore21.deps.json
В настоящее время шлюз .Net должен загружать все зависимости при запуске, поэтому мы информируем его обо всех возможных зависимостях.
ENV PORT 55556CMD dotnet IRISGatewayCore21.dll $PORT 0.0.0.0
Запускаем шлюз на порту 55556, слушаем все сетевые
интерфейсы.
Готово!
Вот полная конфигурация docker-compose, для запуска демо целиком (в том числе и UI для Apache Kafka, для просмотра сообщений).
Запуск демо
Для запуска демо локально:
Установите:
Выполните:
git clone https://github.com/intersystems-community/pex-demo.gitcd pex-demodocker-compose pulldocker-compose up -d
Выводы
-
В интеграционных продукциях InterSystems IRIS появилась возможность создавать любые элементы продукции на языках Java/.Net
-
Код на Java/.Net возможно вызывать из InterSystems ObjectScript и наоборот, код на InterSystems ObjectScript из Java/.Net
-
Генерация прокси классов больше не требуется
-
Возможна как классическая поставка решения, так и поставка в Docker
Ссылки
-
Документация
-
Вебинар про PEX по материалам данной статьи
