Я не могу понять, как подключить WebSocketHandlerAdapter к сетевому серверу реактора. Требования: я хочу запустить netty-сервер реактора и присоединить конечные точки http (REST) ​​и конечные точки websocket к одному и тому же серверу. Я...

Мне нужно как-то проверять запросы веб-сокетов. Есть ли способ добиться этого с помощью spring webflux с реактором-netty? Spring-boot 2.0.5. Выпуск Реактор-netty 0.7.9. Выпуск

Я использую webflux с netty и jdbc , поэтому блокирую операцию jdbc следующим образом: static <T> Mono<T> fromOne(Callable<T> blockingOperation) { return Mono.fromCallable(blockingOperation)...

У меня есть поток SI, который потребляет org.springframework.web.reactive.socket.WebSocketMessage , выполняет некоторую работу с ним, включая обработку его полезной нагрузки с помощью Netty ByteBuf . В какой-то момент в моем потоке произошло...

Я хотел бы узнать больше о базовой модели параллелизма для Springboot WebFlux? Является ли традиционная многопоточная модель с блокировкой более подходящей для веб-сервиса с интенсивным использованием ЦП? Или в целом традиционная модель пула...

В моем микросервисе мне нужно извлекать данные из разных мест. Некоторые URL-адреса являются фиксированными, а некоторые - нет. Так что мне нужно снова и снова создавать Webclient, если мой базовый URL изменится. Если нет, то следующий способ...

Я использую WebClient в проекте Spring Boot MVC 2.1 и обнаружил, что первый запрос, сделанный клиентом, занимает до 6 секунд. Последующие запросы намного быстрее (~ 30 мс). Существует закрытая проблема в Spring JIRA , в которой рекомендуется...

Я работаю над простой службой чата, запускаемой Spring Boot 2.1.1 с WebFlux, Reactor 3.2.3, Mongo 3.8.2 и Netty 4.1.31. Каждая чат-комната имеет 2 коллекции - архив сообщений и ограниченную коллекцию с текущими событиями (например, событие нового...

Springboot Webclient выдает ошибку «Существующее соединение было принудительно закрыто удаленным хостом» при попытке вызвать rest api на удаленном сервере. Когда сервер загружается, первый запрос сервера загружается нормально. Когда я отправляю...

У меня есть тест junit, как указано выше, но когда я запускаю тест, я получаю эту ошибку (JDK 13.0.1): java.lang.UnsupportedOperationException: Reflective setAccessible(true) disabled java.lang.IllegalAccessException: class...

Я читал о Java Fibers как о небольшой единице работы, которая будет отображаться на Threads. В случае блокирующего вызова другое волокно будет сопоставлено с тем же потоком. Поскольку потоки в Java являются потоками уровня ядра, это предотвратит...

Не могли бы вы объяснить, что именно происходит во Flux/Mono, возвращаемом HttpClient.response() ? Я думал, что значение, сгенерированное http-клиентом, НЕ будет передаваться вниз по течению до тех пор, пока Mono не завершится, но я вижу, что...

У меня есть NettyServerCustomizer, следующий код: @Override public HttpServer apply(final HttpServer httpServer) { return httpServer.tcpConfiguration(tcpServer -> tcpServer .bootstrap(serverBootstrap ->...

Мне нужно вычислить какой-то дайджест тела запроса с помощью WebClient Webflux, и этот дайджест должен быть установлен в заголовке HTTP. Использовать старый добрый Spring MVC ClientHttpRequestInterceptor легко, поскольку тело запроса...

Мы используем Spring Cloud Gateway в нашей производственной среде и пытаемся раскрыть метрики пула подключений Netty. Мне не удалось найти конфигурацию для включения метрик подключения Netty в шлюзе. Я думаю, что единственный способ раскрыть метрики...