commit Exercise_31_04

csv77 · csv77 · commit f61381002c9f · 2017-10-05T19:40:15.000+02:00
diff --git a/Chapter_31/exercise_31_04Client/Exercise_31_04Client.java b/Chapter_31/exercise_31_04Client/Exercise_31_04Client.java
@@ -0,0 +1,37 @@
+package exercise_31_04Client;
+
+import java.io.DataInputStream;
+import java.io.IOException;
+import java.net.Socket;
+import javafx.application.Application;
+import javafx.scene.Scene;
+import javafx.scene.control.Label;
+import javafx.scene.layout.BorderPane;
+import javafx.stage.Stage;
+
+public class Exercise_31_04Client extends Application {
+    private Label lbl = new Label();
+    
+    @Override
+    public void start(Stage primaryStage) {
+        Scene scene = new Scene(new BorderPane(lbl), 200, 50);
+        primaryStage.setTitle("Exercise_31_04Client");
+        primaryStage.setScene(scene);
+        primaryStage.show();
+        
+        try {
+            Socket socket = new Socket("localhost", 8000);
+            DataInputStream inputFromServer = new DataInputStream(socket.getInputStream());
+            int count = inputFromServer.readInt();
+            lbl.setText("You are visitor " + count);
+        }
+        catch (IOException ex) {
+            ex.printStackTrace();
+        }
+    }
+
+    public static void main(String[] args) {
+        launch(args);
+    }
+
+}
diff --git a/Chapter_31/exercise_31_04Server/Exercise_31_04Server.java b/Chapter_31/exercise_31_04Server/Exercise_31_04Server.java
@@ -0,0 +1,106 @@
+package exercise_31_04Server;
+
+import java.io.DataOutputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.RandomAccessFile;
+import java.net.InetAddress;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.Date;
+import javafx.application.Application;
+import javafx.application.Platform;
+import javafx.scene.Scene;
+import javafx.scene.control.ScrollPane;
+import javafx.scene.control.TextArea;
+import javafx.stage.Stage;
+
+public class Exercise_31_04Server extends Application {
+    private TextArea taStatus = new TextArea();
+    private int visitorCount;
+    private RandomAccessFile raf;
+    
+    @Override
+    public void start(Stage primaryStage) {
+        taStatus.setWrapText(true);
+        Scene scene = new Scene(new ScrollPane(taStatus), 370, 200);
+        primaryStage.setTitle("Exercise_31_04Server");
+        primaryStage.setScene(scene);
+        primaryStage.show();
+        
+        try {
+            raf = new RandomAccessFile("visitorcount.dat", "rw");
+            if(raf.length() == 0) {
+                visitorCount = 0;
+            }
+            else {
+                visitorCount = raf.readInt();
+            }
+        }
+        catch (FileNotFoundException ex) {
+            ex.printStackTrace();
+        }
+        catch (IOException ex) {
+            ex.printStackTrace();
+        }
+        
+        new Thread(() -> {
+            try {
+                ServerSocket serverSocket = new ServerSocket(8000);
+                Platform.runLater(() -> taStatus.appendText("Exercise_31_04Server started at " + new Date() + "\n"));
+                
+                int i = 0;
+                while(true) {
+                    int threadNumber = i;
+                    Socket socket = serverSocket.accept();
+                    InetAddress inetAddress = socket.getInetAddress();
+                    
+                    Platform.runLater(() -> taStatus.appendText("Starting thread " + threadNumber +
+                            "\nClient IP /" + inetAddress.getHostAddress() + "\n"));
+                    
+                    new Thread(new HandleAClient(socket)).start();
+                    i++;
+                }
+                
+            }catch (IOException ex) {
+                ex.printStackTrace();
+            }
+        }).start();
+    }
+    
+    public synchronized int modifyFile() {
+        try {
+            raf.seek(0);
+            raf.writeInt(++visitorCount);
+        }
+        catch (IOException ex) {
+            ex.printStackTrace();
+        }
+        return visitorCount;
+    }
+
+    private class HandleAClient implements Runnable {
+        private Socket socket;
+
+        public HandleAClient(Socket socket) {
+            this.socket = socket;
+        }
+        
+        @Override
+        public void run() {
+            try {
+                DataOutputStream outputToClient = new DataOutputStream(socket.getOutputStream());
+                int i = modifyFile();
+                outputToClient.writeInt(i);
+            }
+            catch (IOException ex) {
+                ex.printStackTrace();
+            }
+        }
+    }
+    
+    public static void main(String[] args) {
+        launch(args);
+    }
+
+}
