ahrensan79600/Aufgabe10_ChatProgramm
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Server umgebaut

Browse Source
This commit is contained in:
Jens Schuhmann 2023-12-12 10:48:57 +01:00
parent 0853e26034
commit 8a7019bfca
1 changed files with 47 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
src/ChatProgramm/Server.java
View File

@ -23,45 +23,58 @@ import java.util.logging.*;
public class Server public class Server
{ {
private static Logger lg = Logger.getLogger("netz"); private static Logger lg = Logger.getLogger("netz");
private Socket socket;
private BufferedReader reader;
private PrintWriter writer;
private static final int PORT = 35000; //lt. iana port > 2¹⁵ private static final int PORT = 35000; //lt. iana port > 2¹⁵
private static int timeout = 10000;
public void connect() throws IOException
{
try
{
ServerSocket sSocket = new ServerSocket(PORT);
sSocket.setSoTimeout(timeout);
lg.info("Server: warte auf Verbindung");
socket = sSocket.accept();
lg.info("Server: Verbindung akzeptiert");
lg.info("Server: initialisiere reader und writer");
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
OutputStreamWriter osr = new OutputStreamWriter(os, "UTF-8");
reader = new BufferedReader(isr);
writer = new PrintWriter(osr);
lg.info("Server: Initialisierung abgeschlossen");
lg.info("Server: warte auf Nachricht");
}
catch ( java.io.InterruptedIOException e )
{
lg.warning("Timeout"+"("+timeout/1000+"s)");
}
}
public Server() throws IOException public Server() throws IOException
{ {
ServerSocket sSocket = new ServerSocket(PORT); connect();
lg.info("Server: warte auf Verbindung");
Socket s = sSocket.accept(); // ACHTUNG blockiert!
lg.info("Server: Verbindung akzeptiert"); // String nachricht = in.readLine(); // ACHTUNG blockiert
// lg.info("Server: Nachricht erhalten");
InputStream is = s.getInputStream(); // System.out.println("Server: NACHRICHT = " + nachricht);
OutputStream os = s.getOutputStream(); //
// // ACHTUNG: blockiert NICHT!!!!
//Umwandlung der Byteströme // out.println("Server an Client: Nachricht erhalten");
InputStreamReader isr = new InputStreamReader(is, "UTF-8"); // out.flush(); // wichtig
OutputStreamWriter osr = new OutputStreamWriter(os, "UTF-8"); //
// lg.info("Server: fertig");
//Puffer // in.close();
BufferedReader in = new BufferedReader(isr); // out.close();
//BufferedWriter out = new BufferedWriter(osr); // s.close();
//besser
PrintWriter out = new PrintWriter(osr);
lg.info("Server: Streams erfolgreich initialisiert");
lg.info("Server: warte auf Textnachricht");
String nachricht = in.readLine(); // ACHTUNG blockiert
lg.info("Server: Nachricht erhalten");
System.out.println("Server: NACHRICHT = " + nachricht);
// ACHTUNG: blockiert NICHT!!!!
out.println("Server an Client: Nachricht erhalten");
out.flush(); // wichtig
lg.info("Server: fertig");
in.close();
out.close();
s.close();
} }
/** /**