redis-plus-plus 订阅集群 libevent 异步订阅实现 ，可以提供demo吗,用 sw::redis::RedisCluster

好的，下面是一个使用sw::redis::RedisCluster实现异步订阅的demo:

#include <iostream>
#include <thread>
#include <chrono>
#include <sw/redis++/redis++.h>

using namespace std::chrono_literals;

int main() {
    try {
        // 创建 RedisCluster 对象，并设置连接信息
        sw::redis::RedisCluster redis;
        redis.setMaxRedirects(16);
        redis.addNode("127.0.0.1", 7000);
        redis.addNode("127.0.0.1", 7001);
        redis.addNode("127.0.0.1", 7002);
        redis.addNode("127.0.0.1", 7003);
        redis.addNode("127.0.0.1", 7004);
        redis.addNode("127.0.0.1", 7005);

        // 创建 EventLoop 对象，用于异步处理事件
        sw::redis::EventLoop event_loop;

        // 订阅消息，使用回调函数处理接收到的消息
        auto callback = [](const std::string &channel, const std::string &msg) {
            std::cout << "Received message from channel " << channel << ": " << msg << std::endl;
        };

        // 异步订阅消息
        redis.subscribe("test_channel", callback, event_loop);

        // 在单独的线程中运行 EventLoop 对象，以便异步处理事件
        std::thread thread([&](){
            std::cout << "Starting event loop..." << std::endl;
            event_loop.run();
            std::cout << "Event loop stopped." << std::endl;
        });

        // 发送一些测试消息
        for (int i = 0; i < 10; i++) {
            redis.publish("test_channel", "Test message " + std::to_string(i));
            std::this_thread::sleep_for(1s);
        }

        // 关闭订阅
        redis.unsubscribe("test_channel");

        // 等待事件处理线程退出
        thread.join();

    } catch (const std::exception &e) {
        std::cerr << "Error: " << e.what() << std::endl;
        return -1;
    }

    return 0;
}

在这个例子中，我们使用sw::redis::RedisCluster对象创建了一个连接到Redis集群的客户端，并使用EventLoop对象来实现异步订阅。我们首先传递回调函数来订阅一个名为"test_channel"的频道，然后在另一个线程中启动EventLoop对象的运行，并发送一些测试消息。最后，我们取消订阅并等待事件处理线程退出。

注意：为了保持本示例简单，我们只订阅了一个频道。如果你需要订阅多个频道或者订阅/取消订阅频道时处理更多的逻辑，请根据需要进行修改。