分布式通信-tcp/ip 广播 J, k- K# _; S3 K
9 ^6 e) _' y/ e3 h: `/ e( K
服务端 /** * 广播 */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(); } }}
$ c+ V" J2 y* ?" v( L客户端,可以同时有多个客户端 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(); } }}
2 ^! S* \& X/ d6 @7 U# F
: z0 K$ g0 R& d& L [0 K/ @4 ^7 i! S+ _4 u4 m
转载于:https://www.cnblogs.com/newlangwen/p/10383850.html
" ?; ]) e1 a6 w# h& v F1 d5 X, G/ @9 D) x; B
|