qt redis 发布订阅

在Qt中使用Redis进行发布订阅，你需要使用Redis的C++客户端库来实现。其中一个流行的库是hiredis，它提供了与Redis的交互功能。

下面是一个使用Qt和hiredis库实现Redis发布订阅的示例：

首先，你需要安装hiredis库。你可以从GitHub上的hiredis仓库中获取源代码，并按照说明进行编译和安装。

然后，你可以在Qt项目中添加hiredis的头文件和库文件的路径。在.pro文件中添加如下代码：

INCLUDEPATH += /path/to/hiredis
LIBS += -L/path/to/hiredis -lhiredis

接下来，你可以使用以下代码在Qt中实现Redis发布订阅：

#include <QtCore>
#include <hiredis/hiredis.h>

class RedisSubscriber : public QThread
{
public:
    explicit RedisSubscriber(QObject *parent = nullptr)
        : QThread(parent)
    {
    }

protected:
    void run() override
    {
        redisContext *context = redisConnect("localhost", 6379);
        if (context == nullptr || context->err) {
            qDebug() << "Failed to connect to Redis";
            return;
        }

        redisReply *reply = static_cast<redisReply *>(
            redisCommand(context, "SUBSCRIBE channel1")
        );
        if (reply == nullptr) {
            qDebug() << "Failed to subscribe";
            return;
        }

        qDebug() << "Subscribed to channel1";

        while (!isInterruptionRequested()) {
            if (redisGetReply(context, reinterpret_cast<void **>(&reply)) != REDIS_OK) {
                qDebug() << "Failed to receive message";
                break;
            }

            if (reply->type == REDIS_REPLY_ARRAY && reply->elements == 3) {
                QString channel = reply->element[1]->str;
                QString message = reply->element[2]->str;
                qDebug() << "Received message from" << channel << ":" << message;
            }

            freeReplyObject(reply);
        }

        redisFree(context);
    }
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    RedisSubscriber subscriber;
    subscriber.start();

    return a.exec();
}

在这个示例中，我们创建了一个继承自QThread的RedisSubscriber类，用于订阅Redis通道。在run()函数中，我们首先连接到Redis服务器，然后使用redisCommand函数发送订阅命令。然后，我们在一个循环中接收Redis发布的消息，并打印出来。

你可以根据需要修改主函数中的服务器地址、端口和订阅的通道名称。