Создание приложения Red Hat Fuse на основе OSGI-контейнера Karaf

Проверим работу Apache Camel - механизма маршрутизации и посредничества, который обеспечивает реализацию на основе объектов Java шаблонов Enterprise Integration с использованием API (или декларативного языка Java Domain Specific Language) для настройки правил маршрутизации и посредничества.

В Code Ready Studio создадим новый проект следующим образом:

File/New/Other/RedHat Fuse/Fuse Integration Project 

Вводим название проекта. Кликаем Далее.

В окне Select a Target Environment выберите следующие параметры:

Выберите Standalone в качестве платформы развертывания.

Выберите Karaf / Fuse в Karaf  в раскрывающееся ячейке "Runtime"  fuse-karaf-7.8.0.fuse-780038-redhat-00001 RuntimeServer в качестве целевой среды выполнения.

После выбора целевой среды выполнения для вас автоматически выбирается версия Camel, и поле становится серым.
Кликаем "Next".

В открывшемся окне Advanced Project Setup выберите Beginner > Content Based Router - Blueprint DSL template.

Щелкните Готово.

Если будет предложено открыть связанную перспективу "Fuse Integration", нажмите Да.

Подождите, пока CodeReady Studio загрузит необходимые артефакты и построит проект в фоновом режиме.

Важно!

Если вы создаете проект Fuse в CodeReady Studio впервые, ему потребуется несколько минут, чтобы завершить создание проекта.
Не пытайтесь прервать работу или закрыть CodeReady Studio, пока проект строится в фоновом режиме.

Разверните проект на сервере следующим образом:

 В окне « Servers» (нижний левый угол перспективы «Интеграция Fuse»), если сервер еще не запущен, выберите fuse-karaf-7.8.0.fuse-780038-redhat-00001 Runtime Server и щелкните зеленую стрелку, чтобы запустить его.
   

   Примечание

    Если вы видите диалоговое окно, Warning: The authenticity of host 'localhost' can’t be established.t. , нажмите Да, чтобы подключиться к серверу и получить доступ к консоли Karaf.

    Подождите, пока вы не увидите сообщение, подобное следующему, в представлении консоли :

Karaf started in 1s. Bundle stats: 12 active, 12 total

    После запуска сервера вернитесь в окно «Servers» , щелкните правой кнопкой мыши по серверу и выберите «Add and Remove» в контекстном меню.
    В диалоговом окне «Add and Removel» выберите fuse-camel-cbr проект (CBR и Test1) и нажмите кнопку « Добавить» .
    Щелкните готово!                                                                                                         

                                                                                                                                                                                                          Вы можете проверить, запущен ли пакет OSGi проекта, перейдя в Терминал введите  bundle:list | tail. Вы должны увидеть следующий результат:

...
228 ^74; Active ^74;  80 ^74; 1.0.0.201505202023          ^74; org.osgi:org.osgi.service.j
232 ^74; Active ^74;  80 ^74; 1.0.0.SNAPSHOT              ^74; Fuse CBR Quickstart

Заходим в проводник. Сейчас мы сделаем исполняемыми файлы "fuse", "karaf", "start" в папке bin , находящейся по пути: "/home/текущий пользователь/fuse/bin".

Открываем свойства каждого из этих файлов и на закладке Права устанавливаем флажок "Разрешить исполнение файла как программы".

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

# Disable admin user for the default installation
admin = admin,_g_:admingroup
_g_\:admingroup = group,admin,manager,viewer,systembundles,ssh

Вводим команду в терминале от главного администратора:

sudo nano /etc/profile

Добавляем строку как показана на скриншоте:

export JAVA_HOME=$(readlink -f /usr/bin/javac | sed "s:/bin/javac::")

Запускаем сервер через терминал, это можно сделать и в Code Ready Studio и в обычном терминале. Команда "sh fuse:"

$ cd fuse-karaf
$ cd bin
$ sh fuse

Запуск сервера через консоль:

Открываем веб интерфейс (консоль управления Hawtio). Копируем адрес и вставляем его в браузер:

http://localhost:8181/hawtio

Тестируем программу Camel CBR.

В тестовой среде Code Ready Studio настроена рабочее пространство Workspace (у нас это папка /home/akulov.na/Code-workspace), в котором находятся исполняемые файлы нашего проекта и данные, каталоги обмена по умолчанию. Эту папку можно увидеть или поменять с помощью команды меню> File > Switch Workspace>Other:

В каталоге "Workspace>CBR 1/src/main/resources/OSGI-INF/blueprint" (в данном случае это каталог "/home/akulov.na/Code-workspace/CBR 1/src/main/resources/OSGI-INF/blueprint") находится

