Опрос пользователей файлов в Apache

Question

Недавно я начал играть с верблюдом Apache. Так что, будучи экспериментальным типом, я думал, что создам простой проект, который будет проверять каталог файлов каждые пару секунд, чтобы увидеть, есть ли у меня новый файл, который забирает этот файл, а затем копирует его в другую папку. Позже я хочу поместить эти файлы в базу данных.

Так держать с основами первым я создал маршрут, такие как:

from("file://c:/CTest/inbox?noop=true") 
       .to("file://C:/Ctest/outbox"); 

Это сработало, и я думал, что хорошо позволяет добавить таймер. Первоначально я сделал ошибку, используя таймер и пытается это:

from("timer://myTimer?period=50").to("file://c:/CTest/inbox?noop=true") 
       .to("file://C:/Ctest/outbox"); 

я тогда имел какое-то странное исключение о невозможности записать файл. Затем я понял, что поместив маршрут файла после маршрута таймера, он стал продюсером. Поэтому я немного исследовал, и здесь я немного смущен.

Итак, из моего понимания файловый компонент использует запланированный шаблон опроса. Существует даже опция pollStrategy в шаблоне URL-адреса файла. Существует также потребительский EIP опроса.

Так вот где моя путаница наступает.

1) Если компонент файла использует запланированный шаблон опроса не использует/реализации опроса conumser EIP?

2) Как добавить простое расписание к файловому компоненту для использования файлов, скажем, каждые 30 секунд?

3) Как создать свою собственную опросную стратегию путем реализации org.apache.camel.PollingConsumerPollStrategy?

Я подозреваю, что я могу сделать что-то вроде этого:

from("file://c:/CTest/inbox?noop=true&pollStrategy=some-expression") 
       .to("file://C:/Ctest/outbox"); 

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

Благодаря Namphibian

Answer 1

Camel предлагает функцию под названием routepolicy http://camel.apache.org/routepolicy.html

Это позволяет связать политику по маршрутам. Мы предоставляем ряд политик из коробки. Политикой может быть любая логика. Например, мы предлагаем политику дросселирования, которая на лету приостанавливает/возобновляет маршруты, основанные на потоках.

Другая политическая политика - это запланированная политика, поэтому вы можете указать «часы работы» для маршрута. Поэтому вы также можете использовать это. Но учтите его в часы работы, поэтому вы указываете время начала и окончания. Существует политика на основе кварцевого cron http://camel.apache.org/cronscheduledroutepolicy.html, поэтому вы можете настроить это, чтобы начать маршрут в понедельник, и пусть он работает некоторое время.

Если вам нужно остановить маршрут от в пределах маршрута, то вот немного сложнее, есть FAQ об этом здесь: http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html

Answer 2

1) Если компонент файла использует запланированный шаблон опроса делает это использование/осуществлять избирательный conumser EIP?

Да, производитель файлов реализует ScheduledPollEndpoint. Из doc:

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

2) Как добавить простое расписание к файловому компоненту для использования файлов sa каждые 30 секунд?

Использование delay опции:

from("file://c:/CTest/inbox?noop=true&delay=30000").to("file://C:/Ctest/outbox"); 

3) Как создать свой собственный pollingStrategy путем внедрения org.apache.camel.PollingConsumerPollStrategy?

Посмотрите на исходный код: DefaultPollingConsumerPollStrategy или LimitedPollingConsumerPollStrategy.

используется настраиваемый pollStrategy как это:

from("file://inbox/?pollStrategy=#myPoll").to(...) 

Где #myPoll я определен в более registry информации в нижней части страницы this.