UDP的网络编程_udp协议编程

UDP的网络编程

一 ：UDP的基本概念

​ UDP协议的全称是用户数据报，在网络中它与TCP协议一样用于处理数据包。在OSI模型中，在第四层——传输层，处于IP协议的上一层。UDP有不提供数据报分组、组装和不能对数据包的排序的缺点，也就是说，当报文发送之后，是无法得知其是否安全完整到达的。

二：使用UDP的原因

​ 它不属于连接型协议，因而具有资源消耗小，处理速度快的优点，所以通常音频、视频和普通数据在传送时使用UDP较多，因为它们即使偶尔丢失一两个数据包， 也不会对接收结果产生太大影响。比如我们聊天用的ICQ和OICQ就是使用的UDP协议。在选择使用协议的时候，选择UDP必须要谨慎。在网络质量令人不 十分满意的环境下，UDP协议数据包丢失会比较严重。

三：JAVA中UDP的API类

1. InetAddress： 用于描述和包装一个Internet IP地址。

2. DatagramSocket： 用于接收和发送UDP的Socket实例。

3. DatagramPacket：用于处理报文，它将Byte数组、目标地址、目标端口等数据包装成报文或者将报文拆卸成Byte数组。

四：java中UDP的网络编程示例

1. 基础版本

//UDP服务端
public class BaseUdpServer {

    public static void main(String[] args) throws IOException {
        System.out.println("基础版UDP服务器启动....");
        //定义UDP服务端socket
        DatagramSocket datagramSocket = new DatagramSocket(8888);
        //接受客户端传递过来的容器
        byte[] contain = new byte[1024];
        //解包过程
        DatagramPacket datagramPacket = new DatagramPacket(contain,contain.length);
        //等待接受消息阻塞
        datagramSocket.receive(datagramPacket);
        //打印消息
        System.out.println(new String(contain,0,datagramPacket.getLength()));

    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//UDP的客户端
public class BaseUdpClient {

    public static void main(String[] args) throws IOException {
        System.out.println("基础版UDP客户端启动....");
        //定义UDP客户端socket
        DatagramSocket datagramSocket = new DatagramSocket(6666);
        //定义发送的消息
        String msg = "hello UDP";
        //装包过程（注意：需要指定服务器端的IP和端口号）
        DatagramPacket datagramPacket = new DatagramPacket(msg.getBytes(),
                msg.getBytes().length,
                InetAddress.getByName("localhost"),
                8888);
        //发送消息
        System.out.println("消息发送中，发送的消息为: msg = " + msg);
        datagramSocket.send(datagramPacket);

        //关闭连接
        datagramSocket.close();

    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

执行结果为：

2） 发送基本类型数据

//客户端
public class BaseUdpTypeClient {

    public static void main(String[] args) throws IOException {
        System.out.println("基本类型UDP客户端启动....");
        //定义UDP服务端socket
        DatagramSocket datagramSocket = new DatagramSocket(6666);

        //首先思路，要将基本类型转化成字节数据，需要用到两个IO流
        //字节数组输出流
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
        //数据输出流
        DataOutputStream dataOutputStream = new DataOutputStream(
                new BufferedOutputStream(byteArrayOutputStream));
        //输出字符类型
        dataOutputStream.writeUTF("UTF-8");
        //输出数字类型
        dataOutputStream.writeInt(12);
        //输出double类型
        dataOutputStream.writeDouble(12.00);
        //输出boolean类型
        dataOutputStream.writeBoolean(true);
        //数据的刷新
        dataOutputStream.flush();

        //解包过程
        DatagramPacket datagramPacket = new DatagramPacket(byteArrayOutputStream.toByteArray(),0,
                byteArrayOutputStream.toByteArray().length,
                InetAddress.getByName("localhost"),
                8888);
        //发送消息
        System.out.println("消息发送中，发送的消息为: msg = \"UTF-8\"");
        System.out.println("消息发送中，发送的消息为: msg = 12");
        System.out.println("消息发送中，发送的消息为: msg = 12.00");
        System.out.println("消息发送中，发送的消息为: msg = true");
        datagramSocket.send(datagramPacket);

        //关闭连接
        dataOutputStream.close();
        byteArrayOutputStream.close();
        datagramSocket.close();

    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

//服务端
public class BaseUdpTypeServer {
    public static void main(String[] args) throws IOException {
        System.out.println("基础类型UDP服务器启动....");
        //定义UDP服务端socket
        DatagramSocket datagramSocket = new DatagramSocket(8888);
        //接受客户端传递过来的容器
        byte[] contain = new byte[1024];
        //解包过程
        DatagramPacket datagramPacket = new DatagramPacket(contain,contain.length);
        //阻塞消息
        datagramSocket.receive(datagramPacket);
        //获取字节数据
        byte[] data = datagramPacket.getData();
        //获取字节数据长度
        int length = datagramPacket.getLength();
        //获取数据流
        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(data,0,length);

        DataInputStream dataInputStream = new DataInputStream(new BufferedInputStream(byteArrayInputStream));
        System.out.println(dataInputStream.readUTF());
        System.out.println(dataInputStream.readInt());
        System.out.println(dataInputStream.readDouble());
        System.out.println(dataInputStream.readBoolean());

        //关闭
        datagramSocket.close();
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

执行结果: