如何利用Redis和C++開發發布-訂閱功能-Redis-PHP中文網

如何利用Redis和C++開發發布-訂閱功能

王林

發布： 2023-09-21 15:35:32

原創

957 人瀏覽過

如何利用Redis和C++開發發布-訂閱功能

如何利用Redis和C 開發發布-訂閱功能

在開發大規模即時系統時，發布-訂閱模式被廣泛應用於訊息傳遞和事件驅動機制中。 Redis是一個高效能的鍵值儲存系統，透過其提供的發布-訂閱功能，可以輕鬆實現即時通訊和資料傳遞。本文將介紹如何利用Redis和C 開發發布-訂閱功能，並提供具體的程式碼範例。

Redis的發布-訂閱模式概述
Redis的發布-訂閱模式是一種基於訊息傳遞的模式，它可以實現多個訂閱者同時接收相同的訊息。在該模式中，發布者負責發送訊息，而訂閱者則透過訂閱頻道來接收訊息。
Redis發布-訂閱功能的實作
要使用Redis的發布-訂閱功能，首先需要安裝和設定Redis伺服器。然後，在C 程式碼中使用Redis的C 用戶端程式庫進行操作。

以下是一個基本的範例，示範如何使用Redis C 用戶端程式庫實作發布-訂閱功能。

#include <iostream>
#include <string>
#include <thread>
#include <hiredis/hiredis.h>

void subscribeThread()
{
    // 创建Redis上下文
    redisContext* context = redisConnect("127.0.0.1", 6379);
    if (context == NULL || context->err)
    {
        if (context)
        {
            std::cout << "Error: " << context->errstr << std::endl;
            redisFree(context);
        }
        else
        {
            std::cout << "Error: 连接Redis服务器失败！" << std::endl;
        }
        return;
    }

    // 订阅频道
    redisReply* reply = static_cast<redisReply*>(
        redisCommand(context, "SUBSCRIBE mychannel"));

    if (reply == NULL || reply->type == REDIS_REPLY_ERROR)
    {
        std::cout << "Error: 订阅频道失败！" << std::endl;
        freeReplyObject(reply);
        redisFree(context);
        return;
    }

    // 循环接收消息
    while (true)
    {
        redisReply* r = nullptr;
        int status = redisGetReply(context, (void**)&r);

        if (status == REDIS_ERR)
        {
            std::cout << "Error: 接收消息失败！" << std::endl;
            break;
        }

        if (r->type == REDIS_REPLY_ARRAY && r->elements == 3)
        {
            if (strcmp(r->element[0]->str, "message") == 0)
            {
                std::cout << "接收到消息: " << r->element[2]->str << std::endl;
            }
        }

        freeReplyObject(r);
    }

    // 释放资源
    freeReplyObject(reply);
    redisFree(context);
}

void publishThread()
{
    redisContext* context = redisConnect("127.0.0.1", 6379);
    if (context == NULL || context->err)
    {
        if (context)
        {
            std::cout << "Error: " << context->errstr << std::endl;
            redisFree(context);
        }
        else
        {
            std::cout << "Error: 连接Redis服务器失败！" << std::endl;
        }
        return;
    }

    // 发布消息
    while (true)
    {
        std::string message;
        std::cout << "请输入要发布的消息（输入q退出）：";
        std::getline(std::cin, message);

        if (message == "q")
        {
            break;
        }

        redisReply* reply = static_cast<redisReply*>(
            redisCommand(context, "PUBLISH mychannel %s", message.c_str()));

        if (reply == NULL || reply->type == REDIS_REPLY_ERROR)
        {
            std::cout << "Error: 发布消息失败！" << std::endl;
        }

        freeReplyObject(reply);
    }

    // 释放资源
    redisFree(context);
}

int main()
{
    std::thread subThread(subscribeThread);
    std::thread pubThread(publishThread);

    subThread.join();
    pubThread.join();

    return 0;
}

登入後複製

在上述程式碼中，我們使用了Redis的C 用戶端程式庫hiredis來連接Redis伺服器。透過建立不同的線程，可以分別實現發布和訂閱功能。在訂閱線程中，我們使用redisCommand函數來訂閱指定的頻道，並透過redisGetReply函數來接收訊息。在發布線程中，我們使用redisCommand函數來發布訊息。