java p2p 测试代码

import java.net.DatagramPacket; import java.net.InetAddress; import java.net.MulticastSocket; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; public class p2 { public static void main(String[] args) { ArrayList arrayList= new ArrayList(); List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); System.out.printf("启动p2"); int port = 9090; String address = "224.0.0.1"; String data = "hello lai_p2"; try { byte[] buffer = new byte[1024]; InetAddress ip = InetAddress.getByName(address); DatagramPacket packet = new DatagramPacket(data.getBytes(), data.length(), ip, port); MulticastSocket ms = new MulticastSocket(); ms.send(packet); MulticastSocket socket = new MulticastSocket(9090); socket.joinGroup(ip); socket.receive(packet); System.out.println("聊天信息：" + new String(packet.getData(), 0, packet.getLength())); ms.close(); } catch (Exception e) { e.printStackTrace(); } } }