2016-10-19 12 views
0

Источник Http в Flume зависит от обработчика, ответственного за создание Event объектов, которые будут помещены в каналы (каналы). Вызывается ли этот обработчик несколькими потоками, скажем, одним входящим HTTP-сообщением? Если ответ «да», есть ли какой-нибудь пул? Какой размер такого пула? Если ответ «нет», я должен предположить, что входящие HTTP-сообщения обрабатываются последовательно? (Надеюсь, что это не так, и реализуется какой-то параллелизм).Flume: Http-обработчики порождаются параллельными потоками?

Спасибо!

ответ

1

Посмотрите на https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/http/BLOBHandler.java#L63 например (и https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/http/HTTPSource.java#L241), он выглядит однопоточным для меня.

Вы можете распараллелить, настроив несколько HTTP-источников.

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

+0

Я входил в SOF для автоответчика, но вы сделали это заранее :) И да, я сделал несколько тестов, и я проверил только один поток. Я уже думал о параллелизации раковины, когда желал «многопоточности», но никогда не думал об одной и той же концепции для источников. В основном потому, что каким-то образом мой проект ограничивает меня количеством портов, которые я могу открыть. В любом случае, с технической точки зрения, ваш ответ правильный. Благодаря! – frb

+0

Спасибо, frb. Сообщите мне, могу ли я оказать дополнительную помощь – bessbd

 Смежные вопросы

  • Нет связанных вопросов^_^