java - 使用 Lettuce 响应式(Reactive)命令订阅 Redis channel (pubsub)

Question

我正在使用io.lettuce.core库，并且我在使用 RedisPubSubReactiveCommands 界面订阅 channel 时遇到问题。

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

connection.sync().subscribe("channel") 工作正常，connection.async().subscribe("channel") 也是如此。但是，当我使用 Lettuce 提供的响应式(Reactive)“热可观察”接口(interface)时，如下所示:

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

它不会在 Redis 上注册为订阅操作。我觉得我正在遵循 lettuce documentation 中给出的示例密切关注。

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

Answer 1

如果其他人遇到同样的问题，事实证明我传递的是 Set<String>对象转换为接受可变参数的函数 Object...并且没有意识到它将整个集合视为单个元素，而不是将其解析为可变参数数组。

我会把这个留给其他人从我的愚蠢错误中吸取教训。