[theotherguy]

Hello all,
I'm still trying to develop p2p chat application from this thread. I have 2 applications, server and client. A client has: Form1.vb, BB_Client.vb, and RTS_SocketClient.vb. Dataflow is Form1 creates new object of BB_Client, BB_Client calls RTS_SocketClient.

BB_Client

''' <summary>
''' This is the BB client, fill in properties for full effect.
''' </summary>
''' <remarks></remarks>
Public Class BB_Client
    Inherits Object
    Private WithEvents Client As New RTS_SocketClient

#Region " Properties "
    Private esPort As Integer = 8888
    Public Property Port() As Integer
        Get
            Return esPort
        End Get
        Set(ByVal value As Integer)
            esPort = value
        End Set
    End Property

    Private esNickName As String = ""
    Public Property NickName() As String
        Get
            Return esNickName
        End Get
        Set(ByVal value As String)
            esNickName = value
        End Set
    End Property

    Private esConnected As Boolean = False
    Public ReadOnly Property Connected() As Boolean
        Get
            Return esConnected
        End Get
    End Property

    Private esConversationLog As String = ""
    Public ReadOnly Property ConverstationLog() As String
        Get
            Return esConversationLog
        End Get
    End Property
#End Region

#Region " Enums "
    Private Enum Contact As Byte
        Normal = 1
        AdminMessage = 2
        ServerMessage = 3
        Shutdown = 4
        Login = 5
        LoginRejected = 6
    End Enum
#End Region

