sw::redis::RedisCluster libevent 异步订阅消息，提供demo

下面是一个基于sw::redis::RedisCluster和libevent异步订阅消息的示例代码：

#include <iostream>
#include <string>
#include <sw/redis++/redis++.h>
#include <event2/event.h>

using namespace std;
using namespace sw::redis;

void eventCallback(evutil_socket_t fd, short what, void *arg) {
    RedisCluster *redis = (RedisCluster *)arg;
    redis->cluster_recv();
}

int main() {
    const string redis_cluster_address = "tcp://127.0.0.1:7000";
    const string channel_name = "test_channel";

    // 创建 RedisCluster 实例
    auto redis = RedisCluster::create();
    redis->connect(redis_cluster_address);

    // 订阅频道
    auto callback = [](const string &channel, const string &msg) {
        cout << "Received message from channel " << channel << ": " << msg << endl;
    };
    auto sub = redis->subscribe(channel_name, callback);

    // 创建 libevent 实例
    auto event_base = event_base_new();
    auto event = event_new(event_base, sub->fd(), EV_READ | EV_PERSIST, eventCallback, redis.get());

    // 添加事件监听
    event_add(event, nullptr);

    // 进入事件循环
    event_base_dispatch(event_base);

    return 0;
}

这个示例代码中，首先创建了一个 RedisCluster 实例，然后调用其 connect 方法连接 Redis 集群。接着，调用 subscribe 方法订阅指定的频道，并传入一个回调函数来处理接收到的消息。

然后，创建了一个 libevent 实例，并使用 event_new 函数创建一个事件对象，将其绑定到 RedisCluster 实例的 socket 描述符上，并传入一个回调函数。最后，调用 event_base_dispatch 进入事件循环。

在事件循环中，libevent 会监听 Redis 集群返回的消息，当有消息到达时，会触发事件回调函数 eventCallback，在回调函数中调用 RedisCluster 实例的 cluster_recv 方法来处理接收到的消息。