WebSocketConnectionManager.cs

 public class WebSocketConnectionManager
    {
        private ConcurrentDictionary<string, WebSocket> _socketConnection= new ConcurrentDictionary<string, WebSocket>();
       
        public void AddSocket(WebSocket socket)
        {
            string socketId = CreateConnectionId();
            while (!_socketConnection.TryAdd(socketId, socket))
            {
                socketId = CreateConnectionId();
            }
      }

        public async Task RemoveSocket(string id)
        {
            try
            {
                WebSocket socket;

                _socketConnection.TryRemove(id, out socket);


                await socket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, null, CancellationToken.None);


            }
            catch (Exception)
            {

            }

        }
        public WebSocket GetSocketById(string id)
        {
            return _socketConnection.FirstOrDefault(m => m.Key == id).Value;
        }

        public ConcurrentDictionary<string, WebSocket> GetAll()
        {
            return _socketConnection;
        }

        public string GetSocketId(WebSocket socket)
        {
            return _socketConnection.FirstOrDefault(m => m.Value == socket).Key;
        }
        private string CreateConnectionId()
        {
            return Guid.NewGuid().ToString();
        }
    }