Qt Redis发布订阅

【实例简介】Qt 实现的Redis发布订阅功能

  Qt 实现的Redis发布订阅功能，目的是当C 项目和其他Java，NodeJs，C#，PHP当然也可以是另外的C 项目进行消息转发时可以是Redis的订阅转发功能。

【实例截图】

【核心代码】

void getCallback(redisAsyncContext *ctx, void* _reply, void * privdata){

 redisReply* reply = reinterpret_cast<redisReply*>(_reply);

 MainWindow* win = reinterpret_cast<MainWindow*>(privdata);

 redisContext* subctx = &(ctx->c);

 if (redisGetReply(subctx, &_reply) == REDIS_OK)

 {

 if (reply->type == REDIS_REPLY_ARRAY)

 {

 if (reply->elements > 2 && reply->element[0]->str && strcmp(reply->element[0]->str, "message") == 0)

 {

 string channel = reply->element[1]->str;

 qDebug() << reply->element[2]->str;

 win->writeLog(reply->element[2]->str);

 }

 }

 }

}

【核心代码】.
└── Subscribe
    ├── QtHiRedis
    │   ├── Makefile
    │   ├── Makefile.Debug
    │   ├── Makefile.Release
    │   ├── QtHiRedis.pro
    │   ├── QtHiRedis.pro.user
    │   ├── debug
    │   │   ├── QtHiRedis.dll
    │   │   ├── alloc.o
    │   │   ├── async.o
    │   │   ├── hiredis.o
    │   │   ├── libQtHiRedis.a
    │   │   ├── net.o
    │   │   ├── read.o
    │   │   ├── sds.o
    │   │   └── sockcompat.o
    │   └── src
    │       ├── alloc.c
    │       ├── alloc.h
    │       ├── async.c
    │       ├── async.h
    │       ├── async_private.h
    │       ├── dict.c
    │       ├── dict.h
    │       ├── fmacros.h
    │       ├── hiredis.c
    │       ├── hiredis.h
    │       ├── hiredis_ssl.h
    │       ├── net.c
    │       ├── net.h
    │       ├── read.c
    │       ├── read.h
    │       ├── sds.c
    │       ├── sds.h
    │       ├── sdsalloc.h
    │       ├── sockcompat.c
    │       ├── sockcompat.h
    │       └── win32.h
    ├── SubscribeApp
    │   ├── QtHiRedis.pri
    │   ├── QtHiRedis_Lib_PATH
    │   │   ├── include
    │   │   │   ├── adapters
    │   │   │   │   └── qt.h
    │   │   │   ├── alloc.h
    │   │   │   ├── async.h
    │   │   │   ├── async_private.h
    │   │   │   ├── dict.h
    │   │   │   ├── fmacros.h
    │   │   │   ├── hiredis.h
    │   │   │   ├── hiredis_ssl.h
    │   │   │   ├── net.h
    │   │   │   ├── read.h
    │   │   │   ├── sds.h
    │   │   │   ├── sdsalloc.h
    │   │   │   ├── sockcompat.h
    │   │   │   └── win32.h
    │   │   └── libs
    │   │       ├── QtHiRedis.dll
    │   │       └── libQtHiRedis.a
    │   ├── SubscribeApp.pro
    │   ├── SubscribeApp.pro.user
    │   ├── main.cpp
    │   ├── mainwindow.cpp
    │   ├── mainwindow.h
    │   └── mainwindow.ui
    └── build-SubscribeApp-Desktop_Qt_5_14_2_MinGW_32_bit-Debug
        ├── Makefile
        ├── Makefile.Debug
        ├── Makefile.Release
        ├── debug
        │   ├── QtHiRedis.dll
        │   ├── SubscribeApp.exe
        │   ├── credispublisher.o
        │   ├── main.o
        │   ├── mainwindow.o
        │   ├── moc_mainwindow.cpp
        │   ├── moc_mainwindow.o
        │   ├── moc_predefs.h
        │   ├── moc_qt.cpp
        │   └── moc_qt.o
        ├── release
        └── ui_mainwindow.h

12 directories, 72 files