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>();// 添加Signalrservices.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作为底板

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

快速导航