public class TestUDP {
	@Test
	public void send() {
		DatagramSocket ds = null;
		try {
			// 构造数据报套接字并将其绑定到本地主机上任何可用的端口
			ds = new DatagramSocket();
			byte[] b = "test message".getBytes();
			// 创建数据报包(把要发送的数据封装进去)
			DatagramPacket dp = new DatagramPacket(b, 0, b.length, InetAddress.getByName("127.0.0.1"), 6789);
			// 发送数据报包(须＜64KB，不保证投递成功)
			ds.send(dp);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			ds.close();
		}
	}
	@Test
	public void receive() {
		DatagramSocket ds = null;
		try {
			// 构造数据报套接字并将其绑定到本地主机上将要接收发送端数据的端口
			ds = new DatagramSocket(6789);
			byte[] b = new byte[1024];
			// 创建数据报包(指明 b 为接收对象)
			DatagramPacket dp = new DatagramPacket(b, 0, b.length);
			// 接收数据报包
			ds.receive(dp);
			// 打印接受到的数据到控制台
			String str = new String(dp.getData(), 0, dp.getLength());
			System.out.println(str);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			ds.close();
		}
	}
}