Описание тега reactor-netty
Reactor поверх клиент-серверной инфраструктуры Netty
1
ответ
Как ограничить количество открытых сокетов в Spring-webflux WebClient?
У меня есть RESTful-сервис, и у меня была идея подготовить простой тест производительности с Reactor и Spring WebClient. Бенчмарк просто создает N пользователей, а затем за каждый созданный пользовательский пост M голосует. К сожалению, следующий ко…
02 сен '18 в 00:07
3
ответа
Spring Security WebFlux - тело с аутентификацией
Я хочу реализовать простое приложение Spring Security WebFlux.Я хочу использовать JSON сообщение как { 'username': 'admin', 'password': 'adminPassword' } в теле (запрос POST к /signin), чтобы войти в мое приложение. Что я сделал? Я создал эту конфиг…
25 апр '18 в 06:46
0
ответов
Spring WebFlux неблокирующая операция ввода-вывода под капотом
Я нашел отличную статью ( https://www.kotlindevelopment.com/kotlin-webflux/), в которой объясняется, как в основном работает неблокирующий сервер ввода-вывода. Мне интересно: когда мы выполняем неблокирующий запрос, используя Spring WebClient или ре…
21 фев '19 в 12:43
1
ответ
Как настроить TLS для Netty в приложении Spring Boot?
Мои микросервисы используют самые последние версии Spring Boot, Spring WebFlux (Undertow), Spring Data MongoDB, Spring Cloud Netflix и Kotlin... Теперь я настроил демонстрационный проект, чтобы использовать новый функциональный интерфейс вместо анно…
10 авг '17 в 06:24
0
ответов
Как я могу закрыть соединение TcpClient с помощью Netty Reactor?
Я пытаюсь закрыть TCP-соединение с netty реактор.ipc.netty.tcp.TcpClient, но я не могу найти способ сделать это легко, нет метода "отключить", "остановить" или "закрыть". Может кто-нибудь мне помочь? Я использую реактор-netty.0.7.9.RELEASE библиотек…
10 окт '18 в 16:35
5
ответов
Spring Cloud Gateway: измененное тело ответа усечено
Я немного экспериментировал с Spring Cloud Gateway и пытаюсь изменить тело ответа. Используя декоратор ответа, я могу видеть, что тело изменено, однако размер буфера по-прежнему равен размеру исходного ответа. Есть ли способ увеличить размер буфера …
26 янв '18 в 21:47
1
ответ
Проблема при изменении версии Spring Boot с 2.0.3.RELEASE на 2.1.0.M4
У меня есть рабочий код, который перестает работать, когда я меняю версию Spring Boot с 2.0.3.RELEASE на 2.1.0.M4 Ошибка: Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled. *************…
23 окт '18 в 12:12
1
ответ
Spring Reactive Proxy сервер для работы с файлами на S3
Я создаю прокси-сервер, который передает большие файлы с клиентов (iOS, веб и т. Д.) На S3. Я планирую использовать Spring реагировать с Netty. Я догоняю Netty и реактивную архитектуру, и пока она выглядит очень многообещающе. Кто-нибудь из вас реши…
05 мар '18 в 14:09
1
ответ
Декодируйте контент-кодировку gzip с помощью Spring WebClient
Я звоню в веб-сервис, используя Spring WebClient (Spring 5.1.3). Служба отвечает content-type: application/json а также content-encoding: gzip ClientResponse.bodyToMono затем происходит сбой с ошибкой "Ошибка декодирования JSON: недопустимый символ …
27 дек '18 в 04:23
1
ответ
Spring WebFlux с MongoDB - регулирование клиентов SSE
Я работаю над простым чатом, работающим под управлением Spring Boot 2.1.1 с WebFlux, Reactor 3.2.3, Mongo 3.8.2 и Netty 4.1.31. В каждой комнате чата есть 2 коллекции - архив сообщений и закрытая коллекция с текущими событиями (например, событие нов…
03 янв '19 в 08:10
2
ответа
Spring WebFlux: допускается только одно соединение для получения подписчика
Я пишу простое приложение с Spring 5 Webflux и Kotlin. Я пытаюсь реализовать конечную точку PUT следующим образом: PUT("/confs/{id}", { val id = it.pathVariable("id") ServerResponse.ok().body(service.save(it.bodyToMono(Item::class.java)), Item::clas…
31 дек '17 в 23:21
1
ответ
Как я могу освободить пул соединения при использовании реактора tcpclient
Когда я использую TCP-клиент с фиксированным ConnectionProvider, я не могу повторно использовать соединение. Они сделали подключение превышает переменную maxConnection. Это то, что я написал. Даже если я использую 10 maxConnection, например "Connect…
13 фев '19 в 06:03
1
ответ
Как отправить запрос на удаление с пользовательским заголовком, используя Spring WebClient?
Я хочу отправить http запрос на удаление с пользовательским заголовком. Я попытался сделать это с помощью Spring's WebClient, с помощью следующего кода: @Test public void validateDeleteCouldCarryHeader() { WebClient.create("https://jira.spring.io/")…
28 дек '18 в 13:44
0
ответов
Reactor-Netty: неожиданный тип сообщения: PooledUnsafeDirectByteBuf
У меня есть HttpServer и HttpClient. Если я использую HttpServerCodec и HttpObjectAggregator от Netty с обеих сторон, я получаю сообщение об ошибке. Код сервера HttpServer server = HttpServer.create(opts -> opts.listen(8092).afterChannelInit(chan…
13 июн '17 в 06:21
1
ответ
Netty Server не используется в Spring Boot 2 с Reactive Starter
Я разрабатываю реактивный проект с использованием Spring Boot 2 и реактивных стартеров. Моя проблема в том, что когда я запускаю приложение, сервер Tomcat запускается вместо Netty. Вот моя задача зависимостей из файла build.gradle: dependencies { co…
02 апр '18 в 08:27
1
ответ
Spring WebFlux обрабатывает веб-клиента ConnectTimeoutException
Я использую веб-клиент Spring WebFlux для выполнения вызовов REST. Я настроил тайм-аут соединения на 3000 миллисекунды соответственно: WebClient webClient = WebClient.builder() .clientConnector(new ReactorClientHttpConnector(options -> options .o…
10 мар '18 в 09:52
0
ответов
Реактор Netty/Spring Cloud Gateway Зависать от ответа 304
У меня есть API-интерфейс на основе Spring Cloud Gateway, который указывает на серверную службу, реализованную в более старой версии Spring Boot (блокировка). Когда я отправляю запрос PUT, который возвращает ответ о состоянии 204, он работает как пр…
16 окт '18 в 00:46
0
ответов
Отключить фильтр в весеннем облачном шлюзе и не пересылать запрос
Я использую Spring Cloud Gateway для создания Api Gateway. В настоящее время я сопоставляю 10 REST-сервисов и при получении ответа отправляю тело запроса в Kafka Stream. У меня есть 2 глобальных фильтра. Один фильтр используется для отправки (или не…
16 апр '18 в 17:43
1
ответ
УТЕЧКА: ByteBuf.release() не был вызван перед сборкой мусора:LoginFilter
Консольная печать: io.netty.buffer.AdvancedLeakAwareByteBuf.readBytes (AdvancedLeakAwareByteBuf.java:496) org.springframework.core.io.buffer.NettyDataBuffer.read (NettyDataBuffer.java:14oref.NETtyDataBuffer.java:38) ipf.gwservice.filter.LoginFilter$…
18 окт '18 в 13:03
0
ответов
Netty рабочий и начальник проблемы производительности конфигурации потока
Окружающая среда-Нетти 4.1.16 . Ява 8 Создал сервер, определил 2 босса и 8 рабочих потоков и 100 потоков бизнес-обработчиков, EventLoopGroup bossGroup = new NioEventLoopGroup(2); EventLoopGroup workerGroup = new NioEventLoopGroup(8); final EventExec…
20 ноя '18 в 21:10