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

public class GPSServer extends Thread{
    Socket s; 
    int num;

    public GPSServer(){
            try{  
                    int i = 1;
                    ServerSocket server = new ServerSocket(3128);

                    System.out.println("server is started");
                
                    while(true){
                        GPSServer gPSServer = new GPSServer(i, server.accept());
                        
                        i++;
                    }
            }
            catch(Exception e)
            {System.out.println("init error1: "+e);}
    }

    public GPSServer(int num, Socket socket_in)
    {
    
        System.out.println("new connection"+num);
        this.num = num;
        this.s = socket_in;
        
        setDaemon(true);
        setPriority(NORM_PRIORITY);
        start(); 
    }
    
    @Override
    public void run(){
        try{
            while(true)    {                 
                // буффер данных в 64 килобайта
                byte [] buf = new byte[64*1024];
                // читаем 64кб от клиента, результат - кол-во реально принятых данных
                // int r = is.read(buf);
                
                // из сокета клиента берём поток входящих данных
                //InputStream is = s.getInputStream();
                int r = s.getInputStream().read(buf); // количество принятых байт в посылке
                System.out.println("Recessive byte"+r);
                
                if (r==(-1)){
                    System.out.println("socket close");  // если клиент дисконект закрываем сокет
                    return;
                    }
                
                // и оттуда же - поток данных от сервера к клиенту
                OutputStream os = s.getOutputStream();
                
                String data = new String(buf, 0, r);// создаём строку, содержащую полученную от клиента информацию
                System.out.println(data); //выводим полученные данные на экран

                String sss="PWD:8888,STATUS%";//запрос статуса (без него интервал между сообщения не постоянен и часто обрывается коннект
                os.write(sss.getBytes()); // отправляем данные клиенту 
                }
            }
            catch(Exception e){
                System.out.println("init error2: "+e); // вывод исключений                 
            }
    }
    
}