# HG changeset patch # User Yu Taninari # Date 1321938169 -32400 # Node ID e66137b514eb79f55aa89d3be006472fff760ada # Parent 40efe6c25ff60aada77cee9b7b2fb3d0aef1ef42 add BroadCast.java diff -r 40efe6c25ff6 -r e66137b514eb src/myVncClient/BroadCast.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/myVncClient/BroadCast.java Tue Nov 22 14:02:49 2011 +0900 @@ -0,0 +1,57 @@ +package myVncClient; + +import java.io.IOException; +import java.net.DatagramPacket; +import java.net.InetAddress; +import java.net.MulticastSocket; +import java.net.UnknownHostException; + +public class BroadCast implements Runnable { + final int BUFSIZE = 1024; + final String MCASTADDR = "224.0.0.1"; + final int PORT = 8183; + private byte[] buf = new byte[BUFSIZE]; + private InetAddress mAddr; + private MulticastSocket soc; + private String str; + + public BroadCast(String _str) { + str = _str; + } + + void createSocket() { + try { + mAddr = InetAddress.getByName(MCASTADDR); + soc = new MulticastSocket(); + soc.setTimeToLive(1); + } catch (IOException e) { + e.printStackTrace(); + } + } + + void sendData() { + buf = str.getBytes(); + // System.out.println("strlen"+str.length()); + // System.out.println("str"+str); + DatagramPacket sendPacket = new DatagramPacket(buf, str.length(), + mAddr, PORT); + try { + soc.send(sendPacket); + } catch (IOException e) { + e.printStackTrace(); + } + } + + @Override + public void run() { + createSocket(); + while (true) { + sendData(); + try { + Thread.sleep(2000); + } catch (InterruptedException e) { + System.out.println(e); + } + } + } +}