Сервер-клиент. Пересылка пакетов

public class Connection extends Thread {
 
    private Socket socket;
    private String host;
    private int port;
    private DataInputStream in;
    private DataOutputStream out;
    private final int id;
    private static int nextId = 1;
 
    public Connection(String host, int port) throws IOException {
        this.host = host;
        this.port = port;
        socket = new Socket(host, port);
        in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
        out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
        id = getNextId();
    }
 
    private synchronized int getNextId() {
        return nextId++;
    }
    
    @Override
    public void run() {
        String packet;
        try {
            do {
                packet = new String(Data.getData());
                out.writeBytes(packet);
                out.close();
                // Ожидание ответа сервера
            } while(true);
        } catch (IOException e) {
            e.printStackTrace(); 
        }
    }

public class ServerConnection extends Thread {
 
    private Socket socket;
    private DataInputStream in;
    private DataOutputStream out;
 
    public ServerConnection(Socket socket) throws IOException {
        this.socket = socket;
        in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
        out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
    }
 
    @Override
    public void run() {
        int length;
        byte[] packet = new byte[1024];
        do {
            try {
                // Выясняем размер пакета length
                in.readFully(packet, 0, length);
                // Посылаем отввет
                sendResponse(packet, length);
            } catch (IOException e) {
                e.printStackTrace();
            }
        } while(true);
    }
}