net-core-30-Signalr-04-使用Redis做底板来支持横向扩展

在实际的系统中，可能需要多台机器部署; 然而，Signalr 的连接信息是跟站点走的，举个例子
推送系统部署了 A、B 两个服务器，张三访问 A 服务器，李四访问 B 服务器，当张三通过 A 服务器向李四推送的时候，A 服务器上是找不到李四的连接信息的，自然也就推送不过了，这个时候就需要有一个统一协调的玩意，signalr 支持多种，Azure、Redis 等，本节以 Redis 作为底板，介绍如何在 Signalr 中使用 Redis 作为底板来支持横向扩展。

引入 Redis

• 先引入 NuGet 包

Microsoft.AspNetCore.SignalR.StackExchangeRedis

• 修改 Startup 中的 ConfigureServices 方法

  var appSection = Configuration.GetSection("App");
  services.Configure<AppSetting>(option => appSection.Bind(option));
  var appSetting = appSection.Get<AppSetting>();
  
  // 添加 Signalr
  services.AddSignalR(config =>
  {if (_webEnv.IsDevelopment())
      {config.EnableDetailedErrors = true;}
  })
  // 支持 MessagePack
  .AddMessagePackProtocol()
  // 使用 redis 做底板 支持横向扩展 Scale-out
  .AddStackExchangeRedis(o =>
    {
        o.ConnectionFactory = async writer =>
        {
            var config = new ConfigurationOptions
            {
                AbortOnConnectFail = false,
                ChannelPrefix = "__signalr_",
            };
            config.DefaultDatabase = appSetting.SignalrRedisCache.DatabaseId;
            var connection = await ConnectionMultiplexer.ConnectAsync(appSetting.SignalrRedisCache.ConnectionString, writer);
            connection.ConnectionFailed += (_, e) =>
            {Console.WriteLine("Connection to Redis failed.");
            };
  
            if (connection.IsConnected)
            {Console.WriteLine("connected to Redis.");
            }
            else
            {Console.WriteLine("Did not connect to Redis");
            }
  
            return connection;
        };
    });

可以自定义 Redis 相关配置，此处的 appSetting 为已经定义好的配置实体，包括了，主要配置、CROS 配置、Jwt 配置、redis 配置等详情如下

/// <summary>
/// 对应 appsettings 中的 App 节点的配置信息
/// </summary>
public class AppSetting
{public JwtSetting JwtSetting { set;get;}
    public RedisCache RedisCache {set;get;}
    public RedisCache SignalrRedisCache {set; get;}
    public string CORS {set;get;}
    /// <summary>
    /// 是否主站点 (用于运行清理任务等)
    /// </summary>
    public bool MainSite {set;get;}
}

/// <summary>
/// JWT 设置
/// </summary>
public class JwtSetting
{
    /// <summary>
    /// 发行者 表示 token 是谁颁发的
    /// </summary>
    public string Issuer {set; get;}
    /// <summary>
    /// 表示哪些客户端可以使用这个 token
    /// </summary>
    public string Audience {set; get;}
    /// <summary>
    /// 加密的 Key 必须大于 16 位
    /// </summary>
    public string SecretKey {set; get;}
}

public class RedisCache
{public string ConnectionString { set;get;}
    public int DatabaseId {set; get;}
}

对应的配置文件如下

{
"Logging": {
  "LogLevel": {
    "Default": "Debug",
    "System": "Information",
    "Microsoft": "Information",
    "Microsoft.AspNetCore.SignalR": "Trace",
    "Microsoft.AspNetCore.Http.Connections": "Trace"
  }
},
"App": {
  "RedisCache": {
    "ConnectionString": "127.0.0.1:6379,password=#####,ssl=false,abortConnect=true,connectTimeout=5000",
    "DatabaseId": 10
  },
  "SignalrRedisCache": {
    "ConnectionString": "127.0.0.1:6379,password=#####,ssl=false,abortConnect=true,connectTimeout=5000",
    "DatabaseId": 10
  },
  "CORS": "https://localhost:60000,http://localhost:60001",
  "MainSite": true,
  "JwtSetting": {
    "Issuer": "http://localhost:50000", // 颁发者
    "Audience": "http://localhost:50000", // 使用者
    "SecretKey": "Wetrial20196666666" // key 大于 16 位
  }
}
}

首先，将配置文件跟实体对象映射，下次在其他地方使用的时候可以直接通过 DI 注入，然后通过 AddStackExchangeRedis 配置使用 redis 作为底板

更多内容请通过快速导航查看下一篇

快速导航

标题	内容
索引	.net core 3.0 Signalr – 实现一个业务推送系统
上一篇	.net core 3.0 Signalr – 03 使用 MessagePack 压缩传输内容
下一篇	.net core 3.0 Signalr – 05 使用 jwt 将用户跟 signalr 关联
源码地址	源码
官方文档	官方文档