Я выполняю нагрузочные тесты с веб-приложением vert.x и хочу увеличить ограничение параллелизма, которое оно представляет.Я думаю о реализации BackPressure в потоках HttpServerRequest для обеспечения большего параллелизма.Тем не менее проблема возникает, когда я пытаюсь реализовать маршрутизатор.
Это нормальный способ:
server.requestHandler (router);
server.rxListen (). Subscribe ();
Вот как я пытаюсь (не работает):
server.requestStream.. () .toFlowable () onBackpressureBuffer (подписка) (маршрутизатор :: Handle);server.rxListen (). subscribe ();
Я также хочу знать, является ли использование обратного давления в потоках запросов правильным способом обработки высокого параллелизма ?.спасибо