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

Конечная точка REST работает при прямом доступе, но не при доступе через WebClient
Примечание. Ниже приводится изменение / исправление аналогичного сообщения / вопроса с целью лучше определить мою проблему / вопрос и предоставить лучшие образцы кода, демонстрирующие мою проблему. Добавить примечание. В пример кода добавлен...
89 просмотров

Как получить длину сжатого ответа в Reactor-Netty?
httpClient.post().uri(getSearchUrl()) .send(Mono.just(Unpooled.wrappedBuffer(bytes))) .responseSingle((resp, buf) -> { return buf; })...
47 просмотров
schedule 25.03.2022

Как настроить Netty с помощью Spring Boot 2.1 Webflux?
Я хотел бы настроить Netty в моем проекте Spring Boot Webflux. В моем POM я добавил зависимости Spring Boot Webflux и Spring Boot Actuator. Затем я перезаписал метод customize () WebServerFactoryCustomizer, как описано в Документация Spring ....
4245 просмотров

Дескриптор веб-клиента Spring WebFlux ConnectTimeoutException
Я использую веб-клиент Spring WebFlux для выполнения вызовов REST. Я настроил тайм-аут соединения на 3000 миллисекунды соответственно: WebClient webClient = WebClient.builder() .clientConnector(new ReactorClientHttpConnector(options ->...
2637 просмотров
schedule 29.05.2022

Webflux WebClient java.lang.NullPointerException
У меня проблемы с подключением веб-клиента webflux к моей конечной точке. В своем контроллере я пытаюсь открыть горячий поток шоколадных DTO. Когда я пытаюсь вызвать конечную точку с помощью почтальона, это работает. Это предложение существует,...
5322 просмотров

Как получить многостраничную загрузку файла с помощью response-netty (без Spring)?
Я видел примеры с response-netty о том, как публиковать файлы с использованием многостраничной формы (...
477 просмотров
schedule 07.07.2022

Spring 5 WebClient выдает исключение java.util.concurrent.RejectedExecutionException
Я использую Spring WebClient для связи с другими веб-службами в веб-приложении Java 11 / Spring Boot 2.2.6. Вот моя конфигурация bean-компонента для WebClient: @Bean public WebClient.Builder webClientBuilder() { String connectionProviderName...
673 просмотров

Как убедиться, что http-клиент rector netty создает исправленное соединение с http-сервером
Я использую приведенный ниже код для создания http-клиента netty реактора и использую этот клиент для отправки запроса. ConnectionProvider connectionProvider = ConnectionProvider.builder("lead") .maxConnections(10)...
42 просмотров
schedule 31.08.2022

Spring WebFlux: разрешено только одно соединение для получения подписчика
Я пишу простое приложение с помощью Spring 5 Webflux и Kotlin. Я пытаюсь реализовать конечную точку PUT следующим образом: PUT("/confs/{id}", { val id = it.pathVariable("id")...
15418 просмотров

Spring Webflux Netty http и https
У меня есть требование, когда в приложении Spring Webflux мне нужно прослушивать порт HTTP и HTTPS. Я мог легко настроить HTTPS, используя @Bean public WebServerFactoryCustomizer<NettyReactiveWebServerFactory> customizer() { return new...
1329 просмотров

Какая самая простая реализация Reactor/Netty для протокола SSDP?
Я пробовал много вещей с модулем Ip UdpClient, UdpServer, Spring Integration, оборачивая метод получения DatagramSocket для возврата Flux, но я просто не могу получить никакого ответа от стандартного SSDP 239.255.255.250:1900. Бонусные баллы за...
119 просмотров

Как я могу освободить объединенное соединение при использовании реактора tcpclient
Когда я использую TCP-клиент с фиксированным ConnectionProvider, я не могу повторно использовать соединение. Они установили соединение, превышающее переменную maxConnection. Это то, что я написал. Даже если я использую 10 maxConnection,...
1207 просмотров
schedule 31.05.2023

как настроить таймаут простоя объединенного соединения в response-netty
Я использую http-клиент response-netty (серия 0.7.X) с пулом соединений и хотел бы настроить тайм-аут простоя объединенного соединения, но не знаю где. Точнее, мне нужно настроить пул HTTP-клиентских подключений response-netty таким образом, чтобы...
4709 просмотров
schedule 09.05.2023

Spring Webflux Reactor Netty: HTTP-запрос / ответ шестнадцатеричный дамп?
Какой уровень журнала мы должны установить в application.properties, чтобы увидеть полный HTTP-запрос и ответ с заголовками и телом в виде шестнадцатеричного дампа в консоли из response-netty? logging.level.reactor.netty=trace Показывает...
3514 просмотров
schedule 04.02.2023

Можно ли избежать вызова CONNECT для изменения конфигурации HTTP-прокси при использовании WebClient?
Во время миграции spring-web в spring-reactive-web мы заблокировали реализацию HTTP proxy в методе WebClient билдера. Ранее мы уже пробовали приведенный ниже фрагмент кода, на который ссылается Как я могу поддерживать HTTP-прокси с помощью...
740 просмотров

Новое TCP-соединение открывается для каждого запроса в response-netty
Я пытаюсь реализовать простой HTTP-клиент с реактором-netty. Но это работает не так, как я ожидал. Есть код ConnectionProvider connectionProvider = ConnectionProvider.fixed("my-connection-pool", 5); HttpClient httpClient =...
188 просмотров
schedule 05.12.2022

Как люди размещают приложения Spring Boot с WebFlux на Reactor Netty в производственной среде?
Я знаю, что это расплывчатый вопрос, но это потому, что я недостаточно понимаю, что люди делают, чтобы задать что-то более конкретное. В настоящее время я запускаю свои собственные приложения со встроенным сервером netty для разработки реактора и в...
489 просмотров

Получение и освобождение подключений с помощью пула подключений TcpClient (Reactor Netty)
Я настроил TcpClient, как описано в примерах, здесь . Я пытаюсь сделать следующий код устойчивым в ситуациях, когда сервер неожиданно закрывает соединение: TcpClient tcpClient = getTcpClient(); public Mono<String>...
259 просмотров
schedule 22.02.2023

Что эквивалентно .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE) в мире Netty?
Небольшой вопрос относительно Нетти и io.netty.handler.ssl.SslContext В Tomcat и org.apache.http.ssl.SSLContexts у нас есть возможность выполнить следующее: HttpClient httpClient = HttpClients.custom() .setSSLContext(SSLContexts.custom()...
449 просмотров
schedule 30.03.2023

Как установить TCP Keepalive в HTTP-клиенте Reactor Netty?
я видел это HttpClient.from(TcpClient.create().option(ChannelOption.SO_KEEPALIVE, true)) from метод устарел. Как в настоящее время я должен установить SO_KEEPALIVE с помощью HttpClient.create() ?
301 просмотров