#Region " Public Code "
    ''' <summary>
    ''' Sends your message to the server, it will be rejected if it is too long.
    ''' </summary>
    ''' <param name="Message"></param>
    ''' <remarks></remarks>
    Public Sub SendMessage(ByVal Message As String)
        Try
            Client.Send(Contact.Normal, Message)
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Connects you to a remote host
    ''' </summary>
    ''' <param name="IP"></param>
    ''' <remarks></remarks>
    Public Sub Connect(ByVal IP As String)
        Try
            Client.ConnectToHost(IP, Port)
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Disconnect from your remote host.
    ''' </summary>
    ''' <remarks></remarks>
    Public Sub Disconnect()
        Try
            Client.DisconnectFromHost()
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Loggs a Username.
    ''' </summary>
    ''' <param name="Username"></param>
    ''' <remarks></remarks>
    Public Sub Login(ByVal Username As String)
        If Not Me.Connected = True Then
            Throw New ApplicationException("The client must be connected to a host before logging in")
            Exit Sub
        End If
        Client.Send(Contact.Login, Username)
        '//////////////////////////////////////////////////
        MsgBox("Login Sent")
    End Sub
#End Region

#Region " Events "
    Public Event OnConnect()
    Public Event OnDisconnect()
    Public Event OnServerMessage(ByVal Message As String)
    Public Event OnNewMessage(ByVal Message As String)
    Public Event onerror(ByVal _Error As Exception)
    Public Event OnLoginRejected(ByVal RejectMessage As String)

    Private Sub Client_Connect(ByVal sender As RTS_SocketClient) Handles Client.Connect
        esConnected = True
        RaiseEvent OnConnect()
    End Sub

    Private Sub Client_Disconnect(ByVal sender As RTS_SocketClient) Handles Client.Disconnect
        esConnected = False
        RaiseEvent OnDisconnect()
    End Sub

    Private Sub Client_StringReceived(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String) Handles Client.StringReceived
        ' Just checks to ensure the right events are raised.
        ' As a rule of thumb you ownly add server messages to your message display
        ' just to save confusion.
        If msgTag = Contact.ServerMessage Then
            RaiseEvent OnServerMessage(message)
        ElseIf msgTag = Contact.Normal Then
            RaiseEvent OnNewMessage(message)
        ElseIf msgTag = Contact.LoginRejected Then
            RaiseEvent OnLoginRejected(message)
        End If
    End Sub
#End Region
End Class

RTS_SocketClient

Imports System.Net.Sockets
Imports System.IO
Imports System.Net

Friend Class RTS_SocketClient
    Inherits Object

    Private Enum RequestTags As Byte
        Connect = 1
        Disconnect = 2
        DataTransfer = 3
        StringTransfer = 4
        ByteTransfer = 5
    End Enum

    Private PACKET_SIZE As Int16 = 4096
    Private client As TcpClient
    Private readByte(0) As Byte
    Private myTag As Byte
    Private isConnected As Boolean 'set to true when connection is granted by server

#Region "Declare events"
    Public Event DataReceived(ByVal sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal mstream As MemoryStream)
    Public Event MessageReceived(ByVal sender As RTS_SocketClient, ByVal msgTag As Byte)
    Public Event StringReceived(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String)
    Public Event TransferProgress(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal Percentage As Single)
    Public Event Connect(ByVal sender As RTS_SocketClient)
    Public Event Disconnect(ByVal sender As RTS_SocketClient)
#End Region

#Region "Overloaded Constructors and destructor"
    Public Sub New(ByVal client As TcpClient, ByVal PacketSize As Int16)
        'instantiates class for use in server
        'don't handle errors here, allow caller to handle them
        PACKET_SIZE = PacketSize
        Me.client = client
        'Start an asynchronous read from the NetworkStream
        Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
    End Sub

    Public Sub New()

    End Sub

    Public Sub ConnectToHost(ByVal IPServer As String, ByVal Port As Integer)
        'instantiates class for use in client
        'don't handle errors here, allow caller to handle them
        'create a new TcpClient and make a synchronous connection 
        'attempt to the provided host name and port number
        Try
            Me.client = New TcpClient(IPServer, Port)
            Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
        Catch
            RaiseEvent Disconnect(Me)
        End Try

        'Start an asynchronous read from the NetworkStream
        'Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
    End Sub

    Public Sub DisconnectFromHost()
        Me.client.Client.Close()
    End Sub

    Protected Overrides Sub finalize()
        'we don't care about errors in this section since we are ending
        On Error Resume Next
        If isConnected Then Send(RequestTags.Disconnect)
        client.GetStream.Close()
        client.Close()
        client = Nothing
    End Sub

#End Region

#Region "Code Hiding"
    Public Property Tag() As Byte
        Get
            Tag = myTag
        End Get
        Set(ByVal value As Byte)
            myTag = value
        End Set
    End Property

    Private Sub ReceiveOneByte(ByVal ar As IAsyncResult)
        'This is where the data is received.  All data communications 
        'begin with a one-byte identifier that tells the class how to
        'handle what is to follow.
        Dim r As BinaryReader
        Dim sreader As StreamReader
        Dim mStream As MemoryStream
        Dim lData As Int32
        Dim readBuffer(PACKET_SIZE) As Byte
        Dim StrBuffer(PACKET_SIZE) As Char
        Dim passThroughByte As Byte
        Dim nData As Integer
        Dim lenData As Integer
        Try
            SyncLock client.GetStream
                'if error occurs here then socket has closed
                Try
                    client.GetStream.EndRead(ar)
                Catch
                    RaiseEvent Disconnect(Me)
                    Exit Sub
                End Try
            End SyncLock
        Catch ex As Exception
            Exit Sub
        End Try

        'this is the instruction on how to handle the rest of the data to come.
        Select Case readByte(0)
            Case RequestTags.Connect
                'sent from server to client informing client that a successful 
                'connection negotiation has been made and the connection now exists.
                isConnected = True 'identifies this class as on the client end
                RaiseEvent Connect(Me)
                SyncLock client.GetStream
                    r = New BinaryReader(client.GetStream)
                    PACKET_SIZE = r.ReadInt16
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

            Case RequestTags.Disconnect
                'sent to either client or server
                'propagated forward to Listener on server end
                RaiseEvent Disconnect(Me)

            Case RequestTags.DataTransfer
                'a block of data is coming
                'Format of this transaction is
                '   DataTransfer identifier byte
                '   Pass-Through Byte contains user defined data
                '   Length of data block (max size = 2,147,483,647 bytes)
                SyncLock client.GetStream
                    r = New BinaryReader(client.GetStream)
                    'next we expect a pass-through byte
                    client.GetStream.Read(readByte, 0, 1)
                    passThroughByte = readByte(0)
                    'next expect length of data (Int32)
                    nData = r.ReadInt32
                    lenData = nData
                    'now comes the data, save it in a memory stream
                    mStream = New MemoryStream
                    While nData > 0
                        RaiseEvent TransferProgress(Me, passThroughByte, CSng(1.0 - nData / lenData))
                        lData = client.GetStream.Read(readBuffer, 0, PACKET_SIZE)
                        mStream.Write(readBuffer, 0, lData)
                        nData -= lData
                    End While
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock
                'once all data has arrived, pass it on to the end user as a stream
                RaiseEvent DataReceived(Me, passThroughByte, mStream)
                mStream.Dispose()

            Case RequestTags.StringTransfer
                'Here we receive the transfer of string data in a block
                'not to exceed PACKET_SIZE in length.
                SyncLock client.GetStream
                    sreader = New StreamReader(client.GetStream)
                    'next we expect a pass-through byte
                    client.GetStream.Read(readByte, 0, 1)
                    passThroughByte = readByte(0)
                    nData = sreader.Read(StrBuffer, 0, PACKET_SIZE)
                End SyncLock
                Dim strX As New String(StrBuffer, 0, nData)

                'pass string on to end user
                RaiseEvent StringReceived(Me, passThroughByte, strX)
                SyncLock client.GetStream
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

            Case RequestTags.ByteTransfer
                'Here we receive a user-defined one-byte message
                SyncLock client.GetStream
                    client.GetStream.Read(readByte, 0, 1)
                End SyncLock
                'pass byte on to end user
                RaiseEvent MessageReceived(Me, readByte(0))
                SyncLock client.GetStream
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

        End Select

    End Sub

#Region "Overloaded methods to send data between client(s) and server"

    Public Sub Send(ByVal msgTag As Byte)
        ' This subroutine sends a one-byte response
        SyncLock client.GetStream
            Dim writer As New BinaryWriter(client.GetStream)
            'notify that 1-byte is coming
            writer.Write(RequestTags.ByteTransfer)
            'Send user defined message byte
            writer.Write(msgTag)
            ' Make sure all data is sent now.
            writer.Flush()
        End SyncLock
    End Sub

    Public Sub Send(ByVal msgTag As Byte, ByVal strX As String)
        'sends a string of max length PACKET_SIZE
        SyncLock client.GetStream
            Dim writer As New StreamWriter(client.GetStream)
            'Notify other end that a string block is coming
            writer.Write(Chr(RequestTags.StringTransfer))
            'Send user defined message byte
            writer.Write(Chr(msgTag))
            'Send the string
            writer.Write(strX)
            'make sure all data gets sent now
            writer.Flush()
        End SyncLock
    End Sub

    ''' <summary>
    ''' Dont Perform a buffer overflow with this :)/>
    ''' </summary>
    ''' <param name="msgTag"></param>
    ''' <param name="byteData"></param>
    ''' <remarks></remarks>
    Public Sub Send(ByVal msgTag As Byte, ByVal byteData() As Byte)
        'sends array of byte data
        SyncLock client.GetStream
            Dim writer As New BinaryWriter(client.GetStream)
            'Notify that byte data is coming
            writer.Write(RequestTags.DataTransfer)
            'send user-define message byte
            writer.Write(msgTag)
            'send length of data block
            writer.Write(byteData.Length)
            'send the data
            writer.Write(byteData)
            'make sure all data is sent
            writer.Flush()
        End SyncLock
    End Sub

    ''' <summary>
    ''' Max File Size is 2GB
    ''' </summary>
    ''' <param name="msgTag"></param>
    ''' <param name="FilePath"></param>
    ''' <remarks></remarks>
    Public Sub SendFile(ByVal msgTag As Byte, ByVal FilePath As String)
        'max filesize is 2GB
        Dim byteArray() As Byte
        Dim fs As FileStream = New FileStream(FilePath, FileMode.Open, FileAccess.Read)
        Dim r As New BinaryReader(fs)

        SyncLock client.GetStream
            Dim w As New BinaryWriter(client.GetStream)
            'notify that file data is coming
            w.Write(RequestTags.DataTransfer)
            'send user-define message byte
            w.Write(msgTag)
            'send size of file
            w.Write(CInt(fs.Length))
            'Send the file data
            Do
                'read data from file
                byteArray = r.ReadBytes(PACKET_SIZE)
                'write data to Network Stream
                w.Write(byteArray)
            Loop While byteArray.Length = PACKET_SIZE
            'make sure all data is sent
            w.Flush()
        End SyncLock
    End Sub
#End Region


    ''' <summary>
    ''' Get this clients remote IP (Server Use Only)
    ''' </summary>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public Function GetClientIP() As String
        Dim a As String = String.Empty
        Dim clientInfo As IPEndPoint = CType(client.Client.RemoteEndPoint, IPEndPoint)
        a = clientInfo.Address.ToString
        Return a
    End Function

    Private esusername As String = ""
    Public Property Username() As String
        Get
            Return esusername
        End Get
        Set(ByVal value As String)
            esusername = value
        End Set
    End Property
