WebSocket 异步发送和接收数据使用 NuGet websocket-client

问题描述

我正在努力使用 NuGet 包 websocket-client (https://github.com/Marfusios/websocket-client) 的观察者模式

与 WebSocket 服务器的连接稳定且正在运行。

每个请求在负载中都有一个请求 ID。客户端将其发送给服务器，服务器以 ID 和真实数据作为响应。

在客户端，我需要将每个响应分配给相应的请求。

我以为我可以这样做：

public Task<Data> GetDataAsync()
{
    var webSocket = new WebsocketClient(Uri);
    await webSocket.Start();

    var requestId = Guid.NewGuid();

    var tcs = new taskcompletionsource<Data>();

    var disposable = webSocket
    .MessageReceived
    .Where(message => message.Text.Contains(requestId))
    .Subscribe(message=>
    {
        var data = ParseData(message.Text);
        tcs.SetResult(data);
    });

    return tcs.Task;
}

但它实际上从未跳入订阅方法。我用错了吗？

解决方法

我觉得

public Task<Data> GetDataAsync(string request)
{
    var requestId = Guid.NewGuid().ToString();

    var responseTask = WebSocket
    .MessageReceived
    .Timeout(TimeSpan.FromSeconds(5))
    .FirstOrDefaultAsync(message => message.Text.Contains(requestId));

    WebSocket.Send(request);

    var responseMessage = await responseTask;

    return ParseMessage(responseMessage);
}

是要走的路。我什至更喜欢 SingleOrDefaultAsync 而不是 FirstOrDefaultAsync 因为只有一条消息具有该请求 ID。但这不起作用。它总是在超时时间内运行。

,

你让你的代码比我需要的要复杂得多。 Rx 让我们等待一个 observable 来获取最后产生的值。你可以这样写你的代码：

aria-label