Клиент-сервер

import org.xml.sax.SAXException;
 
import javax.xml.parsers.ParserConfigurationException;
import java.io.*;
import java.net.Socket;
 
public class client {
 
    public static void main(String[] args) throws IOException, ParserConfigurationException, SAXException {
 
 
        //Socket clientsocket = null;
        try {
            //clientsocket = new Socket("localhost", 16789);
            clientsrc cl = new clientsrc(new Socket("localhost", 16789));
            System.out.println("complete connection");
            cl.send();
            System.out.println("complete send");
            cl.receive();
            System.out.println("Complete receive");
 
        } catch (IOException e) {
            System.err.println(e);
        }
 
    }
 
    private static class clientsrc {
        private Socket socket;
 
        private clientsrc(Socket s) throws IOException {
            this.socket = s;
        }
 
        public void send() throws FileNotFoundException {
            FileReader xml = new FileReader("test.xml");
            BufferedReader reader = new BufferedReader(xml);
            try {
                String line;
                BufferedWriter pr = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                while ((line = reader.readLine()) != null) {
                    pr.write(line);
                }
            } catch (Exception e) {
                System.err.println("err in send to srv" + e);
            }
        }
 
        public void receive() {
            try {
                BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String line2;
                FileWriter xml2 = new FileWriter(new File("test2.xml"));
                while ((line2 = br.readLine()) != null) {
                    System.out.println(line2);
                    xml2.write(line2);
                }
 
            } catch (Exception e) {
                System.err.println("err in receive" + e);
            }
        }
 
    }
}

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
 
public class server {
 
    static Socket clientSocket = null;
    static ServerSocket serverSocket = null;
 
    static List<clientThread> clientThreads = new ArrayList();
 
    public static void main(String args[]) {
 
        int port_number = 16789;
 
        try {
            serverSocket = new ServerSocket(port_number);
        } catch (IOException e) {
            System.out.println(e);
        }
 
        while (true) {
            try {
                clientSocket = serverSocket.accept();
                clientThread client = new clientThread(clientSocket, clientThreads);
                clientThreads.add(client);
                client.start();
            } catch (IOException e) {
                System.out.println(e);
            }
        }
    }
}
 
class clientThread extends Thread {
 
    BufferedReader is = null;
    BufferedWriter os = null;
    Socket clientSocket = null;
    List<clientThread> clientThreads;
 
 
    public clientThread(Socket clientSocket, List<clientThread> clientThreads) {
        this.clientSocket = clientSocket;
        this.clientThreads = clientThreads;
    }
 
    public void run() {
        String line;
        try {
            is = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            os = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
            //Thread.sleep(10000);
            if((line = is.readLine()) != null) {
                System.out.println(line);
            }
            while (true) {
                System.out.println("start");
                while ((line = is.readLine()) != null) {
                    System.out.println("entered");
                    line = is.readLine();
 
                    for (clientThread client : clientThreads) {
                        Thread.sleep(10000);
                        if (!client.equals(this)) {
                            client.os.write(line);
                        }
 
                    }
                }
            }
 
 
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            try {
                is.close();
                os.close();
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
}