Apache Camel. Запусти свой первый маршрут

Возможно, вы слышали, что порой Apache Camel используется для создания продуктов класса ESB. У него огромные возможности. Можно интегрировать что угодно с чем угодно. Файлы, ftp, почта, брокеры, да все, что угодно. Выбирайте компоненты на любой вкус. Apache Camel позволяет написать маршрут не только при помощи java dsl, но и xml dsl, и yaml dsl. Да, java знать не обязательно!

Вот пример маршрута, который запускается по таймеру (раз в пять секунд), устанавливает в качестве тела "Hello, world!" и выводит тело сообщения в лог:

<route>
    <from uri="timer://my-timer?period=5000" />
    <setBody>
        <constant>Hello, world!</constant>
    </setBody>
    <to uri="log:com.example" />
</route>

Согласитесь, это красиво. Ничего лишнего. Начинаться маршрут может не только с таймера (это лишь пример), а, например, с получения сообщения из брокера сообщений. И заканчиваться, соответственно, он тоже может чем угодно (записью файла, отправкой сообщения в брокер сообщений и т.д.). Также внутри маршрута могут быть всякого рода преобразования, условия и многое другое.

Но как же запустить этот маршрут?  Вариантов тут несколько. Можно создать maven-проект и скомпилировать его. Можно где-то запустить Apache Karaf с Camel на борту и скормить ему маршрут. Но все это звучит как-то сложновато. Да и не хочется ставить дополнительный софт себе на машину. Хочется ведь скорее попробовать свой первый маршрут, а не разбираться во всех этих сложностях, правда?

И такой вариант есть. Можно запустить свой первый маршрут в докере. Ну да, допускаю, что тут тоже кто-то может отвалиться). Ну вот такое допущение, что вы знакомы с докером.

Для тех, кто остался. Есть официальный образ camel-jbang. Правда, там есть проблемы с запуском. Не буду тут вдаваться в подробности, это можно обсудить в комментариях. Я попробовал немного подкорректировать докер-файл из репозитория Apache Camel так, чтобы запустить наш первый маршрут было максимально просто.

Итак, инструкция по запуску нашего первого маршрута для Apache Camel.

1. Склонируте репозиторий https://github.com/pila86/apache-camel-simple-examples. Ну или просто скачайте архив и распакуйте его

   git clone https://github.com/pila86/apache-camel-simple-examples

    

2. Перейдите в каталог

   cd ./apache-camel-simple-examples

    

3. Поправьте при необходимости маршрут, который находится в "./examples/hello-world.camel.xml". Можно пропустить этот шаг.
4. Запустите маршрут при помощи docker compose:

   docker compose up

    

Вот, собственно, и все. Наблюдаем в консоли результат работы нашего маршрута:

camel-jbang-1  | 2024-11-06 17:40:24.693  INFO 7 --- [           main] org.apache.camel.main.MainSupport        : Apache Camel (JBang) 4.8.1 is starting
camel-jbang-1  | 2024-11-06 17:40:24.806  INFO 7 --- [           main] org.apache.camel.main.MainSupport        : Using Java 21.0.5 with PID 7. Started by root in /
camel-jbang-1  | 2024-11-06 17:40:24.886  INFO 7 --- [           main] org.apache.camel.main.ProfileConfigurer  : The application is starting with profile: dev
camel-jbang-1  | 2024-11-06 17:40:25.272  INFO 7 --- [           main] he.camel.cli.connector.LocalCliConnector : Camel JBang CLI enabled
camel-jbang-1  | 2024-11-06 17:40:25.310  INFO 7 --- [           main] e.camel.impl.engine.AbstractCamelContext : Apache Camel 4.8.1 (hello-world) is starting
camel-jbang-1  | 2024-11-06 17:40:25.429  INFO 7 --- [           main] e.camel.impl.engine.AbstractCamelContext : Routes startup (total:1)
camel-jbang-1  | 2024-11-06 17:40:25.429  INFO 7 --- [           main] e.camel.impl.engine.AbstractCamelContext :     Started route1 (timer://my-timer)
camel-jbang-1  | 2024-11-06 17:40:25.429  INFO 7 --- [           main] e.camel.impl.engine.AbstractCamelContext : Apache Camel 4.8.1 (hello-world) started in 118ms (build:0ms init:0ms start:118ms)
camel-jbang-1  | 2024-11-06 17:40:26.377  INFO 7 --- [imer://my-timer] com.example                              : Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello, world!]
camel-jbang-1  | 2024-11-06 17:40:31.370  INFO 7 --- [imer://my-timer] com.example                              : Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello, world!]
camel-jbang-1  | 2024-11-06 17:40:36.371  INFO 7 --- [imer://my-timer] com.example                              : Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello, world!]
camel-jbang-1  | 2024-11-06 17:40:41.370  INFO 7 --- [imer://my-timer] com.example                              : Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello, world!]

Надеюсь, у вас получилось. Если возникли сложности - пишите в комментариях. Пишите, интересны ли другие примеры, или стоит написать, как можно запустить и отладить маршрут в vs code? А еще можно использовать Karavan, чтобы собрать маршрут из "кубиков". Также есть некоторые мысли по примеру маршрута, который подключится сразу к нескольким базам 1С через odata (причем параллельно) и соберет определенные данные в одно сообщение.