如何用C#代码验证SignalR是否使用Redis ElastiCache存储消息

问题 #

我已在项目中配置SignalR使用StackExchangeRedis连接Redis ElastiCache，相关代码如下：

services.AddSignalR()
        .AddStackExchangeRedis("*****.*****.com:6379", opts =>
        {
            opts.Configuration.ChannelPrefix = "SomeMessage";
            opts.Configuration.Ssl = true;
            opts.Configuration.AbortOnConnectFail = true;
            opts.Configuration.ConnectRetry = 3;
            opts.Configuration.ConnectTimeout = 30;
        });

订阅方法：

public Task Subscribe(string subscriptionKey)
{
    return Groups.AddToGroupAsync(Context.ConnectionId, subscriptionKey);
}

广播方法：

public Task SendMessage(SendMessageModel sendMessageModel)
{
    return Clients.Group(sendMessageModel.subscriptionKey).SendAsync(sendMessageModel.eventType, sendMessageModel.payload);
}

目前客户端能正常接收广播消息，但我无法直接访问Redis数据库。我曾通过以下测试代码连接同一Redis ElastiCache并成功存取键值对：

ConnectionMultiplexer cluster = ConnectionMultiplexer.Connect("******.****.com:6379,connectTimeout=30000,responseTimeout=30000,ssl=true,abortConnect=true,syncTimeout=30000");

IDatabase db = cluster.GetDatabase();

db.StringSet("foo", "bar");
var getResult = db.StringGet("foo");
_loggerUtility.LogGenericMessage(LogType.DEBUG, "After getdb of calling Controller TestAsync() cluster value : " + getResult);

我希望用类似方式验证SignalR消息在Redis中的键值对，但不清楚SignalR存储的键名，请问该如何操作？

解决方案 #

首先要明确：SignalR使用Redis作为背板时，核心依赖Redis发布/订阅（Pub/Sub）机制广播消息，消息不会持久化存储；仅分组与连接的映射元数据会以哈希表形式存储在Redis中。以下是两种验证方式：

1. 监听SignalR的Pub/Sub频道 #

SignalR的消息会发送到特定格式的Redis频道，频道名称规则为：
{ChannelPrefix}:{HubName}:{Target}

• ChannelPrefix：你配置的SomeMessage
• HubName：你的SignalR Hub类名称（比如Hub类名为ChatHub，则填ChatHub）
• Target：如果是分组广播，就是你的subscriptionKey

可以用以下代码监听频道，捕获SignalR发送的消息：

var multiplexer = ConnectionMultiplexer.Connect("******.****.com:6379,connectTimeout=30000,responseTimeout=30000,ssl=true,abortConnect=true,syncTimeout=30000");
var subscriber = multiplexer.GetSubscriber();
// 替换为你的Hub名称和实际订阅键
var channelName = "SomeMessage:YourHubName:your-subscription-key";

subscriber.Subscribe(channelName, (channel, message) =>
{
    _loggerUtility.LogGenericMessage(LogType.DEBUG, $"捕获到SignalR广播消息: {message}");
});

2. 读取分组与连接的映射元数据 #

SignalR会将分组对应的连接ID存储在Redis哈希表中，键的格式为：
{ChannelPrefix}:{HubName}:groups:{subscriptionKey}

可以用以下代码读取该哈希表，验证分组下的连接：

var multiplexer = ConnectionMultiplexer.Connect("******.****.com:6379,connectTimeout=30000,responseTimeout=30000,ssl=true,abortConnect=true,syncTimeout=30000");
var db = multiplexer.GetDatabase();
// 替换为你的Hub名称和实际订阅键
var groupKey = "SomeMessage:YourHubName:groups:your-subscription-key";

var connections = db.HashGetAll(groupKey);
foreach (var entry in connections)
{
    _loggerUtility.LogGenericMessage(LogType.DEBUG, $"分组 {groupKey} 下的连接ID: {entry.Name}");
}

注意事项 #

• Pub/Sub消息是即时消费的，发送后不会在Redis中留存，所以无法通过StringGet这类方法读取历史消息
• 分组映射的哈希表会在连接断开或客户端退出分组时自动清理，无需手动维护

内容的提问来源于stack exchange，提问作者vishakha