lht_redis.h

#ifndef LHT_REDIS_H
#define LHT_REDIS_H

#include <QList>
#include <QMutex>
#include <QThread>
#include <lht_errors.h>
#include "lht_redis_i.h"
#include "lht_redis_core.h"

class QTimer;
class LHNodeInfo;
class ctkPluginContext;
class LHLoggerInterface;
class LHSettingsInterface;

struct ThreadRedis
{
    QMutex*      lock;
    QThread*     thread;
    LHRedisCore* core;
};

class LHRedis : public LHRedisInterface
{
    Q_OBJECT
    Q_INTERFACES(LHRedisInterface)
public:
    LHRedis();
    ~LHRedis();

    virtual int Init(const LHParameters &Parameters);
    virtual int Uninit();
    virtual int CreateInstance(QVariant &varInstance, const LHParameters &Parameters);
    virtual int DestroyInstance(const QVariant &varInstance);
    virtual void Upgrade()
    {

    }

public:
    int key_del(QString key, bool *error = NULL);

    QString key_dump(QString key, bool *error = NULL);

    bool key_exists(QString key, bool *error = NULL);

    bool key_expire(QString key,int seconds, bool *error = NULL);

    bool key_expireat(QString key, qint64 timestamp, bool *error = NULL);

    QStringList keys(QString pattern, bool *error = NULL);

    int key_pttl(QString key, bool *error = NULL);

    int key_ttl(QString key, bool *error = NULL);
    bool key_rename(QString key, QString newkey, bool *error = NULL);

    QString key_type(QString key, bool *error = NULL);


    bool string_set(QString key, QString value, bool *error = NULL);

    QString string_get(QString key, bool *error = NULL);

    QString string_getrange(QString key, int start, int stop, bool *error = NULL);

    QStringList string_mget(QStringList keys, bool *error = NULL);

    bool string_mset(QMap<QString, QVariant> map, bool *error = NULL);

    int string_incr(QString key, bool *error = NULL);

    int string_incrby(QString key,int interval, bool *error = NULL);

    int string_decr(QString key, bool *error = NULL);

    int string_decrby(QString key,int interval, bool *error = NULL);

    int string_append(QString key, QString value, bool *error = NULL);


    QStringList list_blpop(QString key, int timeout, bool *error = NULL);

    QStringList list_brpop(QString key, int timeout, bool *error = NULL);

    QStringList list_brpoplpush(QString source, QString destination, int timeout, bool *error = NULL);

    QString list_index(QString key, int index, bool *error = NULL);

    int list_insert(QString key, QString position, QString pivot, QString value, bool *error = NULL);

    int list_len(QString key, bool *error = NULL);

    QString list_lpop(QString key, bool *error = NULL);

    int list_lpush(QString key, QString value, bool *error = NULL);

    int list_lpush(QString key, QStringList values, bool *error = NULL);

    int list_lpushx(QString key, QStringList values, bool *error = NULL);

    QStringList list_range(QString key, int start, int end, bool *error = NULL);

    int list_rem(QString key, int count, QString value, bool *error = NULL);

    int list_set(QString key, int index, QString value, bool *error = NULL);

    bool list_trim(QString key, int start, int stop, bool *error = NULL);

    QString list_rpop(QString key, bool *error = NULL);

    QString list_rpoplpush(QString source, QString destination, bool *error = NULL);

    int list_rpush(QString key, QString value, bool *error = NULL);

    int list_rpush(QString key, QStringList values, bool *error = NULL);

    int list_rpushx(QString key, QStringList values, bool *error = NULL);


    int set_add(QString key, QString member, bool *error = NULL);

    int set_add(QString key, QStringList members, bool *error = NULL);

    int set_card(QString key, bool *error = NULL);

    QStringList set_diff(QStringList keys, bool *error = NULL);

    int set_diffstore(QString destination, QStringList keys, bool *error = NULL);

    QStringList set_inter(QStringList keys, bool *error = NULL);

    int set_interstore(QString destination, QStringList keys, bool *error = NULL);

    bool set_ismember(QString key, QString member, bool *error = NULL);

    QStringList set_members(QString key, bool *error = NULL);

    bool set_move(QString source, QString destination, QString member, bool *error = NULL);

    QString set_pop(QString key, bool *error = NULL);

    virtual QStringList set_randmember(QString key, bool *error = NULL) = 0;

    QStringList set_randmember(QString key, bool *error = NULL);

    int set_rem(QString key, QString member, bool *error = NULL);

    int set_rem(QString key, QStringList members, bool *error = NULL);