#End Region
End Class

So, In my Form1, I want to get stream data that passed between server-client, which is happening in RTS_SocketClient.vb to be displayed into my textbox called txtDisplay. Problem is, I don't have idea on how to allow that.

Will it be possible if I create new tcpclient in Form1 and getstream independently from RTS_SocketClient? Or I need to create a tcpclient in BB_Client and then create new object in Form1? Or any other way?

Thanks.

[Amrykid]

theotherguy, on 08 April 2011 - 12:16 AM, said:

Hello all,
I'm still trying to develop p2p chat application from this thread. I have 2 applications, server and client. A client has: Form1.vb, BB_Client.vb, and RTS_SocketClient.vb. Dataflow is Form1 creates new object of BB_Client, BB_Client calls RTS_SocketClient.

BB_Client

''' <summary>
''' This is the BB client, fill in properties for full effect.
''' </summary>
''' <remarks></remarks>
Public Class BB_Client
    Inherits Object
    Private WithEvents Client As New RTS_SocketClient

#Region " Properties "
    Private esPort As Integer = 8888
    Public Property Port() As Integer
        Get
            Return esPort
        End Get
        Set(ByVal value As Integer)
            esPort = value
        End Set
    End Property

    Private esNickName As String = ""
    Public Property NickName() As String
        Get
            Return esNickName
        End Get
        Set(ByVal value As String)
            esNickName = value
        End Set
    End Property

    Private esConnected As Boolean = False
    Public ReadOnly Property Connected() As Boolean
        Get
            Return esConnected
        End Get
    End Property

    Private esConversationLog As String = ""
    Public ReadOnly Property ConverstationLog() As String
        Get
            Return esConversationLog
        End Get
    End Property
