SignalR给特定User发送消息

1、背景

官网上SignalR的demo很详细，但是有个特别的问题，就是没有详细阐述如何给指定的用户发送消息。

2、解决思路

网上整体解决思路有三个：
1、最简单的方案，客户端连接SignalR的Hub时，只是简单的连接，不包含用户信息。连接完成后，发送一个指定格式的数据包，里面包含用户信息，服务器收到后，完成解析，并将用户信息与connectionID关联起来，用于保存（保存在List或者数据库中均可，看具体应用）。网上这个方案比较多
2、使用Group方案。这个是一个比较取巧的方案，将用户信息放在Group，然后通过Group找到用户，并发送信息。
3、使用用户认证方案。一般有cookie方案和token方案。

因为token方案比较常见，在客户端和网页端都可以使用，所以本篇阐述如何通过用户认证方案（JWT方式），实现SignalR给指定的用户发送消息的功能

3、具体实现

3.1 基本原理

在这里插入图片描述
整体步骤如下：
1、根据API的方法要求，传入用户名、密码
2、认证服务器，将返回一个JWT格式的Token。这儿有个关键，就是第二段（payload）。可以进行自定义。例如：

//payload中的值设定
private static ClaimsIdentity GenerateClaims(User user)
{var ci = new ClaimsIdentity();ci.AddClaim(new Claim("id", user.Id.ToString()));ci.AddClaim(new Claim(ClaimTypes.Name, user.Username));ci.AddClaim(new Claim(ClaimTypes.GivenName, user.Name));ci.AddClaim(new Claim(ClaimTypes.Email, user.Email));ci.AddClaim(new Claim("EmployeeID", user.EmployeeID));foreach (var role in user.Roles)ci.AddClaim(new Claim(ClaimTypes.Role, role));return ci;
}

因此获得的token后，解析payload，就会得到如下的信息。而我们一会儿要用的，就是这些信息。
在这里插入图片描述
3、第三步是在SignalR服务器，自定义识别user方法。代码如下：

public class CustomUserIDProvider : IUserIdProvider
{public string? GetUserId(HubConnectionContext connection){var returnStr = connection.User?.FindFirst("EmployeeID")?.Value!;return returnStr;}
}

我们希望使用员工号（EmployeeID）进行唯一的识别，因此在第二步中，添加了EmployeeID的自定义Claim。
这一步的核心就是，当客户端发起一个SignalR连接时，会一并第2步的token，SignalR中默认会关联connection和userID，而第三步就是确定，用哪个信息能够代表唯一的userID（既方便系统识别，又符合业务逻辑，在本例中，我们使用了员工号）。
实现上述CustomUserIDProvider后，在Program中注册，替换SignalR的默认provider。

builder.Services.AddSingleton<IUserIdProvider, CustomUserIDProvider>();

4、第四步是定义连接，并使用StartAsync()方法，进行连接。

var _token="eyJhbGciOiJIUzI1NiIsInR.XXXXXXX.YYYYYYYYYY";//本人使用Android模拟机发起一个SignalR请求
//虽然SignalR服务器在本机电脑上，但Android虚拟机中不能使用localhost，因为会被系统认为是访问Android虚拟机
//本机的地址，在Android虚拟机的对应地址，可以通过adb进行查看
//一般情况是10.0.0.2、10.0.2.2等，但不是绝对的，可以查看相关的配置
connection = new HubConnectionBuilder().WithUrl("http://10.0.2.2:5261/signalrtc", options =>{options.AccessTokenProvider = () => Task.FromResult(_token);}).WithAutomaticReconnect().Build();
//Android终端，收到消息后，在界面上进行追加展示
connection.On<string>("ReceiveMessage", (message) =>
{this.RunOnUiThread(() =>{showTextView.Text += message + " ";});});

在某个事件中触发StartAsync()方法，实现连接。

private async void FabOnClickAsync(object sender, EventArgs eventArgs)
{try{await connection.StartAsync();}catch (Exception ex){this.RunOnUiThread(() => {showTextView.Text = ex.Message;});}
}

这儿有个关键信息：

In the .NET Client, this access token is passed in as an HTTP “Bearer Authentication” token (Using the Authorization header with a type of Bearer). In the JavaScript client, the access token is used as a Bearer token, except in a few cases where browser APIs restrict the ability to apply headers (specifically, in Server-Sent Events and WebSockets requests). In these cases, the access token is provided as a query string value access_token.

就是在正常情况下，不管是.NET客户端还是在JavaScript端，发送的token信息，都会包到header信息中（header中，key是Authorization，value是"Bearer token的具体值"），只有特殊情况，token会追加到查询字符串中，以access_token的样式，例如：http://xxxxx?access_token=xxxxxx。

而官网上具体例子：

builder.Services.AddAuthentication(options =>
{// Identity made Cookie authentication the default.// However, we want JWT Bearer Auth to be the default.options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
}).AddJwtBearer(options =>{// Sending the access token in the query string is required when using WebSockets or ServerSentEvents// due to a limitation in Browser APIs. We restrict it to only calls to the// SignalR hub in this code.// See https://docs.microsoft.com/aspnet/core/signalr/security#access-token-logging// for more information about security considerations when using// the query string to transmit the access token.options.Events = new JwtBearerEvents{OnMessageReceived = context =>{//【就是这里】，浏览器的方式是可以通过http:xxxxx?access_token=xxx实现的，但是在//NET客户端中，一直在Header中，因此如果使用客户端连接，则下面的accessToken肯定会一直为nullvar accessToken = context.Request.Query["access_token"];// If the request is for our hub...var path = context.HttpContext.Request.Path;if (!string.IsNullOrEmpty(accessToken) &&(path.StartsWithSegments("/hubs/chat"))){// Read the token out of the query stringcontext.Token = accessToken;}return Task.CompletedTask;}};});

我们可以通过断点追踪查看，当客户端发起SignalR请求时，routevalues中没有access_token的值，如下图所示。
在这里插入图片描述
而token信息，是一直在headers中，如下图所示：
因此在SignalR服务器中，获取token的方式应该如下：

options.Events = new JwtBearerEvents
{OnMessageReceived = context =>{if (context.Request.Query.ContainsKey("access_token")){context.Token = context.Request.Query["access_token"];}else if (context.Request.Headers.TryGetValue("Authorization", out var value) && value.Count > 0){context.Token = value[0].Substring("Bearer ".Length);}return Task.CompletedTask;}
};

这样，就能够实现token值的获取了。

3.2 实现效果

在这里插入图片描述

3.2.1 推送的代码

上面的例子中，通过controller方法，进行了推送

[ApiController]
public class HubPushController : ControllerBase
{private readonly IHubContext<SignalRTCHub> _hubContext;public HubPushController(IHubContext<SignalRTCHub> hubContext){_hubContext = hubContext;}//这个是指定用户进行推送[HttpGet]public async Task SendMessageByEmail(string employeeid, string message){await _hubContext.Clients.User(employeeid).SendAsync("ReceiveMessage",message);}//这个是全部用户的推送[HttpGet]public async Task SendMessageToAll(string message)=> await _hubContext.Clients.All.SendAsync("ReceiveMessage", message);
}