Client.java

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;

public class Client {

    Socket client;

    DataInputStream in;
    DataOutputStream out;

    public void connect() {

        try {

            client = new Socket("localhost", 8080);

            System.out.println("Client connected.");

            in = new DataInputStream(client.getInputStream());
            out = new DataOutputStream(client.getOutputStream());
        
        } catch(Exception e) {
            System.out.println("Error while connecting : " + e.getMessage());
        }

    }

    public void send(String str) {
        try {
            out.writeUTF(str);
            out.flush();
        } catch(Exception e) {
            System.out.println("Error while sending : " + e.getMessage());
        }
    }

    public void receive() {
        try {

            while(true) {
                String msg = in.readUTF();
                System.out.println("Client : " + msg);
            }

        } catch(Exception e) {
            System.out.println("Error while receiving : " + e.getMessage());
        }
    }

    public void close() {

        if(!client.isConnected()) {
            System.out.println("Client is not connected.");
            return;
        }

        try {
            client.close();
        } catch(Exception e) {
            System.out.println("Error while closing the client." + e.getMessage());
        }

    }
}