В настоящее время в одном из наших приложений существует код, подобный следующему:
@Component
public class ProcessRequestImpl {
private ExecutorService executorService;
public processRequest(...) {
// code to pre-process request
executorService.execute(new Runnable() {
public void run() {
ProcessRequestImpl.this.doWork(...);
}
}
}
private void doWork(...) {
// register in external file that request is being processed
// call external service to handle request
}
}
Целью этого является создание очереди запросов к внешней службе. Внешней службе может потребоваться некоторое время для обработки каждого входящего запроса. После обработки каждого из них он обновит внешний файл, чтобы зарегистрировать, что конкретный запрос был обработан.
ProcessRequestImpl сам по себе не имеет состояния, поскольку все состояние задается в конструкторе, и нет внешнего доступа к этому состоянию. Метод process() вызывается другим компонентом приложения.
Если бы это было реализовано в приложении Spring Integration, какой из следующих двух подходов был бы лучше всего рекомендован:
- Сохраните приведенный выше код как есть.
- Извлеките
doWork()в отдельную конечную точку, настройте эту конечную точку для приема сообщений по каналу и используйте конфигурацию для достижения многопоточности вместо службы исполнителя.
Вот некоторые из причин, по которым мы смотрим на Spring Integration:
- Чтобы удалить логику рабочего процесса из самого кода, чтобы рабочий процесс и цепочка обработки были очевидны на более высоком уровне.
- Чтобы упростить каждый класс, улучшив читаемость и тестируемость.
- Чтобы избежать многопоточности кода, если это возможно, и определить это на более высоком уровне абстракции в конфигурации.
Учитывая пример кода, можно ли достичь этих целей с помощью Spring Integration. Также, что было бы примером DSL для достижения этого.
Спасибо
