Java Threads

nikonst · web-flow · commit 0589b95a4c04 · 2018-12-19T21:17:30.000+02:00
diff --git a/Threads/GreetingClient.java b/Threads/GreetingClient.java
@@ -0,0 +1,36 @@
+package myjavanet;
+
+/**
+ *
+ * @author Nikos Konstantakis
+ */
+
+import java.net.*;
+import java.io.*;
+
+public class GreetingClient {
+    
+    // File Name GreetingClient.java
+
+   public static void main(String [] args) {
+      String serverName = args[0];
+      int port = Integer.parseInt(args[1]);
+      try {
+         System.out.println("Connecting to " + serverName + " on port " + port);
+         Socket client = new Socket(serverName, port);
+         
+         System.out.println("Just connected to " + client.getRemoteSocketAddress());
+         OutputStream outToServer = client.getOutputStream();
+         DataOutputStream out = new DataOutputStream(outToServer);
+         
+         out.writeUTF("Hello from " + client.getLocalSocketAddress());
+         InputStream inFromServer = client.getInputStream();
+         DataInputStream in = new DataInputStream(inFromServer);
+         
+         System.out.println("Server says " + in.readUTF());
+         client.close();
+      } catch (IOException e) {
+         e.printStackTrace();
+      }
+   }
+}
diff --git a/Threads/GreetingServer.java b/Threads/GreetingServer.java
@@ -0,0 +1,57 @@
+package myjavanet;
+
+/**
+ *
+ * @author Nikos Konstantakis
+ */
+
+import java.net.*;
+import java.io.*;
+
+public class GreetingServer extends Thread {
+    
+    // File Name GreetingServer.java
+
+   private ServerSocket serverSocket;
+   
+   public GreetingServer(int port) throws IOException {
+      serverSocket = new ServerSocket(port);
+      serverSocket.setSoTimeout(60000);
+   }
+
+   public void run() {
+      while(true) {
+         try {
+            System.out.println("Waiting for client on port " + serverSocket.getLocalPort() + "...");
+            Socket server = serverSocket.accept();
+            
+            System.out.println("Just connected to " + server.getRemoteSocketAddress());
+            DataInputStream in = new DataInputStream(server.getInputStream());
+            
+            System.out.println(in.readUTF());
+            DataOutputStream out = new DataOutputStream(server.getOutputStream());
+            out.writeUTF("Thank you for connecting to " + server.getLocalSocketAddress()
+               + "\nGoodbye!");
+            server.close();
+            
+         } catch (SocketTimeoutException s) {
+            System.out.println("Socket timed out!");
+            break;
+         } catch (IOException e) {
+            e.printStackTrace();
+            break;
+         }
+      }
+   }
+   
+   public static void main(String [] args) {
+      int port = Integer.parseInt(args[1]);
+      System.out.println(args[0]);
+      try {
+         Thread t = new GreetingServer(port); // t is a thread
+         t.start(); // calls the run function
+      } catch (IOException e) {
+         e.printStackTrace();
+      }
+   }
+}
diff --git a/Threads/MyJavaNet.java b/Threads/MyJavaNet.java
@@ -0,0 +1,22 @@
+package myjavanet;
+
+/**
+ *
+ * @author Nikos Konstantakis
+ */
+
+public class MyJavaNet {
+    /**
+     * @param args the command line arguments
+     */
+    public static void main(String[] args) {
+        // TODO code application logic here
+        if(args.length != 0) {
+            System.out.println("Arg 0:"+args[0]);
+            System.out.println("Arg 1:"+args[1]);
+        }
+        else {
+            System.out.println("No arguments");
+        }
+    } 
+}
