Dim BnetSock As Socket
Dim IncomingData(0) As Byte

...

Do While BnetSock.Connected
	If BnetSock.Available > 0 Then
		ReDim IncomingData(BnetSock.Available - 1)
		BnetSock.Receive(IncomingData)
	End If
Loop

byte[] recvBuff = new byte[4];
int read = 0;
int totalRead = 0;
int length = 0;

while (totalRead < 4) 
{
	   read = sock.GetStream().Read(recvBuff, totalRead, recvBuff.Length - totalRead);
	   if (read == 0) throw new Exception("Remote closed the connection");
					totalRead += read;
}

length = BitConverter.ToInt32(recvBuff,0);

if (length > MAX_SIZE) throw new Exception("Message reported too large");

totalRead = 0;
read = 0;
recvBuff = new byte[length];
					
while (totalRead < length) 
{
	 read = sock.GetStream().Read(recvBuff, totalRead, recvBuff.Length - totalRead);
	 if (read == 0) throw new Exception("Remote closed the connection");
	 totalRead += read;
}

Imports System
Imports System.Net
Imports System.Net.Sockets
Imports System.Text

Public Class clsStateObject
    Public workSocket As Socket = Nothing
    Public BufferSize As Integer = 1024
    Public buffer(1024) As Byte
    Public sb As New StringBuilder
End Class

Public Class SocketsClient
    Public Event onConnect()
    Public Event onError(ByVal Description As String)
    Public Event onDataArrival(ByVal Data As Byte(), ByVal TotalBytes As Integer)
    Public Event onDisconnect()
    Public Event onSendComplete(ByVal DataSize As Integer)

    Private Shared response As [String] = [String].Empty
    Private Shared port As Integer = 21
    Private Shared ipHostInfo As IPHostEntry
    Private Shared ipAddress As ipAddress
    Private Shared client As New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
    Public Sub Connect(ByVal RemoteHostName As String, ByVal RemotePort As Integer)
        Try
            client = New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
            port = RemotePort
            ipHostInfo = Dns.Resolve(RemoteHostName)
            ipAddress = ipHostInfo.AddressList(0)
            Dim remoteEP As New IPEndPoint(ipAddress, port)
            client.BeginConnect(remoteEP, AddressOf sockConnected, client)
        Catch
            RaiseEvent onError(Err.Description)
            Exit Sub
        End Try
    End Sub
    Public Sub SendData(ByVal Data() As Byte)
        Try
            Dim byteData As Byte() = Data
            client.BeginSend(byteData, 0, byteData.Length, 0, AddressOf sockSendEnd, client)
        Catch
            RaiseEvent onError(Err.Description)
            Exit Sub
        End Try
    End Sub
    Public Sub Disconnect()
        Try
            client.Shutdown(SocketShutdown.Both)
        Catch
        End Try
        client.Close()
    End Sub
    Public Function StringToBytes(ByVal Data As String) As Byte()
        StringToBytes = ASCIIEncoding.ASCII.GetBytes(Data)
    End Function
    Public Function BytestoString(ByVal Data As Byte()) As String
        BytestoString = ASCIIEncoding.ASCII.GetString(Data)
    End Function
    Private Sub sockConnected(ByVal ar As IAsyncResult)
        Try
            If client.Connected = False Then
                RaiseEvent onError("Connection refused.")
                Return
            End If
            Dim state As New clsStateObject
            state.workSocket = client
            client.BeginReceive(state.buffer, 0, state.BufferSize, 0, AddressOf sockDataArrival, state)
            RaiseEvent onConnect()
        Catch
            RaiseEvent onError(Err.Description)
            Exit Sub
        End Try
    End Sub
    Private Sub sockDataArrival(ByVal ar As IAsyncResult)
        Dim state As clsStateObject = CType(ar.AsyncState, clsStateObject)
        Dim client As Socket = state.workSocket
        Dim bytesRead As Integer

        Try
            bytesRead = client.EndReceive(ar)
        Catch
            Exit Sub
        End Try

        Try
            Dim Data() As Byte = state.buffer
            If bytesRead = 0 Then
                client.Shutdown(SocketShutdown.Both)
                client.Close()
                RaiseEvent onDisconnect()
                Exit Sub
            End If
            ReDim state.buffer(1024)

            client.BeginReceive(state.buffer, 0, state.BufferSize, SocketFlags.None, AddressOf sockDataArrival, state)
            RaiseEvent onDataArrival(Data, bytesRead)
        Catch
            RaiseEvent onError(Err.Description)
            Exit Sub
        End Try
    End Sub
    Private Sub sockSendEnd(ByVal ar As IAsyncResult)
        Try
            Dim client As Socket = CType(ar.AsyncState, Socket)
            Dim bytesSent As Integer = client.EndSend(ar)
            RaiseEvent onSendComplete(bytesSent)
        Catch
            RaiseEvent onError(Err.Description)
            Exit Sub
        End Try
    End Sub
    Public ReadOnly Property Connected() As Boolean
        Get
            Try
                Return client.Connected
            Catch
                RaiseEvent onError(Err.Description)
                Exit Property
            End Try
        End Get
    End Property
End Class