Wie TCP/UDP Client richtig schließen?

  • C#

Es gibt 7 Antworten in diesem Thema. Der letzte Beitrag () ist von RodFromGermany.

    Wie TCP/UDP Client richtig schließen?

    Ich bin wirklich überfragt wie man ein TCP/UDP Client richtig schließt ohne eine Exception auszulösen.

    Ich habe hier einmal den Code für den TCP Client
    Spoiler anzeigen

    C#-Quellcode

    1. public class TCP {
    3. #region Variables
    4. public TcpClient socket;
    5. private NetworkStream stream;
    6. private Packet receivedData;
    7. private byte[] receiveBuffer;
    8. #endregion
    10. public void Connect()
    11. {
    12. socket = new TcpClient {
    13. ReceiveBufferSize = dataBufferSize,
    14. SendBufferSize = dataBufferSize
    15. };
    17. receiveBuffer = new byte[dataBufferSize];
    18. socket.BeginConnect(instance._iP, instance._port, ConnectCallback, socket);
    19. }
    20. public void Disconnect(bool fromError)
    21. {
    22. if (fromError) {
    23. instance.Disconnect(true); // Ruft diese Disconnect Methode auf nur vom einem anderen Ort
    24. }
    25. else {
    26. if (socket != null) {
    27. socket.Close();
    28. socket.Dispose();
    29. socket = null;
    30. }
    31. if (stream != null) {
    32. stream.Close();
    33. stream.Dispose();
    34. stream = null;
    35. }
    36. if (receivedData != null) {
    37. receivedData.Dispose();
    38. receivedData = null;
    39. }
    41. receiveBuffer = null;
    42. }
    43. }
    45. private void ConnectCallback(IAsyncResult ar)
    46. {
    47. try {
    48. socket.EndConnect(ar);
    50. if (!socket.Connected) {
    51. throw new Exception("Unknown error.");
    52. }
    54. stream = socket.GetStream();
    55. receivedData = new Packet();
    56. stream.BeginRead(receiveBuffer, 0, dataBufferSize, ReceiveCallback, null);
    57. Main.instance.Log(string.Format("Successfully connected to {0}:{1}.", instance._iP, instance._port.ToString()), false);
    58. instance.IsConnected = true;
    59. instance.Connected?.Invoke(instance, EventArgs.Empty);
    60. }
    61. catch (Exception ex) {
    62. Main.instance.Log("Could not connect to server. Details: " + ex.Message, false);
    63. instance.CouldNotConnect?.Invoke(instance, EventArgs.Empty);
    64. instance.Disconnect(false);
    65. }
    66. }
    68. public void SendData(Packet packet)
    69. {
    70. try {
    71. if (socket != null) {
    72. if (stream != null) stream.BeginWrite(packet.ToArray(), 0, packet.Length(), null, null);
    73. }
    74. }
    75. catch (Exception ex) {
    76. Main.instance.Log(string.Format("Error sending data to server via TCP. Exception: {0}", ex.Message), false);
    77. }
    78. }
    80. private void ReceiveCallback(IAsyncResult ar)
    81. {
    82. try {
    83. if (socket != null) {
    84. if (stream != null) {
    85. if (receivedData != null) {
    86. int _byteLength = stream.EndRead(ar);
    87. if (_byteLength <= 0) {
    88. instance.Disconnect(true);
    89. return;
    90. }
    92. byte[] _data = new byte[_byteLength];
    93. Array.Copy(receiveBuffer, _data, _byteLength);
    95. receivedData.Reset(HandleData(_data));
    96. stream.BeginRead(receiveBuffer, 0, dataBufferSize, ReceiveCallback, null);
    97. }
    98. }
    99. }
    100. }
    101. catch (Exception ex) {
    102. Main.instance.LogErrorToFile(ex, new List<string>() { @"Error in: Client\TCP\ReceiveCallback" });
    103. Main.instance.Log(string.Format("Error while receiving TCP data. If you manually disconnected, then ignore this error. Details: {0}", ex.Message), false); // Info
    104. Game.DisplayText("GTAIVOnline: Error while receiving TCP data. Check the console for details.", 5000); // Info
    105. instance.Disconnect(true);
    106. }
    107. }
    109. private bool HandleData(byte[] data)
    110. {
    111. int _packetLength = 0;
    113. receivedData.SetBytes(data);
    114. if (receivedData.UnreadLength() >= 4) {
    115. _packetLength = receivedData.ReadInt();
    116. if (_packetLength <= 0) {
    117. return true;
    118. }
    119. }
    121. while (_packetLength > 0 && _packetLength <= receivedData.UnreadLength()) {
    122. byte[] _packetBytes = receivedData.ReadBytes(_packetLength);
    123. ThreadManager.ExecuteOnMainThread(() =>
    124. {
    125. using (Packet packet = new Packet(_packetBytes)) {
    126. int _packetID = packet.ReadInt();
    127. packetHandlers[_packetID].Invoke(packet);
    128. }
    129. });
    131. _packetLength = 0;
    132. if (receivedData.UnreadLength() >= 4) {
    133. _packetLength = receivedData.ReadInt();
    134. if (_packetLength <= 0) {
    135. return true;
    136. }
    137. }
    138. }
    140. if (_packetLength <= 1) {
    141. return true;
    142. }
    144. return false;
    145. }
    147. }



    Und hier einmal der UDP Code
    Spoiler anzeigen

    C#-Quellcode

    1. public class UDP {
    3. #region Variables
    4. public UdpClient socket;
    5. public IPEndPoint iPEndPoint;
    6. #endregion
    8. #region Constructor
    9. public UDP()
    10. {
    11. iPEndPoint = new IPEndPoint(IPAddress.Parse(instance._iP), instance._port);
    12. }
    13. #endregion
    15. public void Connect(int localPort)
    16. {
    17. socket = new UdpClient(localPort);
    19. socket.Connect(iPEndPoint);
    20. socket.BeginReceive(ReceiveCallback, null);
    22. using (Packet packet = new Packet()) {
    23. SendData(packet);
    24. }
    25. }
    26. public void Disconnect(bool fromError)
    27. {
    28. if (fromError) {
    29. instance.Disconnect(true); // Ruft diese Disconnect Methode auf nur vom einem anderen Ort
    30. }
    31. else {
    32. iPEndPoint = null;
    33. if (socket != null) {
    34. socket.Close();
    35. socket.Dispose();
    36. socket = null;
    37. }
    38. }
    39. }
    41. public void SendData(Packet packet)
    42. {
    43. try {
    44. packet.InsertInt(instance._iD);
    45. if (socket != null) socket.BeginSend(packet.ToArray(), packet.Length(), null, null);
    46. }
    47. catch (Exception ex) {
    48. Main.instance.Log(string.Format("Error sending data to server via UDP. Exception: {0}", ex.Message), false);
    49. }
    50. }
    52. private void ReceiveCallback(IAsyncResult ar)
    53. {
    54. try {
    55. if (socket != null) {
    56. byte[] _data = socket.EndReceive(ar, ref iPEndPoint);
    57. socket.BeginReceive(ReceiveCallback, null);
    59. if (_data.Length < 4) {
    60. instance.Disconnect(true);
    61. return;
    62. }
    64. HandleData(_data);
    65. }
    66. }
    67. catch (Exception ex) {
    68. Main.instance.LogErrorToFile(ex, new List<string>() { @"Error in: Client\UDP\ReceiveCallback" });
    69. Main.instance.Log(string.Format("Error while receiving UDP data. If you manually disconnected, then you can ignore this error. Details: {0}", ex.ToString()), false); // Info
    70. Game.DisplayText("GTAIVOnline: Error while receiving UDP data. Check the console for details.", 5000); // Info
    71. Disconnect(true);
    72. }
    73. }
    75. private void HandleData(byte[] data)
    76. {
    77. using (Packet packet = new Packet(data)) {
    78. int packetLength = packet.ReadInt();
    79. data = packet.ReadBytes(packetLength);
    80. }
    82. ThreadManager.ExecuteOnMainThread(() => {
    83. using (Packet packet = new Packet(data)) {
    84. int packetID = packet.ReadInt();
    85. packetHandlers[packetID](packet);
    86. }
    87. });
    88. }
    90. }



    Nun löst der UDP Code folgende Exception aus wenn ich ihn disconnecten will
    Spoiler anzeigen

    System.ObjectDisposedException: Auf das verworfene Objekt kann nicht zugegriffen werden.
    Objektname: "System.Net.Sockets.Socket".
    bei System.Net.Sockets.Socket.EndReceiveFrom(IAsyncResult asyncResult, EndPoint& endPoint)
    bei System.Net.Sockets.UdpClient.EndReceive(IAsyncResult asyncResult, IPEndPoint& remoteEP)
    bei GTAIVOnline.Network.Client.UDP.ReceiveCallback(IAsyncResult ar)


    Und der TCP Code löst dies aus
    Spoiler anzeigen

    System.ObjectDisposedException: Auf das verworfene Objekt kann nicht zugegriffen werden.
    Objektname: "System.Net.Sockets.NetworkStream".
    bei System.Net.Sockets.NetworkStream.EndRead(IAsyncResult asyncResult)
    bei GTAIVOnline.Network.Client.TCP.ReceiveCallback(IAsyncResult ar)


    Beide Exceptions sind eigentlich selbsterklärend. Das Objekt ist Disposed es wird aber versucht auf dieses zuzugreifen.
    Aber ich weiß trotzdem nicht wie man sie richtig disconnected. Muss ich TCP Socket/Stream in einer bestimment Reihenfolge schließen?

    Meine Frage ist jetzt wie man nun TCP/UDP Client richtig disconnecten/schließen kann?
    Ich möchte keine Exception beim schließen erhalten, das kommt mir so nach einem dirty weg rüber die Clients zu schließen.
    Wenn ich dir auf irgendeiner Art und Weise helfen konnte, drück doch bitte den "Hilfreich" Button :thumbup:

    Für VB.NET Entwickler: Option Strict On nicht vergessen!

    @ClonkAndre Bei welchen Code-Zeilen kommen die Exceptions?
    Fakt ist, dass Dein Programm auf die Objekte zugreifen will, obwohl sie bereits zerstört sind.
    Setze die Variablen nach dem Disposen auf null und teste beim Zugriff, ob sie verschieden von null sind.
    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!

    Die TCP Exception kommt von Zeile 86 das wäre diese Zeile

    ClonkAndre schrieb:

    int _byteLength = stream.EndRead(ar);


    Und die UDP Exception kommt von Zeile 56 das wäre diese Zeile

    ClonkAndre schrieb:

    byte[] _data = socket.EndReceive(ar, ref iPEndPoint);


    RodFromGermany schrieb:

    Setze die Variablen nach dem Disposen auf null

    Das macht die Disconnect Methode ja bereits. Sie setzt die Variablen nach dem Disposen auf null.
    Wenn ich dir auf irgendeiner Art und Weise helfen konnte, drück doch bitte den "Hilfreich" Button :thumbup:

    Für VB.NET Entwickler: Option Strict On nicht vergessen!

    ClonkAndre schrieb:

    Das macht die Disconnect Methode ja bereits.
    Das sieht mir so aus, als ob da ein anderer Thread das Objekt zerstört.
    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!

    Hmm.. Sonst greift nichts anderes auf die Disconnect Methode zu außer die instance.Disconnect(true); Methode (Welche einfach nur dazu da ist um die Disconnect Methoden von der TCP und UDP Klasse aufzurufen)

    Die instance.Disconnect Methode:

    C#-Quellcode

    1. public void Disconnect(bool triggerDisconnectEvent, bool fromError = false)
    2. {
    3. if (IsConnected) {
    4. tcp.Disconnect(fromError);
    5. udp.Disconnect(fromError);
    6. tcp = null;
    7. udp = null;
    9. Main.instance.serverInformations = null;
    10. isNetworkReady = false;
    11. isTCPReady = false;
    12. isUDPReady = false;
    14. if (triggerDisconnectEvent) {
    15. Main.instance.Log("Disconnected from the server.", false);
    16. Disconnected?.Invoke(this, EventArgs.Empty);
    17. }
    18. IsConnected = false;
    19. }
    20. }


    Wenn ich dir auf irgendeiner Art und Weise helfen konnte, drück doch bitte den "Hilfreich" Button :thumbup:

    Für VB.NET Entwickler: Option Strict On nicht vergessen!

    Meinst Du damit diese Zeile?

    ClonkAndre schrieb:

    Disconnected?.Invoke(this, EventArgs.Empty);


    Das ist einfach nur ein Event das invoked wird wenn man disconnected.
    Ich abonniere es in einer anderen Klasse und setzte einfach eine Variable zu false, welche aber noch nicht verwendet wird.
    Wenn ich dir auf irgendeiner Art und Weise helfen konnte, drück doch bitte den "Hilfreich" Button :thumbup:

    Für VB.NET Entwickler: Option Strict On nicht vergessen!

    @ClonkAndre OK.
    Wenn Du das Event so deklarierst:

    C#-Quellcode

    1. private event EventHandler<EventArgs> Disconnected = delegate { };
    musst Du keinen null-Test durchführen.
    Falls Du diesen Code kopierst, achte auf die C&P-Bremse.
    Jede einzelne Zeile Deines Programms, die Du nicht explizit getestet hast, ist falsch :!:
    Ein guter .NET-Snippetkonverter (der ist verfügbar).
    Programmierfragen über PN / Konversation werden ignoriert!