Описание тега quarkus-reactive

2 ответа

Правильное использование Quarkus Cache с Reactive и Mutiny

Я пытаюсь перенести свой проект на Quarkus Reactive с помощью Hibernate Reactive Panache и не знаю, как поступить с кэшированием. Мой оригинальный метод выглядел так @Transactional @CacheResult(cacheName = "subject-cache") public Subject getSubject(…
1 ответ

Mutiny — объединить Uni и Multi на основе бизнес-логики

Я новичок в реактивном программировании. Пожалуйста, помогите в достижении ниже в Mutiny. У меня есть класс DTO public class UserAppSessionDto{ private UserDto user; private List<OrgDto> userOrgs; private List<AppDto> userApps; } и 3 мет…
04 фев '22 в 16:31
0 ответов

Quarkus Reactive выдает «Сеанс в настоящее время подключается к базе данных»

У меня возникла проблема с Quarkus Reactive при запуске нагрузочных тестов. Кажется, соединения не освобождаются достаточно быстро. Конечная точка в основном выполняет поиск в базе данных по полученному коду, а затем сохраняет новое событие с сущнос…
1 ответ

Как записать каждый бросок при использовании .onFailure().retry() с задержкой между попытками

Мне нужно записать причину сбоя в метриках для каждого неудачного HTTP-вызова при использовании Vert.x WebClient. Это компилирует: .onFailure() .retry() .withBackOff(Duration.ofMillis(INITIAL_RETRY_DELAY_MS)) .until(retryTimeExpired(wrapper)) я запи…
1 ответ

Quarkus Reactive выдает «hibernate.connection.provider_disables_autocommit» включен».

Я перенес свое приложение в Quarkus Reactive и вижу это сообщение в журнале всякий раз, когда сохраняю объект с помощью Hibernate Reactive Panache. 2022-01-30 17:04:04,864 ОТЛАДКА [org.hib.res.jdb.int.LogicalConnectionManagedImpl](vert.x-eventloop-t…
0 ответов

Ошибки после перехода на quarkus-resteasy-reactive

Я использую Quarkus 2.8.2. До сих пор я использовал зависимости quarkus-resteasy в своем проекте. В примечаниях к выпуску 2.8 говорится, что я должен переключиться на quarkus-resteasy-reactive , и это замена 1:1, и никаких изменений не требуется. Од…
28 апр '22 в 15:20
1 ответ

Примените сложную бизнес-логику к объекту Multi и верните объект Uni в Rest API.

Внутри функции отдыха я делаю реактивный вызов Postgres Db, который возвращает Multi. Я намерен запустить сложную бизнес-логику на Multi и вернуть новый Uni. @GET public Uni<Object2> get() { Multi<Object1> objects = DB.getAll(dbClient); …
0 ответов

Проблема TLS (javax.crypto.BadPaddingException) с quarkus-rest-client-reactive

У меня есть рабочий образец взаимного клиента TLS rest-client с quarkus-rest-client. Но переключение с quarkus-rest-client на quarkus-rest-client-reactive приводит к проблемам с загрузкой ключей TLS с javax.crypto.BadPaddingException. Это действител…
0 ответов

Как указать QuarkusApplication ждать, пока реактивная вершина MySQLPool завершит выполнение оператора executeBatchAndForget?

У нас есть требование загрузить огромный файл в базу данных MySQL. Я написал простой QuarkusApplicationс quarkus-reactive-mysql-clientвыполнить executeBatchAndForgetдля пакетного импорта записей в БД. Я вижу приведенную ниже ошибку, которая предпола…
1 ответ

Добавление кэша Mongodb Panache Quarkus Reactive

я пытаюсь ускорить мой запрос mongodb panache, используя quarkus и реактивный, я пытаюсь использовать кеш и получить лучшую разбивку на страницы, но не могу заставить его работать, это мой класс java: @ApplicationScoped @RegisterForReflection public…
1 ответ

Закончились соединения SQL с Quarkus и hibernate-reactive-panache

У меня есть приложение Quarkus, которое использует hibernate-reactive-panache для выполнения некоторых запросов, а затем обрабатывает результат и возвращает JSON через вызов отдыха. Для каждого вызова Rest выполняется 5 запросов к БД, последний загр…
22 апр '22 в 10:52
2 ответа

Фильтр отклика статического содержимого Quarkus

Есть ли способ добавить фильтр/перехватчик к статическим ресурсам, обслуживаемым из META-INF/resources? Кажется, я перепробовал все возможные варианты: @ServerResponseFilter, ContainerResponseFilter, WriterInterceptorоднако все эти функции вызываютс…
19 апр '22 в 16:20
1 ответ

Обновить объект массива mongoDB

У меня есть массив объектов, и я хотел бы обновить количество объектов, где categoryId = "menu2" и subCategoryId = "1". в моем mongodb у меня сейчас есть две записи в массиве: { "_id": "xyz", "badges": [{ "count": 2, "categorieId": "menu1", "subCate…
28 апр '22 в 13:35
0 ответов

Что представляет собой эффективное решение для загрузки файлов с использованием Quarkus?

У меня есть три службы (A, B, C). Порядок, в котором они общаются, таков: A -> B -> C. Учитывая, что у меня есть большой файл, который мне нужно загрузить, какое эффективное решение с использованием Quarkus? В настоящее время я использую Quark…
0 ответов

У Quarkus и Panache есть пример API?

Я ищу API-интерфейс Quarkus, который работает как API-интерфейс Spring Data Example в Panache, но мне не удалось найти ничего подобного. Для тех, кто не знает, что такое Example API, вы можете представить его как запрос, выполняемый Exampleобъект, к…
0 ответов

Quarkus Mutiny и Imperitave против Reactive

TL;DR: какой шаблон больше? Использовать мятеж + императивный отдых или просто использовать реактивный отдых? Насколько я понимаю, Mutiny позволяет мне передать Quarkus более продолжительное действие и заставить его обрабатывать особенности того, ка…
05 апр '22 в 16:00
0 ответов

Как преобразовать Multi<Document>в Map<Long,List<Offer> в Quarkus Reactive с клиентской библиотекой Mongo

Я пытаюсь прочитать данные коллекций из MongoDB, используя ReactiveMongoClient в Quarkus. Я получаю Multi и пытаюсь сопоставить свой пользовательский объект и подготовить список и преобразовать в Map<Long,List> offerMapGroubyCustomerId, но без…
24 май '22 в 19:47
1 ответ

Как Quarkus Reactive должен работать с Panache для Kotlin?

Я пробую Quarkus Reactive + Kotlin, и у меня, кажется, есть проблемы с выяснением того, как часть доступа к данным должна работать в этом случае. Quarkus предлагает:quarkus-hibernate-orm-panache-kotlin ИЛИ quarkus-hibernate-reactive-pache Нет кварка…
0 ответов

Реактивный клиент Quarkus - отправка Multipart из ByteArray

я пытаюсь использоватьio.quarkus:quarkus-rest-client-reactive-jacksonдля отправки составного файла. Вот мой клиентский класс @RegisterRestClient(configKey = "foo") interface FooClient { @POST @Path("/upload") fun uploadFile( @RestForm("file") @PartT…
1 ответ

@Timed на реактивной конечной точке quarkus не дает правильного времени отклика

Ниже моя конечная точка. @Path("/data") @POST @Produces(MediaType.APPLICATION_JSON) @Consumes(MediaType.APPLICATION_JSON) @Timed("rest.request.timer") public Multi<***> getData(***) { \\ app logic return x; } Micrometer по умолчанию измеряет H…
19 окт '22 в 13:18