Вопросы по теме 'reactor-netty'

Невозможно прочитать значения из Flux/Mono
У меня есть простая программа, состоящая из двух частей: сервер Spring 5 с одной конечной точкой, которая возвращает Mono‹Double›, и клиентская программа, которая считывает значение и печатает его. Когда я перехожу к http://localhost:8080/rand ,...
1550 просмотров

Читаемый журнал отладки для HTTP-запросов с помощью Spring Webclient
Я использую Spring реактивный WebClient для отправки запросов на http-сервер. Чтобы просмотреть отправляемый базовый запрос и ответ, я включил ведение журнала отладки для пакета reactor.ipc.netty . Заголовки исходящих запросов можно просмотреть в...
5743 просмотров

Правильный способ настройки тайм-аута чтения запроса на Spring 5 WebClient
Контекст Я пытаюсь найти лучший способ объединить Spring 5 WebClient и Hystrix . Используя Hystrix, я устанавливаю разные тайм-ауты для разных типов запросов, выполняемых WebClient . Когда Hystrix достигает тайм-аута, я также хочу...
1768 просмотров

WebClient не читает ответ, пока не завершится запись запроса.
Я пытаюсь реализовать потоковый прокси. Я столкнулся с проблемой с WebClient из Spring Reactive. Может ли кто-нибудь помочь мне понять, я ошибаюсь или это просто ошибка со стороны WebClient? Стек: response-netty 0.7.8.RELEASE...
1708 просмотров

Как создать горячий поток Reactor Netty
Я пытаюсь найти способ создать горячий поток, в который я мог бы вставлять данные одним методом, а подписчик мог бы получать данные другим методом. Мне удалось использовать WorkQueueProcessor , но я не уверен, что это правильный способ сделать это....
483 просмотров

Настройте Spring Boot с помощью Reactor Netty для прослушивания 2 портов
Как настроить Spring Boot с Reactor Netty для прослушивания двух отдельных портов (в дополнение к порту Actuator) и привязать к каждому отдельные @RestController ? Вот вариант использования: у меня есть один ограниченный контекст с четырьмя...
1118 просмотров
schedule 22.08.2022

Как можно использовать SOAP с веб-клиентом Spring Reactor?
Мне удалось установить SSL-соединение с сервером песочницы и отправить объект как сериализованный объект XML, применив тип содержимого MediaType.APPLICATION_XML. Однако этого недостаточно, так как целевая служба поддерживает только SOAP и ожидает,...
1650 просмотров

Как обработать в Reactor Netty исключение io.netty.channel.ConnectTimeoutException
Я пытаюсь использовать Reactor Netty TcpClient реактивным способом для взаимодействия с хостами, которые могут быть недоступны. Вот пример логики инициализации канала: ConnectionProvider connectionProvider = ConnectionProvider.fixed("fixed",...
2799 просмотров
schedule 29.06.2022

Netty автоматически устанавливает длину содержимого
Я хочу, чтобы Netty (точнее, Reactor Netty) устанавливала заголовок Content-Length в моих запросах. В настоящее время, даже когда я отправляю тело запроса в своем запросе, заголовок Content-Length не устанавливается. Можно ли настроить Netty...
643 просмотров
schedule 01.02.2023

Реактивный веб-клиент Spring 5 не такой асинхронный?
Я встретил странное поведение Spring WebClient. У меня два URL-адреса, медленный и быстрый. Бот ничего не делает, а просто подождите десять секунд до ответа. Когда я вызываю их одновременно с помощью WebClient, я ожидаю, что быстрый URL-адрес будет...
101 просмотров
schedule 11.05.2023

Используйте OAuth2 с Spring Security OAuth2 и реактором netty в проекте webflux без api сервлета
Я хочу использовать webflux с реактором netty, но мой проект, который полагается на spring -security-oauth2, в частности с классом...
301 просмотров

Конечные точки Spring WebFlux в порту 8080 могут быть доступны через порт metrics:9443.
В моем загрузочном приложении Spring у меня есть зависимость от WebFlux как spring-boot-starter-webflux , и при запуске сервера он говорит, что приложение готово с Netty. НеттиВебсервер: Netty started on port(s): 8080 Кроме того, у меня есть...
508 просмотров

Spring Cloud Gateway не возвращает правильный код ответа, предоставленный службой Downstream (для загрузки файла)
У меня есть простой сервис для загрузки файлов. Образец кода @RestController @RequestMapping("/file") public class FileController { @PostMapping("/upload") public ResponseEntity<?> uploadFile(@RequestParam("file") MultipartFile...
1110 просмотров

Как отключить пул подключений клиента HTTP Netty?
Мы используем Spring Cloud Gateway для аутентификации. Spring Security OAuth2LoginAuthenticationWebFilter использует HTTP-клиент Netty для отправки запроса поставщику удостоверений. Netty имеет пул соединений, который нарушен сервером балансировки...
683 просмотров

Вложенные вызовы доступа к данным с помощью Spring WebFlux-Reactor
Я пытаюсь выполнить вложенные вызовы в базу данных, используя spring webflux /actor, чтобы вернуть Mono вложенных объектов (пользователя с его ролями). Сценарий следующий: получить из базы данных строку пользователя, имеющую имя пользователя;...
737 просмотров

с пружинной загрузкой rsocket захватывает тип отмены кадра
У меня есть реализация rsocket с весенней загрузкой, где, если клиент отменяет или закрывает свой запрос rsocket, я хочу отменить другие регистрации подписки на сервере. В журналах на сервере весенней загрузки я вижу, что сообщение об отмене...
248 просмотров

Есть ли библиотека Redis для Netty?
Я пишу службу отдыха на Netty Framework, которая использует Redis для получения некоторых данных. Я ищу библиотеку Redis, которую можно использовать с Netty. Я попробовал Jedis и Lettuce , и оба они очень сильно влияют на производительность...
289 просмотров
schedule 01.04.2023

Как получить как тело ответа HTTP, так и статус при использовании HTTP-клиента Reactor Netty
Я использую HTTP-клиент Reactor Netty здесь как автономная зависимость, т.е. не через spring-webflux , потому что я не хочу перетаскивать связанные с Spring зависимости Как видно из документации, можно сделать запрос, возвращающий...
1220 просмотров
schedule 16.01.2023

ClassCastException при включении поддержки HTTP / 2 в Spring Cloud API Gateway в 2.1.9.
См. Я могу включить поддержку HTTP / 2 в пользовательском интерфейсе на сервере пристани с JDK8, исключив стартер tomcat и добавив причал, запущенный в весеннюю веб-конфигурацию, а также добавив пристань-alpn-Sovrypt-server, зависимость http2-server....
125 просмотров

Как можно настроить клиент с помощью Reactor Netty HttpClient для отправки более одного элемента с помощью издателя Flux на сервер?
Более конкретный вопрос: почему Flux.fromIterable () не работает с Reactor Netty HttpClient? Этот простой пример отлично работает. Все 10 элементов выпущены издателем Flux: public class ConcurrentLinkedQueueFluxTest { public static final...
384 просмотров
schedule 26.04.2022