SignalR 从控制器 ASP.NET Core 2.1 调用特定客户端

Question

用户在浏览器中提交表单后，我需要从服务器向客户端发送即时消息。

我按照微软的步骤 here 设置了一个 signalR 连接，创建了一个 Hub 类，signalr.js 等。

问题是我只能向所有客户端调用消息，但我需要将消息调用给发起请求的特定调用者（否则每个人都会收到消息）。

这是我在 HomeController.cs 中的 POST 操作：

[HttpPost]
    [ValidateAntiForgeryToken]
    public async Task<IActionResult> Submit(string signalRconnectionId, Dictionary<string, string> inputs)
    {
        //Invoke signal to all clients sending a message to initSignal WORKS FINE
        await _signalHubContext.Clients.All.SendAsync("initSignal", "This is a message from the server!");

        //Invoke signal to specified client where signalRConnectionId = connection.id DOES NOT WORK
        await _signalHubContext.Clients.Client(signalRconnectionId).SendAsync("initSignal", "This is a message from server to this client: " + signalRconnectionId);

        return RedirectToAction("Success", inputs);
    }

我的客户端 javascript 文件：

    //Create connection and start it
const connection = new signalR.HubConnectionBuilder()
    .withUrl("/signalHub")
    .configureLogging(signalR.LogLevel.Information)
    .build();
connection.start().catch(err => console.error(err.toString()));

console.log("connectionID: " + connection.id);
$("#signalRconnectionId").attr("value", connection.id);

//Signal method invoked from server
connection.on("initSignal", (message) => {

    console.log("We got signal! and the message is: " + message);


});

我已尝试调试操作方法，并且正确传递了“0”的 connectionId（每个连接递增 1）

Answer 1

这是我在this thread 的答案的启发下提出的最终解决方案

我通过从客户端调用 Hub 类，然后从客户端调用传入 connectionId 的控制器来获取 connectionId。

集线器类：

public class SignalHub : Hub
{
    

    public string GetConnectionId()
    {
        return Context.ConnectionId;
    }
}

在启动时执行的客户端 javascript 代码：

connection.start().catch(err => console.error(err.toString())).then(function(){
connection.invoke('getConnectionId')
    .then(function (connectionId) {
        // Send the connectionId to controller
        console.log("connectionID: " + connectionId);
        $("#signalRconnectionId").attr("value", connectionId);
    });
});

HomeController.cs：

public async Task<IActionResult> Submit(string signalRconnectionId, Dictionary<string, string> inputs)
    {
        
        //Invoke signal to specified client WORKS NOW
        await _signalHubContext.Clients.Client(signalRconnectionId).SendAsync("initSignal", "This is a message from server to this client: " + signalRconnectionId);

        return RedirectToAction("Success", inputs);
    }

它工作得很好，但仍然感觉有点像往返，如果我们不必通过 hub 类来实现这一点会更容易。也许只是从客户端开始使用 connectionId，但也许设计有充分的理由:)

Answer 2

根据微软的说法，您无法从集线器外部访问 ConnectionId 和 Caller https://docs.microsoft.com/en-us/aspnet/core/signalr/hubcontext?view=aspnetcore-2.1

当从Hub 类外部调用集线器方法时，没有 与调用关联的调用者。因此，无法访问 ConnectionId、Caller 和 Others 属性。