From 1defd31146359995059da81302c1121179698c8d Mon Sep 17 00:00:00 2001
From: Gerhard Switalski <gerhardswitalski@live.de>
Date: Sat, 15 Dec 2018 11:45:39 +0100
Subject: [PATCH] =?UTF-8?q?Klassen=20in=20Model=20angelegt.=20Transmitter?=
 =?UTF-8?q?=20soll=20H=C3=A4ndler=20zwischen=20Client=20Thread=20und=20Ser?=
 =?UTF-8?q?ver=20Thread=20werden.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chatprogramm/model/Client.java      | 77 +++++++++++++++++++++++++
 src/chatprogramm/model/Server.java      | 77 +++++++++++++++++++++++++
 src/chatprogramm/model/Transmitter.java | 19 ++++++
 3 files changed, 173 insertions(+)
 create mode 100644 src/chatprogramm/model/Client.java
 create mode 100644 src/chatprogramm/model/Server.java
 create mode 100644 src/chatprogramm/model/Transmitter.java

diff --git a/src/chatprogramm/model/Client.java b/src/chatprogramm/model/Client.java
new file mode 100644
index 0000000..b1de18c
--- /dev/null
+++ b/src/chatprogramm/model/Client.java
@@ -0,0 +1,77 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+
+package chatprogramm.model;
+
+import chatprogramm.logger.OhmLogger;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.PrintWriter;
+import java.net.Socket;
+import java.util.logging.Logger;
+
+/**
+ * Builder Class
+ * @author le
+ */
+public class Client
+{
+  private static final Logger lg = OhmLogger.getLogger();
+  private static final int PORT = 35000;
+  private static final String IP_ADRESSE = "127.0.0.1";
+  
+  public Client() throws IOException
+  {
+    lg.info("Client: verbinde ...");
+    Socket s = new Socket(IP_ADRESSE, PORT); // Achtung: blockiert!
+    lg.info("Client: Verbindung hergestellt");
+    InputStream iStream = s.getInputStream();
+    OutputStream oStream = s.getOutputStream();
+    
+    InputStreamReader isr = new InputStreamReader(iStream, "UTF-8");
+    OutputStreamWriter osr = new OutputStreamWriter(oStream, "UTF-8");
+    
+    BufferedReader in = new BufferedReader(isr);
+    //BufferedWriter out = new BufferedWriter(osr);
+    PrintWriter out = new PrintWriter(osr);
+    
+    lg.info("Client: Stream initialisiert");
+    
+    out.println("Hallo Du Server Du - ich bin der client");
+    out.flush(); // wirklich absenden!!
+    
+    lg.info("Client: Nachricht versendet");
+    
+    String quittung = in.readLine(); // Achtung blockiert
+    lg.info("Client: Quittung empfangen");
+
+    System.out.println("Client: Quittung EMPFANGEN - " + quittung);
+
+    
+    
+    out.close();
+    in.close();
+  }
+
+  /**
+   * @param args the command line arguments
+   */
+  public static void main(String[] args) 
+  {
+    try
+    {
+      new Client();
+    }
+    catch (IOException ex)
+    {
+      lg.severe(ex.toString());
+    }
+  }
+}
diff --git a/src/chatprogramm/model/Server.java b/src/chatprogramm/model/Server.java
new file mode 100644
index 0000000..f762176
--- /dev/null
+++ b/src/chatprogramm/model/Server.java
@@ -0,0 +1,77 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+
+package chatprogramm.model;
+
+import chatprogramm.logger.OhmLogger;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.PrintWriter;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.logging.Logger;
+
+/**
+ * Builder Class
+ * @author le
+ */
+public class Server
+{
+  private static final Logger lg = OhmLogger.getLogger();
+  private static final int PORT = 35000;
+  
+  public Server() throws IOException
+  {
+    ServerSocket sSocket = new ServerSocket(PORT);  
+    lg.info("Server: Warte auf Verbindung ...");
+    Socket s = sSocket.accept(); // Achtung: blockiert!
+    lg.info("Server: Verbindung akzeptiert");
+    InputStream iStream = s.getInputStream();
+    OutputStream oStream = s.getOutputStream();
+    
+    InputStreamReader isr = new InputStreamReader(iStream, "UTF-8");
+    OutputStreamWriter osr = new OutputStreamWriter(oStream, "UTF-8");
+    
+    BufferedReader in = new BufferedReader(isr);
+    //BufferedWriter out = new BufferedWriter(osr);
+    PrintWriter out = new PrintWriter(osr);
+    
+    lg.info("Server: Stream initialisiert");
+    lg.info("Server: warte auf Nachricht ...");
+    
+    String nachricht = in.readLine(); // Achtung blockiert
+    lg.info("Server: Nachricht empfangen");
+
+    System.out.println("Server: NACHRICHT EMPFANGEN - " + nachricht);
+
+    out.println("Server -> ich habe die Nachricht erhalten");
+    lg.info("Server: Quittung versendet");
+    
+    out.flush(); // wirklich absenden!!
+    
+    out.close();
+    in.close();
+  }
+
+  /**
+   * @param args the command line arguments
+   */
+  public static void main(String[] args) 
+  {
+    try
+    {
+      new Server();
+    }
+    catch (IOException ex)
+    {
+      lg.severe(ex.toString());
+    }
+  }
+}
diff --git a/src/chatprogramm/model/Transmitter.java b/src/chatprogramm/model/Transmitter.java
new file mode 100644
index 0000000..06efa61
--- /dev/null
+++ b/src/chatprogramm/model/Transmitter.java
@@ -0,0 +1,19 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+
+package chatprogramm.model;
+
+/**
+ *
+ * @author Gerhard
+ */
+public class Transmitter
+{
+  public Transmitter()
+  {
+
+  }
+}