spring-boot - redissonClient.poll() 只返回String类型值的前8个字符

标签 spring-boot redis redisson

目前正在使用 reddison,创建一个 redissonClient 并尝试从 redis 服务器轮询数据。如果我通过 redis-cli 检查,我可以在 redis 数据库中看到数据,但是当我在我的 java 应用程序中查看字符串值时,它始终是字符串的前 8 个字符,仅此而已。不确定为什么它不能给我全部值(value)。

我也尝试过使用 .peek() 方法,但我看到了相同的症状,即我只得到返回字符串的 8 个字符。

这是代码的主要部分,我可以根据需要提供更多详细信息:

@Service
@Slf4j
public class RedisConsumer {

RedisConfig redisConfig;
//RQueue<String> redisQueue;
RBlockingQueue<String> redisQueue;

@Autowired
RedisConsumer(RedisConfig redisConfig) {
    this.redisConfig = redisConfig;
}

public void pollAuditQueue() {

    //Redisson
    redisQueue.add("{JSON string here snipped out for brevity}");
    String item = redisQueue.poll();

    if (!Objects.isNull(item)) {
        log.info("I found this item: " + item);

    } else {
       log.info("Nothing in queue...");
   }
}

@PostConstruct
private void init() throws Exception {
    RedissonClient redissonClient = redisConfig.redisson();
    redisQueue = redissonClient.getBlockingQueue("test");

    while(true) {
        pollAuditQueue();
        Thread.sleep(5000);
    }
}

当我查看控制台中的打印语句时,我看到:

I found this item: {"AuditEv

当我检查 redis-cli 时,我可以看到整个值:

1) "\xfc\t{\"AuditEvent\":{\"timestamp\":\"2018-11-27 04:31:47.818000+0000\" snipped the rest out for brevity}"

最后,如果我在 Java 应用程序中进行轮询后检查项目是否已从 Redis 中删除,我可以确认它是。

任何帮助都会很棒,因为它不会抛出任何特定错误我没有在网上找到任何资源来帮助解决它。

最佳答案

我发现了一件我在之前的测试中没有注意到的事情。当我使用 redis cli 手动插入时,我正在复制我通过 Java 所做的第一次测试,将\xfc\t 放在前面,这可以在我上面的示例中看到。

刚才,当我在我的应用程序中使用 redisQueue.add 时,我注意到在 redis 中它有\xfc\x80\x90\x01 而不是在我的应用程序中将整个字符串返回给我。我假设这与内存分配有某种关系?我将问题标记为已解决,因为我不再遇到该问题。如果有人可以对这些字母/数字的含义发表评论,尽管它可能对以后阅读这篇文章的任何人有意义。一旦我研究了它,如果没有人先于我,我会自己添加评论!

关于spring-boot - redissonClient.poll() 只返回String类型值的前8个字符,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55523190/

相关文章:

java - 如何修复 'java.lang.ClassCastException: org.redisson.RedissonReference cannot be cast to org.redisson.api.RLock'

Spring Boot - 缓慢的请求/响应

java - 嵌入式tomcat找不到 Controller

php - 带列表的 Redis 通知

python - python 3.5 中的 json.loads 和 Redis

java - 单例模式是 RedissonClient 的一个很好的用例吗?

redis - RedissonClient.getSet ("my-set").size() 返回一个数字后,为什么该集合在下次运行之前显示为空?

java - 强制 Spring Boot @Scheduled 方法在失败时调用 "out of schedule"

spring - Kotlin Spring Boot 中的 Controller 验证

exception - redis.clients.jedis.exceptions.JedisDataException:ERR错误编译脚本(新功能):user_script:1:附近的格式错误的数字