server.output.java

package Talk16T;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;

public class Output extends Thread {
    private Socket connectionSocket;
    private DataOutputStream outToClient;
     private BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));

    public Output(Socket connectionSocket) {
        this.connectionSocket = connectionSocket;

        try {
            outToClient = new DataOutputStream(connectionSocket.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        boolean done = false;
        while (!done) {
            try {
                String fromUser = inFromUser.readLine();
                if (fromUser.equalsIgnoreCase("/close")) {
                    done = true;
                } else {
                    outToClient.writeBytes("Server: " + fromUser + "\n");
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        try {
            connectionSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}