Homework2

projects/Assignments/homework2/MaroonMulticastReceiver.java

@@ -3,6 +3,11 @@
 
 import java.io.*;
 import java.net.*;
+import javax.swing.*;
+import java.awt.*;
+import java.awt.event.ActionEvent;
+import java.awt.event.ActionListener;
+
 
 /**
  *
@@ -14,57 +19,78 @@ public class MaroonMulticastReceiver {
     public static final int DESTINATION_PORT = 1717;
     /** How many routers can be crossed */
     public static final int TTL = 10; 
-    
+      
     public static void main(String[] args) 
     {
-        try
-        {
+        JFrame guiFrame = new JFrame();
+        guiFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
+        guiFrame.setTitle("Read a message");
+        guiFrame.setSize(300,250);
+        guiFrame.setLocationRelativeTo(null);
+        
+        final JPanel output = new JPanel();
+        output.setVisible(true);
+        JLabel outputLbl= new JLabel("Hit the Button");
+        output.add(outputLbl);
+        
+        JButton MCButton = new JButton( "Push Me");
+ 
+        MCButton.addActionListener(new ActionListener(){
+            @Override
+            public void actionPerformed(ActionEvent event){
+                try {
         
-            // This is a java/IPv6 problem. You should also add it to the
-            // arguments used to start the app, eg -Djava.net.preferIPv4Stack=true
-            // set in the "run" section of preferences. Also, typically
-            // netbeans must be restarted after these settings.
-            // https://stackoverflow.com/questions/18747134/getting-cant-assign-requested-address-java-net-socketexception-using-ehcache
-            System.setProperty("java.net.preferIPv4Stack", "true");
+                    // This is a java/IPv6 problem. You should also add it to the
+                    // arguments used to start the app, eg -Djava.net.preferIPv4Stack=true
+                    // set in the "run" section of preferences. Also, typically
+                    // netbeans must be restarted after these settings.
+                    // https://stackoverflow.com/questions/18747134/getting-cant-assign-requested-address-java-net-socketexception-using-ehcache
+                    System.setProperty("java.net.preferIPv4Stack", "true");
             
             
-            MulticastSocket multicastSocket = new MulticastSocket(DESTINATION_PORT);
-            multicastSocket.setTimeToLive(TTL);
-            InetAddress multicastAddress = InetAddress.getByName(MULTICAST_ADDRESS);
-            System.out.println(multicastAddress);            
-            // Join group useful on receiving side
-            multicastSocket.joinGroup(multicastAddress);
-            // You can join multiple groups here
+                    MulticastSocket multicastSocket = new MulticastSocket(DESTINATION_PORT);
+                    multicastSocket.setTimeToLive(TTL);
+                    InetAddress multicastAddress = InetAddress.getByName(MULTICAST_ADDRESS);
+                    System.out.println(multicastAddress);            
+                    // Join group useful on receiving side
+                    multicastSocket.joinGroup(multicastAddress);
+                    // You can join multiple groups here
             
-            int count = 0;
+                    int count = 0;
             
-            while(true)
-            {
-                byte[] packetArray = new byte[1500];
-                DatagramPacket packet = new DatagramPacket(packetArray, packetArray.length);
+                    byte[] packetArray = new byte[1500];
+                    DatagramPacket packet = new DatagramPacket(packetArray, packetArray.length);
                 
-                multicastSocket.receive(packet);
-                count++;
+                    multicastSocket.receive(packet);
+                    count++;
                 
-                ByteArrayInputStream bais = new ByteArrayInputStream(packet.getData());
-                DataInputStream dis = new DataInputStream(bais);
-                int firstNumber = dis.readInt();
-                int messageLength = dis.readInt();
-                String message = "";
-                    for (int i = 0; i < messageLength; i++){
-                        message += dis.readChar();
-                    }
+                    ByteArrayInputStream bais = new ByteArrayInputStream(packet.getData());
+                    DataInputStream dis = new DataInputStream(bais);
+                    int firstNumber = dis.readInt();
+                    int messageLength = dis.readInt();
+                    String message = "";
+                        for (int i = 0; i < messageLength; i++){
+                            message += dis.readChar();
+                        }
               
                    
+                    outputLbl.setText(message);
                 
-                
-                System.out.println("Number received: " + count + " First number:" + firstNumber + " message:" + message);
+                    System.out.println("Number received: " + count + " First number:" + firstNumber + " message:" + message);     
+                }
+                catch(Exception e){
+                    System.out.println(e);
+                 }
             }
         }
-        catch(Exception e)
-        {
-            System.out.println(e);
-        }
+        );
+ 
+  
+        guiFrame.add(output, BorderLayout.CENTER);
+        guiFrame.add(MCButton,BorderLayout.NORTH);
+        guiFrame.setVisible(true);
+        
+
     }
     
 }

projects/Assignments/homework2/MaroonMulticastSenderExample.java

@@ -43,7 +43,7 @@ public class MaroonMulticastSenderExample {
             ByteArrayOutputStream baos = new ByteArrayOutputStream();
             DataOutputStream dos = new DataOutputStream(baos);
             dos.writeInt(1);
-            String message = "Hammertime";
+            String message = "**********************************";
             dos.writeInt(message.length());
             dos.writeChars(message);
             byte[] buffer = baos.toByteArray();
@@ -52,7 +52,7 @@ public class MaroonMulticastSenderExample {
             
             baos.reset();
             dos.writeInt(2);
-            message = "Collaberate and Listen";
+            message = "<===========================>";
             
             dos.writeInt(message.length());
             dos.writeChars(message);