分布式通信-tcp/ip 广播

杨利霞

分布式通信-tcp/ip 广播
3 U2 q1 z& E7 _3 ]8 I6 I* x# P- V& g
# T9 c4 t! }5 u( N

服务端

/** *  广播 */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();        }    }}
3 V5 d7 X, l: W1 J

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

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();        }    }}

3 F2 C0 S, d  E7 w( r* K

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

) b4 k) D$ s( D6 ?8 s. v
$ Y1 q8 E: \$ ^9 a1 E( ]+ c