Java 网络编程 —— 基于 UDP 的数据报和套接字

news/2024/10/30 11:20:27/

UDP 简介

UDP(User Datagram Protocol,用户数据报协议)是传输层的另一种协议,比 TCP 具有更快的传输速度,但是不可靠。UDP 发送的数据单元被称为 UDP 数据报,当网络传输 UDP 数据报时,无法保证数据报一定到达目的地,也无法保证各个数据报按发送的顺序到达目的地,例如:当发送方先发送包含字符串【hello】的数据报,再发送包含字符串【everyone】的数据报时,接收方有可能先接收到字符串【everyone】,再接收到字符串【hello】,也有可能什么数据也没有接收到,因为发送方发送的数据有可能在传输途中都被丢失了


DatagramPacket 类

DatagramPacket 表示数据报,它的构造方法可以被分为两种:

  • 创建用来接收数据的 DatagramPacket 对象
  • 创建用来发送数据的 DatagramPacket 对象

两种构造方法的主要区别是:

  • 用于发送数据的构造方法需要设定数据报到达的目的地的地址
  • 用于接收数据的构造方法无须设定地址

用于接收数据的构造方法包括:

//data:用来存放接收到的数据
//length:指定要接收的字节数
//offset:指定在data存放数据的起始位置,即data[offset],如果没有设定,那么初始位置为data[0]
public DatagramPacket(byte[] data, int length);
public DatagramPacket(bytel data, int offset, int length);

用于发送数据的构造方法包括:

//data:用来存放要发送的数据
//length:指定要发送的字节数
//offset:指定在data要发送数据的起始位置,即data[offset],如果没有设定,那么初始位置为data[0]
//address和port:来指定目的地的地址
public DatagramPacket(byte[] data, int offset, int length, InetAddress address, int port);
public DatagramPacket(byte[] data, int offset, int length, SocketAddress address);
public DatagramPacket(byte[] data, int length, InetAddress address, int port);
public DatagramPacket(byte[] data, int length, SocketAddress address);

DatagramPacket 类包括以下属性,提供了一系列 get/set 方法来获取或设置这些属性:

  • data:表示数据报的数据缓冲区
  • offset:表示数据报的数据缓冲区的起始位置
  • length: 表示数据报的长度
  • address:对于用于发送的数据报,address 属性表示数据报的目标地址。对于用于接收的数据报,address 属性表示发送者的地址
  • port:对于用于发送的数据报,port 属性表示数据报的目标 UDP 端口。对于用于接收的数据报,port 属性表示发送者的 UDP 端口

DatagramSocket 类

DatagramSocket 类负责接收和发送数据报,每个 DatagramSocket 对象都会与一个本地端口绑定,在此端口监听发送过来的数据报。在客户程序中,一般由操作系统为 DatagramSocket 类分配本地端口,这种端口也被称为匿名端口。在服务器程序中,一般由程序显式地为 DatagramSocket 类指定本地端口

DatagramSocket 的构造方法有以下几种重载形式:

//由操作系统分配的任意的可用端口
DatagramSocket();
//显式指定本地端口
DatagramSocket(int port);
//同时指定IP和端口
DatagramSocket(int port, InetAddress laddr);
DatagramSocket(SocketAddress bindaddr);

DatagramSocket 的 send 方法负责发送一个数据报,该方法的定义如下:

public void send(DatagramPacket dp) throws IOException

值得注意的是,UDP 提供不可靠的传输,如果数据报没有到达目的地,那么 send 方法不会抛出任何异常,发送方程序就无法知道数据报是否被接收方接收到,除非双方通过应用层的特定协议来确保接收方未收到数据报时,发送方能重发数据报

DatagramSocket 的 receive 方法负责接收一个数据报,该方法的定义如下:

public void receive(DatagramPacket datagramPacket) throws IOException

此方法从网络上接收一个数据报,如果网络上没有数据报,执行该方法的线程就会进入阻塞状态,直到收到数据报为止。参数 datagramPacket 用来存放接收到的数据报,如果接收的数据报太大,receive 方法会在 datagramPacket 的数据缓冲区内存放尽可能多的数据,其余的数据则丢弃

两个 TCP Socket 之间存在固定的连接关系,而一个 DatagramSocket 可以与其他任意一个 DatagramSocket 交换数据报。在某些场合,一个 DatagramSocket 可能只希望与固定的另一个远程 DatagramSocket 通信,从 JDK1.2 开始,DatagramSocket 添加了一些方法,利用这些方法,可以使一个 DatagramSocket 只能与另一个固定的 DatagramSocket 交换数据报

//该方法实际上不建立TCP意义上的连接,但能限制当前DataramSocket只对参数指定的远程主机和UDP端口收发数据报
public void connect(InetAddress host, int port);
//中止当前DatagramSocket已经建立的连接
public void disconnect();
//当且仅当DatagramSocket已经建立连接时返回所连接的远程UDP端口,否则返回“-1”
public int getPort();
//当且仅当DatagramSocket已经建立连接时返回所连接的远程主机的IP地址,否则返回null
public InetAddress getlnetAddress();
//当且仅当DatagramSocket已经建立连接时返回所连接的SocketAddress,否则返回null
public SocketAddress getRemoteSocketAddress();

