Как получить последние данные от Redis в режиме реального времени? - PullRequest
Новая
       15

Как получить последние данные от Redis в режиме реального времени?

2 голосов
/ 13 июня 2019

Я хочу реализовать приложения в реальном времени с Redis.

Существуют данные, которые передаются в реальном времени на Redis, например, исходный код ниже, который использовал библиотеку салата.

RedisClient redisClient = RedisClient.create(uri);
StatefulRedisConnection<String, String> connection = redisClient.connect() 

RedisStringAsyncCommands<String, String> asyncCommands = connection.async();
List<RedisFuture<?>> futures = Lists.newArrayList(); 

while(true) {
    futures.add(asyncCommands.set("key", "value"));
}

Если я хочу проверить данные на клиенте в режиме реального времени, как я могу это реализовать?
Сначала я использовал метод pub / sub, но метод pub / sub не смог получить сохраненные данные.
Это была просто публикация данных - канал - подписка данных в режиме реального времени.

Например, Кафка может непрерывно получать данные через потребителя, вот так.

while(true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        logger.info("offset = {}, value = {}", record.offset(), record.value());
    }
}

Есть ли способы?

...