C++实现redis发布订阅模式

在C++中实现Redis的发布/订阅模式，你可以使用hiredis库，这是一个流行的C语言Redis客户端库。以下是一个简单的例子，展示了如何使用hiredis进行发布和订阅。

首先，确保你已经安装了hiredis库。如果没有安装，你可以通过包管理器或从源代码构建它。

#include <hiredis/hiredis.h>
#include <iostream>
#include <string>
 
int main() {
    // 创建连接到Redis服务器的连接
    redisContext *c = redisConnect("127.0.0.1", 6379);
    if (c != NULL && c->err) {
        std::cerr << "连接错误: " << c->errstr << std::endl;
        // 处理错误
        return 1;
    }
 
    // 订阅频道
    redisReply *reply = (redisReply*)redisCommand(c, "SUBSCRIBE mychannel");
    if (reply->type == REDIS_REPLY_ARRAY && reply->elements == 3) {
        // 确保回复是正确的类型和结构
        if (strcmp(reply->element[0]->str, "message") == 0) {
            // 接收到消息
            std::cout << "接收到消息: " << reply->element[2]->str << std::endl;
        }
    }
    freeReplyObject(reply);
 
    // 发布消息
    reply = (redisReply*)redisCommand(c, "PUBLISH mychannel HelloWorld");
    if (reply->type == REDIS_REPLY_INTEGER) {
        // 确保回复是正确的类型
        std::cout << "消息已发布给 " << reply->integer << " 订阅者" << std::endl;
    }
    freeReplyObject(reply);
 
    // 断开连接
    redisFree(c);
 
    return 0;
}

在上面的代码中，我们首先连接到Redis服务器，然后订阅名为mychannel的频道。接下来，我们发布一条消息到同一频道。在实际应用中，订阅通常会在一个循环中进行，以持续接收消息，而发布的操作可以在程序的任何地方进行。

请注意，这个例子没有处理异常情况，如网络问题或Redis服务器响应错误。在实际应用中，你应该添加适当的错误检查和异常处理。