Azure Serverless SignalR环境下如何通过HubConnection.SendAsync发送消息？

核心结论 #

在Azure Serverless SignalR模式下，客户端无法直接通过HubConnection.SendAsync/InvokeAsync发送消息给其他客户端，这是由Serverless模式的架构设计决定的。

问题根源 #

Azure Serverless SignalR与传统SignalR的核心差异在于：

• 传统SignalR中，客户端通过HubConnection.SendAsync调用后端Hub的方法，后端Hub处理后再转发消息给其他客户端；
• 而Serverless模式下，Azure SignalR服务仅作为消息路由枢纽，不存在后端Hub实例来处理客户端的方法调用请求。

你捕获到的两种请求路径差异正体现了这一点：

• 客户端SendAsync发送的/client/?hub=testhub&id=xxx请求，是SignalR客户端向后端Hub发起的方法调用请求，但Serverless模式下没有对应的Hub端点处理该请求，因此Azure SignalR服务会直接丢弃消息，导致订阅端无法收到消息。
• 服务端HubContext使用的/api/testhub/:send请求，是Azure SignalR提供的管理API，仅允许服务端（如Azure Function）通过该接口推送消息，与客户端的消息通道完全独立。

官方推荐方案的原因 #

ServiceManager/HubContext是Azure Serverless SignalR专门设计的服务端消息推送方式，它直接使用Azure SignalR连接字符串调用管理API，无需依赖协商端点，符合Serverless模式「服务端推送、客户端接收」的架构逻辑。

客户端发起消息的可行流程 #

如果需要客户端触发消息发送，必须通过服务端中间层（如Azure Function）中转，流程如下：

1. 客户端调用一个Http Trigger类型的Azure Function，传递消息内容；
2. 在该Function内部，通过ServiceManager创建HubContext，调用hubContext.Clients.All.SendAsync(...)推送消息；
3. 其他客户端通过HubConnection.On订阅对应方法接收消息。

代码示例 #

客户端调用Function

using var httpClient = new HttpClient();
var messageContent = new StringContent(JsonSerializer.Serialize(new { Message = "some text" }), Encoding.UTF8, "application/json");
await httpClient.PostAsync("https://myfunctionapp.com/api/SendMessage", messageContent);

Azure Function实现

using Microsoft.Azure.SignalR.Management;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using System.IO;
using System.Text.Json;

[FunctionName("SendMessage")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req,
    ILogger log)
{
    var requestBody = await new StreamReader(req.Body).ReadToEndAsync();
    var data = JsonSerializer.Deserialize<dynamic>(requestBody);
    string message = data?.Message;

    var serviceManager = new ServiceManagerBuilder()
        .WithConnectionString(Environment.GetEnvironmentVariable("AzureSignalRConnectionString"))
        .BuildServiceManager();
    
    using var hubContext = await serviceManager.CreateHubContextAsync("testhub", CancellationToken.None);
    await hubContext.Clients.All.SendAsync("HubMethodName", message);

    return new OkResult();
}

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