Websocket Server crash beim BeginAccept

  • C#
  • .NET (FX) 4.0

Es gibt 3 Antworten in diesem Thema. Der letzte Beitrag () ist von Goldwing Studios.

    Websocket Server crash beim BeginAccept

    Hallo,
    ich habe hier ein Websocket-Script welches ich mir aus ein paar Foren ein bisschen zusammen gewurschtelt habe und habe jetzt allerdings ein Problem, das Programm beendet sich einfach Sang- und Klanglos in der Zeile 99.
    Sonst klappt alles perfekt, Daten werden vom Client und zurück gesendet.

    Weiß zufällig jemand warum das Programm abbricht?

    C#-Quellcode

    1. using System;
    2. using System.Collections.Generic;
    3. using System.Linq;
    4. using System.Net;
    5. using System.Net.Sockets;
    6. using System.Security.Cryptography;
    7. using System.Text;
    8. using System.Threading;
    9. using System.Threading.Tasks;
    11. namespace WebSockets_Test
    12. {
    13. class Program
    14. {
    15. static Socket serverSocket = new Socket(AddressFamily.InterNetwork,
    16. SocketType.Stream, ProtocolType.IP);
    17. static private string guid = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
    19. static void Main(string[] args)
    20. {
    21. serverSocket.Bind(new IPEndPoint(IPAddress.Any, 8080));
    22. serverSocket.Listen(128);
    23. serverSocket.BeginAccept(null, 0, OnAccept, null);
    24. Console.Read();
    25. }
    27. private static void OnAccept(IAsyncResult result)
    28. {
    29. byte[] buffer = new byte[1024];
    30. try
    31. {
    32. Socket client = null;
    33. string headerResponse = "";
    34. if (serverSocket != null && serverSocket.IsBound)
    35. {
    36. client = serverSocket.EndAccept(result);
    37. var i = client.Receive(buffer);
    38. headerResponse = (System.Text.Encoding.UTF8.GetString(buffer)).Substring(0, i);
    39. // write received data to the console
    40. Console.WriteLine(headerResponse);
    42. }
    43. if (client != null)
    44. {
    45. /* Handshaking and managing ClientSocket */
    47. var key = headerResponse.Replace("ey:", "`")
    48. .Split('`')[1] // dGhlIHNhbXBsZSBub25jZQ== \r\n .......
    49. .Replace("\r", "").Split('\n')[0] // dGhlIHNhbXBsZSBub25jZQ==
    50. .Trim();
    52. // key should now equal dGhlIHNhbXBsZSBub25jZQ==
    53. var test1 = AcceptKey(ref key);
    55. var newLine = "\r\n";
    57. var response = "HTTP/1.1 101 Switching Protocols" + newLine
    58. + "Upgrade: websocket" + newLine
    59. + "Connection: Upgrade" + newLine
    60. + "Sec-WebSocket-Accept: " + test1 + newLine + newLine
    61. //+ "Sec-WebSocket-Protocol: chat, superchat" + newLine
    62. //+ "Sec-WebSocket-Version: 13" + newLine
    63. ;
    65. // which one should I use? none of them fires the onopen method
    66. client.Send(System.Text.Encoding.UTF8.GetBytes(response));
    68. var i = client.Receive(buffer); // wait for client to send a message
    70. // once the message is received decode it in different formats
    71. Console.WriteLine(Convert.ToBase64String(buffer).Substring(0, i));
    73. try
    74. {
    75. if (serverSocket != null && serverSocket.IsBound)
    76. {
    77. var Respone = EncodeMessageToSend("Test");
    78. client.Send(Respone);
    79. }
    80. }
    81. catch (Exception ex)
    82. {
    83. Console.Write(ex);
    84. }
    85. Thread.Sleep(5000);//wait for message to be send
    87. }
    88. }
    89. catch (SocketException exception)
    90. {
    91. throw exception;
    92. }
    93. finally
    94. {
    95. if (serverSocket != null && serverSocket.IsBound)
    96. {
    97. try
    98. {
    99. serverSocket.BeginAccept(null, 0, OnAccept, null);
    100. }
    101. catch (SocketException exception)
    102. {
    103. throw exception;
    104. }
    105. }
    106. }
    107. }
    109. private static Byte[] EncodeMessageToSend(String message)
    110. {
    111. Byte[] response;
    112. Byte[] bytesRaw = Encoding.UTF8.GetBytes(message);
    113. Byte[] frame = new Byte[10];
    115. Int32 indexStartRawData = -1;
    116. Int32 length = bytesRaw.Length;
    118. frame[0] = (Byte)129;
    119. if (length <= 125)
    120. {
    121. frame[1] = (Byte)length;
    122. indexStartRawData = 2;
    123. }
    124. else if (length >= 126 && length <= 65535)
    125. {
    126. frame[1] = (Byte)126;
    127. frame[2] = (Byte)((length >> 8) & 255);
    128. frame[3] = (Byte)(length & 255);
    129. indexStartRawData = 4;
    130. }
    131. else
    132. {
    133. frame[1] = (Byte)127;
    134. frame[2] = (Byte)((length >> 56) & 255);
    135. frame[3] = (Byte)((length >> 48) & 255);
    136. frame[4] = (Byte)((length >> 40) & 255);
    137. frame[5] = (Byte)((length >> 32) & 255);
    138. frame[6] = (Byte)((length >> 24) & 255);
    139. frame[7] = (Byte)((length >> 16) & 255);
    140. frame[8] = (Byte)((length >> 8) & 255);
    141. frame[9] = (Byte)(length & 255);
    143. indexStartRawData = 10;
    144. }
    146. response = new Byte[indexStartRawData + length];
    148. Int32 i, reponseIdx = 0;
    150. //Add the frame bytes to the reponse
    151. for (i = 0; i < indexStartRawData; i++)
    152. {
    153. response[reponseIdx] = frame[i];
    154. reponseIdx++;
    155. }
    157. //Add the data bytes to the response
    158. for (i = 0; i < length; i++)
    159. {
    160. response[reponseIdx] = bytesRaw[i];
    161. reponseIdx++;
    162. }
    164. return response;
    165. }
    167. private static string AcceptKey(ref string key)
    168. {
    169. string longKey = key + guid;
    170. byte[] hashBytes = ComputeHash(longKey);
    171. return Convert.ToBase64String(hashBytes);
    172. }
    174. static SHA1 sha1 = SHA1CryptoServiceProvider.Create();
    175. private static byte[] ComputeHash(string str)
    176. {
    177. return sha1.ComputeHash(System.Text.Encoding.ASCII.GetBytes(str));
    178. }
    179. }
    180. }​

    Es lag daran, dass ich immer so doof war und während des Window-Focus irgendwelche Tasten zu drücken um halt das Console.Read() zu feuern und deshalb ist er immer so still und heimlich abgerauscht.

    Hab mir jetzt aber angewöhnt, das zu unterlassen bzw. habe mir jetzt eh einen Message-Loop eingefuddelt und das läuft nun besser:

    C#-Quellcode

    1. ​while ((i = client.Receive(buffer)) > 6)
    2. {
    3. var cmd = DecodeMessage(buffer).Substring(0, i);
    4. var Respone = EncodeMessageToSend(exec_command(cmd));
    5. if (serverSocket != null && serverSocket.IsBound)
    6. {
    7. client.Send(Respone);
    8. }
    9. }


    Ich kann damit nun Befehle vom Client empfangen und Antworten zurücksenden, das klappt auch herz-allerliebst!