DatagramSocket 的 close 方法会释放所占用的本地 UDP 端口,在程序中及时关闭不再需要的 DatagramSocket,这是好的编程习惯


DatagramChannel 类

DatagramChannel 是 SelectableChannel 的子类,可以被注册到一个 Selector。使用 DatagramChannel,可以使 UDP 服务器只需用单个线程就能同时与多个客户通信。DatagramChannel 在默认情况下采用阻塞模式,如果希望该为非阻塞模式,那么可以调用 configureBlocking(false) 方法

DatagramChannel 类的静态 open 方法返回一个 DatagramChannel 对象,每个 DatagramChannel 对象都关联了一个 DatagramSocket 对象,DatagramChannel 对象的 socket 方法返回这个 DatagramSocket 对象

DatagramChannel 对象被创建后,与它关联的 DatagramSocket 对象还没有被绑定到任何地址,必须调用 DatagramSocket 对象的 bind 方法来与一个本地地址绑定

DatagramChannel channel = DatagramChannel.open();
DataqramSocket socket = channel.socket();
SocketAddress address = new InetSocketAddress(8000);
socket.bind(address);

与 DatagramSocket 一样,DatagramChannel 的 connect(SocketAddress remote) 方法使得通道只能对特定的远程地址收发数据报

DatagramChannel 使用 send 方法发送数据

//把参数src的剩余数据作为一个数据报写到通道中,参数target指定目标地址,该方法返回发送的字节数
public int send(ByteBuffer src, SocketAddress target) throws IOException

DatagramChannel 使用 receive 方法从通道中读取一个数据报,存放在参数指定的 ByteBufer,并返回数据报的发送方的地址

public SocketAddress receive(ByteBuffer dst) throws IOException

如果 DatagramChannel 工作于阻塞模式,那么 receive 方法在读取到数据报之前不会返回。如果 DatagramChannel 工作于非阻寒模式,那么 receive 方法在没有数据报可读取的情况下立即返回 null

DatagramChannel 也可以使用 write 方法发送数据,与 send 方法区别在于:write 方法要求 DatagramChannel 已经建立连接

public int write(ByteBuffer src) throws IOException;
//依次发送ByteBuffer数组中每个ByteBuffer的数据
public long write(ByteBufferl] srcs) throws IOException;
//参数offse指定ByteBuffer数组的起始位置参数,length指定发送的ByteBuffer的数目
public long write(ByteBufferl] srcs, int offset, int length) throws IOException;

DatagramChannel 也可以使用 read 方法接收数据,同样的,它也要求 DatagramChannel 已经建立连接

public int read(ByteBuffer src) throws IOException;
//把数据报的数据保存到 ByteBuffer 数组中
public long read(ByteBuffer[l srcs) throws IOException;
public long read(ByteBuffer[] srcs, int offset, int length) throws IOException;

http://www.ppmy.cn/news/329885.html

相关文章

Tcl常用命令备忘录-访问文件篇

1)file命令 介绍:Tcl的file命令是用于操作文件系统的命令,可以进行文件或目录的创建、删除、重命名、复制、移动、属性获取等操作。 语法:file option ?arg arg ...? 参数说明: option 表示要执行的操作&#xff…

能测试成绩的学习软件,普通话学习测试这个软件上,我平均成绩能达到二甲,请问如果在真正的普通话考试上,我大概能得到什么等级...

满意答案 Lza3321 2019.04.01 采纳率:40% 等级:7 已帮助:109人 应该可以达到二甲。 一级 甲等 朗读和自由交谈时,语音标准,语汇、语法正确无误,语调自然,表达流畅。测试总失分率在3%以内。 乙…

计算机辅助普通话水平证书要考吗,目前普通话证书考试都是机器测试吗?

【导读】 相信许多考生在报考普通话等级考试的时候都会发现一个问题,就是现在报考的普通话等级考试好像都是机器考核的,那么考试是全部都是机器完成的还是有普通话测试员在一起考试的呢?下面就由小编来为大家讲解一下。 首先是机测不比人测难&#xff0…

计算机二级幼师学哪个好,科普下幼儿教师资格证好考吗

近日有关于科普下幼儿教师资格证好考吗的问题受到了很多网友们的关注,大多数网友都想要知道科普下幼儿教师资格证好考吗的具体情况,那么关于到科普下幼儿教师资格证好考吗的相关信息,小编也是在网上进行了一系列的信息,那么接下来…

普通话考试

今天上午参加了普通话测试,感觉还凑合。前面的单字和词语以及短文的朗读情况感觉不错,就是最后那个说话啊,实在是不爽。磕磕巴巴的,而且感觉自己说了一大堆废话,甚至有些不知所云了。 上午10点的时候在教三有个培训&am…

普通话水平测试用朗读作品60篇-(练习版)

普通话考试题型有读单音节字词、读多音节字词、朗读作品和命题说话。 具体分值如下: 1、读单音节字词100个,占10分;目的考查应试人普通话声母、韵母和声调的发音。 2、读双音节词语50个,占20分;目的是除了考查应试人…