Вопросы по теме 'reactor'
Что такое рабочие потоки и какова их роль в шаблоне реактора?
Я пытаюсь понять шаблон Reactor (параллельный), но во многих примерах речь идет о «рабочих потоках». Что такое рабочие потоки? Чем они отличаются от «обычных» потоков? И какова их роль в схеме реактора?
24549 просмотров
schedule
08.10.2022
Обработчик UDP с Reactor в Spring
Я хочу, чтобы мое приложение реагировало на события UDP, отправленные тысячами разных клиентов. Каждый клиент отправляет 1-10 пакетов UDP каждые 5-10 секунд. Каждый пакет будет и должен обрабатываться очень быстро (в основном в памяти и небольших...
944 просмотров
schedule
31.05.2022
Потерянные сообщения с Spring Reactor
Кажется, я теряю сообщения, отправленные в реактор в моем приложении Spring. Я подозреваю, что это связано с тем временем в жизненном цикле контейнера Spring, когда я начинаю создавать сообщения.
В моем конкретном случае использования есть Spring...
312 просмотров
schedule
05.06.2022
Замена Python scrapy ReactorNotRestartable
Я пытался создать приложение на Python, используя Scrapy , которое имеет следующие функции:
rest api (я сделал это с помощью flask) прослушивает все запросы на сканирование/удаление и возвращает ответ после сканирования (часть сканирования...
883 просмотров
schedule
18.04.2023
Скрученный реактор неправильно вызывает функции из потока
У меня проблемы с twisted.internet.reactor Все мои клиенты имеют полностью идентичные среды, но только у некоторых возникает эта проблема:
Они корректно connectTCP к серверу через ws и обмениваются первыми несколькими сообщениями. Примерно...
99 просмотров
schedule
28.05.2023
Reactor 3.x: есть ли оператор для дросселя Latest (conlate)?
В rx-java 2.x есть оператор с именем throttleLatest , который объединяет входящие события на основе заданного времени:
https://github.com/ReactiveX/RxJava/pull/5979
Есть ли аналогичный оператор в Reactor 3? Или можно добиться такого же...
92 просмотров
schedule
02.03.2023
Reactor WebClient
У меня есть функция HandlerFunction, которая принимает POST-запрос BookingRecord. Я получаю Mono от ServerRequest с помощью bodyToMono (), а затем подписываюсь на Mono, поскольку мне нужен тип BookingRecord, чтобы вызвать службу REST, чтобы вернуть...
294 просмотров
schedule
20.03.2022
Каков правильный синтаксис/вызов для работы sls-файла - соль
Я пытаюсь создать sls-файл реактора, который запускается при возникновении события.
Содержимое файла sls должно быть в виде следующих команд cli:
sudo salt minion git.add /srv/salt .
sudo salt minion git.commit /srv/salt test
sudo salt minion...
358 просмотров
schedule
10.06.2022
Почему Reactor Mono ‹Void› распознается как пустой Mono?
Вот фрагмент кода
@Test
public void test_mono_void_mono_empty() {
Mono.just("DATA")
.flatMap(s -> Mono.just(s.concat("-")
.concat(s))
.doOnNext(System.out::println)...
6757 просмотров
schedule
23.02.2022
GEKKO Недостижимая система уравнений ОДУ для биореактора с подпиткой
Я новичок в GEKKO, а также в моделировании биореакторов, поэтому я могу упустить что-то очевидное.
У меня есть система из 10 ODE, описывающих биореактор периодического действия с подпиткой. Приведены все константы. На рисунке ниже показано...
301 просмотров
schedule
30.03.2022
Комбинируйте моно с флюсом
Я хочу создать сервис, который объединяет результаты из двух реактивных источников. Один производит Mono, а другой - Flux. Для слияния мне нужно одно и то же значение моно для каждого испускаемого потока.
А пока у меня есть что-то вроде этого...
1354 просмотров
schedule
02.06.2023
Доступен ли адаптер от Reactor Flux или RxJava2 Observable / Flowable к источнику AkkaStreams?
Иногда есть библиотеки, такие как R2DBC, которые возвращают Reactive Stream, а именно Reactor Flux, но тогда на уровне Http нам нужен другой Reactive Stream, а именно AkkaStreams Source, который AkkaHttp знает и создает сценарий потоковой передачи с...
269 просмотров
schedule
24.04.2023
Spring WebClient - Как обрабатывать сценарии ошибок
Мы используем org.springframework.web.reactive.function.client.WebClient с reactor.netty.http.client.HttpClient как часть Spring 5.1.9 для выполнения запросов с использованием метода exchange() . документация по этому методу подчеркивает...
3871 просмотров
schedule
30.03.2022
Репозиторий Reactor Spring mongodb объединяет несколько результатов вместе
Я как бы новичок в реактивном программировании и в настоящее время работаю над приложением на основе Spring webflux. Я застрял между несколькими вопросами.
public class FooServiceImpl {
@Autowired
private FooDao fooDao;
@Autowired
private...
216 просмотров
schedule
16.03.2023
Контроллер загрузки Spring, возвращающий Mono из scala.concurrent.Future
Я запускаю систему акторов Akka внутри приложения Spring Boot. У меня работает группа Актеров.
Из своего класса контроллера я вызываю свой класс обслуживания, который, используя шаблон запроса «Актер», отправляет сообщение актору и ожидает ответа....
218 просмотров
schedule
26.08.2022
Как добавить ведение журнала в конечную точку webflux в Spring-mvc?
У меня есть spring-mvc приложение с другим @RestController . Теперь я хочу добавить Mono<String> конечную точку и записать метку времени запроса с указанием пути URL, а также метку времени ответа.
Но как? Я не могу просто...
74 просмотров
schedule
25.09.2022
Как я могу использовать Mono‹Boolean› как условие для вызова второго метода
Я пытаюсь позвонить в одну службу после проверки условия из другой службы
итеративно, я могу сделать это
if (productService.isProductNotExcluded(product)){
List<Properties> properties =...
1263 просмотров
schedule
20.02.2023
BlockHound определяет метод WebClient ExchangeFunction .next () как блокирующий
Я профилирую свое приложение-реактор, используя BlockHound . У меня на ExchangeFunction есть фильтр:
@Override
public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) {
final ClientRequest.Builder builder =...
172 просмотров
schedule
04.05.2023
Выполняется ли doFinally в том же потоке в Reactor
Выполняется ли doFinally в одном потоке? Будет ли ниже код блокировать основной поток?
mono
.map(fileName -> asyncDownloadFile(fileName, folderName))
.doFinally(v -> {
FileUtils.cleanDirectory(folderName); // this method is blocking
});...
416 просмотров
schedule
10.11.2022
Правильный способ использования реактивного метода с if/else
Этот код работает нормально. Он все равно возвращает Flux<Cars> . Но я хочу знать, правильно ли это, потому что сначала оценивается оператор if, а издатель оценивает, когда произойдет подписка?
Должен ли я использовать оператор if/else...
86 просмотров
schedule
01.06.2024
