AJAX在C#中處理WebSocket消息優先級排序

在C#中，處理WebSocket消息的優先級排序可以通過使用隊列（Queue）或者優先隊列（PriorityQueue）來實現。這里我們將使用一個簡單的隊列來處理WebSocket消息的優先級排序。

首先，創建一個WebSocket服務器：

using System;
using System.Collections.Generic;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;

public class WebSocketHandler
{
    private readonly List<WebSocket> _clients = new List<WebSocket>();
    private readonly Queue<Message> _messageQueue = new Queue<Message>();

    public async Task OnConnected(HttpContext context, WebSocket webSocket)
    {
        _clients.Add(webSocket);

        await ProcessMessagesAsync();
    }

    public void EnqueueMessage(Message message)
    {
        lock (_messageQueue)
        {
            _messageQueue.Enqueue(message);
        }
    }

    private async Task ProcessMessagesAsync()
    {
        while (true)
        {
            Message message;

            lock (_messageQueue)
            {
                if (_messageQueue.Count == 0)
                {
                    break;
                }

                message = _messageQueue.Dequeue();
            }

            foreach (var client in _clients)
            {
                if (client.State == WebSocketState.Open)
                {
                    await client.SendAsync(new ArraySegment<byte>(message.Data), WebSocketMessageType.Text, true, CancellationToken.None);
                }
            }
        }
    }
}

接下來，創建一個消息類：

public class Message
{
    public int Priority { get; set; }
    public byte[] Data { get; set; }
}

現在，你可以在WebSocket連接中發送消息并設置優先級：

public class HomeController : Controller
{
    private readonly WebSocketHandler _webSocketHandler;

    public HomeController(WebSocketHandler webSocketHandler)
    {
        _webSocketHandler = webSocketHandler;
    }

    [HttpPost]
    public IActionResult SendMessage(string message, int priority)
    {
        var data = Encoding.UTF8.GetBytes(message);
        _webSocketHandler.EnqueueMessage(new Message { Priority = priority, Data = data });

        return Ok();
    }
}

在這個例子中，我們創建了一個簡單的WebSocket服務器，它可以接收客戶端連接并處理消息隊列。當客戶端發送消息時，我們將消息添加到隊列中，并根據優先級進行排序。這樣，我們就可以確保高優先級的消息會在低優先級的消息之前被處理。