如何利用Redis和C++实现消息订阅功能

#include <hiredis/hiredis.h>

int main() {
    redisContext *redis = redisConnect("127.0.0.1", 6379);
    if (redis == NULL || redis->err) {
        if (redis) {
            printf("Error: %s
", redis->errstr);
            redisFree(redis);
        } else {
            printf("Error: Can't allocate redis context
");
        }
        return -1;
    }
    printf("Connected to Redis server
");

    // 这里可以进行其他操作，如发布消息、订阅频道等

    redisFree(redis); // 断开与Redis服务器的连接
    return 0;
}

#include <hiredis/hiredis.h>

int main() {
    redisContext *redis = redisConnect("127.0.0.1", 6379);
    if (redis == NULL || redis->err) {
        // 连接失败的错误处理代码...
    }

    // 发布消息
    redisReply *reply = (redisReply *)redisCommand(redis, "PUBLISH channel_name message");
    if (reply == NULL) {
        // 发布消息失败的错误处理代码...
    }
    freeReplyObject(reply);

    redisFree(redis);
    return 0;
}

#include <hiredis/hiredis.h>

int main() {
    redisContext *redis = redisConnect("127.0.0.1", 6379);
    if (redis == NULL || redis->err) {
        // 连接失败的错误处理代码...
    }

    // 订阅频道
    redisReply *reply = (redisReply *)redisCommand(redis, "SUBSCRIBE channel_name");
    if (reply == NULL) {
        // 订阅频道失败的错误处理代码...
    }
    freeReplyObject(reply);

    while (1) {
        // 接收并处理消息
        if (redisGetReply(redis, (void **)&reply) != REDIS_OK) {
            // 获取消息失败的错误处理代码...
        }

        // 处理订阅的消息
        if (reply->type == REDIS_REPLY_ARRAY && reply->elements == 3) {
            // 判断是否是订阅的消息
            if (strcasecmp(reply->element[0]->str, "message") == 0) {
                printf("Received message: %s
", reply->element[2]->str);
            }
        }

        freeReplyObject(reply);
    }

    redisFree(redis);
    return 0;
}