Multicast Datagram Quotes threads

Author: begandroide

MulticastDatagram/Makefile

@@ -0,0 +1,8 @@
+javac ./*.java
+
+clean:
+	rm ./*.class
+    
+run:
+	java MulticastServer &
+	java MulticastClient localhost

MulticastDatagram/MulticastClient.java

@@ -0,0 +1,26 @@
+
+import java.io.*;
+import java.net.*;
+
+public class MulticastClient {
+    public static void main(String[] args) throws IOException {
+        
+        //create a MulticastSocket
+        MulticastSocket multiSocket = new MulticastSocket(4446);
+        InetAddress address = InetAddress.getByName("230.0.0.1");
+        multiSocket.joinGroup(address);
+
+        DatagramPacket packet;
+
+        for(int i = 0; i < 5; i++){
+            byte[] buf = new byte[256];
+            packet = new DatagramPacket(buf, buf.length);
+            multiSocket.receive(packet);
+
+            String received = new String(packet.getData(),0,packet.getLength());
+            System.out.println("Cita del momento: " + received);
+        }
+        multiSocket.leaveGroup(address);
+        multiSocket.close();
+    }
+}

MulticastDatagram/MulticastServer.java

@@ -0,0 +1,8 @@
+
+import java.io.*;
+
+public class MulticastServer {
+    public static void main(String[] args) throws IOException {
+        new MulticastServerThread().start();       
+    }
+}

MulticastDatagram/MulticastServerThread.java

@@ -0,0 +1,48 @@
+
+import java.net.*;
+import java.util.Date;
+import java.io.*;
+
+public class MulticastServerThread extends QuoteServerThread {
+
+    private long FIVE_SECONDS = 5000;
+
+    public MulticastServerThread() throws IOException{
+        super("MulticastServerThread");
+    }
+
+    public void run(){
+        while(moreQuotes){
+            try {
+                byte[] buf = new byte[256];
+                
+                //resolver y enviar respuesta
+                String dString = null;
+                if(in == null){
+                    dString = new Date().toString();
+                } else{
+                    dString = getNextQuote();
+                }
+
+                buf = dString.getBytes();
+
+                //debemos enviar la respuesta a los cliente
+                // se debe saber dirección del cliente y puerto desde donde llegó 
+                // la request
+                InetAddress groupAddress = InetAddress.getByName("230.0.0.1");
+                
+                DatagramPacket packet = new DatagramPacket(buf, buf.length,groupAddress,4446);
+                socket.send(packet); 
+                try {
+                    sleep((long)(Math.random() * FIVE_SECONDS));
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+                moreQuotes = false;
+            }
+        }
+    }
+
+}

MulticastDatagram/QuoteServerThread.java

@@ -0,0 +1,73 @@
+
+import java.net.*;
+import java.util.Date;
+import java.io.*;
+
+public class QuoteServerThread extends Thread {
+    protected DatagramSocket socket = null;
+    protected BufferedReader in = null;
+    protected Boolean moreQuotes = true;
+
+    public QuoteServerThread() throws IOException{
+        this("QuoteServerThread");
+    }
+
+    public QuoteServerThread(String name) throws IOException {
+        super(name);
+        socket = new DatagramSocket(4445);
+
+        try {
+            in =  new BufferedReader(new FileReader("one-liniers.txt"));            
+        } catch (FileNotFoundException e) {
+            System.err.println("No podemos abrir el archivo. Server time en cambio.");
+        }
+    }
+
+    public void run(){
+        while(moreQuotes){
+            try {
+                byte[] buf = new byte[256];
+                //recibir datagrama
+                DatagramPacket packet = new DatagramPacket(buf, buf.length);
+                socket.receive(packet);
+
+                //resolver y enviar respuesta
+                String dString = null;
+                if(in == null){
+                    dString = new Date().toString();
+                } else{
+                    dString = getNextQuote();
+                }
+
+                buf = dString.getBytes();
+
+                //debemos enviar la respuesta al cliente
+                // se debe saber dirección del cliente y puerto desde donde llegó 
+                // la request
+                InetAddress iAddress = packet.getAddress();
+                int port  = packet.getPort();
+                packet = new DatagramPacket(buf, buf.length,iAddress,port);
+                socket.send(packet); 
+            } catch (IOException e) {
+                e.printStackTrace();
+                moreQuotes = false;
+            }
+        }
+    }
+
+    protected String getNextQuote(){
+        String returnValue = null;
+        try {
+            if((returnValue = in.readLine()) == null){
+                in.close();
+                moreQuotes = false;
+                returnValue = "No more Quotes, Good Bye";
+            }
+        } catch (IOException e) 
+        {
+            returnValue = "IOException en obtener nueva cita en servidor";
+        }
+        return returnValue;
+    }
+
+}

MulticastDatagram/one-liniers.txt

@@ -0,0 +1,3 @@
+Buena compare'
+single quote element
+jaulas