#End Region

#Region " Enums "
    Private Enum Contact As Byte
        Normal = 1
        AdminMessage = 2
        ServerMessage = 3
        Shutdown = 4
        Login = 5
        LoginRejected = 6
    End Enum
#End Region

#Region " Public Code "
    ''' <summary>
    ''' Sends your message to the server, it will be rejected if it is too long.
    ''' </summary>
    ''' <param name="Message"></param>
    ''' <remarks></remarks>
    Public Sub SendMessage(ByVal Message As String)
        Try
            Client.Send(Contact.Normal, Message)
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Connects you to a remote host
    ''' </summary>
    ''' <param name="IP"></param>
    ''' <remarks></remarks>
    Public Sub Connect(ByVal IP As String)
        Try
            Client.ConnectToHost(IP, Port)
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Disconnect from your remote host.
    ''' </summary>
    ''' <remarks></remarks>
    Public Sub Disconnect()
        Try
            Client.DisconnectFromHost()
        Catch ex As Exception
            RaiseEvent onerror(ex)
        End Try
    End Sub

    ''' <summary>
    ''' Loggs a Username.
    ''' </summary>
    ''' <param name="Username"></param>
    ''' <remarks></remarks>
    Public Sub Login(ByVal Username As String)
        If Not Me.Connected = True Then
            Throw New ApplicationException("The client must be connected to a host before logging in")
            Exit Sub
        End If
        Client.Send(Contact.Login, Username)
        '//////////////////////////////////////////////////
        MsgBox("Login Sent")
    End Sub
#End Region

#Region " Events "
    Public Event OnConnect()
    Public Event OnDisconnect()
    Public Event OnServerMessage(ByVal Message As String)
    Public Event OnNewMessage(ByVal Message As String)
    Public Event onerror(ByVal _Error As Exception)
    Public Event OnLoginRejected(ByVal RejectMessage As String)

    Private Sub Client_Connect(ByVal sender As RTS_SocketClient) Handles Client.Connect
        esConnected = True
        RaiseEvent OnConnect()
    End Sub

    Private Sub Client_Disconnect(ByVal sender As RTS_SocketClient) Handles Client.Disconnect
        esConnected = False
        RaiseEvent OnDisconnect()
    End Sub

    Private Sub Client_StringReceived(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String) Handles Client.StringReceived
        ' Just checks to ensure the right events are raised.
        ' As a rule of thumb you ownly add server messages to your message display
        ' just to save confusion.
        If msgTag = Contact.ServerMessage Then
            RaiseEvent OnServerMessage(message)
        ElseIf msgTag = Contact.Normal Then
            RaiseEvent OnNewMessage(message)
        ElseIf msgTag = Contact.LoginRejected Then
            RaiseEvent OnLoginRejected(message)
        End If
    End Sub
#End Region
End Class

RTS_SocketClient

Imports System.Net.Sockets
Imports System.IO
Imports System.Net

Friend Class RTS_SocketClient
    Inherits Object

    Private Enum RequestTags As Byte
        Connect = 1
        Disconnect = 2
        DataTransfer = 3
        StringTransfer = 4
        ByteTransfer = 5
    End Enum

    Private PACKET_SIZE As Int16 = 4096
    Private client As TcpClient
    Private readByte(0) As Byte
    Private myTag As Byte
    Private isConnected As Boolean 'set to true when connection is granted by server

#Region "Declare events"
    Public Event DataReceived(ByVal sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal mstream As MemoryStream)
    Public Event MessageReceived(ByVal sender As RTS_SocketClient, ByVal msgTag As Byte)
    Public Event StringReceived(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String)
    Public Event TransferProgress(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal Percentage As Single)
    Public Event Connect(ByVal sender As RTS_SocketClient)
    Public Event Disconnect(ByVal sender As RTS_SocketClient)
#End Region

#Region "Overloaded Constructors and destructor"
    Public Sub New(ByVal client As TcpClient, ByVal PacketSize As Int16)
        'instantiates class for use in server
        'don't handle errors here, allow caller to handle them
        PACKET_SIZE = PacketSize
        Me.client = client
        'Start an asynchronous read from the NetworkStream
        Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
    End Sub

    Public Sub New()

    End Sub

    Public Sub ConnectToHost(ByVal IPServer As String, ByVal Port As Integer)
        'instantiates class for use in client
        'don't handle errors here, allow caller to handle them
        'create a new TcpClient and make a synchronous connection 
        'attempt to the provided host name and port number
        Try
            Me.client = New TcpClient(IPServer, Port)
            Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
        Catch
            RaiseEvent Disconnect(Me)
        End Try

        'Start an asynchronous read from the NetworkStream
        'Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
    End Sub

    Public Sub DisconnectFromHost()
        Me.client.Client.Close()
    End Sub

    Protected Overrides Sub finalize()
        'we don't care about errors in this section since we are ending
        On Error Resume Next
        If isConnected Then Send(RequestTags.Disconnect)
        client.GetStream.Close()
        client.Close()
        client = Nothing
    End Sub

#End Region

#Region "Code Hiding"
    Public Property Tag() As Byte
        Get
            Tag = myTag
        End Get
        Set(ByVal value As Byte)
            myTag = value
        End Set
    End Property

    Private Sub ReceiveOneByte(ByVal ar As IAsyncResult)
        'This is where the data is received.  All data communications 
        'begin with a one-byte identifier that tells the class how to
        'handle what is to follow.
        Dim r As BinaryReader
        Dim sreader As StreamReader
        Dim mStream As MemoryStream
        Dim lData As Int32
        Dim readBuffer(PACKET_SIZE) As Byte
        Dim StrBuffer(PACKET_SIZE) As Char
        Dim passThroughByte As Byte
        Dim nData As Integer
        Dim lenData As Integer
        Try
            SyncLock client.GetStream
                'if error occurs here then socket has closed
                Try
                    client.GetStream.EndRead(ar)
                Catch
                    RaiseEvent Disconnect(Me)
                    Exit Sub
                End Try
            End SyncLock
        Catch ex As Exception
            Exit Sub
        End Try

        'this is the instruction on how to handle the rest of the data to come.
        Select Case readByte(0)
            Case RequestTags.Connect
                'sent from server to client informing client that a successful 
                'connection negotiation has been made and the connection now exists.
                isConnected = True 'identifies this class as on the client end
                RaiseEvent Connect(Me)
                SyncLock client.GetStream
                    r = New BinaryReader(client.GetStream)
                    PACKET_SIZE = r.ReadInt16
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

            Case RequestTags.Disconnect
                'sent to either client or server
                'propagated forward to Listener on server end
                RaiseEvent Disconnect(Me)

            Case RequestTags.DataTransfer
                'a block of data is coming
                'Format of this transaction is
                '   DataTransfer identifier byte
                '   Pass-Through Byte contains user defined data
                '   Length of data block (max size = 2,147,483,647 bytes)
                SyncLock client.GetStream
                    r = New BinaryReader(client.GetStream)
                    'next we expect a pass-through byte
                    client.GetStream.Read(readByte, 0, 1)
                    passThroughByte = readByte(0)
                    'next expect length of data (Int32)
                    nData = r.ReadInt32
                    lenData = nData
                    'now comes the data, save it in a memory stream
                    mStream = New MemoryStream
                    While nData > 0
                        RaiseEvent TransferProgress(Me, passThroughByte, CSng(1.0 - nData / lenData))
                        lData = client.GetStream.Read(readBuffer, 0, PACKET_SIZE)
                        mStream.Write(readBuffer, 0, lData)
                        nData -= lData
                    End While
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock
                'once all data has arrived, pass it on to the end user as a stream
                RaiseEvent DataReceived(Me, passThroughByte, mStream)
                mStream.Dispose()

            Case RequestTags.StringTransfer
                'Here we receive the transfer of string data in a block
                'not to exceed PACKET_SIZE in length.
                SyncLock client.GetStream
                    sreader = New StreamReader(client.GetStream)
                    'next we expect a pass-through byte
                    client.GetStream.Read(readByte, 0, 1)
                    passThroughByte = readByte(0)
                    nData = sreader.Read(StrBuffer, 0, PACKET_SIZE)
                End SyncLock
                Dim strX As New String(StrBuffer, 0, nData)

                'pass string on to end user
                RaiseEvent StringReceived(Me, passThroughByte, strX)
                SyncLock client.GetStream
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

            Case RequestTags.ByteTransfer
                'Here we receive a user-defined one-byte message
                SyncLock client.GetStream
                    client.GetStream.Read(readByte, 0, 1)
                End SyncLock
                'pass byte on to end user
                RaiseEvent MessageReceived(Me, readByte(0))
                SyncLock client.GetStream
                    'Continue the asynchronous read from the NetworkStream
                    Me.client.GetStream.BeginRead(readByte, 0, 1, AddressOf ReceiveOneByte, Nothing)
                End SyncLock

        End Select

    End Sub

#Region "Overloaded methods to send data between client(s) and server"

    Public Sub Send(ByVal msgTag As Byte)
        ' This subroutine sends a one-byte response
        SyncLock client.GetStream
            Dim writer As New BinaryWriter(client.GetStream)
            'notify that 1-byte is coming
            writer.Write(RequestTags.ByteTransfer)
            'Send user defined message byte
            writer.Write(msgTag)
            ' Make sure all data is sent now.
            writer.Flush()
        End SyncLock
    End Sub

    Public Sub Send(ByVal msgTag As Byte, ByVal strX As String)
        'sends a string of max length PACKET_SIZE
        SyncLock client.GetStream
            Dim writer As New StreamWriter(client.GetStream)
            'Notify other end that a string block is coming
            writer.Write(Chr(RequestTags.StringTransfer))
            'Send user defined message byte
            writer.Write(Chr(msgTag))
            'Send the string
            writer.Write(strX)
            'make sure all data gets sent now
            writer.Flush()
        End SyncLock
    End Sub

    ''' <summary>
    ''' Dont Perform a buffer overflow with this :)/>
    ''' </summary>
    ''' <param name="msgTag"></param>
    ''' <param name="byteData"></param>
    ''' <remarks></remarks>
    Public Sub Send(ByVal msgTag As Byte, ByVal byteData() As Byte)
        'sends array of byte data
        SyncLock client.GetStream
            Dim writer As New BinaryWriter(client.GetStream)
            'Notify that byte data is coming
            writer.Write(RequestTags.DataTransfer)
            'send user-define message byte
            writer.Write(msgTag)
            'send length of data block
            writer.Write(byteData.Length)
            'send the data
            writer.Write(byteData)
            'make sure all data is sent
            writer.Flush()
        End SyncLock
    End Sub

    ''' <summary>
    ''' Max File Size is 2GB
    ''' </summary>
    ''' <param name="msgTag"></param>
    ''' <param name="FilePath"></param>
    ''' <remarks></remarks>
    Public Sub SendFile(ByVal msgTag As Byte, ByVal FilePath As String)
        'max filesize is 2GB
        Dim byteArray() As Byte
        Dim fs As FileStream = New FileStream(FilePath, FileMode.Open, FileAccess.Read)
        Dim r As New BinaryReader(fs)

        SyncLock client.GetStream
            Dim w As New BinaryWriter(client.GetStream)
            'notify that file data is coming
            w.Write(RequestTags.DataTransfer)
            'send user-define message byte
            w.Write(msgTag)
            'send size of file
            w.Write(CInt(fs.Length))
            'Send the file data
            Do
                'read data from file
                byteArray = r.ReadBytes(PACKET_SIZE)
                'write data to Network Stream
                w.Write(byteArray)
            Loop While byteArray.Length = PACKET_SIZE
            'make sure all data is sent
            w.Flush()
        End SyncLock
    End Sub
#End Region


    ''' <summary>
    ''' Get this clients remote IP (Server Use Only)
    ''' </summary>
    ''' <returns></returns>
    ''' <remarks></remarks>
    Public Function GetClientIP() As String
        Dim a As String = String.Empty
        Dim clientInfo As IPEndPoint = CType(client.Client.RemoteEndPoint, IPEndPoint)
        a = clientInfo.Address.ToString
        Return a
    End Function

    Private esusername As String = ""
    Public Property Username() As String
        Get
            Return esusername
        End Get
        Set(ByVal value As String)
            esusername = value
        End Set
    End Property
