下面是一个使用Qt编写的Redis订阅类的简单示例：
#include <QObject>
#include <QTcpSocket>
class RedisSubscriber : public QObject
{
Q_OBJECT
public:
explicit RedisSubscriber(QObject *parent = nullptr)
: QObject(parent), socket(new QTcpSocket(this))
{
connect(socket, &QTcpSocket::connected, this, &RedisSubscriber::onConnected);
connect(socket, &QTcpSocket::readyRead, this, &RedisSubscriber::onReadyRead);
connect(socket, &QTcpSocket::disconnected, this, &RedisSubscriber::onDisconnected);
}
public slots:
void connectToServer(const QString& hostName, quint16 port)
{
socket->connectToHost(hostName, port);
}
private slots:
void onConnected()
{
qDebug() << "Connected to Redis server";
// 订阅消息
QString subscribeCmd = "SUBSCRIBE channel_name";
socket->write(subscribeCmd.toUtf8());
socket->flush();
}
void onReadyRead()
{
QByteArray data = socket->readAll();
// 解析收到的数据并处理订阅消息
QString message = QString(data).trimmed();
if (message.startsWith("message")) {
QStringList parts = message.split(" ");
QString channel = parts[1];
QString content = parts[2];
qDebug() << "Received message from channel" << channel << ":" << content;
}
}
void onDisconnected()
{
qDebug() << "Disconnected from Redis server";
// 处理重新连接等逻辑（如果需要）
// ...
}
private:
QTcpSocket *socket;
};
在上述示例中，RedisSubscriber类继承自QObject，并使用QTcpSocket来与Redis服务器建立连接和接收消息。通过在connectToServer()槽函数中指定Redis服务器的主机名和端口号，可以连接到服务器。一旦连接成功，便发送订阅命令并在onReadyRead()槽函数中解析收到的消息。
请注意，这只是一个简单的示例，没有处理所有可能的错误情况和异常情况。实际应用中还需要根据具体需求进行适当的错误处理和重连机制。
记得在头文件中添加Q_OBJECT宏以启用信号与槽机制，并在.pro文件中添加QT += network以链接网络模块。
希望以上示例能帮助你开始编写一个基本的Redis订阅类。
内容由零声教学AI助手提供，问题来源于学员提问
