TCP/IP Async multiserver, extrem komsiches Problem mit String

  • VB.NET

Es gibt 15 Antworten in diesem Thema. Der letzte Beitrag () ist von schockerjo.

    TCP/IP Async multiserver, extrem komsiches Problem mit String

    Ich habe ein , meiner Meinung nach, extrem merkwürdiges Problem mit einem, von mir modifizierten, VersuchsChat mit leistungsfähigem Server .
    Ich
    habe ein Event das ausgelöst wird, wenn einer der Clients eine Naricht
    bekommt. Und jedes Client Objekt hat ein Objekt, das ein paar Infos
    besitzt. Soweit so gut, nur das Problem ist, dass wenn ich z.B.

    VB.NET-Quellcode

    1. Info.Nickname & ":" & Naricht
    schreibe kommt einfach nur der Nickname und die Nachricht wird sozusagen abgeschnitten.

    Hier mal der "wichtige" Code:

    Client
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Imports System.Net.Sockets
    2. Imports System.Text
    3. Imports TCPAsynServer.Disposer
    4. Imports TCPAsynServer.EventArgs
    5. Imports System.Net
    7. Public Class Client : Implements IDisposable
    9. Private _TcpClient As TcpClient
    10. Private _Stream As NetworkStream
    12. Private Buf(&H400 - 1) As Byte
    14. Public settingsObject As Object
    16. Public ReadOnly Property TcpClient As TcpClient
    17. Get
    18. Return _TcpClient
    19. End Get
    20. End Property
    22. Public Sub New(ByVal TC As TcpClient)
    23. _TcpClient = TC
    24. _Stream = _TcpClient.GetStream
    25. End Sub
    27. Public Sub New(ByVal IP As Long, ByVal Port As UShort)
    28. Me.New(New TcpClient(New IPEndPoint(IP, Port)))
    29. End Sub
    31. Public Sub New(ByVal _IPEndPoint As IPEndPoint)
    32. Me.New(New TcpClient(_IPEndPoint))
    33. End Sub
    35. Private Sub EndRead(ByVal ar As IAsyncResult)
    36. If Me.IsDisposed Then Return
    37. Dim read As Integer = 0
    38. Try
    39. read = _Stream.EndRead(ar)
    40. Catch
    41. CrossThread.RunGui(AddressOf Dispose)
    42. Return
    43. End Try
    44. If read = 0 Then
    45. CrossThread.RunGui(AddressOf Dispose)
    46. Return
    47. End If
    48. Dim readArray As Byte() = Buf
    49. Do While _Stream.DataAvailable
    50. read = _Stream.Read(Buf, 0, Buf.Length)
    51. readArray(readArray.Length) = CByte(read)
    52. Loop
    53. Dim NewMessageArgs As New NewMessageEventargs(Me, readArray.ToArray)
    54. CrossThread.RunGui(AddressOf OnNewMessage, NewMessageArgs)
    55. Dim tempar(&H400 - 1) As Byte
    56. Buf = tempar
    57. _Stream.BeginRead(Buf, 0, Buf.Length, AddressOf EndRead, Nothing)
    58. End Sub
    60. Public Sub Dispose() Implements IDisposable.Dispose
    61. If _IsDisposed Then Return
    62. _IsDisposed = True
    63. DisposeAll(_Stream, _TcpClient)
    64. CrossThread.RunGui(AddressOf OnDisposed)
    65. GC.SuppressFinalize(Me)
    66. End Sub
    68. Public Sub [Stop]()
    69. Me.Dispose()
    70. End Sub
    72. Public Sub Start()
    73. If _TcpClient.Client.RemoteEndPoint.ToString = "" Then
    75. Throw New NullReferenceException("You tried to start an empty
    76. 'Client'-object. Please, use 'Sub New' and its overloads to create an
    77. instance of the class.")
    78. Else
    79. _Stream.BeginRead(Buf, 0, Buf.Length, AddressOf EndRead, Nothing)
    80. End If
    81. End Sub
    83. #Region "SendOverloads"
    84. Public Sub Send(ByVal Content As Byte())
    85. _Stream.Write(Content, 0, Content.Length)
    86. End Sub
    88. Public Sub Send(ByVal Content As String)
    89. Dim Buffer() As Byte = Encoding.UTF8.GetBytes(Content)
    90. Send(Buffer)
    91. End Sub
    92. #End Region
    94. #Region "Events"
    96. Private _IsDisposed As Boolean = False
    97. Public ReadOnly Property IsDisposed() As Boolean
    98. Get
    99. Return _IsDisposed
    100. End Get
    101. End Property
    102. Public Event Disposed(ByVal sender As Object)
    103. Protected Sub OnDisposed()
    104. RaiseEvent Disposed(Me)
    105. End Sub
    108. Public Event NewMessage(ByVal sender As Object, ByVal e As NewMessageEventargs)
    109. Protected Sub OnNewMessage(ByVal e As NewMessageEventargs)
    110. RaiseEvent NewMessage(Me, e)
    111. End Sub
    113. #End Region
    115. End Class


    Settingsklasse

    Spoiler anzeigen

    VB.NET-Quellcode

    1. Imports System.Net.Sockets
    2. Imports System.Text
    3. Imports TCPAsynServer.EventArgs
    4. Imports System.Net
    6. Public Class CustomClientSettings
    8. Protected _Nickname As String
    9. Public Property Nickname As String
    10. Get
    11. Return _Nickname
    12. End Get
    13. Set(ByVal value As String)
    14. _Nickname = value
    15. End Set
    16. End Property
    18. Protected _IP As IPEndPoint
    19. Public ReadOnly Property getIP As String
    20. Get
    21. Return _IP.Address.ToString
    22. End Get
    23. End Property
    24. Public Property IP As IPEndPoint
    25. Get
    26. Return _IP
    27. End Get
    28. Set(ByVal value As IPEndPoint)
    29. _IP = value
    30. End Set
    31. End Property
    33. Protected _initialised As Boolean
    34. Public Property initialised As Boolean
    35. Get
    36. Return _initialised
    37. End Get
    38. Set(ByVal value As Boolean)
    39. _initialised = value
    40. End Set
    41. End Property
    44. End Class


    EventArgs

    Spoiler anzeigen

    VB.NET-Quellcode

    1. Public Class EventArgs
    3. Public Class NewMessageEventargs : Inherits EventArgs
    4. Public ReadOnly Message As Byte()
    5. Public ReadOnly Client As Client
    6. Public Sub New(ByVal sender As Client, ByVal Content() As Byte)
    7. MyBase.New()
    8. Me.Message = Content
    9. Me.Client = sender
    10. End Sub
    11. End Class
    13. Public Class ClientNewStatusEventArgs : Inherits EventArgs
    14. Public ReadOnly Client As Client
    15. Public Sub New(ByVal c As Client)
    16. MyBase.New()
    17. Me.Client = c
    18. End Sub
    19. End Class
    21. End Class


    Server

    Spoiler anzeigen

    VB.NET-Quellcode

    1. Imports System.Net.Sockets
    2. Imports System.Net
    3. Imports TCPAsynServer.EventArgs
    5. Public Class Server
    7. Private _Listener As TcpListener
    8. Private _Clients As New List(Of Client)
    10. Public Sub New(ByVal EP As IPEndPoint)
    11. _Listener = New TcpListener(EP)
    12. _Listener.ExclusiveAddressUse = False
    13. End Sub
    15. Public Sub Start()
    16. _Listener.Start()
    17. _Listener.BeginAcceptTcpClient(AddressOf EndAccept, Nothing)
    18. End Sub
    20. Private Sub EndAccept(ByVal ar As IAsyncResult)
    21. If _IsDisposed Then Return
    22. Dim c As New Client(_Listener.EndAcceptTcpClient(ar))
    23. With c
    24. AddHandler .NewMessage, AddressOf Client_OnNewMessage
    25. AddHandler .Disposed, AddressOf Client_OnDispose
    26. _Clients.Add(c)
    27. Client_OnConnect(c)
    28. .Start()
    29. End With
    30. _Listener.BeginAcceptTcpClient(AddressOf EndAccept, Nothing)
    31. End Sub
    33. Protected Sub Dispose()
    34. _Listener.Stop()
    35. For i As Integer = _Clients.Count - 1 To 0 Step -1
    36. _Clients(i).Dispose()
    37. Next
    38. _IsDisposed = True
    39. CrossThread.RunGui(AddressOf OnDisposed)
    40. End Sub
    42. Public Sub [Stop]()
    43. Dispose()
    44. End Sub
    46. #Region "Server_Events"
    47. Private _IsDisposed As Boolean = False
    48. Public ReadOnly Property IsDisposed() As Boolean
    49. Get
    50. Return _IsDisposed
    51. End Get
    52. End Property
    54. Public Event Disposed(ByVal sender As Object)
    55. Protected Sub OnDisposed()
    56. RaiseEvent Disposed(Me)
    57. End Sub
    58. #End Region
    60. #Region "Client_Events"
    62. Public Event Client_Disposed(ByVal sender As Object, ByVal e As ClientNewStatusEventArgs)
    63. Protected Sub OnClient_Disposed(ByVal e As ClientNewStatusEventArgs)
    64. RaiseEvent Client_Disposed(Me, e)
    65. End Sub
    67. Public Event Client_Connected(ByVal sender As Object, ByVal e As ClientNewStatusEventArgs)
    68. Protected Sub OnClient_Connected(ByVal e As ClientNewStatusEventArgs)
    69. RaiseEvent Client_Connected(Me, e)
    70. End Sub
    72. Public Event Client_NewMessage(ByVal sender As Object, ByVal e As NewMessageEventargs)
    73. Protected Sub OnClient_NewMessage(ByVal e As NewMessageEventargs)
    74. RaiseEvent Client_NewMessage(Me, e)
    75. End Sub
    77. Protected Sub Client_OnDispose(ByVal sender As Object)
    78. CrossThread.RunGui(AddressOf OnClient_Disposed, New ClientNewStatusEventArgs(DirectCast(sender, Client)))
    79. End Sub
    80. Protected Sub Client_OnConnect(ByVal sender As Object)
    81. CrossThread.RunGui(AddressOf OnClient_Connected, New ClientNewStatusEventArgs(DirectCast(sender, Client)))
    82. End Sub
    83. Protected Sub Client_OnNewMessage(ByVal sender As Object, ByVal e As NewMessageEventargs)
    84. CrossThread.RunGui(AddressOf OnClient_NewMessage, e)
    85. End Sub
    88. #End Region
    90. End Class


    Form1 (zum Testen des Codes)

    Spoiler anzeigen

    VB.NET-Quellcode

    1. Imports System.Net
    2. Imports System.Text
    4. Public Class Form1
    5. Dim WithEvents s As Server
    6. Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
    7. s = New Server(New System.Net.IPEndPoint(IPAddress.Any, 8900))
    8. s.Start()
    9. End Sub
    12. Private Sub s_Client_Connected(ByVal sender As Object, ByVal e As
    13. EventArgs.ClientNewStatusEventArgs) Handles s.Client_Connected
    14. StatusMessage("Client connected")
    15. e.Client.settingsObject = New CustomClientSettings
    17. DirectCast(e.Client.settingsObject, CustomClientSettings).IP =
    18. CType(e.Client.TcpClient.Client.RemoteEndPoint, Net.IPEndPoint)
    19. End Sub
    22. Private Sub s_Client_Disposed(ByVal sender As Object, ByVal e As
    23. EventArgs.ClientNewStatusEventArgs) Handles s.Client_Disposed
    24. Dim settings As CustomClientSettings = CType(e.Client.settingsObject, CustomClientSettings)
    25. StatusMessage(settings.Nickname & " disconnected")
    26. End Sub
    29. Private Sub s_Client_NewMessage(ByVal sender As Object, ByVal e As
    30. EventArgs.NewMessageEventargs) Handles s.Client_NewMessage
    31. Dim settings As CustomClientSettings = CType(e.Client.settingsObject, CustomClientSettings)
    32. Dim messageToString As String = Encoding.UTF8.GetString(e.Message)
    33. If settings.initialised = False Then
    34. Dim split() As String = messageToString.Split(CChar("|")) 'Später mache ich das dann mit Serialisierung
    35. settings.Nickname = split(0)
    36. settings.initialised = True
    37. e.Client.settingsObject = settings
    38. Else
    39. Dim nickname As String = settings.Nickname
    40. StatusMessage(nickname & ": " & messageToString) 'Ergebenis: nickname
    41. End If
    42. End Sub
    44. Private Sub s_Disposed(ByVal sender As Object) Handles s.Disposed
    45. StatusMessage("Server stopped")
    46. End Sub
    48. Private Sub StatusMessage(ByVal message As String)
    49. RichTextBox1.Text &= vbNewLine & message
    50. End Sub
    51. End Class


    Wäre super, wenn mir jemand helfen könnte, da ich schon den ganzen Abend an diesem Problem hänge :S
    Vielleicht ist der String ja einfach verflucht, wer weiß =O

    MfG :)

    Dieser Beitrag wurde bereits 2 mal editiert, zuletzt von „schockerjo“ ()

    Guck mal in Form1, beim Client_NewMessageEvent.

    Und hier wo die Nachricht im Client empfangen wird:

    VB.NET-Quellcode

    1. Private Sub EndRead(ByVal ar As IAsyncResult)
    2. If Me.IsDisposed Then Return
    3. Dim read As Integer = 0
    4. Try
    5. read = _Stream.EndRead(ar)
    6. Catch
    7. CrossThread.RunGui(AddressOf Dispose)
    8. Return
    9. End Try
    10. If read = 0 Then
    11. CrossThread.RunGui(AddressOf Dispose)
    12. Return
    13. End If
    14. Dim readArray As Byte() = Buf
    15. Do While _Stream.DataAvailable
    16. read = _Stream.Read(Buf, 0, Buf.Length)
    17. readArray(readArray.Length) = CByte(read)
    18. Loop
    19. Dim NewMessageArgs As New NewMessageEventargs(Me, readArray.ToArray)
    20. CrossThread.RunGui(AddressOf OnNewMessage, NewMessageArgs)
    21. Dim tempar(&H400 - 1) As Byte
    22. Buf = tempar
    23. _Stream.BeginRead(Buf, 0, Buf.Length, AddressOf EndRead, Nothing)
    24. End Sub


    Aber schon mal danke, dass du dich überhaupt einliest :thumbup:


    MfG

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

    Keine Ahnung, ob ich das falsch verstehe, aber in dem Beispiel handelt es sich nur um Strings. Die Nachricht wird konvertiert und der Nickname ist , ja, "as string"
    Und die Testausgabe erfolgt ja auch als String ?(

    Ausgabe
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Private Sub StatusMessage(ByVal message As String)
    2. RichTextBox1.Text &= vbNewLine & message
    3. End Sub



    NewMessage Event
    Spoiler anzeigen

    VB.NET-Quellcode

    1. Private Sub s_Client_NewMessage(ByVal sender As Object, ByVal e As
    2. EventArgs.NewMessageEventargs) Handles s.Client_NewMessage
    3. Dim settings As CustomClientSettings = CType(e.Client.settingsObject, CustomClientSettings)
    4. Dim messageToString As String = Encoding.UTF8.GetString(e.Message)
    5. If settings.initialised = False Then
    6. Dim split() As String = messageToString.Split(CChar("|")) 'Später mache ich das dann mit Serialisierung
    7. settings.Nickname = split(0)
    8. settings.initialised = True
    9. e.Client.settingsObject = settings
    10. Else
    11. Dim nickname As String = settings.Nickname
    12. StatusMessage(nickname & ": " & messageToString) 'Ergebenis: nickname
    13. End If
    14. End Sub



    MfG

    Du verstehst es glaube ich nicht, ich will keine Strings versenden. Soweit ich weiß, ist das unsauber.(Lasse mich auch gerne eines besseren belehren) Das Beispiel war nur mit Strings, weil ich die Funktionen getestet habe, fürs Clientinformationen lesen.

    Nochmal, um das ganze etwas konkreter zu gestalten: Weißt du/ Weiß jemand, warum ein String den kompletten String "kaputt"schneiden kann ?

    MfG

    Meintest du hier ?

    VB.NET-Quellcode

    1. Dim settings As CustomClientSettings = CType(e.Client.settingsObject, CustomClientSettings)
    2. Dim messageToString As String = Encoding.Default.GetString(e.Message, 0, e.Message.Length) 'Hab mal das Split enfernt, weil ich dachte, dass es daran liegt :(
    3. If settings.initialised = False Then
    4. settings.Nickname = messageToString 'Später mache ich das dann mit Serialisierung
    5. settings.initialised = True
    6. e.Client.settingsObject = settings
    7. Else
    8. Dim nickname As String = settings.Nickname
    9. StatusMessage(nickname & ": " & messageToString) 'Ergebenis: nickname :/
    10. End If


    Wenn ja, das hat leider nicht geholfen. Aber trotzdem danke !

    Und die Sache, die ich nicht verstehe ist die: Alle anderen Strings die versenden werden funktionieren problemlos, nur halt der in den Settings gespeicherte nicht

    MfG

    Hab den Fehler gefunden, aber leider krieg ich ihn nicht behoben :/.

    Wenn ich eine Nachricht bekomme, benutzte ich ja einen Buffer. Und wenn ich mir dann die Länge des Temporärenarrays zum Lesen ausgeben lasse, ist diese immer 1024. Ich glaub, dort liegt der Fehler. Meine Frage: Soll ich das Array einfach kürzen oder ist das zu Perfomance lastig (Darauf war der Code speziell ausgelegt)

    Spoiler anzeigen
    Hier mal der Code:

    VB.NET-Quellcode

    1. Private Buf(&H400 - 1) As Byte
    2. Private Sub EndRead(ByVal ar As IAsyncResult)
    3. If Me.IsDisposed Then Return
    4. Dim read As Integer = 0
    5. Try
    6. read = _Stream.EndRead(ar)
    7. Catch
    8. CrossThread.RunGui(AddressOf Dispose)
    9. Return
    10. End Try
    11. If read = 0 Then
    12. CrossThread.RunGui(AddressOf Dispose)
    13. Return
    14. End If
    15. Dim readArray() As Byte = Buf '
    16. Do While _Stream.DataAvailable
    17. read = _Stream.Read(Buf.ToArray, 0, Buf.Length)
    18. readArray(readArray.Count) = CByte(read)
    19. Loop
    20. Dim NewMessageArgs As New NewMessageEventargs(Me, readArray.ToArray) 'Readarray hat immer die Größe des Buffers :/
    21. CrossThread.RunGui(AddressOf OnNewMessage, NewMessageArgs)
    22. Dim tempar(&H400 - 1) As Byte 'Ist das sehr Perfomance lastig jedesmal ein neues Array zu erstellen ?
    23. Buf = tempar
    24. _Stream.BeginRead(Buf, 0, Buf.Length, AddressOf EndRead, Nothing) 'Wieder von vorne Anfangen, sollte ich hier lieber ein Array mit der Größe des Buffers erstellen und das benutzen,damit ich mir das oben mit dem neuen erstelle spare ?
    25. End Sub


    MfG und Danke für alle Antworten

    Hat niemand eine Idee ? :(

    Hab hier mal weiter rumprobiert, Fehler steht als Kommentar im Code

    Spoiler anzeigen

    VB.NET-Quellcode

    1. Dim buffer As Byte() = New Byte(1024) {}
    3. ns.BeginRead(buffer, 0, buffer.Length, New AsyncCallback(AddressOf ReadComplete), buffer)
    4. Sub ReadComplete(ByVal ar As IAsyncResult)
    6. If ns.CanRead = False Then
    8. Exit Sub
    10. End If
    14. Dim ar_buffer() As Byte = ar.AsyncState
    16. Dim bytesRead As Integer = ns.EndRead(ar)
    18. 'Hier hätte man entsprechend Array + Länge, nur das Problem ist, dass 1. der Code bei mir nicht funktioniert "NetworkStream.EndRead kann pro asynchronem Vorgang nur einmal ausgeführt werden" und 2. Würde ich das ganze gerne mit Fortschritts Event machen, nur so geht das ja nicht, weil die While-Schleife wegfällt.
    22. ns.BeginRead(ar_buffer, 0, ar_buffer.Length, AddressOf ReadComplete, ar_buffer)
    24. End Sub

Facebook
Telefonspende