Вопросы по теме 'project-reactor'
Потерянные сообщения с Spring Reactor
Кажется, я теряю сообщения, отправленные в реактор в моем приложении Spring. Я подозреваю, что это связано с тем временем в жизненном цикле контейнера Spring, когда я начинаю создавать сообщения.
В моем конкретном случае использования есть Spring...
312 просмотров
schedule
05.06.2022
Обработка исключений в потоках Spring XD
Как вы можете создать отказоустойчивый поток Spring XD, который будет продолжать работать правильно после того, как исключение будет вызвано для одного конкретного сообщения (т. е. регистрирует ошибку, но продолжает потреблять следующие сообщения в...
194 просмотров
schedule
19.07.2023
Project Reactor: подождите, пока вещатель закончит
Есть Broadcaster, который принимает строки и добавляет их в StringBuilder.
Я хочу это проверить.
Мне нужно использовать Thread#sleep , чтобы ждать, пока вещатель закончит обработку строк. Я хочу удалить sleep .
Попытался использовать...
1634 просмотров
schedule
11.07.2022
Общая шина событий для нескольких приложений и контейнеров для Reactor
Я смотрю, как с Spring Boot и Reactor возможно иметь несколько приложений (каждое из которых работает в своем собственном контейнере Spring Boot), которые используют один общий/общий EventBus, работающий в автономном контейнере. Это среда...
933 просмотров
schedule
12.07.2023
Параллельная обработка проектного потока реактора
Я новичок в проектировании реакторов или реактивного программирования в целом, поэтому я, вероятно, делаю что-то не так. Я изо всех сил пытаюсь создать поток, который бы делал следующее:
Учитывая класс Entity:
Entity {
private...
3627 просмотров
schedule
06.06.2023
Spring MVC интегрируется с реактивным потоком
У меня есть приложение RESTful api, построенное на spring mvc.
недавно я делал что-то интеграцию между spring mvc и реактивным потоком (например, rxjava и project -actor) и пытался сделать приложение более реактивным.
Я только что собрал демо,...
806 просмотров
schedule
18.03.2023
Преимущества того, что конечные точки HTTP возвращают экземпляры Flux/Mono вместо DTO
Я посмотрел Spring Tips: Functional Reactive Endpoints with Spring Framework 5.0 и немного почитал о пружинный реактор, но я не совсем понимаю.
Каковы преимущества того, что конечные точки возвращают Flux / Mono экземпляры (jacksonified)...
9108 просмотров
schedule
30.12.2022
Spring 5 Web Reactive - Как мы можем использовать WebClient для получения потоковых данных в Flux?
Документация по текущей вехе (M4) показывает и пример того, как получить Mono с помощью WebClient :
WebClient webClient = WebClient.create(new ReactorClientHttpConnector());
ClientRequest<Void> request =...
8677 просмотров
schedule
02.10.2022
Mono.elapse не работает со StepVerifier?
Согласно его Javadoc, Mono.elapse() создаст Mono<Tuple2<Long, T>> , где первым значением будет время, прошедшее между подпиской и первым следующим сигналом.
Следующий тест не работает
StepVerifier.withVirtualTime(() ->...
321 просмотров
schedule
21.03.2022
Reactor 3.x (Java): для парсинга веб-страниц
Reactor noob здесь.
Это скорее вопрос HowTo.
Допустим, у меня есть веб-сайт, который я хочу очистить, содержащий разбитый на страницы набор результатов поиска. Количество страниц результатов поиска неизвестно. На каждой странице поиска есть...
116 просмотров
schedule
03.07.2022
Реактивные потоки с использованием Spring и Akka
На момент написания этого вопроса я использую Spring Framework 5.0.0.M5 и Akka 2.4.17. В проекте я использую обмен сообщениями с актерами и потоки из Akka. Я вижу, что в Spring Framework v5 также есть потоки.
Согласно http://projectreactor.io/...
797 просмотров
schedule
08.01.2023
Реактивный подход к использованию временной карты поиска
У меня есть код, который я хотел бы сделать более реактивным, используя RxJava или Proj. Реактор. Я немного борюсь с этим.
Имея список CatalogRequests, некоторые из которых могут быть для одного и того же CatalogItem, но с другим условием (NEW...
83 просмотров
schedule
03.06.2023
Ограничение скорости запросов с помощью Reactor
Я использую проектный реактор для загрузки данных из веб-службы с помощью отдыха. Это делается параллельно с несколькими потоками. Я начинаю сталкиваться с ограничениями скорости в веб-службе, поэтому я хотел бы отправлять не более 10 запросов в...
3507 просмотров
schedule
28.08.2022
Повторить логику в случае сбоя - Spring Reactor
Как выполнить модульный тест RetryWhen,
public Mono<List<Transaction>> get(String id) {
return class
.get(id).log()
.retryWhen(throwableFlux -> throwableFlux)...
2205 просмотров
schedule
20.11.2022
Асинхронная отправка электронной почты Project Reactor с повторной попыткой при ошибке
Мне нужно отправить некоторые данные после регистрации пользователя. Я хочу сделать первую попытку в основном потоке, но если есть какие-либо ошибки, я хочу повторить попытку 5 раз с интервалом в 10 минут.
@Override
public void...
2621 просмотров
schedule
02.03.2022
Что такое Spring MVC на основе Reactor?
Я только что прочитал все, что мог, о Spring и Reactor и понял, что Reactor должен быть включен в грядущую Spring Framework 5 (кстати, кто-нибудь использует это в производстве?)
Меня интересует использование его в Spring MVC, поскольку в настоящее...
536 просмотров
schedule
14.07.2022
Java с Project Reactor: почему блок Mono () не видит ошибку?
Учитывая следующий код, result.block () равен «xx», isError () == false, но обработчик ошибок стрелы запущен, отображается трассировка стека, обещание не выполнено. Я ожидал, что результат будет «ко».
Что я делаю неправильно ? block () Javadoc...
6178 просмотров
schedule
09.10.2022
Reactor StepVerifier.withVirtualTime блокируется на неопределенный срок
Я пытаюсь использовать функцию виртуального времени Reactor, но тест блокируется на неопределенный срок (без таймаута) или выдает AssertionError (с таймаутом):
@Test
public void test() {
StepVerifier.withVirtualTime(() ->...
2124 просмотров
schedule
18.07.2022
Как автоматически подписаться на внутренний Flux/Mono?
У меня есть поток (ограниченный) Flux, который я хочу преобразовать в поток Long, где Long — это размер внутреннего потока:
Flux.just( Flux.just(1, 2, 3), Flux.just(1, 2) )
.map(Flux::count)
.log()
.subscribe();...
3688 просмотров
schedule
08.08.2022
Как правильно читать Flux ‹DataBuffer› и преобразовывать его в один inputStream
Я использую WebClient и пользовательский BodyExtractor class для своего приложения с весенней загрузкой
WebClient webLCient = WebClient.create();
webClient.get()
.uri(url, params)
.accept(MediaType.APPLICATION.XML)
.exchange()...
38714 просмотров
schedule
31.03.2023
