Qt 访问redis接口代码

#include "qRedis.h" qRedis::qRedis(QString host, int port, QObject *parent) : QObject(parent) { this->host = host; this->port = port; reader = new Reader(host, port); connect(reader, SIGNAL(response(QVariant)), this, SLOT(response(QVariant))); } qRedis::~qRedis() { delete reader; } bool qRedis::openConnection() { connectHost(host,port); QEventLoop loop; connect(reader, SIGNAL(connected()), &loop, SLOT(quit())); loop.exec(); if(!reader->isConnected()) { return false; } return true; } void qRedis::connectHost(const QString &host, const quint16 port) { reader->connectHost(host,port); connect(reader, SIGNAL(connected()), this, SLOT(slotConnected())); } void qRedis::disconnectHost() { reader->disconnectHost(); } void qRedis::slotConnected() { connect(reader, SIGNAL(disconnected()), this, SLOT(slotDisconnected())); emit connected(); } void qRedis::slotDisconnected() { emit disconnected(); } /* Redis Public API */ void qRedis::publish(QString channel, QString message) { QString cmd; cmd.append("PUBLISH "); cmd.append(channel); cmd.append(" "); cmd.append(message); reader->sendData(cmd); } void qRedis::subscribe(QString channel) { QString cmd; cmd.append("SUBSCRIBE "); cmd.append(channel); reader->sendData(cmd); } void qRedis::unsubscribe(QString channel) { QString cmd; cmd.append("UNSUBSCRIBE "); cmd.append(channel); reader->sendData(cmd); } void qRedis::psubscribe(QString channel) { QString cmd; cmd.append("PSUBSCRIBE "); cmd.append(channel); reader->sendData(cmd); } void qRedis::punsubscribe(QString channel) { QString cmd; cmd.append("PUNSUBSCRIBE "); cmd.append(channel); reader->sendData(cmd); } void qRedis::response(QVariant response) { QStringList res = response.toStringList(); Reply reply; if (res[1] == "message") { reply.type = res[0]; reply.message = res[1]; reply.channel = res[2]; reply.value = res[3]; emit returnData(reply); } else if (res[1] == "pmessage") { reply.type = res[0]; reply.message = res[1]; reply.pattern = res[2]; reply.channel = res[3]; reply.value = res[4]; emit returnData(reply); } else { responseData = res; } } qRedis::Reply qRedis::command(QString cmd) { Reply reply; reader->sendData(cmd); QEventLoop loop; connect(reader, SIGNAL(response(QVariant)), &loop, SLOT(quit())); loop.exec(); if(responseData[0] == "integer") { reply.type = responseData[0]; reply.value = responseData[1].toInt(); } else if(responseData[0] == "list") { reply.type = responseData[0]; QStringList list; for(int i=1; i < responseData.length(); i++) { list << responseData[i]; } reply.value = list; } else { reply.type = responseData[0]; reply.value = responseData[1]; } return reply; } int qRedis::append(QString key, QString value) { QString cmd("APPEND "); cmd.append(key); cmd.append(" "); cmd.append(value); Reply reply = command(cmd); return reply.value.toInt(); } bool qRedis::auth(QString password) { QString cmd("AUTH "); cmd.append(password); Reply reply = command(cmd); if(reply.value.toString() == "OK") return true; return false; } QStringList qRedis::blpop(QString key, int timeout) { QString cmd("BLPOP "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(timeout)); Reply reply = command(cmd); return reply.value.toStringList(); } QStringList qRedis::brpop(QString key, int timeout) { QString cmd("BRPOP "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(timeout)); Reply reply = command(cmd); return reply.value.toStringList(); } QStringList qRedis::brpoplpush(QString source, QString destination, int timeout) { QString cmd("BRPOPLPUSH "); cmd.append(source); cmd.append(" "); cmd.append(destination); cmd.append(" "); cmd.append(QString::number(timeout)); Reply reply = command(cmd); return reply.value.toStringList(); } int qRedis::decr(QString key) { QString cmd("DECR "); cmd.append(key); Reply reply = command(cmd); return reply.value.toInt(); } int qRedis::decrby(QString key,int interval) { QString cmd("DECRBY "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(interval)); Reply reply = command(cmd); return reply.value.toInt(); } int qRedis::del(QString key) { QString cmd("DEL "); cmd.append(key); Reply reply = command(cmd); return reply.value.toInt(); } QString qRedis::dump(QString key) { QString cmd("DUMP "); cmd.append(key); Reply reply = command(cmd); return reply.value.toString(); } bool qRedis::exists(QString key) { QString cmd("EXISTS "); cmd.append(key); Reply reply = command(cmd); return reply.value.toBool(); } bool qRedis::expire(QString key,int seconds) { QString cmd("EXPIRE "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(seconds)); Reply reply = command(cmd); return reply.value.toBool(); } bool qRedis::expireat(QString key, qint64 timestamp) { QString cmd("EXPIREAT "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(timestamp)); Reply reply = command(cmd); return reply.value.toBool(); } QVariant qRedis::eval(QString script, int numkeys, QString keys, QString arguments) { QString cmd("EVAL "); cmd.append(script); cmd.append(" "); cmd.append(QString::number(numkeys)); cmd.append(" "); cmd.append(keys); cmd.append(" "); cmd.append(arguments); Reply reply = command(cmd); return reply.value; } QVariant qRedis::evalsha(QString sha1, int numkeys, QString keys, QString arguments) { QString cmd("EVALSHA "); cmd.append(sha1); cmd.append(" "); cmd.append(QString::number(numkeys)); cmd.append(" "); cmd.append(keys); cmd.append(" "); cmd.append(arguments); Reply reply = command(cmd); return reply.value; } QString qRedis::get(QString key) { QString cmd("GET "); cmd.append(key); Reply reply = command(cmd); return reply.value.toString(); } QString qRedis::getrange(QString key, int start, int stop) { QString cmd("GETRANGE "); cmd.append(key); cmd.append(" "); cmd.append(QString::number(start)); cmd.append(" "); cmd.append(QString::number(stop)); Reply reply = command(cmd); return reply.value.toString(); } int qRedis::hdel(QString key, QString field) { QString cmd("HDEL "); cmd.append(key); cmd.append(" "); cmd.append(field); Reply reply = command(cmd); return reply.value.toInt(); } bool qRedis::hexists(QString key, QString field) { QString cmd("HEXISTS "); cmd.append(key); cmd.append(" "); cmd.append(field); Reply reply = command(cmd); return reply.value.toBool(); } QString qRedis::hget(QString key, QString field) { QString cmd("HGET "); cmd.append(key); cmd.append(" "); cmd.append(field); Reply reply = command(cmd); return reply.value.toString(); } QMap<QString,QVariant> qRedis::hgetall(QString key) { QString cmd("HGETALL "); cmd.append(key); Reply reply = command(cmd); QMap<QString,QVariant> keypairs; QStringList list = reply.value.toStringList(); for(int i=0; i<list.length(); i++) { QString k = list[i]; i++; QString v = list[i]; keypairs[k] = QString(v); } return keypairs; } int qRedis::hincrby(QString key, QString field, int increment) { QString cmd("HINCRBY "); cmd.append(key); cmd.appe