Я немного протестировал предложение в этой ветке: служба-исполнитель и я немного упростил пример, чтобы его было легче понять. Итак, вот пример: ExecutorService executorService = Executors.newSingleThreadExecutor(); Flux.just("1",...

Я использую облачный шлюз Spring в качестве пограничного сервера. Это поток Если запрос имеет заголовок с именем «x-foo», найдите значение заголовка, получите строку с другого сервера и отправьте эту строку в качестве ответа вместо фактического...

Я учусь использовать Spring WebFlux, и в рамках этого я разработал приложение, которое использует Redis для сохранения и извлечения данных. Но проблема, с которой я сталкиваюсь, заключается в том, что когда запрос пытается подключиться к Redis, я...

Я пытаюсь создать поток, в котором поток испускает 10 элементов, каждый параллельно, причем каждый элемент спит в течение 1 секунды. Поскольку каждый элемент публикуется в отдельном потоке, я ожидаю, что весь процесс займет 1 с. Но журналы...

Я пытаюсь написать реактивную службу Spring Cloud Function с использованием RabbitMQ, которая будет потреблять одну очередь и производить обмен. У меня 2 вопроса. Почему я получаю ошибку ниже в логах. Как мне отклонить запрос с doOnError?...

У меня есть вызов репозитория, который даст мне Mono. ex: private User getUserData (User user) { Mono<User> monoUser=userRepository.insert(user); User user= monoUser.block; return user; } Как добиться этого без блокировки в...

У меня есть существующее весеннее веб-приложение, которое использует spring-boot-starter-web; Я планировал ввести реактивный в это приложение. Для новой функции, над которой я работаю, я подключил реактивный веб-сокет Spring, настроенный и...

Получил вот такой боб: @Bean("reactiveNeo4jDatabaseNameProvider") public ReactiveDatabaseSelectionProvider reactiveDatabaseSelectionProvider() { log.info("Database selection step"); return () ->...