Что такое Apache Camel и зачем он нужен в Java-проектах?

Что такое Apache Camel?

Apache Camel — это open-source фреймворк для интеграции приложений, который реализует Enterprise Integration Patterns (EIP) — проверенные шаблоны проектирования для соединения разных систем. Простыми словами: Camel — это "клей" для сервисов. Он берёт на себя всю рутину по маршрутизации, трансформации и обработке данных между различными протоколами (HTTP, JMS, FTP, файлы, Kafka и т.д.).

Camel использует маршруты (routes) — цепочки шагов, которые описывают, откуда взять данные, что с ними сделать и куда отправить. Всё это конфигурируется в Java-коде или XML/DSL. Главная фишка — вы не пишете низкоуровневый код для каждого протокола, а используете готовые компоненты.

Как Camel решает вашу проблему?

Ваш пример с CSV-файлом можно переписать так:

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.main.Main;

public class FileProcessorRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // Маршрут: читаем файл из папки input
        from("file:input?noop=true")
            // Преобразуем CSV в объект Order (используем Bean)
            .unmarshal().csv()
            .split(body())
            .bean(OrderProcessor.class, "processOrder")
            // Сохраняем в базу (через JDBC)
            .to("jdbc:dataSource?useHeadersAsParameters=true")
            // Отправляем email
            .to("smtp://smtp.gmail.com?username=...&password=...");
    }

    public static void main(String[] args) throws Exception {
        Main main = new Main();
        main.addRouteBuilder(new FileProcessorRoute());
        main.run();
    }
}

Что здесь происходит:

• from("file:input") — Camel автоматически мониторит папку input и забирает новые файлы.
• .unmarshal().csv() — парсит CSV в список строк.
• .split(body()) — разбивает на отдельные строки.
• .bean(OrderProcessor.class) — вызывает ваш Java-метод для обработки заказа (например, валидации).
• .to("jdbc:...") — сохраняет в базу через JDBC-компонент Camel (без вашего boilerplate-кода).
• .to("smtp:...") — отправляет email.

Почему это круто?

• Модульность: чтобы добавить новый протокол (например, Kafka вместо файла), меняете только первую строку: from("kafka:orders").
• Error handling: Camel встроенно поддерживает повторные попытки, dead letter queues, логирование.
• Трансформации: легко конвертировать JSON в XML, CSV в объекты, применять XSLT.
• Тестирование: Camel предоставляет тестовые фреймворки для mock-объектов и эмуляции.

Когда стоит использовать Camel?

• У вас много разнородных систем (REST, JMS, FTP, базы данных).
• Нужны сложные маршруты с трансформацией и маршрутизацией на основе контента.
• Хотите избавиться от boilerplate-кода для интеграции.

Недостатки: для простых проектов (2-3 HTTP-вызова) Camel избыточен. Он добавляет зависимость и немного кривую обучения. Но для микросервисной архитектуры с множеством каналов — это must-have инструмент.

@Bean
public IntegrationFlow fileFlow() {
    return IntegrationFlows
        .from(Files.inboundAdapter(new File("input")))
        .handle(Files.toStringTransformer())
        .split(String.class, line -> line.split(System.lineSeparator()))
        .transform(csvLine -> {
            String[] parts = csvLine.split(",");
            return new Order(parts[0], parts[1], Double.parseDouble(parts[2]));
        })
        .handle("orderService", "saveOrder")
        .get();
}