接受 websocket 使用 tcp .net 很慢？

Question

我使用 websocket 服务器创建了一个 .NET 类套接字。当我的浏览器尝试连接到我的程序上的套接字时，我看到在我的浏览器连接后调用方法“接受套接字”的速度非常慢或几秒钟。我尝试创建许多连接，但套接字每秒接受一个 websocket。我也试过alchemy websocket，结果和我的代码一样。

我在IIS8上使用过Miscrosoft websocket后，发现速度还不错。

我不是实验性的。

我的代码（快递）

class Connection
{
    byte[] buffer = new byte[1024];
    Socket socket;
    bool IsAuthencation;
    public Connection(Socket socket)
    {
        this.socket = socket;
        socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(OnReceive), null);
    }

    void OnReceive(IAsyncResult result)
    {
        try
        {
            int count = socket.EndReceive(result);
            if (count != 0)
            {
                if (!IsAuthencation)
                {
                    byte[] tmp = new byte[count];
                    Array.Copy(buffer, 0, tmp, 0, count);
                    string Request = Encoding.UTF8.GetString(tmp);
                    if (Request.Contains("GET"))
                    {
                        if (!IsAuthencation)
                        {
                            int indexStart = Request.IndexOf("Sec-WebSocket-Key: ");
                            int indexEnd = Request.IndexOf("Sec-WebSocket-Version:");
                            string key = Request.Substring(indexStart + 19, indexEnd - indexStart - 21);
                            string magic = string.Concat(key, "258EAFA5-E914-47DA-95CA-C5AB0DC85B11");
                            string base64 = "";
                            using (SHA1 sha1 = SHA1.Create())
                            {
                                byte[] bufferMagic = sha1.ComputeHash(Encoding.UTF8.GetBytes(magic));
                                base64 = Convert.ToBase64String(bufferMagic);
                            }

                            Byte[] response = Encoding.UTF8.GetBytes("HTTP/1.1 101 Switching Protocols" + Environment.NewLine
                                + "Connection: Upgrade" + Environment.NewLine
                                + "Upgrade: websocket" + Environment.NewLine
                                + "Sec-WebSocket-Accept: " + base64
                                + Environment.NewLine
                                + Environment.NewLine);
                            socket.BeginSend(response, 0, response.Length, SocketFlags.None, new AsyncCallback(OnSend), null);
                            IsAuthencation = true;
                        }
                    }
                }
                socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(OnReceive), null);
            }
            else
            {
                // disconnect
            }
        }
        catch (Exception)
        {

        }
    }

    void OnSend(IAsyncResult result)
    {
        try
        {
            socket.EndSend(result);
        }
        catch (Exception)
        {

        }
    }

}
class Program
{
    static List<Connection> clients;
    static Socket socket;

    static void Main(string[] args)
    {
        clients = new List<Connection>();
        socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 30000);
        socket.Bind(endPoint);
        socket.Listen(0);
        socket.BeginAccept(new AsyncCallback(AcceptAsync), null);
        Console.ReadLine();
    }

    static void AcceptAsync(IAsyncResult result)
    {
        Console.WriteLine("a new connection");
        Socket s = socket.EndAccept(result);
        clients.Add(new Connection(s));
        socket.BeginAccept(new AsyncCallback(AcceptAsync), null);
    }


}

您可以尝试命令 javascript var socket= new WebSocket("ws://localhost:30000")，我的代码中没有发现问题。 谢谢

Answer 1

您必须接受套接字，并异步处理它，然后立即返回接受更多套接字。

更新

查看您的代码后，您似乎正在异步接受连接。你是如何创建这些测试连接的？如果您创建的太多，您可能会使应用饱和。

我想我看到了问题所在，你为什么将 socket backlog 设置为 0？从 SO 中读取this answer。

尝试设置更大的值：socket.Listen(100);