    QStringList set_union(QStringList keys, bool *error = NULL);

    int set_unionstore(QString destination, QStringList keys, bool *error = NULL);


    int hash_del(QString key, QString field, bool *error = NULL);

    int hash_del(QString key, QStringList fields, bool *error = NULL);

    bool hash_exists(QString key, QString field, bool *error = NULL);

    QString hash_get(QString key, QString field, bool *error = NULL);

    QVariantMap hash_getall(QString key, bool *error = NULL);

    int hash_incrby(QString key, QString field, int increment, bool *error = NULL);

    float hash_incrbyfloat(QString key, QString field, float increment, bool *error = NULL);

    QStringList hash_keys(QString key, bool *error = NULL);

    int hash_len(QString key, bool *error = NULL);

    QStringList hash_mget(QString key, QStringList fields, bool *error = NULL);

    bool hash_mset(QString key, QMap<QString,QVariant> map, bool *error = NULL);

    bool hash_set(QString key, QString field, QString value, bool *error = NULL);

    bool hash_setnx(QString key, QString field, QString value, bool *error = NULL);

    QStringList hash_values(QString key, bool *error = NULL);

    void publish(QString channel, QString message, bool *error = NULL);

    void subscribe(QString channel, bool *error = NULL);

    void unsubscribe(QString channel, bool *error = NULL);

    void psubscribe(QString channel, bool *error = NULL);

    void punsubscribe(QString channel, bool *error = NULL);

public:
    int getLastError();
public:
    enum FuncType
    {
        //<1> key操作
        KEY_DEL         = 100,
        KEY_DUMP,
        KEY_EXISTS,
        KEY_EXPIRE,
        KEY_EXPIRE_AT,
        KEYS,
        KEY_PTTL,
        KEY_TTL,
        KEY_RENAME,
        KEY_TYPE,

        //<2> string操作
        STRING_SET      = 200,
        STRING_GET,
        STRING_GET_RANGE,
        STRING_MGET,
        STRING_MSET,
        STRING_INCR,
        STRING_INCRBY,
        STRING_DECR,
        STRING_DECRBY,
        STRING_APPEND,

        //<3> list操作
        LIST_BLPOP      = 300,
        LIST_BRPOP,
        LIST_BRPOPLPUSH,
        LIST_INDEX,
        LIST_INSERT,
        LIST_LEN,
        LIST_LPOP,
        LIST_LPUSH,
        LIST_LPUSHX,
        LIST_RANGE,
        LIST_REMOVE,
        LIST_SET,
        LIST_TRIM,
        LIST_RPOP,
        LIST_RPOPLPUSH,
        LIST_RPUSH,
        LIST_RPUSHX,

        //<4> set操作
        SET_ADD         = 400,
        SET_CARD,
        SET_DIFF,
        SET_DIFFSTORE,
        SET_INTER,
        SET_INTERSTORE,
        SET_ISMEMBER,
        SET_MEMBERS,
        SET_MOVE,
        SET_POP,
        SET_RANDMEMBER,
        SET_REMOVE,
        SET_UNION,
        SET_UNIONSTORE,

        //<5> hash操作
        HASH_DEL        = 500,
        HASH_EXISTS,
        HASH_GET,
        HASH_GETALL,
        HASH_INCRBY,
        HASH_INCRBYFLOAT,
        HASH_KEYS,
        HASH_LEN,
        HASH_MGET,
        HASH_MSET,
        HASH_SET,
        HASH_SETNX,
        HASH_VALUES,

        //<6> 订阅发布
        PUBLISH         = 600,
        SUBSCRIBE,
        UNSUBSCRIBE,
        PSUBSCRIBE,
        PUNSUBSCRIBE
    };


private:
    LHRedisCore *getRedisInstance();
    bool validKey(QString &key, QString funcName, bool *error);
    bool validKeys(QStringList &key, QString funcName, bool *error);
    void setLastError(int error);
    QVariant dealwithCmd(FuncType type, QVariantList &data, bool *error);
    QVariant excuteCmd(FuncType type, LHRedisCore* redis, QVariantList &data);

private:

    bool                    m_bInit;
    int                     m_nInstance;
    int                     m_nSettingsInstance;

    QString                 m_redisHost;
    qint16                  m_redisPort;
    int                     m_redisCmdTimeout;

    QMap<void *, ThreadRedis>  m_redis;

    LHSettingsInterface    *m_Settings;
    LHLoggerInterface      *m_Log4qt;
    ctkPluginContext       *m_PluginContext;   

    QMutex                  m_Lock;
};

#endif // LHT_REDIS_H