无视图ASP.NET Core Web API控制器调用SignalR Hub的方法咨询

你不需要把Hub的收发逻辑完全迁移到控制器，只需要通过注入IHubContext<ChatHub>的方式，就能在控制器中实现所有业务处理、主动消息推送的需求，Hub仅做连接管理即可，全程不需要任何视图和JS文件。

1. 服务端基础配置 #

首先保留ChatHub，仅做基础连接管理，不需要实现业务方法：

public class ChatHub : Hub
{
    // 不需要客户端直接调用Hub方法的话可以完全留空
    // 仅用于SignalR内部的连接生命周期管理
}

在Program.cs中注册相关服务并配置路由：

var builder = WebApplication.CreateBuilder(args);
// 注册SignalR服务
builder.Services.AddSignalR();
// 保留原有Web API控制器注册
builder.Services.AddControllers();

var app = builder.Build();
// 保留原有鉴权等中间件配置
app.UseAuthorization();
// 映射Hub路由，客户端连接地址为 /chathub
app.MapHub<ChatHub>("/chathub");
app.MapControllers();

app.Run();

2. 控制器中实现业务逻辑与消息推送 #

直接在控制器中注入IHubContext<ChatHub>即可调用所有SignalR的消息推送能力，所有业务逻辑都可以写在控制器中：

[ApiController]
[Route("api/[controller]")]
public class ChatController : ControllerBase
{
    private readonly IHubContext<ChatHub> _hubContext;
    // 构造函数注入Hub上下文
    public ChatController(IHubContext<ChatHub> hubContext)
    {
        _hubContext = hubContext;
    }

    // 提供HTTP接口给客户端1调用发送消息
    [HttpPost("send")]
    public async Task<IActionResult> SendMessage(string fromUserId, string toUserId, string message)
    {
        // 此处写你的业务处理逻辑：比如消息校验、持久化、权限判断、内容加工等
        // ...

        // 处理完成后推送消息给指定客户端2
        await _hubContext.Clients.Group(toUserId).SendAsync("ReceiveMessage", fromUserId, message);
        // 也支持其他推送范围：
        // - 推给所有在线客户端：_hubContext.Clients.All.SendAsync(...)
        // - 推给指定分组：_hubContext.Clients.Group("自定义分组名").SendAsync(...)

        return Ok("消息处理完成并推送");
    }
}

3. 客户端适配与精准推送实现 #

如果需要实现按用户精准推送，只需要在Hub中补充连接绑定逻辑，WPF客户端连接时带上用户ID即可：

public class ChatHub : Hub
{
    public override async Task OnConnectedAsync()
    {
        // WPF客户端建立连接时在query参数中携带当前登录用户ID
        var userId = Context.GetHttpContext()?.Request.Query["userId"].ToString();
        if (!string.IsNullOrEmpty(userId))
        {
            // 将当前连接加入对应用户的分组，后续即可通过用户ID直接推送
            await Groups.AddToGroupAsync(Context.ConnectionId, userId);
        }
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception? exception)
    {
        var userId = Context.GetHttpContext()?.Request.Query["userId"].ToString();
        if (!string.IsNullOrEmpty(userId))
        {
            await Groups.RemoveFromGroupAsync(Context.ConnectionId, userId);
        }
        await base.OnDisconnectedAsync(exception);
    }
}

WPF客户端原有监听ReceiveMessage事件的逻辑完全不需要修改，发消息时不再调用Hub方法，改为请求/api/chat/send接口即可。

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