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();
}
}
Comments