ObjectInputStream

public class Client implements Runnable {
 
    private final SeaController controller;
    private String address = "localhost";
    int port = 6666;
    private Socket server;
 
    private Receiver receiver;
    private Thread treadReceiver;
 
    private ObjectOutputStream objectSender;
    private boolean gameProcess = true;
    
 
    public Client(String address, int port, SeaController controller) {
        this.controller = controller;
        this.address = address;
        this.port = port;
    }
 
    private void startClient() {
        address = "localhost";
        port = 6666;
        try {
            server = new Socket(address, port);
        } catch (IOException ex) {
            System.out.println(ex + " сокет не открылся");
        }
        try {
            objectSender = new ObjectOutputStream(server.getOutputStream());
        } catch (IOException ex) {
            System.out.println(ex + " objectSender не открылся");
        }
        receiver = new Receiver(server);
        treadReceiver = new Thread(receiver);
        treadReceiver.start();
        controller.startGUI();
        controller.closeStartWindow();
    }
 
    public void sendMessage(CellState[][] msg) {
        try {
            objectSender.writeObject(new Message("field", msg));
            objectSender.flush();
        } catch (IOException ex) {
            System.out.println(ex + " не записался объект");
        }
    }
 
    public void sendMessage(String msg) {
        try {
            System.out.println("отправлено на сервер string");
            objectSender.writeObject(new Message("String", msg));
            objectSender.flush();
        } catch (IOException ex) {
            System.out.println(ex + " не записался объект");
        }
    }
 
    @Override
    public void run() {
        startClient();
    }
}

public class Receiver implements Runnable {
 
    private Socket socket = null;
    private ObjectInputStream objectReceiver;
 
    Receiver(Socket socket) {
        this.socket = socket;
        System.out.println(socket);
        System.out.println("receiver стартует 1");
    }
 
    @Override
    public void run() {
        Message msg = null;
 
        try {
            InputStream in = socket.getInputStream();
            objectReceiver = new ObjectInputStream(in);
            System.out.println(objectReceiver + " objectReceiver стартует");
        } catch (IOException ex) {
            System.out.println(objectReceiver + " objectReceiver не стартует");
        }
        while (true) {
            try {
                try {
                    System.out.println(objectReceiver + " ждем данных");
                    Object rawMessage = objectReceiver.readObject();
                    System.out.println("что-то принялось");
                    msg = (Message) rawMessage;
                } catch (ClassNotFoundException ex) {
                    System.out.println("что-то не то принялось");
                }
                if (msg.getType().equals("String")) {
                    System.out.println((String) msg.getData()); //это потом превратится в messageProcess
                }
                msg = null;
            } catch (IOException ex) {
                msg = null;
                System.out.println(ex + "С приемом сообщения что-то не так");
            }
        }
    }
}