#End Region
End Class

So, In my Form1, I want to get stream data that passed between server-client, which is happening in RTS_SocketClient.vb to be displayed into my textbox called txtDisplay. Problem is, I don't have idea on how to allow that.

Will it be possible if I create new tcpclient in Form1 and getstream independently from RTS_SocketClient? Or I need to create a tcpclient in BB_Client and then create new object in Form1? Or any other way?

Thanks.

In this case, the best way to get data from a Object to a Form is to use events. You defined the event

Public Event StringReceived(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String)

in your socket code. Now, I suggest you use that to display code.

To do that, use the following code:
Place this wherever (in the form) you start to use the socket and begin the communication.

'change socketname to whatever variable name of the socket object
AddHandler socketname.StringReceived, AddressOf HandleMsg

Now create the handle msg function like this:

Public Sub HandleMsg(ByVal Sender As RTS_SocketClient, ByVal msgTag As Byte, ByVal message As String)
'Here, you handle adding the text to a text box.
End Sub

EDIT: After rereading your code, your BBClient has a better event. The

Public Event OnNewMessage(ByVal Message As String)

event.

So the code would be nearly the same.

'change socketname to whatever variable name of the socket object
AddHandler socketname.OnNewMessage, AddressOf HandleMsg

Public Sub HandleMsg(ByVal message As String)
'Here, you handle adding the text to a text box.
End Sub

