我正在使用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 的接口進行編程，并且我即將用我自己的反應式包裝器來包裝同步或異步連接接口，并將它們?nèi)舆M管道中。我在這里做錯了什么？