Fórum Comunicação Socket #530489

    
    protected Socket socket = null;
    protected final OutputStream streamOut;
    protected final InputStream streamIn;
    private final Scanner s;
    protected String codigoAcesso = "";

    public ThreadClient(Socket socket) throws IOException {
        super();
        this.socket = socket;
        streamOut = socket.getOutputStream();
        streamOut.flush();
        streamIn = socket.getInputStream();
        s = new Scanner(streamIn);

    }

    @Override
    public void run() {
        while (s.hasNextLine()) {
            String mensage = s.nextLine();
            disparaMessageReceived(mensage);
        }
    }

class ClientConnection
    {
        private const int TIMEOUT_MILLISECONDS = 5000;
        private const int MAX_BUFFER_SIZE = 2048;
        private int serverPort;
        private string serverHostnameString;
        private ManualResetEvent _clientDone = new ManualResetEvent(false);
        private SocketAsyncEventArgs _socketEventArg;
        private Socket _socket = null;
        
        public ClientConnection(String ip, int port)
        {
            this.serverPort = port;
            this.serverHostnameString = ip;
            
        }

        public void connect()
        {
            string result = string.Empty;
            DnsEndPoint hostEntry = new DnsEndPoint(this.serverHostnameString, this.serverPort);
            _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            SocketAsyncEventArgs socketEventArg = new SocketAsyncEventArgs();
            socketEventArg.RemoteEndPoint = hostEntry;

            socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
            {
                result = e.SocketError.ToString();
                _clientDone.Set();
            });

            _clientDone.Reset();
            _socket.ConnectAsync(socketEventArg);
            _clientDone.WaitOne(TIMEOUT_MILLISECONDS);

        }

        public void Send(String data)
        {
            if (_socket != null)
            {
                _socketEventArg = new SocketAsyncEventArgs();

                _socketEventArg.RemoteEndPoint = _socket.RemoteEndPoint;
                _socketEventArg.UserToken = null;

                _socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
                {

                    _clientDone.Set();
                    _socketEventArg = null;
                });
            }


            if (_socketEventArg != null)
            {
                var payload = Encoding.UTF8.GetBytes(data);
                _socketEventArg.SetBuffer(payload, 0, payload.Length);

                _clientDone.Reset();

                _socket.SendAsync(_socketEventArg);

                _clientDone.WaitOne(TIMEOUT_MILLISECONDS);
                
            }
        }

        
    }