Я пытаюсь запустить приложение на основе Spring boot 2.0.0.M7. Вот зависимости, связанные с Spring, которые у меня есть в моем build.gradle: compile "org.springframework.boot:spring-boot-starter-webflux:2.0.0.M7" compile...

Я создаю прокси-сервер, который передает большие файлы от клиентов (iOS, Интернет и т. д.) на S3. Я планирую использовать Spring Reactive с Netty. Я догоняю Netty и реактивную архитектуру, и пока это выглядит очень многообещающе. Кто-нибудь из вас...

Я получаю сообщение об ошибке MonoError, вызванное IllegalStateException, с причиной «Базовый клиент HTTP завершен без отправки ответа». NetworkList — это класс, содержащий списки топологии сети и имеющий setList, который вызывается из метода...

Основной вопрос: как Spring Reactors WebClient обеспечивает отсутствие блокировки по сравнению с RestTemplate? Разве ему не нужно где-то блокироваться после того, как он отправил запрос внешней службе (например)? HTTP по своей природе синхронен,...

У меня есть сервис RESTful, и у меня возникла идея подготовить простой тест производительности с помощью Reactor и Spring WebClient. Бенчмарк просто создает N пользователей, а затем за каждый созданный пользовательский пост M голосует. К...

Поэтому мы используем веб-сокет Spring STOMP + RabbitMQ на бэкэнде, и у нас возникают проблемы с дескрипторами открытых файлов. Через определенное время мы достигли предела на сервере, и сервер не принимает никаких подключений, включая как...

Я пытаюсь закрыть TCP-соединение из netty response.ipc.netty.tcp.TcpClient, но не могу найти способ сделать это легко, нет методов «отключить», «остановить» или «закрыть». Может кто-нибудь мне помочь? Я использую библиотеку...

Я как бы новичок в реактивном программировании и в настоящее время работаю над приложением на основе Spring webflux. Я застрял между несколькими вопросами. public class FooServiceImpl { @Autowired private FooDao fooDao; @Autowired private...

У меня есть HTTP-служба, открывающая конечную точку GET, которая подключается к простому эхо-серверу через TCP. Служба HTTP работает на Netty. @RestController public class OurTcpClient { private Connection connection;...

Я использую ant в качестве инструмента сборки и использую Ivy для управления зависимостями. <dependency conf="compile->master;runtime->default" org="org.springframework" name="spring-web" rev="5.1.6.RELEASE"/> <dependency...

Я профилирую свое приложение-реактор, используя BlockHound . У меня на ExchangeFunction есть фильтр: @Override public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) { final ClientRequest.Builder builder =...

Я пытаюсь настроить прокси-сервер с помощью веб-клиента реактора, но он выдает недопустимый метод 405, в то время как, когда я пытался сделать ту же конфигурацию с помощью org.apache.http.client.HttpClient, он возвращает статус 200, а в Postman также...

У меня есть функция ниже public Mono<CarAndShip> getCarAndShip(Long id) { Mono<Car> carMono = carService.getCar(id).subscribeOn(Schedulers.elastic()); Mono<Ship> shipMono =...

Я пытаюсь отправить POJO через поток запросов RSocket: import java.io.Serializable; class GreetingRequest implements Serializable { private String name; public GreetingRequest() {} public GreetingRequest(String name) {...