Differences

This shows you the differences between two versions of the page.

--- java:sockets [2015/03/24 09:14] – gthanos
+++ java:sockets [Unknown date] (current) – external edit (Unknown date) 127.0.0.1
@@ Line 7: / Line 7: @@
 {{ :java:socket-connect.png |}}
+Το πακέτο java.net της Java παρέχει την κλάση, [[http://docs.oracle.com/javase/7/docs/api/java/net/Socket.html|Socket]], που υλοποιεί μία πλευρά μίας αμφίδρομης σύνδεσης μεταξύ ενός προγράμματος σε Java και ενός άλλου προγράμματος (όχι απαραίτητα σε java) μέσα από το δίκτυο. Η κλάση Socket χρησιμοποιεί την υποδομή των sockets του λειτουργικού συστήματος, κρύβοντας τις λεπτομέρειες του κάθε συστήματος από το πρόγραμμα σας και απαιτώντας ένα ενιαίο API ανεξάρτητα από το λειτουργικό σύστημα που βρίσκεται από κάτω. Επιπλέον, η Java περιλαμβάνει την κλάση [[http://docs.oracle.com/javase/7/docs/api/java/net/ServerSocket.html|ServerSocket]], η οποία υλοποιεί ένα server-side socket το οποίο ακούει σε συγκεκριμένη πόρτα, ώστε να αποδέχεται συνδέσεις από τον έξω κόσμο.
+Δείτε τα παρακάτω προγράμματα πελάτη/εξυπηρετητή τα οποία επικοινωνούν μεταξύ τους. Συγκεκριμένα ο πελάτης συνδέεται στον εξυπηρετητή και αποστέλλει περιεχόμενο το οποίο διαβάζει από το standard input. Ο εξυπηρετητής διαβάζει αυτό που του έστειλε ο πελάτης και του το επιστρέφει πίσω. Ο πελάτης λαμβάνει τελικά πίσω αυτό που αρχικά έστειλε στον εξυπηρετητή.
+<code java EchoServer.java>
+import java.net.*;
+import java.io.*;
+public class EchoServer {
+  public static void main(String[] args) throws IOException {
+    if (args.length != 1) {
+      System.err.println("Usage: java EchoServer <port number>");
+      System.exit(1);
+    }
+    int portNumber = Integer.parseInt(args[0]);
+    try (
+      ServerSocket serverSocket =
+        new ServerSocket(Integer.parseInt(args[0]));
+      Socket clientSocket = serverSocket.accept();
+      PrintWriter out =
+        new PrintWriter(clientSocket.getOutputStream(), true);
+      BufferedReader in = new BufferedReader(
+        new InputStreamReader(clientSocket.getInputStream()));
+    ) {
+      String inputLine;
+      while ((inputLine = in.readLine()) != null) {
+        out.println(inputLine);
+        System.out.println("echoing: "+inputLine);
+      }
+    } catch (IOException e) {
+      System.out.println("Exception caught when trying to listen on port "
+        + portNumber + " or listening for a connection");
+      System.out.println(e.getMessage());
+    }
+  }
+}
+</code>
+<code java EchoClient.java>
+import java.io.*;
+import java.net.*;
+public class EchoClient {
+  public static void main(String[] args) throws IOException {
+    if (args.length != 2) {
+      System.err.println(
+        "Usage: java EchoClient <host name> <port number>");
+      System.exit(1);
+    }
+    String hostName = args[0];
+    int portNumber = Integer.parseInt(args[1]);
+    try (
+      Socket echoSocket = new Socket(hostName, portNumber);
+      PrintWriter out = new PrintWriter(echoSocket.getOutputStream(), true);
+      BufferedReader in = new BufferedReader( new InputStreamReader(echoSocket.getInputStream() ));
+      BufferedReader stdIn = new BufferedReader( new InputStreamReader(System.in));
+    ) {
+      String userInput;
+      while ((userInput = stdIn.readLine()) != null) {
+        out.println(userInput);
+        System.out.println("echoed : "+in.readLine());
+      }
+    } catch (UnknownHostException e) {
+      System.err.println("Don't know about host " + hostName);
+      System.exit(1);
+    } catch (IOException e) {
+      System.err.println("Couldn't get I/O for the connection to " +
+        hostName);
+      System.exit(1);
+    }
+  }
+}
+</code>
+Για να εκτελέσετε τα δύο προγράμματα θα πρέπει να εκκινήσετε πρώτα το //EchoServer// δηλώνοντας το port στο οποίο θα ακούει (π.χ. ''java EchoServer 8888''). Στην συνέχεια εκκινείτε το //EchoClient// ως εξής ''java EchoClient localhost 8888''.
+Δύο παραλλαγές των παρακάτω προγραμμάτων είναι η παρακάτω. Στο πρόγραμμα //EchoClient.java// πρώτα δημιουργείται το socket και μετά γίνεται connect σε συγκεκριμένη διεύθυνση (hostname, portnumber). Αντίστοιχα στο πρόγραμμα //EchoServer// πρώτα δημιουργείται το socket και στη συνέχεια γίνεται bind το server socket σε συγκεκριμένη διεύθυνση ("localhost", portnumber).
+<code java EchoServer.java>
+import java.net.*;
+import java.io.*;
+public class EchoServer {
+  public static void main(String[] args) throws IOException {
+    if (args.length != 1) {
+      System.err.println("Usage: java EchoServer <port number>");
+      System.exit(1);
+    }
+    int portNumber = Integer.parseInt(args[0]);
+    try (
+      ServerSocket serverSocket = new ServerSocket();
+    ) {
+      serverSocket.bind(new InetSocketAddress("localhost", Integer.parseInt(args[0]) ) );
+      try (
+        Socket clientSocket = serverSocket.accept();
+        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
+        BufferedReader in = new BufferedReader( new InputStreamReader(clientSocket.getInputStream()));
+      ) {
+      // no catch here
+        System.out.println("Connected to "+clientSocket.getInetAddress().toString()+":"+clientSocket.getPort());
+        String inputLine;
+        while ((inputLine = in.readLine()) != null) {
+          out.println(inputLine);
+          System.out.println("echoing: "+inputLine);
+        }
+      } catch (IOException e) {
+        System.out.println("Exception caught when trying to listen on port "
+          + portNumber + " or listening for a connection");
+        System.out.println(e.getMessage());
+      }
+    }
+  }
+}
+</code>
+<code java EchoClient.java>
+import java.io.*;
+import java.net.*;
+public class EchoClient {
+  public static void main(String[] args) throws IOException {
+    if (args.length != 2) {
+      System.err.println(
+        "Usage: java EchoClient <host name> <port number>");
+      System.exit(1);
+    }
+    String hostName = args[0];
+    int portNumber = Integer.parseInt(args[1]);
+    InetSocketAddress socketAddress = new InetSocketAddress(hostName, portNumber);
+    try (
+      Socket echoSocket = new Socket();
+      BufferedReader stdIn =
+        new BufferedReader(
+          new InputStreamReader(System.in));
+    ) {
+      echoSocket.connect(socketAddress);
+      System.out.println("Connected to "+echoSocket.getInetAddress().toString()+":"+echoSocket.getPort());
+      try (
+        PrintWriter out = new PrintWriter(echoSocket.getOutputStream(), true);
+        BufferedReader in = new BufferedReader( new InputStreamReader(echoSocket.getInputStream() ));
+      ) {
+        String userInput;
+        while ((userInput = stdIn.readLine()) != null) {
+          out.println(userInput);
+          System.out.println("echoed: "+in.readLine());
+        }
+      }
+      // no catch
+    } catch (UnknownHostException e) {
+      System.err.println("Don't know about host " + hostName);
+      System.exit(1);
+    } catch (IOException e) {
+      System.err.println("Couldn't get I/O for the connection to " +
+        hostName);
+      System.exit(1);
+    }
+  }
+}
+</code>
+|Προηγούμενο: [[:java:object_serialization| Object Serialization/Deserialization ]] | [[:toc | Περιεχόμενα ]] | Επόμενο: [[:java:urls| URLs ]]|