class  Client {

     public   static   void  main(String args[]) {
         try  {
             Socket s =  new  Socket("127.0.0.1",  21 );

              byte  testbytes[] =  new   byte [ 100000 ];
              for  ( int  i =  0 ; i < testbytes.length; i++) {
                 testbytes[i] =  56 ;
             }
             // исходящий поток
             OutputStream printout = s.getOutputStream();
             printout.write(testbytes);
             printout.flush();

        }
         catch  (Exception e) {
            e.printStackTrace();
        } // вывод исключений
    }    

     java.net.SocketException: Connection reset by peer: socket write error
	at java.net.SocketOutputStream.socketWrite0( Native  Method)
	at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java: 92 )
	at java.net.SocketOutputStream.write(SocketOutputStream.java: 124 )
	at Client.main(Client.java: 22 )

 import  java.io.*;
 import  java.net.*;

 class  Server  extends  Thread {

    Socket s;
     int  num;

     public   static   void  main(String args[]) {
         try  {
             int  i =  0 ; // счётчик подключений

            ServerSocket server =  new  ServerSocket( 21 ,  0 , InetAddress.getByName("localhost"));
            System.out.println("server is started");
            // слушаем порт
             while  (true) {
                 new  Server(i, server.accept());
                i++;
            }
        }  catch  (Exception e) {
            System.out.println("init error: " + e);
        }
    }

     public  Server( int  num, Socket s) {
        // копируем данные
         this .num = num;
         this .s = s;

        // и запускаем новый вычислительный поток (см. ф-ю run())
        setDaemon(true);
        setPriority(NORM_PRIORITY);
        start();
    }

     public   void  run() {
         try  {
            // из сокета клиента берём поток входящих данных
            InputStream is = s.getInputStream();
            // и оттуда же - поток данных от сервера к клиенту
            OutputStream os = s.getOutputStream();

            // буффер данных в 64 килобайта
             byte  buf[] =  new   byte [ 64  *  1024 ];
            // читаем 64кб от клиента, результат - кол-во реально принятых данных
             int  r = is.read(buf);

            // создаём строку, содержащую полученную от клиента информацию
            String data =  new  String(buf,  0 , r);

            System.out.println("data from emulator:" + data);
            
            // завершаем соединение
            s.close();
        }
         catch  (Exception e) {
            System.out.println(e);
        }
    }
}

OutputStream printout = s.getOutputStream();
 for  ( int  i =  0 ; i <  200000 ; i++) {
    printout.write( 56 );
    printout.flush();
}