Java Java Client-Server socket sending/receiving

Code

package client;



import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.net.Socket;

import java.net.UnknownHostException;



public class ServerComm{

    

    private Socket socket;

    private static ObjectOutputStream oos;

        

    public ServerComm(Socket socket) throws UnknownHostException, IOException {

        

        this.socket = socket;

        oos = new ObjectOutputStream(socket.getOutputStream());

        



    }



    protected static void sendLine(String line, String type, Socket socket) throws IOException{

        

        String[] a = {line,type};

        sendToServerStringArray(a);

            System.out.println("Sending line: " + line);

            System.out.println("Sending type: " + type);

            

    }

    

    public Socket getSocket() {

        return this.socket;

    }

    

    protected static boolean sendAuth(Socket socket) throws IOException {

        

        

        

        String project_id = Config.getProject_id();

        String user_id = Config.getUser_id();



        String[] auths = {project_id, user_id};

        sendToServerStringArray(auths);

        System.out.println("Authentication process started");

        

        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());

        

        if(ois.readBoolean() == true) {

            System.out.println("Authentication successfull!");

            return true;

        }

            System.out.println("Authentication failed, dropping connection.");  

            return false;

    }    

    

    protected static void sendToServerStringArray(String[] array) throws IOException {

        

        oos.reset();

        oos.writeUnshared(array);

        oos.flush();

        

        

    }

    

}

Code

package server;



import java.io.BufferedReader;

import java.io.EOFException;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.ArrayList;



class ServerThread extends Thread {  

    

    public static String name;



    String line = null;

    BufferedReader is = null;

    PrintWriter os = null;

    public static Socket socket = null;

    static ObjectInputStream ois;





    @SuppressWarnings("static-access")

    public ServerThread(Socket socket) throws ClassNotFoundException, IOException{

        

            this.setName("Client");

            name = this.getName();

        this.socket = socket;

        ois = new ObjectInputStream(socket.getInputStream());





    }



    public void run() {

    

        try {

            

            while(true) {

                

     

                        String[] variables = getInputFromClient();

                        for(String variable : variables) {

                            System.out.println(variable);

                        }

                

            }

        }

        catch(NullPointerException e)

        {

            line = this.getName();

            System.out.println("Client "+line+" Closed");

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    

        finally

        {    

            try{

                System.out.println("Connection Closing..");

                if (is != null){

                    is.close(); 

                    System.out.println("Socket Input Stream Closed");

                }

        

                if(os!=null){

                    os.close();

                    System.out.println("Socket Out Closed");

                }

                if (socket!=null){

                socket.close();

                System.out.println("Socket with :" + this.getName() + " were closed");

                }

        

                }

            catch(IOException ie){

                System.out.println("Socket Close Error");

            }

        }

    }

    

    protected static boolean checkAuth() throws IOException, ClassNotFoundException {

        ArrayList<String> auths = new ArrayList<String>();

        

        // read ois truksta

        

        String[] authsFromClient = getInputFromClient();

        

        for(String auth : authsFromClient) {

            auths.add(auth);

        }        

        

        int temp = 0;

        

        for(int i = 0 ; i < auths.size() ; i++) {

            

            if(Config.getProjectId().equals(auths.get(i)) || Config.getUserId().equals(auths.get(i)) ){

                temp += 1;

            }

            else {

                temp -= 1;

            }

            

        }

        if(temp == auths.size()) {

            temp = 0;

            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());

            oos.writeBoolean(true);

            oos.flush();

            return true;

        }

        else {



            temp = 0;

                ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());

                oos.writeBoolean(false);

                oos.flush();

            return false;

            

        }

            

    }

    

    private static String[] getInputFromClient() throws ClassNotFoundException, IOException {

        

        String[] temp = (String[]) ois.readObject();

        return temp;

        

    }

   

}