使用 Lettuce 反应式命令订阅 Redis 通道 (pubsub)

Question

我正在使用io.lettuce.core库，但在使用该界面订阅频道时遇到问题RedisPubSubReactiveCommands。

我有一个StatefulRedisPubSubConnection正在尝试订阅的活动 Redis 集群。

connection.sync().subscribe("channel")工作正常，就像 一样connection.async().subscribe("channel")。但是，当我使用 Lettuce 提供的反应式“热可观察”接口时，如下所示：

connection.reactive().subscribe(channels).subscribe();
connection.reactive().observeChannels().doOnNext(this::notifyObservers).subscribe();

它不会在 Redis 上注册为订阅操作。我觉得我正在密切关注生菜文档中给出的示例。

我正在为一个接受热FluxObservable 的接口进行编程，并且我即将用我自己的反应式包装器来包装同步或异步连接接口，并将它们扔进管道中。我在这里做错了什么？

Answer 1

如果其他人遇到同样的问题，事实证明我将一个对象传递到一个Set<String>接受可变参数的函数中Object...，并且没有意识到它将整个集合视为单个元素，而不是将其解析为可变参数数组。我会把这个留给其他人从我的愚蠢错误中吸取教训。