是否有具有"return value to server"功能的 SignalR 替代方案？

Question

我的目标：将数据传递给连接到服务器的特定客户端，并在不调用server方法的情况下获得结果。

我试着用SignalR来做这件事(因为这对我来说是一个非常简单的工具(，但我无法得到结果(现在我知道为什么了(。我正在开发ASP.NET Core 3.1。

我的问题：是否有SignalR替代方案具有"向服务器返回值"功能(在目标客户端上使用params调用方法并获取结果(？

Answer 1

SignalR通常用于有多个客户端和客户端连接到的单个服务器的设置中。这使得客户端调用服务器并期望返回结果成为一件正常的事情。由于服务器通常并不真正关心单个客户端连接了什么，并且由于服务器通常向一组客户端广播(例如使用组(，因此通信方向主要用于通知或广播。单目标消息是可能的，但没有用于请求/响应模式的内置机制。

为了使用SignalR，需要有一种方法让客户端回调服务器。因此，您将需要一个集线器操作来将响应发送到。

这本身并不困难，但可能需要将客户端调用与集线器接收的传入结果消息链接起来。为此，你必须建造一些东西。

下面是一个示例实现，让您开始学习。MyRequestClient是一个单例服务，它基本上封装了消息传递，并为您提供了一个异步方法，该方法将调用客户端，并且只有在客户端通过调用集线器上的回调方法做出响应时才能完成：

public class MyRequestClient
{
private readonly IHubContext<MyHub> _hubContext;
private ConcurrentDictionary<Guid, object> _pendingTasks = new ConcurrentDictionary<Guid, object>();
public MyRequestClient(IHubContext<MyHub> hubContext)
{
_hubContext = hubContext;
}
public async Task<int> Square(string connectionId, int number)
{
var requestId = Guid.NewGuid();
var source = new TaskCompletionSource<int>();
_pendingTasks[requestId] = source;
await _hubContext.Clients.Client(connectionId).SendAsync("Square", nameof(MyHub.SquareCallback), requestId, number);
return await source.Task;
}
public void SquareCallback(Guid requestId, int result)
{
if (_pendingTasks.TryRemove(requestId, out var obj) && obj is TaskCompletionSource<int> source)
source.SetResult(result);
}
}

在集线器中，您需要回调操作来调用请求客户端来完成任务：

public class MyHub : Hub
{
private readonly ILogger<MyHub> _logger;
private readonly MyRequestClient _requestClient;
public MyHub(ILogger<MyHub> logger, MyRequestClient requestClient)
{
_logger = logger;
_requestClient = requestClient;
}
public Task SquareCallback(Guid requestId, int number)
{
_requestClient.SquareCallback(requestId, number);
return Task.CompletedTask;
}

// just for demo purposes
public Task Start()
{
var connectionId = Context.ConnectionId;
_ = Task.Run(async () =>
{
var number = 42;
_logger.LogInformation("Starting Square: {Number}", number);
var result = await _requestClient.Square(connectionId, number);
_logger.LogInformation("Square returned: {Result}", result);
});
return Task.CompletedTask;
}
}

Start集线器操作仅用于演示目的，以便使用有效的连接id启动此操作。

在客户端上，您需要实现客户端方法，并在完成后让它调用指定的回调方法：

connection.on('Square', (callbackMethod, requestId, number) => {
const result = number * number;
connection.invoke(callbackMethod, requestId, result);
});

最后，您可以通过客户端调用Start操作来尝试这一点：

connection.invoke('Start');

当然，这个实现是非常基本的，需要一些东西，比如正确的错误处理，以及在客户端没有正确响应的情况下对任务超时的支持。也可以将其扩展为支持任意调用，而无需手动创建所有这些方法(例如，在集线器上有一个能够完成任何任务的回调方法(。