数据报模型

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketAddress;
import java.net.SocketException;

/**
 * 服务器 
 */
public class Server {

    public static void main(String[] args) {
        DatagramSocket ds = null; // 发送 和接收
        DatagramPacket dp = null; // 打包 和拆包
        // 回复的新包裹
        DatagramPacket dpTo = null; // 打包 和拆包
        try {
            // 实例化服务器
            ds = new DatagramSocket(8800);
            // 创建一个byte类型的数组 ==》快递的内容
            byte[] buf = new byte[1024];
            dp = new DatagramPacket(buf, buf.length);
            // 接收B用户给我们的快递
            ds.receive(dp);
            /**
             * 拆包操作
             * dp.getData():包裹实际内容
             * 0 ：从什么位置开始获取信息
             * dp.getLength()：包裹所有内容
             */
            String msg = new String(dp.getData(), 0, dp.getLength());
            System.out.println("用户B的地址==》" + dp.getAddress().getHostName());
            System.out.println("用户B包裹的内容==》" + msg);
            // 用户A想给用户B回信 获取B用户的地址
            SocketAddress address = dp.getSocketAddress();
            // 用户A开始打包
            byte[] reply = "您好！ 我是用户A已经收到了您的包裹！".getBytes();
            dpTo = new DatagramPacket(reply, reply.length, address);
            // 发送
            ds.send(dpTo);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally { // 释放资源
            ds.close();
        }

    }
}

/**
 * 客户端   
 */
public class Client {
    public static void main(String[] args) {
        DatagramSocket ds = null; // 发送 和接收
        DatagramPacket dp = null; // 打包 和拆包

        // 回复的新包裹
        DatagramPacket dpTo = null; // 打包 和拆包

        try {
            byte[] say = "我是B用户，给您买了一张春节回家的火车票".getBytes();
            InetAddress address = InetAddress.getByName("localhost");
            // 打包
            dp = new DatagramPacket(say, say.length, address, 8800);
            // 发送
            ds = new DatagramSocket();
            ds.send(dp);
            // 用户B 开始接收 A用户的数据
            byte[] buf = new byte[1024];
            dpTo = new DatagramPacket(buf, buf.length);
            // 接收
            ds.receive(dpTo);
            // 拆包
            String reply = new String(dpTo.getData(), 0, dpTo.getLength());
            System.out.println("我是用户B得到了A的回信地址====》"
                    + dpTo.getAddress().getHostAddress());
            System.out.println("我是用户B得到了A的回信内容====》" + reply);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally { // 释放资源
            ds.close();
        }
    }
}

数据通过DatagramPacket类打包，通过DatagramSocket类发送与接收。