UDP数据交互

public static void main(String[] args) {
        // 1、创建一个服务器 套接字
        DatagramSocket server = null;
        try {
            server = new DatagramSocket(18899);
            // 2、定一个字节 数组来接收数据
            byte[] data = new byte[1024];
            // 3、定义一个数据包对象
            DatagramPacket recePacket = new DatagramPacket(data, data.length);
            // 4、阻塞式的接收
            server.receive(recePacket);
            System.out.println("*************客户端来消息了***********");
            // 5、打印消息
            String msg = new String(recePacket.getData(), 0,
                    recePacket.getLength());
            // 6、向发过来的那个客户端回复点消息
            InetAddress addr = recePacket.getAddress(); // 客户端的IP
            int port = recePacket.getPort(); // 客户端的端口号
            System.out.println(addr.toString()+"-"+port+":客户端发过来的消息是：" + msg);
            // 7、回复 :收到了
            String str = "收到了";
            byte[] buf = str.getBytes();
            // 8、创建一个发送的报文
            DatagramPacket sendPacket = new DatagramPacket(buf, buf.length,
                    addr, port);
            server.send(sendPacket);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (server != null) {
                server.close();
            }
        }
    }

public static void main(String[] args) {
        //创建一个客户端 
        DatagramSocket client=null;
        try {
            client=new DatagramSocket();
            //向服务器发送消息
            String str="客户端测试消息!";
            byte[] buf=str.getBytes();
            //3、定义服务器的IP
            InetAddress addr=InetAddress.getByName("192.168.16.171");
            //4、创建一个数据报对象
            DatagramPacket sendPacket=new DatagramPacket(buf, buf.length, addr, 18899);
            //5、发送消息
            client.send(sendPacket);
            //6、客户端等待服务器发送过来的消息
            byte[] data=new byte[1024];
            DatagramPacket recePacket=new DatagramPacket(data, data.length);
            //7、客户阻止式的接收消息
            client.receive(recePacket);
            //8、把消息转换成字符串
            String msg=new String(recePacket.getData(),0,recePacket.getLength()  );
            System.out.println("服务器回复的消息是："+msg);
        } catch (SocketException e) { 
            e.printStackTrace();
        } catch (UnknownHostException e) { 
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            if(client!=null){
                client.close();
            }
        }
    }