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

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了.net core 3.0 Signalr - 04 使用Redis做底板来支持横向扩展，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3825字，纯文字阅读大概需要6分钟。

内容图文

在实际的系统中，可能需要多台机器部署;然而，Signalr的连接信息是跟站点走的，举个例子 推送系统部署了A、B两个服务器，张三访问A服务器，李四访问B服务器，当张三通过A服务器向李四推送的时候，A服务器上是找不到李四的连接信息的，自然也就推送不过了，这个时候就需要有一个统一协调的玩意，signalr支持多种，Azure、Redis等，本节以Redis作为底板，介绍如何在Signalr中使用Redis作为底板来支持横向扩展。 ## 引入Redis - 先引入NuGet包 Microsoft.AspNetCore.SignalR.StackExchangeRedis - 修改Startup中的ConfigureServices方法 ``` C# var appSection = Configuration.GetSection("App"); services.Configure(option => appSection.Bind(option)); var appSetting = appSection.Get(); // 添加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配置等详情如下 ``` C# ///

/// 对应appsettings中的App节点的配置信息 ///

public class AppSetting { public JwtSetting JwtSetting { set;get;} public RedisCache RedisCache { set;get;} public RedisCache SignalrRedisCache { set; get; } public string CORS { set;get;} ///

/// 是否主站点(用于运行清理任务等) ///

public bool MainSite { set;get;} } ///

/// JWT设置 ///

public class JwtSetting { ///

/// 发行者 表示token是谁颁发的 ///

public string Issuer { set; get; } ///

/// 表示哪些客户端可以使用这个token ///

public string Audience { set; get; } ///

/// 加密的Key 必须大于16位 ///

public string SecretKey { set; get; } } public class RedisCache { public string ConnectionString { set;get;} public int DatabaseId { set; get; } } ``` 对应的配置文件如下 ``` json { "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 - 实现一个业务推送系统](/2019/09/20/dotnetcore/signalr/00-introduct/) | 上一篇 | [.net core 3.0 Signalr - 03 使用MessagePack压缩传输内容](/2019/09/29/dotnetcore/signalr/03-message-pack/) | 下一篇 | [.net core 3.0 Signalr - 05 使用jwt将用户跟signalr关联](https://blogs.xxgtalk.cn/2019/10/02/dotnetcore/signalr/05-jwt/) | 源码地址 | [源码](https://github.com/xiexingen/CTS.Signalr) | 官方文档 | [官方文档](https://docs.microsoft.com/zh-CN/aspnet/core/signalr/redis-backplane?view=aspnetcore-3.0) 

内容总结

以上是互联网集市为您收集整理的.net core 3.0 Signalr - 04 使用Redis做底板来支持横向扩展全部内容，希望文章能够帮你解决.net core 3.0 Signalr - 04 使用Redis做底板来支持横向扩展所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---