Spring Cloud Stream: свойство spring.cloud.stream.default.consumer.concurrency точно означает
Вместо этого вы хотите использовать Net::Ping::HTTP. Класс External используется для хостов ICMP-хоста (будет проверять, только ли хост, а не служба на этом хосте).
Проверьте, работает ли HTTP-сервер с использованием протокола HTTP:
check = Net::Ping::HTTP.new('http://localhost:5000')
check.ping?
Если вы хотите настроить таймаут вместо 2 секунд (по умолчанию 5):
check = Net::Ping::HTTP.new('http://localhost:5000', nil, 2)
check.ping?
1 ответ
Семантика параллелизма зависит от фактической реализации связующего. Например, в случае связывателя Кафки, когда вы устанавливаете параллелизм, это значение будет передано в базовый MessageListenerContainer. Допустим, ваше потребительское приложение использует тему из 3 разделов, и вы установите значение concurrency в 3. Это создаст 3 потока в контейнере, в котором каждый из них обрабатывает один раздел из темы (В На самом деле, в случае связующего Kafka, 3 контейнера слушателя будут созданы за кулисами). Если в теме больше разделов, чем параллельных потоков, то разделы будут распределены по различным потокам. Та же самая семантика применима и к связующему с Кроликом, хотя его фактическая реализация может немного отличаться внутри страны.