UDP方式的传输
- 2019 年 10 月 18 日
- 筆記
UDP
部分内容需要查文档学习，我们需要了解下面的两个类：java.net.DatagramSocket和java.net.DatagramPacket
java.net.DatagramSocket:
- 此类表示用来发送和接收数据报包的套接字。它就像数据传输过程中的司机或者接站员一样，它指引着数据发送的方向和传输到达的地方
构造方法:
-
DatagramSocket() 构造数据报套接字并将其绑定到本地主机上任何可用的端口。
-
DatagramSocket(int port, InetAddress laddr) 创建数据报套接字，将其绑定到指定的本地地址。
常用的方法:
-
send(DatagramPacket p) 从此套接字发送数据报包。
-
receive(DatagramPacket p)从此套接字接收数据报包。
-
close() 关闭此数据报套接字。
java.net.DatagramPacket:
- 此类表示数据报包。它就像数据传输中的交通工具，就是它承载着数据在主机之间传输，这个对象将数据打了个包，里面不光封装了数据内容，还有数据的来源，发送数据的主机IP端口等等都一并被封装到了里面。
构造方法:
-
DatagramPacket(byte[] buf, int offset, int length, InetAddress address, int port)
构造数据报包，用来将长度为 length 偏移量为 offset 的包发送到指定主机上的指定端口号。 -
DatagramPacket(byte[] buf, int length, InetAddress address, int port)
构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。 -
DatagramPacket(byte[] buf, int length)
构造 DatagramPacket，用来接收长度为 length 的数据包。
UDP接收端
先写一个UDP的接收端，大概思路就是，先通过
DatagramSocket ds = new DatagramSocket(10003);new一个对象，这个对象用来发送和接收数据包的套接字。然后通过
DatagramPacket dp = new DatagramPacket(buf, buf.length);定义数据包，最后调用recieve函数来接收数据，并将数据封装在数据包中。
值得注意的是发送端的发送至的IP地址及其端口必须和接收端的主机IP以及端口相对应
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; public class UdpRecieve { public static void main(String[] args) throws IOException, IOException { System.out.println("udp 接收端......run"); /** * 定义一个udp的接收端，接收发送过来的数据。并显示在屏幕上 * * 思路： * 1、先有udp socket服务，就是先有插座。 而且记住：接收端一定要明确端口，否则，收不到数据 * 2、接受数据。之前应该先将数据存储到数据包中。因为数据还有解析 * 3、先定义数据包 * 4、通过数据包对象获取数据包的内容，发送端的ip、发送端的端口、发送过来的数据 * 5、关闭资源 * */ //1、先有udp socket服务，就是先有插座。而且记住：接收端一定要明确端口，否则，收不到数据 DatagramSocket ds = new DatagramSocket(10000); //2、接受数据。之前应该先将数据存储到数据包中。因为数据还有解析 //3、先定义数据包 byte[] buf = new byte[1024]; //缓冲区，保存数据 DatagramPacket dp = new DatagramPacket(buf, buf.length); ds.receive(dp); //阻塞，在接受到数据之前一直处于阻塞状态，类似于输入操作 //4、通过数据包对象获取数据包的内容，发送端的ip、发送端的端口、发送过来的数据 String ip = dp.getAddress().getHostAddress(); int port = dp.getPort(); String text = new String(dp.getData(),0,dp.getLength()); System.out.println(ip+"---:---"+port+"---:---"+text); //5、关闭资源 ds.close(); } } 将其装在一个while(true)循环里，可以持续接收数据
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; public class UdpRecieve2 { public static void main(String[] args) throws IOException, IOException { System.out.println("udp 接收端 run"); /** * 定义一个udp的接收端，接收发送过来的数据。并显示在屏幕上 * * 思路： * 1、先有udp socket服务，就是先有插座。 而且记住：接收端一定要明确端口，否则，收不到数据 * 2、接受数据。之前应该先将数据存储到数据包中。因为数据还有解析 * 3、先定义数据包 * 4、通过数据包对象获取数据包的内容，发送端的ip、发送端的端口、发送过来的数据 * 5、关闭资源 * */ //1、先有udp socket服务，就是先有插座嘛。而且记住：接收端一定要明确端口，否则，收不到数据 DatagramSocket ds = new DatagramSocket(10000); while(true) { //2、接受数据。之前应该先将数据存储到数据包中。因为数据还有解析 //3、先定义数据包 byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf, buf.length); ds.receive(dp); //阻塞 //4、通过数据包对象获取数据包的内容，发送端的ip、发送端的端口、发送过来的数据 String ip = dp.getAddress().getHostAddress(); int port = dp.getPort(); String text = new String(dp.getData(),0,dp.getLength()); System.out.println(ip+":"+port+": "+text); } } }UDP发送端
用下面这句先创建一个socket来指引数据的去向，这个里面的参数“8888”表示的不是发送目的地主机的端口，而是发送起点的端口，表示从这个主机的8888端口发出去的。
DatagramSocket ds = new DatagramSocket(8888);然后再用下面这句将数据内容，发送的目的地都封装到这么一个数据包里面，里面的参数buf表示字节数组，必须是字节数组，不能是字符串数组，buf.length无疑是传输的长度， InetAddress.getByName("127.255.25.1")是目的地的主机地址，这句的含义是通过ip地址获取主机地址，10000表示目的地接收这个数据的端口，这个端口要保证没有被其他应用占用。
DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("127.255.25.1"), 10000);最后调用send函数即可完成发送
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class UdpSend { public static void main(String[] args) throws IOException, IOException { System.out.println("udp 发送端 run"); /** * 通过查阅文档，了解到用于UDP传输协议的对象是DatagramSocket * * 通过UDP协议发送一段文本数据 * 思路： * 1、需要先建立UDP的socket。它具备发送和接收功能 * 2、将数据封装到数据包中。数据包对象是DatagramPacket * 3、使用socket对象的send方法将数据包发送出去 * 4、关闭资源 * */ //1、需要先建立UDP的socket。它具备发送和接收功能 DatagramSocket ds = new DatagramSocket(8888); //2、将数据封装到数据包中。数据包对象是DatagramPacket String text = "hello udp来了！"; byte[] buf = text.getBytes(); //将数据转成字节数组 //将字节数组封装到数据包中 DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("127.255.25.1"), 10000); //3、使用socket对象的send方法将数据包发送出去 ds.send(dp); //4、关闭资源 ds.close(); } }发送键盘输入的数据，这里其实就是加了键盘录入，IO流的操作
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class UdpSend2 { public static void main(String[] args) throws IOException, IOException { System.out.println("udp 发送端 run"); /** * 通过查阅文档，了解到用于UDP传输协议的对象是DatagramSocket * * 通过UDP协议发送一段文本数据 思路： * 1、需要先建立UDP的socket。它具备发送和接收功能 * 2、将数据封装到数据包中。数据包对象是DatagramPacket * 3、使用socket对象的send方法将数据包发送出去 * 4、关闭资源 */ // 1、需要先建立UDP的socket。它具备发送和接收功能 DatagramSocket ds = new DatagramSocket(9999); // 2、将数据封装到数据包中。数据包对象是DatagramPacket。数据来自于键盘录入 BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in)); String line = null; while ((line = bufr.readLine()) != null) { if("over".equals(line)) break; byte[] buf = line.getBytes(); // 将数据转成字节数组 // 将字节数组封装到数据包中 DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("127.255.25.1"), 10000); ds.send(dp); } // 4、关闭资源 ds.close(); } }成功示例：
发送前
从键盘录入发送内容
接收端
