在OnOpenAsync方法中调用GetOrAddAsync_在TaskService中调用方法？_c 中调用js方法调用方法调用 - 腾讯云开发者社区

在OnOpenAsync方法中调用GetOrAddAsync

OnOpenAsync 方法通常是在 WebSocket 连接打开时调用的异步方法。GetOrAddAsync 是 ConcurrentDictionary 类中的一个异步方法，用于获取与指定键关联的值，如果该键不存在，则添加一个新值。

基础概念

WebSocket：WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议。它允许服务器主动向客户端推送数据。
ConcurrentDictionary：这是一个线程安全的字典类，适用于多线程环境。
GetOrAddAsync：这个方法用于异步地获取或添加字典中的项。

类型

键值对存储：ConcurrentDictionary 是一种键值对存储结构。
异步方法：GetOrAddAsync 是一种异步方法，返回 Task<TValue>。

应用场景

在 WebSocket 连接打开时，可能需要初始化一些资源或数据结构。使用 GetOrAddAsync 可以确保这些资源或数据结构只被初始化一次，即使在多线程环境下也是如此。

示例代码

public class WebSocketHandler
{
    private ConcurrentDictionary<string, WebSocket> _connections = new ConcurrentDictionary<string, WebSocket>();

    public async Task OnOpenAsync(WebSocketContext context)
    {
        string connectionId = Guid.NewGuid().ToString();
        WebSocket webSocket = context.WebSocket;

        // 获取或添加连接
        var added = await _connections.GetOrAddAsync(connectionId, _ => webSocket);

        if (added == webSocket)
        {
            // 连接成功
            Console.WriteLine($"New connection: {connectionId}");
        }
        else
        {
            // 连接已存在
            Console.WriteLine($"Connection already exists: {connectionId}");
        }
    }

    public async Task OnCloseAsync(string connectionId)
    {
        if (_connections.TryRemove(connectionId, out var webSocket))
        {
            await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Connection closed", CancellationToken.None);
            Console.WriteLine($"Connection closed: {connectionId}");
        }
    }
}