Imports System
Imports System.Net
Imports System.Net.Sockets
Imports System.Threading
Imports System.Text
Imports System.IO
Public Class ClaseClienteTCP
#Region "VARIABLES"
    Private Stm As Stream 'Utilizado para enviar datos al Servidor y recibir datos del mismo 
    Private m_IPDelHost As String 'Direccion del objeto de la clase Servidor 
    Private m_PuertoDelHost As String 'Puerto donde escucha el objeto de la clase Servidor 
    Private tcpThd As Thread    'Un handler a un clase thread para capturar los eventos de la clase
    Private tcpClnt As TcpClient 'Variable de clase TcpClient
#End Region

#Region "EVENTOS"
    Public Event ConexionTerminada()
    'Public Event DatosRecibidos(ByVal datos As String)
    Public Event DatosRecibidos(ByVal datos As Byte(), ByVal numbytes As Integer)
    Public Event OnErrorDeConexion(ByVal ex As Exception)
#End Region

#Region "PROPIEDADES"
    Public Property IPDelHost() As String
        Get
            IPDelHost = m_IPDelHost
        End Get
        Set(ByVal Value As String)
            m_IPDelHost = Value
        End Set
    End Property

    Public Property PuertoDelHost() As String
        Get
            PuertoDelHost = m_PuertoDelHost
        End Get
        Set(ByVal Value As String)
            m_PuertoDelHost = Value
        End Set
    End Property
    Public ReadOnly Property Conectado() As Boolean
        Get
            Conectado = tcpClnt.Connected
        End Get
    End Property
#End Region

#Region "METODOS"
    Public Sub Conectar()
        tcpClnt = New TcpClient()
        'Me conecto al objeto de la clase Servidor, 
        '  determinado por las propiedades IPDelHost y PuertoDelHost 
        Try
            tcpClnt.Connect(IPDelHost, PuertoDelHost)
            Stm = tcpClnt.GetStream()
            'Creo e inicio un thread para que escuche los mensajes enviados por el Servidor 
            tcpThd = New Thread(AddressOf LeerSocket)
            tcpThd.Start()
        Catch ex As Exception
            RaiseEvent OnErrorDeConexion(ex)
        End Try
    End Sub
    Public Sub Desconectar()
        tcpThd.Abort()
        tcpClnt.Close()
    End Sub

    Public Sub EnviarDatos(ByVal Datos As String)
        Dim BufferDeEscritura() As Byte

        BufferDeEscritura = Encoding.ASCII.GetBytes(Datos)

        If Not (Stm Is Nothing) Then
            'Envio los datos al Servidor 
            Stm.Write(BufferDeEscritura, 0, BufferDeEscritura.Length)
        End If
    End Sub
#End Region

#Region "FUNCIONES PRIVADAS"
    Private Sub LeerSocket()
        Dim BufferDeLectura() As Byte
        Dim BytesLeidos As Integer
        While True
            'Try
            BufferDeLectura = New Byte(100) {}
            'Me quedo esperando a que llegue algun mensaje 
            BytesLeidos = Stm.Read(BufferDeLectura, 0, BufferDeLectura.Length)
            'Genero el evento DatosRecibidos, ya que se han recibido datos desde el Servidor 
            RaiseEvent DatosRecibidos(BufferDeLectura, BytesLeidos)
            'Catch e As Exception
            '   Exit While
            'End Try
        End While

        'Finalizo la conexion, por lo tanto genero el evento correspondiente 
        RaiseEvent ConexionTerminada()
    End Sub
#End Region

End Class