Apache Camel с использованием Groovy Введение

В каждой работе, на которой я был до сих пор, люди так или иначе пишут свои собственные решения для решения многих общих проблем (или они покупают очень дорогие корпоративные ESB-серверы, на изучение, настройку и обслуживание которых уходят месяцы и месяцы). ). Вещи, которые мы обычно решаем, — это интеграция (склеивание) кода существующих бизнес-сервисов вместе, обработка данных определенным образом, или перемещение и преобразование данных из одного места в другое и т. Д. Это очень типичная потребность во многих ИТ-средах. Apache Camel может использоваться в подобных случаях; не только это, но и очень продуктивно и эффективно!

В этой статье я покажу вам, как начать работу с Apache Camel вместе с несколькими строками скрипта Groovy . Конечно, вы также можете начать с полноценного Java-проекта, чтобы опробовать Camel, но я считаю, что Groovy даст вам самый короткий рабочий пример и кривую обучения.

Начало работы с Apache Camel с использованием Groovy

Итак, начнем. Сначала давайте посмотрим демо «Привет, мир!» С Camel + Groovy.

Сохраните выше в файл с именем helloCamel.groovy а затем запустите его так:

Небольшой сценарий выше прост, но в нем представлено несколько ключевых особенностей Camel Groovyness. Первый и последний раздел скрипта helloCamel.groovy — это просто отличные персонажи Groovy. Аннотация @Grab автоматически загрузит указанные вами банки зависимостей. Мы импортируем пакеты Java, чтобы использовать их классы позже. В конце мы завершим работу над Camel перед выходом из JVM через механизм Java Shutdown Hook. Программа будет сидеть и ждать, пока пользователь не нажмет CTRL+C , как обычное поведение процесса на сервере.

В средней части находится действие «Верблюд». Вы всегда должны создать контекст Camel, чтобы начать (думать о нем как о сервере или менеджере процесса). А затем вы добавите маршрут Camel (представьте его как рабочий процесс или конвейер), который вам нравится обрабатывать данные (любит Camel) называть эти данные «сообщения»). Маршрут состоит из начальной точки «от» (где генерируются данные) и одной или нескольких точек «до» (где будут обрабатываться данные). Верблюд называет эти пункты назначения «точками» как «Конечными точками». Эти конечные точки могут быть выражены в простом формате строки URI, таком как 'timer://jdkTimer?period=3000' . Здесь мы генерируем сообщение таймера каждые 3 секунды в потоке потока, а затем обрабатываем с помощью URI регистратора, который просто выводит на консольный вывод.

После запуска верблюжьего контекста он начнет обрабатывать данные в рабочем процессе, как вы можете видеть из приведенного выше примера вывода. Теперь попробуйте нажать CTRL+C чтобы завершить процесс. Обратите внимание, как Верблюд очень изящно отключит все.

Так что это наш первый вкус езды на верблюде! Тем не менее, мы назвали этот раздел «Hello World!» демо, а еще мы не видели ни одного. Но вы, возможно, также заметили, что вышеприведенный скрипт — это в основном код, который мы установили. Пользовательская логика еще не была добавлена. Даже не запись части сообщения! Мы просто настраиваем маршрут.

Теперь давайте немного изменим скрипт, чтобы мы добавили нашу пользовательскую логику для обработки сообщения таймера.

Обратите внимание, как я могу просто добавить часть кода процесса сразу после строки to('log...') . Я добавил кодовый блок «процессор» для обработки сообщения таймера. Логика проста: мы приветствуем мир на каждом тике.

Как сделать верблюжий маршрут более лаконичным и практичным

Теперь, ты уже в Привет? Если нет, то я надеюсь, что вы будете терпеливы и продолжите следить за некоторыми практическими особенностями Camel. Во-первых, если вы хотите использовать Camel в реальных условиях, я бы порекомендовал вам настроить бизнес-логику отдельно от определения маршрута рабочего процесса. Это сделано для того, чтобы вы могли четко выразить и увидеть весь поток маршрутов с первого взгляда. Для этого вы хотите переместить «процессор» в служебный компонент.

Теперь посмотрите, насколько компактным стал этот рабочий процесс? Java DSL Camel, такой как 'from().to().to()' для определения маршрута, настолько прост и удобен в использовании. Вы даже можете показать этот фрагмент кода своим бизнес-аналитикам, и они, вероятно, смогут легко проверить ваш бизнес-поток! Разве это не стоит одного миллиона долларов?

Как насчет другой демонстрации: Обработка FilePoller

Обработка опроса файлов является очень распространенным и эффективным способом решения многих бизнес-задач. Если вы работаете в коммерческих компаниях достаточно долго, вы, возможно, уже написали его раньше. Типичный файл-поллер обрабатывает входящие файлы из каталога, затем обрабатывает содержимое, а затем перемещает файл в выходной каталог. Давайте сделаем верблюжий маршрут, чтобы сделать именно это.

Здесь вы видите, что я определил маршрут для опроса $HOME/test/file-poller-demo/in текстовых файлах. Как только он найден, он регистрирует его в консоли, а затем обрабатывает с помощью службы, которая преобразует текст содержимого в верхний регистр. После этого он отправит файл в каталог $HOME/test/file-poller-demo/out . Боже мой, прочитав вышеприведенный маршрут «Верблюд», я могу выразить то, что я записал, столь же эффективно. Видите ли вы преимущества здесь?

Что такое «батарейки» входит в комплект.

Если вы раньше использовали программирование на Python, возможно, вы слышали фразу, которую они часто утверждают: в Python включены «батареи». Это означает, что их интерпретатор поставляется с богатыми библиотеками для большинства общих потребностей программирования. Вы часто можете написать программу на Python без необходимости загружать отдельные внешние библиотеки.

Я делаю аналогичные аналогии здесь с Apache Camel. Проект Camel поставляется с таким количеством готовых к использованию компонентов, что вы можете найти практически любой транспортный протокол, который может нести данные. Эти компоненты Camel поддерживают разные URI конечной точки, которые мы видели в наших демонстрациях выше. Мы просто показали вам bean timer , log , bean и file , но их более 120. Вы найдете jms , http , ftp , cfx или tcp чтобы назвать несколько.

В проекте Camel также есть возможность определить маршрут в декларативном формате xml . Xml — это просто расширение конфигурации Spring xml с обработчиком пространства имен Camel, добавленным сверху. Spring не обязателен для Camel, но вы можете использовать его вместе очень мощным способом.

Ссылка: Начало работы с Apache Camel с использованием Groovy от нашего партнера по JCG Земьяна Дена в блоге журнала A Programmer’s Journal .