package local.sandbox;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class ClientServerTest {
    static class Server implements Runnable {
        @Override
        public void run() {
            try {
                ServerSocket socket = new ServerSocket(4123);
                System.out.println("Server läuft...");

                InputStreamReader reader = new InputStreamReader(socket.accept().getInputStream());

                System.out.println("Empfange Daten...");
                System.out.println(reader.read());

                System.out.println("Stoppe Server...");
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static class Client implements Runnable {
        @Override
        public void run() {
            try {
                Socket socket = new Socket("localhost", 4123);
                OutputStreamWriter writer = new OutputStreamWriter(socket.getOutputStream());

                writer.write(5);
                writer.flush();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        Thread server = new Thread(new Server());
        server.start();

        Thread client = new Thread(new Client());
        client.start();
    }
}