<?xml version="1.0" encoding="UTF-8"?>
<!--
    Copyright 2014-2017, Red Hat, Inc. and/or its affiliates, and individual
    contributors by the @authors tag. 

    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
    https://www.apache.org/licenses/LICENSE-2.0
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
-->
<!--
   This is the OSGi Blueprint XML file defining the Camel context and routes.  Because the file is in the
   OSGI-INF/blueprint directory inside our JAR, it will be automatically activated as soon as the bundle is installed.

   The root element for any OSGi Blueprint file is 'blueprint' - you also see the namespace definitions for both the Blueprint
   and the Camel namespaces.
-->
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="              http://www.osgi.org/xmlns/blueprint/v1.0.0 https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd              http://camel.apache.org/schema/blueprint https://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
    <!--
      The namespace for the camelContext element in Blueprint is 'https://camel.apache.org/schema/blueprint'.

      While it is not required to assign id's to the <camelContext/> and <route/> elements, it is a good idea
      to set those for runtime management purposes (logging, JMX MBeans, ...)
    -->
    <camelContext id="cbr-example-context" xmlns="http://camel.apache.org/schema/blueprint">
        <!--
          When this route is started, it will automatically create the work/cbr/input directory where you can drop the
          file that need to be processed.

          The <log/> elements are used to add human-friendly business logging statements. They make it easier to see what the
          route is doing.

          The <choice/> element contains the content based router. The two <when/> clauses use XPath to define the criteria 
          for entering that part of the route. When the country in the XML message is set to UK or US, the file will be 
          moved to a directory for that country. The <otherwise/> element ensures that any file that does not meet the 
          requirements for either of the <when/> elements will be moved to the work/cbr/output/others directory.
        -->
        <route id="cbr-route">
            <from id="_from1" uri="file:work/cbr/input"/>
            <log id="_log1" message="Receiving order ${file:name}"/>
            <choice id="_choice1">
                <when id="_when1">
                    <xpath id="_xpath1">/order/customer/country = 'UK'</xpath>
                    <log id="_log2" message="Sending order ${file:name} to the UK"/>
                    <to id="_to1" uri="file:work/cbr/output/uk"/>
                </when>
                <when id="_when2">
                    <xpath id="_xpath2">/order/customer/country = 'US'</xpath>
                    <log id="_log3" message="Sending order ${file:name} to the US"/>
                    <to id="_to2" uri="file:work/cbr/output/us"/>
                </when>
                <otherwise id="_otherwise1">
                    <log id="_log4" message="Sending order ${file:name} to another country"/>
                    <to id="_to3" uri="file:work/cbr/output/others"/>
                </otherwise>
            </choice>
            <log id="_log5" message="Done processing ${file:name}"/>
        </route>
    </camelContext>
</blueprint>

Открываем проводник, заходим в папку рабочего пространства (workspace), внутри рабочей папки выбираем CBR. Эта папка  установленного в начале данной статьи приложения Camel CBR. Переходим в "src, main, data".

workspace name/cbr/src/main/fuse/data

В папке "data". В папке "data" находятся примеры  XML- файлов заказов покупателей. 

<?xml version="1.0"?>
<!DOCTYPE xml>
<!--
    Copyright 2014-2017, Red Hat, Inc. and/or its affiliates, and individual
    contributors by the @authors tag.

    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
    https://www.apache.org/licenses/LICENSE-2.0
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
-->
<order>

    <customer id="B0002">
        <name>Bristol Zoo Gardens</name>
        <city>Bristol</city>
        <country>UK</country>
    </customer>

    <date>2012-03-02</date>

    <orderlines>
        <orderline>
            <article id="B0002">
                <description>Badger</description>
            </article>
            <quantity>2</quantity>
        </orderline>
        <orderline>
            <article id="B0202">
                <description>Bee</description>
            </article>
            <quantity>200</quantity>
        </orderline>
    </orderlines>
</order>

В каждом XML файле прописан адрес, куда он должен переместиться из папки "input". Их нужно скопировать в папку "input", которая находится по пути:

workspace name/work/cbr/input

Как только вы закинете XML файл в папку Input, они сразу же переместятся в только что создавшуюся папку "Output". В этой папке есть еще несколько папок: other, us,uk. XML файлы сами распределятся по папкам.

На закладке "Console" CodeReadyStudio показан лог (см. скриншот выше):

[ead #4 - file://work/cbr/input] cbr-route                      INFO  Receiving order order1.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Sending order order1.xml to another country
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Done processing order1.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Receiving order order2.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Sending order order2.xml to the UK
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Done processing order2.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Receiving order order3.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Sending order order3.xml to the US
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Done processing order3.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Receiving order order4.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Sending order order4.xml to the UK
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Done processing order4.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Receiving order order5.xml
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Sending order order5.xml to the US
[ead #4 - file://work/cbr/input] cbr-route                      INFO  Done processing order5.xml

Открываем консоль управления Hawtio и переходим в Logs.

Лог работы Camel CBR на сервере Red Hat Fuse: