分布式通信-tcp/ip 广播

杨利霞

分布式通信-tcp/ip 广播

/ v6 e" V" N- f. T/ R' I

服务端

/** *  广播 */public class MulticastServer {    public static void main(String[] args) {        try {            //地址是224.0.0.0 --239.255.255.255            InetAddress group = InetAddress.getByName("225.0.0.0");            MulticastSocket socket = new MulticastSocket();            for(int i=0;i<10;i++){                String data ="hello world";                byte[] bytes = data.getBytes();                socket.send(new DatagramPacket(bytes,bytes.length,group,8888));                System.out.println("send data");                TimeUnit.SECONDS.sleep(2);            }        } catch (UnknownHostException e) {            e.printStackTrace();        } catch (IOException e) {            e.printStackTrace();        } catch (InterruptedException e) {            e.printStackTrace();        }    }}
) d7 x1 S# b( B9 ?! q. X

客户端，可以同时有多个客户端

public class MulticastClient {    public static void main(String[] args) {        //地址是224.0.0.0 --239.255.255.255        try {            InetAddress group = InetAddress.getByName("225.0.0.0");            MulticastSocket socket = new MulticastSocket(8888);            socket.joinGroup(group); // 加到指定的組裡面            byte[] buf = new byte[256];            while (true){                DatagramPacket msgPacket = new DatagramPacket(buf, buf.length);                //读不到一直处于阻塞状态                socket.receive(msgPacket);                System.out.println("receive data");                String msg = new String(msgPacket.getData());                System.out.println("接收到的数据："+msg);            }        } catch (UnknownHostException e) {            e.printStackTrace();        } catch (IOException e) {            e.printStackTrace();        }    }}
9 o! r5 J6 L6 C, ~1 H

$ S& R) q0 L& T  _2 V

转载于:https://www.cnblogs.com/newlangwen/p/10383850.html

* H) d% t6 _* |& f