This post has been edited by Amrykid: 08 April 2011 - 06:24 AM

[theotherguy]

Hello, thanks for reply.

I tried what you suggested, and it doesn't work. Now still getting error of not safe cross thread error. It means I need to run the handlemsg in background thread right? But how to return the string value from handlemsg?

'change socketname to whatever variable name of the socket object
AddHandler socketname.OnNewMessage, AddressOf HandleMsg

Public Sub HandleMsg(ByVal message As String)
'Here, you handle adding the text to a text box.
End Sub

[Amrykid]

theotherguy, on 08 April 2011 - 02:15 PM, said:

Hello, thanks for reply.

I tried what you suggested, and it doesn't work. Now still getting error of not safe cross thread error. It means I need to run the handlemsg in background thread right? But how to return the string value from handlemsg?

'change socketname to whatever variable name of the socket object
AddHandler socketname.OnNewMessage, AddressOf HandleMsg

Public Sub HandleMsg(ByVal message As String)
'Here, you handle adding the text to a text box.
End Sub

The cross thread error is a good sigh. In programming, you shouldn't use GUI objects from two threads directly as it may cause a deadlock (if I recall correctly).

In the HandleMessage code, you have a variable called "message" from

(ByVal message As String)

.

"message" is going to be the text you received from your socket class (if thats what you programmed it to be).

