TCP/IP - Probleme mit ListenThread

  • VB.NET

Es gibt 22 Antworten in diesem Thema. Der letzte Beitrag () ist von luckay.

    TCP/IP - Probleme mit ListenThread

    Hallo,

    ich erstelle momentan ein Programm, mit dem ich Telegramme (in Bytes) an einen Clienten versende, der mir automatisch 2 Telegramme zurück sendet.
    Das Programm beinhaltet einen ListenThread, der solange eine Verbindung besteht, Telegramme empfangängt und diese in einem "Monitor" ausgibt.
    Ich hatte die ganze Zeit Probleme damit, nach dem disconnecten zum Clienten wieder zu reconnecten. Die Lösung zu diesem Problem habe ich hier im Forum gefunden, jedoch macht der ListenThread nun Probleme.
    Ich muss diesen bevor ich bevor ich die Verbindung trenne "aborten", weil ansonsten der Thread hängen bleibt nachdem ich den Stream und Clienten beende und folgende Fehlermeldung im ListenThread erhalte:
    Fehlermeldung 1:
    Eine Ausnahme (erste Chance) des Typs "System.IO.IOException" ist in System.dll aufgetreten.

    Wenn ich nun reconnecten will, nachdem der Thread abgebrochen wurde, kommt folgende Fehlermeldung im Privat Sub "Connect":
    Fehlermeldung 2:
    Ausnahme:Ausgelöst: "Der Thread wird ausgeführt oder wurde abgebrochen. Neustart nicht möglich." (System.Threading.ThreadStateException)
    System.Threading.ThreadStateException wurde ausgelöst: "Der Thread wird ausgeführt oder wurde abgebrochen. Neustart nicht möglich."

    Wie kann ich das nun mit dem Thread regeln, das dieser nach einem reconnect wieder läuft?

    Hier die "Codeschnipsel":
    Initialisierungen nach Public Class:

    VB.NET-Quellcode

    1. Dim Client As New Net.Sockets.TcpClient
    2. Dim Stream As NetworkStream = Nothing
    4. Private ListenTCPIPThread As New Thread(AddressOf ListenTCPIP)
    5. Private ReceiveBytesTCPIP(Client.ReceiveBufferSize) As Byte
    6. Private bListenTCPIP As Boolean
    7. Private bNewTCPIP As Boolean


    ListenThread:

    VB.NET-Quellcode

    1. Public Delegate Function refreshMonitorDel(ByVal lstnng As String)
    3. Public Function refreshMonitor(ByVal lstnng As String)
    4. Try
    5. Me.txtAnzeige.AppendText(DateTime.Now & " : " & "Recieved: " + lstnng + vbCrLf)
    6. Catch ex As Exception
    7. txtAnzeige.AppendText(DateTime.Now & " : " & "Failure." + vbCrLf)
    8. End Try
    9. Return Nothing
    10. End Function
    12. Sub ListenTCPIP()
    13. While bListenTCPIP
    14. Dim thrdAnswer As Integer
    15. Dim lLoop As Short = 0
    17. While lLoop < 2
    18. Dim strTmp As String = ""
    19. thrdAnswer = Stream.Read(ReceiveBytesTCPIP, 0, Client.ReceiveBufferSize) 'FEHLERMELDUNG 1
    20. For i = 0 To ReceiveBytesTCPIP(1) - 1
    21. strTmp += "." + ReceiveBytesTCPIP(i).ToString("X2")
    22. Next
    23. If Me.txtAnzeige.InvokeRequired Then
    24. Me.Invoke(New refreshMonitorDel(AddressOf refreshMonitor), New Object() {strTmp})
    25. Else
    26. Me.txtAnzeige.AppendText(DateTime.Now & " : " & "Recieved: " + strTmp + vbCrLf)
    27. End If
    28. lLoop += 1
    29. End While
    31. End While
    32. End Sub


    Connect:

    VB.NET-Quellcode

    1. Dim Client As New Net.Sockets.TcpClient
    2. txtAnzeige.AppendText(DateTime.Now & " : " & "Attempting To Connect..." + vbCrLf)
    4. Try
    5. Client.Connect("172.24.55.186", 10000)
    6. Catch ex As SystemException
    7. bListenTCPIP = False
    8. Stream.Close()
    9. Client.Close()
    10. txtAnzeige.AppendText(DateTime.Now & " : " & "Connection Fails" + vbCrLf)
    11. Exit Sub
    12. End Try
    14. If Client.Connected Then
    15. Stream = Client.GetStream()
    16. bListenTCPIP = True
    17. ListenTCPIPThread.Start() 'FEHLERMELDUNG 2
    18. txtAnzeige.AppendText(DateTime.Now & " : " & "Connected" + vbCrLf)
    19. End If
    20. End Sub


    Disconnect

    VB.NET-Quellcode

    1. bListenTCPIP = False
    3. Try
    4. ListenTCPIPThread.Abort()
    5. Catch ex As SystemException
    6. End Try
    8. Try
    9. Stream.Close()
    10. Catch ex As SystemException
    11. txtAnzeige.AppendText(DateTime.Now & " : " & "Closing stream failed." + vbCrLf)
    12. Exit Sub
    13. End Try
    14. txtAnzeige.AppendText(DateTime.Now & " : " & "Stream closed." + vbCrLf)
    16. Try
    17. Client.Close()
    18. Catch ex As SystemException
    19. txtAnzeige.AppendText(DateTime.Now & " : " & "Disconnecting failed." + vbCrLf)
    20. Exit Sub
    21. End Try
    22. txtAnzeige.AppendText(DateTime.Now & " : " & "Connection closed." + vbCrLf)
    23. End Sub



    Sollte ich etwas unverständlich ausgedrückt haben oder Details die benötigt werden fehlen, einfach bescheid geben.
    Danke euch schonmal für die Hilfe!

    Gruß,
    luckay

    @singu:
    Die Fehlermeldung eins ist mit einem Kommentar im Code von "Connect" markiert, du musst nur etwas zur Seite scrollen.

    @jvbsl:
    Ich habs jetzt im Privat Sub Connect eingefügt

    VB.NET-Quellcode

    1. Dim Client As New Net.Sockets.TcpClient
    2. ListenTCPIPThread = New Thread(AddressOf ListenTCPIP)

    und er startet den Thread. Jedoch macht mir der ListenThread dann Ärger, genau an der Stelle an welcher auch die Fehlermeldung 1 auftaucht (Stream.Reader)
    Ausnahme:Ausgelöst: "Der Objektverweis wurde nicht auf eine Objektinstanz festgelegt." (System.NullReferenceException)
    System.NullReferenceException wurde ausgelöst: "Der Objektverweis wurde nicht auf eine Objektinstanz festgelegt."

    Zur Ausnahme finde ich jedoch keine Erläuterung in der MSDN Library ... liegt bestimmt daran das der reader nicht sofort etwas empfängt, aber das tut er beim ersten connect auch nicht. Kann mir jemand weiterhelfen?

    jvbsl schrieb:

    dann setz mal nen Haltepunkt und gucke, welches Objekt Nothing ist...

    Ist vermutlich eh der Stream, der ja beim Abort geschlossen wurde.

    Würde das Ganze etwas besser strukturieren und den Connect und das Listen in den gleichen Thread packen. Ausserdem prüft man bitte nicht immer nur auf Exception, sondern gezielt auf die Exception die man abfangen will.

    Edit: war falsch^^

    ich sehe gerade, dass das Client und Server getrennt waren...

    also musst du diesen Listenthread schließen und erst den nächsten neuen starten, wenn ein Client akzeptiert wurde also über AcceptClient oder BeginAccept...
    Ich wollte auch mal ne total überflüssige Signatur:
    ---Leer---

    Dieser Beitrag wurde bereits 1 mal editiert, zuletzt von „jvbsl“ ()

    doch die codes sind vollständig. was sollte ich eingebaut haben?

    Stand bisher ist folgender:
    ich kann reconnecten und er startet den ListenThread wo er dann aber bei

    VB.NET-Quellcode

    1. thrdAnswer = Stream.Read(ReceiveBytesTCPIP, 0, Client.ReceiveBufferSize)

    in der "Sub ListenTCPIP()" hängen bleibt.
    Dort erhalte ich folgende Fehlermeldung:
    Ausnahme:Ausgelöst: "Der Objektverweis wurde nicht auf eine Objektinstanz festgelegt." (System.NullReferenceException)
    System.NullReferenceException wurde ausgelöst: "Der Objektverweis wurde nicht auf eine Objektinstanz festgelegt."

    Das Eigenartige hierbei ist, das mein ReceiveBytesTCPIP die als letztes gesendeten Bytes (vor dem disconnect) noch enhält ... weshalb wohl die Fehlermeldung erscheint.

    das ganze sieht in so aus:

    VB.NET-Quellcode

    1. Imports System.Net
    2. Imports System.Net.Sockets
    3. Imports System.IO
    4. Imports System.Threading
    5. Imports System.Text
    6. Imports Microsoft.VisualBasic
    8. Public Class Form1
    10. Dim Client As New Net.Sockets.TcpClient
    11. Dim Stream As NetworkStream = Nothing
    13. Private ListenTCPIPThread As New Thread(AddressOf ListenTCPIP)
    14. Private ReceiveBytesTCPIP(Client.ReceiveBufferSize) As Byte
    15. Private bListenTCPIP As Boolean
    16. Private bNewTCPIP As Boolean
    19. 'START LISTENTHREAD
    20. Public Delegate Function refreshMonitorDel(ByVal lstnng As String)
    22. Public Function refreshMonitor(ByVal lstnng As String)
    23. Try
    24. Me.txtAnzeige.AppendText(DateTime.Now & " : " & "Recieved: " + lstnng + vbCrLf)
    25. Catch ex As Exception
    26. txtAnzeige.AppendText(DateTime.Now & " : " & "Failure." + vbCrLf)
    27. End Try
    28. Return Nothing
    29. End Function
    31. Sub ListenTCPIP()
    32. While bListenTCPIP
    33. Dim thrdAnswer As Integer
    34. Dim lLoop As Short = 0
    36. While lLoop < 2
    37. Dim strTmp As String = ""
    38. thrdAnswer = Stream.Read(ReceiveBytesTCPIP, 0, Client.ReceiveBufferSize) 'FEHLERMELDUNG
    39. For i = 0 To ReceiveBytesTCPIP(1) - 1
    40. strTmp += "." + ReceiveBytesTCPIP(i).ToString("X2")
    41. Next
    42. If Me.txtAnzeige.InvokeRequired Then
    43. Me.Invoke(New refreshMonitorDel(AddressOf refreshMonitor), New Object() {strTmp})
    44. Else
    45. Me.txtAnzeige.AppendText(DateTime.Now & " : " & "Recieved: " + strTmp + vbCrLf)
    46. End If
    47. lLoop += 1
    48. End While
    50. End While
    51. End Sub
    52. 'ENDE LISTENTHREAD
    54. Private Sub cmdOpen_Click()
    55. Dim Client As New Net.Sockets.TcpClient
    56. txtAnzeige.AppendText(DateTime.Now & " : " & "Attempting To Connect..." + vbCrLf)
    58. Try
    59. Client.Connect("172.24.55.186", 10000)
    60. Catch ex As SystemException
    61. bListenTCPIP = False
    62. Stream.Close()
    63. Client.Close()
    64. txtAnzeige.AppendText(DateTime.Now & " : " & "Connection Fails" + vbCrLf)
    65. Exit Sub
    66. End Try
    68. If Client.Connected Then
    69. Stream = Client.GetStream()
    70. bListenTCPIP = True
    71. ListenTCPIPThread = New Thread(AddressOf ListenTCPIP)
    72. ListenTCPIPThread.Start()
    73. txtAnzeige.AppendText(DateTime.Now & " : " & "Connected" + vbCrLf)
    74. End If
    75. End Sub
    77. Private Sub cmdClose_Click()
    78. bListenTCPIP = False
    80. Try
    81. ListenTCPIPThread.Abort()
    82. Catch ex As SystemException
    83. End Try
    85. Try
    86. Stream.Close()
    87. Catch ex As SystemException
    88. txtAnzeige.AppendText(DateTime.Now & " : " & "Closing stream failed." + vbCrLf)
    89. Exit Sub
    90. End Try
    91. txtAnzeige.AppendText(DateTime.Now & " : " & "Stream closed." + vbCrLf)
    93. Try
    94. Client.Close()
    95. Catch ex As SystemException
    96. txtAnzeige.AppendText(DateTime.Now & " : " & "Disconnecting failed." + vbCrLf)
    97. Exit Sub
    98. End Try
    99. txtAnzeige.AppendText(DateTime.Now & " : " & "Connection closed." + vbCrLf)
    100. End Sub

    und da haben wir das Problem :P ich hab gedacht das eine wäre Server und das andere Client...
    Dim Client As New Net.Sockets.TcpClient
    in cmdOpen_Click->
    Client = New Net.Sockets.TcpClient
    Ich wollte auch mal ne total überflüssige Signatur:
    ---Leer---

    yeah, super ... es läuft :)
    Vielen Dank!

    Hätte noch ne Frage bzgl. dem Client.Connect:
    Wenn ich eine IP-Adresse eingebe die nicht vorhanden ist/mit der er sich nicht verbinden kann, dann stürzt das Programm ab ... ohne jegliche Meldung. Das war vorher nicht der fall da hat er immer brav "Connecting failed" ausgegeben. Woran könnte das liegen?

    vor:
    Stream.Close()
    Client.Close()
    im Catch Block solltest du überprüfen ob das überhaupt möglich ist, also ob Stream nicht Nothing ist und ob Client auch nicht Nothing ist...
    Ich wollte auch mal ne total überflüssige Signatur:
    ---Leer---

    wenn sie nicht verbunden sind ja, aber nicht wenn diese Nothing sind, weil dann bekommst du eine NullReferenceException, aus diesem Grund wird der Code nicht vollständig zu ende geführt...
    Ich wollte auch mal ne total überflüssige Signatur:
    ---Leer---

    hallo,

    hatte dieses problem (mit dem client.connect) hinten angestellt, weil es nicht direkt bewältigen konnte ... jedoch ist mein programm nun soweit fertig, bis auf diesen bug.
    wenn die falsche ip eingegeben wird bzw. das programm nicht connecten kann hängt es sich auf.
    komme einfach nicht dahinter wie ich diese abfrage "ob stream/client nothing ist" realsieren kann?
    kann mir hierbei jemand weiterhelfen?


    vielen dank
    luckay

    If stream is Nothing? oder If client Is Nothing^^

    du kannst auch einfach einen Try Catch block machen:

    VB.NET-Quellcode

    1. Try
    2. 'hier der Code zum verbinden
    3. Catch ex As Exception
    4. MsgBox(ex.Message)
    5. End Try

    was zwischen Try und Catch steht wird probiert auszuführen, falls ein Fler auftritt springt es in Catch und gibt hier die Fehlermeldung aus(kannste auch ersetzen...)
    Ich wollte auch mal ne total überflüssige Signatur:
    ---Leer---