Описание тега spring-data-redis-reactive

Вопросы с тегом

0 ответов

Можно ли реализовать Redis-реактивную функциональность, используя spring-boot-starter-web?

Я собираюсь использовать редис-реактив в весенней загрузке. Однако весь существующий код - это код, который работает в режиме webmvc. Есть ли какие-либо проблемы при попытке использовать redis-реактивный с webmvc вместо webflux? В сервлете 3.1 он ра…

08 июл '19 в 03:05

0 ответов

Должен ли я заблокировать моно в методах Аспекта?

Я пытаюсь контролировать кэш Redis в своем классе Aspect. @Aspect public class SomeServiceAspect { @Before("execution(* ...Service.addSome(..))") public void evictSome(JoinPoint joinPoint) { Mono<Boolean> deleted = redisService.getSomeValueOpe…

spring spring-data-redis spring-data-redis-reactive

19 июн '19 в 15:44

2 ответа

Использование функции elapsed() на Mono?

Я пытаюсь получить время выполнения для чтения из Redis в реактивном программировании, при поиске документов я могу видеть, что elapsed() Метод будет выполнять тот же и реализованный код, как показано ниже. Flux.fromIterable(getActions(httpHeaders))…

java spring-webflux project-reactor spring-data-redis-reactive

10 июл '19 в 14:02

1 ответ

Странное поведение с конечной точкой SSE с использованием Redis

Мне нужно передать некоторые данные клиенту, если он находится в Redis, но клиент продолжает подключаться к конечной точке SSE каждые 5 секунд. Код бэкэнда: @RestController @RequestMapping("/reactive-task") public class TaskRedisController { private…

spring redis spring-webflux server-sent-events spring-data-redis-reactive

17 июл '19 в 11:00

0 ответов

Приемник потока данных Redis Spring завершается преждевременно

Я использую данные Spring Redis для потребления из потока Redis, используя приемник реактивного потока для прослушивания работы группы потребителей, но заметил, что поток Flux иногда преждевременно закрывается и больше не прослушивает новые сообщени…

spring-data-redis spring-data-redis-reactive

09 окт '19 в 17:54

2 ответа

Есть ли способ установить тайм-аут в Java с реактивным Redis?

Я использую ReactiveRedisConnection для настройки подключения к локальному контейнеру Redis. Но в будущем приложение будет размещаться на веб-сервере, а Redis - на другом сервере. Есть ли возможность установить тайм-аут для запроса?

java spring-webflux spring-data-redis-reactive

18 сен '19 в 19:27

1 ответ

Поддержка async отсутствует в реактивном соединении Redis

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

spring-webflux reactive-programming spring-data-redis spring-reactive spring-data-redis-reactive

25 мар '20 в 13:52

4 ответа

Невозможно подключиться к Redis; вложенное исключение - io.lettuce.core.RedisConnectionException с использованием ReactiveRedisTemplate

Я новичок в реактивном программировании. Мне нужно подключиться к Redis, чтобы сохранить и получить данные. Экземпляр Redis присутствует в облаке. Я использую фабрику Lettuce Connection для установления соединения. при установке соединения с Redis з…

redis reactive spring-data-redis lettuce spring-data-redis-reactive

26 мар '20 в 20:05

0 ответов

Как правильно связать операции redis в spring-data-redis-reactive?

В spring-data-redis-reactive, операции записи возвращают результат выполнения redis, что значительно усложняет связывание операторов. Возьмем, к примеру, Reddit в главе 1 Redis In Action. Я пытаюсь реализовать так: @Service public class ArticleServi…

spring redis project-reactor spring-data-redis spring-data-redis-reactive

17 апр '20 в 06:48

0 ответов

Spring Data Redis Streams (Reactive) - каков правильный способ обработки ошибок?

Я использую Redis Streams с Spring Data Redis 2.2.4. Одна вещь, которую я хочу выяснить, - это правильный способ обработки ошибок . Для модели без реакции мы устанавливаем ErrorHandler и EancelSubscriptionOnError на StreamReadRequest. Затем мы можем…

redis spring-data-redis redis-streams spring-data-redis-reactive

25 фев '20 в 09:09

0 ответов

почему в шаблоне redis opsForZSet Spring счет должен быть удвоен

Я бы хотел использовать ZSetдля хранения отметок времени и значения. Отметка времени должна быть Score, ноRedisReactiveTemplateтребуется двойной. Проблема в том, что когда я меняю Long на Double, я получаю что-то вроде "1.31232...E8", есть ли способ…

spring kotlin redis spring-data-redis spring-data-redis-reactive

16 апр '20 в 09:29

4 ответа

Как непрерывно прослушивать поток Redis с помощью библиотеки java lettuce

Я пытаюсь прослушивать поток Redis и обрабатывать сообщения по мере их поступления. Я использую команду async и ожидаю, что сообщение будет отправлено, а не извлечено. Поэтому я не думаю, что нужен цикл while. Но следующий код, похоже, не работает. …

java spring-data-redis lettuce redis-streams spring-data-redis-reactive

27 июл '20 в 04:26

1 ответ

Шаблон Redis для реактивного хэша Spring Data для настраиваемых объектов

Я пытался использовать Jackson2JsonRedisSerializerдля сериализации настраиваемого экземпляра в качестве хеш-значения в магазине Redis. Кажется, что хотя я правильно создал шаблон, хеш не создается. Просто примечание, что я использую spring-data-reac…

spring kotlin redis spring-data-redis-reactive

13 янв '20 в 23:27

1 ответ

Поддерживается ли XClaim / претензия в данных Redis Spring - ReactiveRedisOperations.opsForStream()

Чтобы создать надежную очередь сообщений с использованием потоков redis, я использую зависимость spring-boot-starter-data-redis-reactive и lettuce для обработки сообщений из потока redis. Хотя я могу добавлять, читать, подтверждать и удалять сообщен…

redis spring-data spring-data-redis lettuce spring-data-redis-reactive

01 июн '20 в 14:38

1 ответ

Spring data redis реактивное чтение Ошибка приведения LocaldateTime

Я использую Spring Data Redis Reactive framework, а версия Spring Boot - 2.3.0. Вот моя конфигурация Redis: @Bean("reactiveRedisTemplate") public ReactiveRedisTemplate<String, Object> reactiveRedisTemplateString(ReactiveRedisConnecti…

jackson spring-data spring-data-redis spring-data-redis-reactive

23 июн '20 в 11:57

1 ответ

добавить модуль "spring интеграции redis", который распечатывает "XXX не может быть обработан всеми процессорами BeanPostProcessors.

Я интегрирую модуль spring integration-redis, чтобы использовать RedisLockRegistry. но я получил следующие журналы при запуске весенней загрузки. 19: 2020/09/11 21:02:25,006 2312 [INFO] [main] [integration.config.DefaultConfiguringBeanFactoryPostPro…

java spring-boot spring-integration spring-data-redis-reactive

11 сен '20 в 16:36

0 ответов

Исключение Spring WebSession Redis

Я хочу сохранить свою веб-сессию в Redis. Нет проблем с операцией размещения, но она вызывает исключение при получении сохраненной записи. Вот мой пример трассировки стека Вызвано: com.fasterxml.jackson.databind.exc.MismatchedInputException: неожида…

jackson spring-webflux spring-data-redis spring-session spring-data-redis-reactive

13 ноя '20 в 15:25

0 ответов

Неподдерживаемая операция в потоках восстановления Spring-Data-Redis

Я использую реактивный код spring data redis для прослушивания входящих сообщений из потока redis. Иногда я получаю следующее исключение, и я не уверен, когда это произойдет. Когда я копаюсь в исходном коде класса DefaultStreamReceiver spring-data-r…

java project-reactor spring-data-redis spring-data-redis-reactive

10 ноя '20 в 20:43

0 ответов

Реализация сервера с использованием реактивных потоков Spring

Я работаю над инструментом, который прослушивает потоки на нескольких узлах Redis. Новые узлы могут быть добавлены / удалены в зависимости от нагрузки. У меня есть планировщик, который запускается каждую секунду в поисках активных в данный момент уз…

reactive-programming project-reactor spring-data-redis reactor spring-data-redis-reactive

20 ноя '20 в 17:56

0 ответов

Правильный способ хранения списка объектов в Spring Data Redis Reactive

Мне нужно сохранить список объектов в Redis. Каждый элемент списка должен быть доступен по уникальному ключу. Для этого я думаю, что список объектов должен храниться как карта объектов в Redis (я преобразовал в String перед тем, как сохранить его): …

redis spring-data-redis spring-data-redis-reactive

14 ноя '20 в 11:25