Now, for adding the message, you will need to use Form.Invoke to get around the Cross-Thread protection (which throws the exception). It should be something like this:

Public Sub HandleMsg(ByVal message As String)
'Here, you handle adding the text to a text box.
'Below, the code will only work if this code is used inside of a form and your using VB.NET 10 (VB Express 2010) because I'm using Anonymous Methods.
Me.Invoke(Sub()
            'change txtbox to the name of your text about.
            txtbox.Append(message)
          End Sub)
End Sub

That should be enough to get you started.

[theotherguy]

Hi

I still ran into errors. Here is the error screenshot when I tried yours. Btw, I'm using VS 2008.


The addhandler, I added it into form load sub, as shown below.

Private Sub Form1_Load(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles MyBase.Load

        x.Connect("127.0.0.1")
        
        AddHandler x.OnNewMessage, AddressOf HandleMsg
    End Sub

Please help, thanks.

[Amrykid]

theotherguy, on 09 April 2011 - 04:46 AM, said:

Hi

I still ran into errors. Here is the error screenshot when I tried yours. Btw, I'm using VS 2008.


The addhandler, I added it into form load sub, as shown below.

Private Sub Form1_Load(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles MyBase.Load

        x.Connect("127.0.0.1")
        
        AddHandler x.OnNewMessage, AddressOf HandleMsg
    End Sub

Please help, thanks.

So your not using VB10 (which means no Anonymous Methods) so that means a small detour.

Add a new function called PrintMsg like this:

Public Sub PrintMsg(byval message as string)
    'change txtbox to the name of your text about.
    txtbox.Append(message)
End Sub

And change the handlemsg function to this:

Private Delegate Sub PrintMessageDelegate(Byval message as string)
Public Sub HandleMsg(ByVal message As String)
    'Here, you handle adding the text to a text box.
    Me.Invoke(new PrintMessageDelegate(PrintMsg),message)
End Sub

We create a delegate as a kind of pointer to a function since we can "grab" functions directly. We can only execute them and get their value (if any).

Then, we pass the Delegate pointing to the function to the Form's Invoke Function along with the message.

This post has been edited by Amrykid: 09 April 2011 - 09:56 AM

[theotherguy]

Hi

It really works. Thanks for your great help. But I still got a bit confused with these. Like addhandler, i only trigger it once under Form1_Load sub, but I don't need to do any infinite loop to keep the handler functioning right?

Thanks.

[Amrykid]

theotherguy, on 10 April 2011 - 06:34 AM, said:

Hi

It really works. Thanks for your great help. But I still got a bit confused with these. Like addhandler, i only trigger it once under Form1_Load sub, but I don't need to do any infinite loop to keep the handler functioning right?

Thanks.

Yeah, only call the AddHandler bit once. Putting it in a loop will produce nasty results.