Java网络编程:UDP通信篇

目录
UDP协议
Java中的UDP通信
DatagramSocket
DatagramPacket
UDP客户端-服务端代码实现
UDP协议
对于UDP协议,这里简单做一下介绍:
在TCP/IP协议簇中,用户数据报协议(UDP)是传输层的一个主要协议之一,它与传输控制协议(TCP)一起构成了互联网的基础。UDP具有以下几个主要特点:
- 无连接:UDP是一个无连接的协议,这意味着在通信之前不需要建立连接。每个数据包独立传输,没有握手过程。这使得UDP的传输延迟较低,适合需要快速传输数据的应用场景。
- 不可靠传输:UDP不保证数据的可靠传输。数据包可能会丢失、重复或乱序到达。协议本身不提供错误检测和重传机制。如果需要可靠性,必须在应用层实现。
- 面向报文:UDP是面向报文的协议。发送方将数据分成独立的报文,每个报文包含完整的消息。接收方按报文接收数据,报文的边界在接收时保持不变。
- 低开销:由于UDP没有连接建立、维护和终止的开销,也没有复杂的错误控制和流量控制机制,其报头信息较少,仅包含源端口、目标端口、长度和校验和。这使得UDP的开销非常低,适合需要高效传输的应用。
- 支持广播和多播:UDP支持广播和多播,这意味着可以将数据包发送到一个或多个网络中的所有主机。这在某些网络应用中非常有用,例如视频流和在线游戏。
- 实时性好:由于没有连接建立和维护的开销,加上较低的协议处理时间,UDP适合实时性要求高的应用,如视频会议、语音通信和在线游戏。
- 简单性:UDP协议相对简单,实现和使用都比较方便。应用程序可以直接在UDP之上构建,并根据需要添加错误处理、重传等机制。
适用场景
- 实时应用:如视频流、语音通信、在线游戏等,要求低延迟和实时性,数据丢失影响较小。
- 简单查询服务:如DNS查询,发送一个请求并期望快速响应,偶尔的丢包可以通过重试解决。
- 广播和多播:如网络发现、服务公告等,需要将消息发送给多个主机。
Java中的UDP通信
市面上大部分Java应用存在着大量的通信交流的需求,那了解了UDP协议的相关信息和使用场景后,对于Java程序我们该如何来实现通信呢?
在Java中实现UDP通信涉及两个主要类:
DatagramSocket和DatagramPacket。
DatagramSocket
DatagramSocket类用于创建和管理UDP套接字。它负责发送和接收数据包,并提供了基本的网络通信功能。
主要功能包括:
- 绑定到特定的IP地址和端口。
- 发送和接收
DatagramPacket。 - 管理网络连接的基本设置(例如超时、缓冲区大小)。
主要方法
DatagramSocket(): 创建一个绑定到任意可用端口的套接字。DatagramSocket(int port): 创建一个绑定到指定端口的套接字。DatagramSocket(int port, InetAddress laddr): 创建一个绑定到指定端口和本地地址的套接字。send(DatagramPacket p): 发送数据包。receive(DatagramPacket p): 接收数据包。close(): 关闭套接字。
更多详细的方法和参数讲解可以查看oracle官方的API文档:
DatagramSocket (Java SE 17 & JDK 17) (oracle.com)
这里是中文版本的:
DatagramSocket - Java17中文文档 - API参考文档 - 全栈行动派 (qzxdp.cn)
DatagramPacket
DatagramPacket类用于表示一个数据包。它包含发送或接收的数据,以及目标或来源的IP地址和端口。
主要功能包括:
- 封装数据(字节数组)。
- 存储发送或接收数据包的目标或来源信息(IP地址和端口)。
主要方法
DatagramPacket(byte[] buf, int length): 创建用于接收数据的数据包。DatagramPacket(byte[] buf, int length, InetAddress address, int port): 创建用于发送数据的数据包。getData(): 获取数据包中的数据。getLength(): 获取数据包中数据的长度。getAddress(): 获取数据包的目标或来源地址。getPort(): 获取数据包的目标或来源端口。setData(byte[] buf): 设置数据包中的数据。setLength(int length): 设置数据包中数据的长度。setAddress(InetAddress address): 设置数据包的目标地址。setPort(int port): 设置数据包的目标端口。
笔者这里还是将官方的API文档和对应的中文文档给出:
DatagramPacket (Java SE 17 & JDK 17) (oracle.com)
DatagramPacket - Java17中文文档 - API参考文档 - 全栈行动派 (qzxdp.cn)
DatagramSocket主要通过DatagramPacket来传输和接收数据。在UDP通信中,DatagramPacket用于封装数据和相关信息(如目标地址和端口),而DatagramSocket则用于实际的发送和接收操作。
举个点外卖的例子来说明,假如今天是疯狂星期四,小李想要点个肯德基的芝士汉堡,
DatagramSocket就相对于是肯德基的大门以及小李家的大门,DatagramPacket就相对于是外卖小哥,小李点的汉堡等食品就相对于是要传输的数据,当肯德基做好汉堡后,外卖小哥通过肯德基的大门的地址信息(DatagramSocket)拿到汉堡(DatagramPacket),然后由外卖小哥将食品包装好,到小李家楼下后通过小李家的门牌号的信息(DatagramSocket)找到小李,并且将汉堡交付给小李。
另外,这里对套接字需要简单的做一个解释:
套接字(Socket)是网络通信的基本组件,它提供了一种机制,使得计算机能够通过网络进行数据传输。套接字是一个抽象概念,用于表示网络通信的一个端点。无论是TCP还是UDP通信,套接字都是必不可少的。
UDP客户端-服务端代码实现
服务器端和客户端在代码实现方面是非常简单的,在前文中有说到:UDP不是面向连接的而且协议本身就很简单。因此在实现方面需要做的功能也很少,大致可以分为以下几步:
- 创建套接字(DatagramSocket)。
- 发送(Send)和接收(Receive)数据包(DatagramPacket)。
- 关闭(Close)套接字。
还是拿刚才买汉堡的例子,我们就可以这样来实现:
UDP客户端:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Arrays;public class UDPClient {public static void main(String[] args) throws IOException {// 要发送的信息String messg = "我是小李,我想点一个芝士汉堡";// 建立SocketDatagramSocket socket = new DatagramSocket();// 建立收发容器byte[] sendData;byte[] receiveData = new byte[1024];// 发送数据包sendData = messg.getBytes();InetAddress serverAddress = InetAddress.getByName("localhost");DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, serverAddress, 9999);socket.send(sendPacket);// 接收数据包DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);socket.receive(receivePacket);String receivedMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());System.out.println("Received from Server: " + receivedMessage);// 关闭套接字socket.close();}
}
UDP服务端:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Arrays;public class UDPServer {public static void main(String[] args) throws IOException {// 要发送的信息String messg = "这里是肯德基,您的芝士汉堡已经制作完毕,祝您用餐愉快";// 建立SocketDatagramSocket socket = new DatagramSocket(9999);try {// 建立收发容器byte[] sendData;byte[] receiveData = new byte[1024];// 接收数据包DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);socket.receive(receivePacket);String receivedMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());System.out.println("Received from Client: " + receivedMessage);// 发送数据包sendData = messg.getBytes();InetAddress clientAddress = receivePacket.getAddress();int clientPort = receivePacket.getPort();DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, clientAddress, clientPort);socket.send(sendPacket);} finally {// 关闭套接字if (socket != null && !socket.isClosed()) {socket.close();}}}
}
上述只是一个非常简单的例子,实现了UDP通信中的一发一收的功能。要实现更丰富的功能也只需要稍微改一改就行,比如加上while循环就可以使得通信可以不间断,一直发消息一直收消息,也可以加上文件读写的操作使得用户的输入可以更多样化。
本次的分享就到此为止了,希望我的分享能给您带来帮助,创作不易也欢迎大家三连支持,你们的点赞就是博主更新最大的动力!
如有不同意见,欢迎评论区积极讨论交流,让我们一起学习进步!
有相关问题也可以私信博主,评论区和私信都会认真查看的,我们下次再见![]()
相关文章:
Java网络编程:UDP通信篇
目录 UDP协议 Java中的UDP通信 DatagramSocket DatagramPacket UDP客户端-服务端代码实现 UDP协议 对于UDP协议,这里简单做一下介绍: 在TCP/IP协议簇中,用户数据报协议(UDP)是传输层的一个主要协议之一…...
HTML+CSS+JS简易计算器
HTMLCSSJS简易计算器 index.html <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>简易计算器</t…...
STM32使用ST-LINK下载程序中需要注意的几点
使用keil5的ST-link下载界面 前提是ST-LINK已经连接好,(下图中是没有连接ST-link设备),只是为了展示如何查看STlink设备是否连接的方式 下载前一定设置下载完成后自启动 这个虽然不是必须,但对立即看到新程序的现象…...
我和jetson-Nano的故事(12)——安装pytorch 以及 torchvision
在jetson nano中安装Anaconda、pytorch 以及 torchvision 1.Pytorch下载安装2.Torchvision安装 1.Pytorch下载安装 首先登录英伟达官网下载Pytorch安装包,这里以PyTorch v1.10.0为例 安装依赖库 sudo apt-get install libjpeg-dev zlib1g-dev libpython3-dev liba…...
「异步魔法:Python数据库交互的革命」(一)
Hi,我是阿佑,今天将和大家一块打开异步魔法的大门,进入Python异步编程的神秘领域,学习如何同时施展多个咒语而不需等待。了解asyncio的魔力,掌握Async SQLAlchemy和Tortoise-ORM的秘密,让你的数据库操作快如…...
探秘GPT-4o:从版本对比到技术能力的全面评价
随着人工智能技术的不断发展,自然语言处理领域的突破性技术——GPT(Generative Pre-trained Transformer)系列模型也在不断演进。最新一代的GPT-4o横空出世,引起了广泛的关注和讨论。在本文中,我们将对GPT-4o进行全面评…...
四川汇烁面试总结
自我介绍项目介绍、 目录 1.jdk和jre的区别? 2.一段代码的执行流程? 3.接口与抽象类的区别? 4.ArrayList与LinkList的区别? 5.对HashMap的理解? 6.常见的异常? 7.throw 和 throws 有什么区别? 8.…...
【小程序 按钮 表单 】
按钮 代码演示 xxx.wxml <view class"boss" hover-class"box"hover-start-time"2000"hover-stay-time"5000">测试文本<view hover-stop-propagation"true">子集</view><view>子集2</view>…...
高铁Wifi是如何接入的?
使用PC端的朋友,请将页面缩小到最小比例,阅读最佳! 在飞驰的高铁上,除了窗外一闪而过的风景,你是否好奇过,高铁Wifi信号如何连接的呢? 远动的火车可不能连接光纤吧,难道是连接的卫星…...
gitlab之docker-compose汉化离线安装
目录 概述离线资源docker-compose结束 概述 gitlab可以去 hub 上拉取最新版本,在此我选择汉化 gitlab ,版本 11.x 离线资源 想自制离线安装镜像,请稳步参考 docker镜像的导入导出 ,无兴趣的直接使用在此提供离线资源 百度网盘(链…...
【算法】dd爱转转
✨题目链接: dd爱旋转 ✨题目描述 读入一个n∗n的矩阵,对于一个矩阵有以下两种操作 1:顺时针旋180 2:关于行镜像 如 变成 给出q个操作,输出操作完的矩阵 ✨输入描述: 第一行一个数n(1≤n≤1000),表示矩阵大小 接下来n行ÿ…...
Python3 笔记:IDLE的几个基本设置
1、设置字体: Options > Configure IDLE > Fonts 2、设置文字颜色(设置高亮): Options > Configure IDLE > Highlights 3、设置背景颜色: Options > Configure IDLE > Highlights 4、设置窗口&a…...
Mysql:存储过程练习
create table stu( id int(3) primary key auto_increment, name varchar(20) not null, grade float, gender char(2)); insert into stu(name,grade,gender) values(tom,60,男),(jack,70,男),(rose,90,女),(lucy,100,…...
详解Java ThreadLocal
个人博客 详解Java ThreadLocal | iwts’s blog Java ThreadLocal ThreadLocal提供了线程内存储变量的能力,这些变量不同之处在于每一个线程读取的变量是对应的互相独立的。通过get和set方法就可以得到当前线程对应的值。 TreadLocal存储模型 ThreadLocal的静态…...
Unable to parse response body for Response{requestLine=PUT
1 异常信息: Caused by: java.lang.RuntimeException: Unable to parse response body for Response{requestLinePUT /an_path_statistic_log/_doc/11?timeout1m HTTP/1.1, hosthttp://192.168.3.60:9200, responseHTTP/1.1 200 OK}at org.springframework.data.e…...
GitHub的原理及应用详解(六)
本系列文章简介: GitHub是一个基于Git版本控制系统的代码托管平台,为开发者提供了一个方便的协作和版本管理的工具。它广泛应用于软件开发项目中,包括但不限于代码托管、协作开发、版本控制、错误追踪、持续集成等方面。 GitHub的原理可以简单…...
基于PHP+MySQL组合开发的微信小程序分销商城源码系统 分销商城+积分商城+多商户 功能强大 带完整的安装代码包以及搭建教程
系统概述 在当今数字化商业时代,拥有一个强大而多功能的分销商城系统对于企业的发展至关重要。本文将重点介绍基于 PHPMySQL 组合开发的微信小程序分销商城源码系统,它融合了分销商城、积分商城和多商户等功能,不仅功能强大,还提…...
kafka-消费者组偏移量重置
文章目录 1、消费者组偏移量重置1.1、列出所有的消费者组1.2、查看 my_group1 组的详细信息1.3、获取 kafka-consumer-groups.sh 的帮助信息1.4、 偏移量重置1.5、再次查看 my_group1 组的详细信息 1、消费者组偏移量重置 1.1、列出所有的消费者组 [rootlocalhost ~]# kafka-…...
一书读懂Python全栈安全,剑指网络空间安全
写在前面 通过阅读《Python全栈安全/网络空间安全丛书》,您将能够全面而深入地理解Python全栈安全的广阔领域,从基础概念到高级应用无一遗漏。本书不仅详细解析了Python在网络安全、后端开发、数据分析及自动化等全栈领域的安全实践,还紧密贴…...
原生js实现拖拽改变元素顺序
代码展示如下: <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>Document</title>…...
不用手动设置滤波参数,程序自动根据信号特征,匹配滤波参数,零基础也能抗干扰。
在智能仪器的世界里,我们经常面临一个尴尬的局面:实验室里算法跑得飞起,一到现场就被噪声淹没。今天,我将结合《智能仪器设计》中的自适应信号处理理念,带你手撸一个“傻瓜式”自适应滤波器。这个工具的目标很明确&…...
Java函数计算迁移避坑清单:12个被官方文档隐瞒的关键限制(含Classloader隔离失效实录)
第一章:Java函数计算迁移避坑清单:12个被官方文档隐瞒的关键限制(含Classloader隔离失效实录)Java函数计算(如阿里云FC、AWS Lambda Java Runtime)在迁移传统Spring Boot应用时,常因底层沙箱机制…...
MelonLoader完全解决方案:Unity游戏Mod加载实战指南
MelonLoader完全解决方案:Unity游戏Mod加载实战指南 【免费下载链接】MelonLoader The Worlds First Universal Mod Loader for Unity Games compatible with both Il2Cpp and Mono 项目地址: https://gitcode.com/gh_mirrors/me/MelonLoader 当你兴致勃勃地…...
Axios遭供应链投毒攻击(附排查与紧急补救指南)
每周下载3亿次的Axios遭供应链投毒攻击,附排查与修复指南 事件概述 2026 年 3 月 31 日,著名云安全平台 StepSecurity 监测到,在 JavaScript 生态系统中最受欢迎的 HTTP 客户端库 Axios(每周下载量超 3 亿次)遭遇了严重…...
ONLYOFFICE社区模块功能详解:博客、论坛、投票与Wiki的完整协作指南
ONLYOFFICE社区模块功能详解:博客、论坛、投票与Wiki的完整协作指南 【免费下载链接】CommunityServer Free open source office suite with business productivity tools: document and project management, CRM, mail aggregator. 项目地址: https://gitcode.co…...
一个防止GPT“降智”的简单方法
GPT客户端容易“降智”?教你一个简单解决办法 正文 最近一直感觉 GPT 手机客户端有点“降智”,回答质量不太稳定。 后来我拿同一账号做了对比,发现用手机浏览器登录网页版时,整体会正常不少,所以来给大家分享一下。 我…...
互联网大厂Java求职者面试全场景详解(含技术栈解析与问答)
互联网大厂Java求职者面试全场景详解(含技术栈解析与问答) 文章标签 Java SE, Jakarta EE, JVM, Spring Boot, Maven, 微服务, 消息队列, 互联网大厂面试, 求职招聘, 技术问答 文章简述 本文围绕互联网大厂Java求职者面试场景,设计了由严肃面…...
你还在用for循环清洗CSV?Polars 2.0的scan_csv()+expression DSL已支持自动列式推断与零拷贝转换——立即升级避免被淘汰
第一章:Polars 2.0大规模数据清洗的核心范式变革Polars 2.0 不再将数据清洗视为一系列离散的、命令式的转换操作,而是以“惰性执行图列式语义优先”为基石,重构整个清洗生命周期。其核心变革体现在计算模型、内存管理与API设计三重维度的协同…...
告别盲调!用STM32的编码器模式+定时器中断,精准测量电机转速(附速度计算源码)
STM32编码器模式实战:从脉冲计数到精准转速测量的全链路解析 在电机控制系统中,转速测量就像给盲人配上一副眼镜——它让抽象的旋转运动变得可视化、可量化。许多工程师在完成电机基础驱动后常陷入一个尴尬境地:电机确实转起来了,…...
告别SSH一息屏就断连!用Termux-wake-lock让你的手机后台稳定运行
告别SSH一息屏就断连!用Termux-wake-lock让你的手机后台稳定运行 你是否遇到过这样的场景:正通过电脑SSH连接到手机的Termux环境进行开发调试,突然一个微信消息弹出,切出去回复后,SSH连接立刻中断?或是手机…...
