UDP 协议详解与实战

目录

  • 简介
    • 什么是 UDP?
    • UDP 与 TCP 的区别
  • UDP 数据传输方式
    • 单播 - Unicast(1:1)
    • 广播 - Broadcast(1:n)
      • 有限广播 - Limited Broadcast
      • 直接广播 - Directed Broadcast
    • 组/多播 - Multicast(n:m)
    • 任播 - Anycast
  • 注意事项

简介

什么是 UDP?

UDP(User Datagram Protocol,用户数据报协议)是一种简单的面向 无连接 的传输层协议,它提供了一种 不可靠 的数据传输服务。

UDP 与 TCP 的区别

UDP 与 TCP 处于 OSI 模型 的传输层,都属于传输层协议。
在这里插入图片描述

其与 TCP 的区别如下图:

/UDPTCP
面向连接不面向连接面向连接
可靠性不可靠可靠
数据传输速度较快较慢
数据传输方式单播(1:1)、广播(1:n)、组播(n:m)、任播单播(1:1)
OSI模型传输层传输层
用途游戏、语音、视频等场景文件传输、HTTP等场景
优点低延迟、低开销、无连接特性、支持组播与广播可靠传输、流量控制、拥塞控制、面向连接、有序传输
缺点不可靠传输、无流量控制、无拥塞控制、安全性较低较高开销、较复杂、不支持组播和广播

在这里插入图片描述

UDP 数据传输方式

UDP 的数据传输方式有四种,分别是 单播广播组播任播

单播 - Unicast(1:1)

单播是指数据报从一个单一的发送方发送到一个单一的接收方。它是最常见的UDP数据传输方式,适用于一对一的通信。其与 TCP 通信类似。

udp单播
在上图中,消息发送者在知道了消息接收者的 IP 地址,并给消息接收者发送了数据,消息接收者通过监听与消息发送者发送数据的端口号,即可监听到消息发送者发送过来的数据。代码如下:

消息发送者

@Override
public void sendMessage(@NonNull String ip, @NonNull String message) {SingleThreads.getInstance().execute(() -> {try {DatagramSocket socket = new DatagramSocket();// 设置端口复用byte[] sendData = message.getBytes();// 创建回复的数据包InetAddress inetAddress = InetAddress.getByName(ip);DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, inetAddress, port);// 发送消息到目标IPsocket.send(sendPacket);socket.close();Log.e(TAG, "发送广播成功,message:" + message);} catch (IOException e) {Log.e(TAG, "发送广播失败,message:" + e.getMessage());throw new RuntimeException(e);}});
}

消息接收者

@Override
public void onReceiveMessageListener(@NonNull String ip, @NonNull ReceiveMessageInterface receiveMessage) {SingleThreads.getInstance().execute(() -> {try {byte[] receiveData = new byte[1024];DatagramSocket socket = new DatagramSocket(port);// 创建DatagramPacket准备接收数据while (isFinish) {DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);// 接收数据包socket.receive(receivePacket);// 获取数据和发送方地址String message = new String(receivePacket.getData(), 0, receivePacket.getLength());Log.e(TAG, "广播收到一条消息,message:" + message);receiveMessage.onReceiveMessageListener(message);}socket.close();} catch (IOException e) {Log.e(TAG, "广播接收消息失败,message:" + e.getMessage());throw new RuntimeException(e);}});
}

使用场景:在线游戏、VoIP(网络电话)等需要低延迟的通信。

广播 - Broadcast(1:n)

广播是指数据报从一个发送方发送到同一网络内的所有设备。UDP 广播常用于局域网(LAN)内的设备发现和服务公告。UDP 广播不会通过路由器将数据包传播到其他网络,仅限于本地网络中的设备可见并响应。

有限广播 - Limited Broadcast

有限广播(Limited Broadcast)使用特殊的 IP 地址 255.255.255.255 作为目标地址。

有限广播的广播消息限制在本地局域网(LAN)内部,不会穿过路由器传播到其他网络。它是向当前网络段内所有主机发送数据的一种方式。
udp广播
在上图中,消息发送者发送一条数据到 255.255.255.255 的地址,这个地址被称为“有限广播地址”,它代表了本网络广播,即当一个 UDP 数据包发送到该地址时,该数据包会在局域网内部广播,传递给同一子网的内的所有设备。示例代码如下:

消息发送者

 @Overridepublic void sendMessage(@NonNull String ip, @NonNull String message) {SingleThreads.getInstance().execute(() -> {try {byte[] bytes = message.getBytes();// 有限广播 ip 一般为 255.255.255.255InetAddress inet = InetAddress.getByName(ip);DatagramPacket packet = new DatagramPacket(bytes, bytes.length, inet, port);DatagramSocket datagramSocket = new DatagramSocket();datagramSocket.send(packet);Log.e(TAG, "发送广播成功,message:" + message);} catch (IOException e) {Log.e(TAG, "发送广播失败,message:" + e.getMessage());e.printStackTrace();}});}

消息接收者

@Override
public void onReceiveMessageListener(@NonNull String ip, @NonNull ReceiveMessageInterface receiveMessage) {SingleThreads.getInstance().execute(() -> {try {// 创建缓冲区以接收数据byte[] receiveData = new byte[1024];DatagramSocket socket = new DatagramSocket(port);socket.setBroadcast(true);while (isFinish) {// 创建DatagramPacket来接收数据DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);// 接收广播消息socket.receive(receivePacket);// 处理接收到的数据String message = new String(receivePacket.getData(), 0, receivePacket.getLength());receiveMessage.onReceiveMessageListener(message);Log.e(TAG, "广播收到一条消息,message:" + message);}socket.close();} catch (IOException e) {Log.e(TAG, "广播接收消息失败,message:" + e.getMessage());throw new RuntimeException(e);}});
}

使用场景:局域网内配置设备时发送广播包来发现或配置新设备。

直接广播 - Directed Broadcast

直接广播(Directed Broadcast)是针对特定子网的广播,使用子网的广播地址进行。

子网广播地址是通过将子网的网络地址部分保持不变,而将主机地址部分全部设为 1 得到的。例如,如果子网是 192.168.1.0/24(即 IP 地址为 192.168.1.1 ~ 192.168.1.254),则其广播地址为192.168.1.255。

这种广播可以跨路由器传播,但需要路由器配置允许广播流量通过,这在现代网络中较为少见,因为广播通常被限制在本地网络以减少广播风暴和提高网络效率。

udp广播-直接广播
上图中,消息发送者往 192.168.1.255 发送了数据,同网段的设备(即IP地址为 192.168.1.1 ~ 192.168.1.254 的设备)监听与消息发送者相同的端口即可收到该广播消息。示例代码如下:

消息发送者

@Override
public void sendMessage(@NonNull String ip, @NonNull String message) {SingleThreads.getInstance().execute(() -> {try {// 创建DatagramSocket实例,并启用广播DatagramSocket socket = new DatagramSocket();socket.setBroadcast(true);// 准备发送的数据byte[] sendData = message.getBytes();// 构建DatagramPacket,目标地址为子网广播地址,IP 一般为 192.168.子网网段.255InetAddress broadcastAddress = InetAddress.getByName(ip);DatagramPacket packet = new DatagramPacket(sendData, sendData.length, broadcastAddress, PORT);// 发送广播数据包socket.send(packet);Log.e(TAG, "发送广播成功,message:" + message);// 关闭socketsocket.close();} catch (IOException e) {Log.e(TAG, "发送广播失败,message:" + e.getMessage());e.printStackTrace();}});
}

消息接收者

@Override
public void onReceiveMessageListener(@NonNull String ip, @NonNull ReceiveMessageInterface receiveMessage) {SingleThreads.getInstance().execute(() -> {try {// 创建缓冲区以接收数据byte[] receiveData = new byte[1024];DatagramSocket socket = new DatagramSocket(PORT);socket.setBroadcast(true);while (isFinish) {// 创建DatagramPacket来接收数据DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);// 接收广播消息socket.receive(receivePacket);// 处理接收到的数据String message = new String(receivePacket.getData(), 0, receivePacket.getLength());receiveMessage.onReceiveMessageListener(message);Log.e(TAG, "广播收到一条消息,message:" + message);}socket.close();} catch (IOException e) {Log.e(TAG, "广播接收消息失败,message:" + e.getMessage());throw new RuntimeException(e);}});
}

使用场景:向整个子网发送告警或通知。

组/多播 - Multicast(n:m)

组播(Multicast,又称多播)是指数据报从一个发送方发送到多个接收方,但这些接收方是预先定义的一组设备,而不是整个网络。

组播常用于需要同时向多个接收方发送数据的场景,如视频直播、股票行情分发等。组播数据报发送到一个特定的组播地址,只有加入该组的接收方才能接收到数据。

当然,组播预定义的一组设备的 IP 也是有所要求的,组播地址范围一般在 224.0.0.0 至 239.255.255.255 之间。
udp组播/多播
在上图中,消息发送者 A 和消息发送者 B 分别向 224.0.0.1 和 224.0.0.2 发送数据,消息接收者 A 只加入了 224.0.0.1 的组,那么它只能接收到 224.0.0.1 的消息,而消息接收者 B 分别加入了 224.0.0.1 和 224.0.0.2 的组,那么它就可以接收到消息发送者 A 和消息发送者 B 发送的消息。示例代码如下:

消息发送者

@Override
public void sendMessage(@NonNull String ip, @NonNull String message) {SingleThreads.getInstance().execute(() -> {try {// 组播地址,范围在224.0.0.0至239.255.255.255InetAddress group = InetAddress.getByName(ip);// 将消息转换为字节数组byte[] buffer = message.getBytes();// 创建DatagramPacket,使用组播地址和端口DatagramPacket packet = new DatagramPacket(buffer, buffer.length, group, port);// 发送组播消息MulticastSocket socket = new MulticastSocket();socket.send(packet);socket.close();Log.e(TAG, "发送广播成功,message:" + message);} catch (IOException e) {Log.e(TAG, "发送广播失败,message:" + e.getMessage());throw new RuntimeException(e);}});
}

消息接收者

@Override
public void onReceiveMessageListener(@NonNull String ip,@NonNull ReceiveMessageInterface receiveMessage) {SingleThreads.getInstance().execute(() -> {try {MulticastSocket socket = new MulticastSocket(port);InetAddress group = InetAddress.getByName(ip);// 加入组播组,一个设备可加入多个组播组socket.joinGroup(group);// 创建缓冲区以接收数据byte[] receiveData = new byte[1024];while (isFinish) {// 创建DatagramPacket来接收数据DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);// 接收组播消息socket.receive(receivePacket);// 处理接收到的数据String message = new String(receivePacket.getData(), 0, receivePacket.getLength());receiveMessage.onReceiveMessageListener(message);Log.e(TAG, "广播收到一条消息,message:" + message);}socket.close();} catch (IOException e) {Log.e(TAG, "广播接收消息失败,message:" + e.getMessage());e.printStackTrace();}});
}

使用场景:数据分发、在线会议、视频流媒体传输。

任播 - Anycast

任播(Anycast)是一种网络地址分配方法,其中多个主机共享同一个IP地址,当客户端发送数据包到该地址时,网络路由器会根据一定的策略将数据包发送到其中一个最接近的主机。与广播(将数据包发送到所有主机)和组播(将数据包发送到组内所有主机)不同,任播只将数据包发送到一个特定的、通常是最优路径的单个主机。

使用场景:服务冗余和负载均衡。

注意事项

1、设备 A 同时发送数据给设备 A 与设备 B,设备 A 能接收到,但设备 B 无法接收到,这时候要考虑是否是网络问题,也可以尝试使用自己的手机开热点,再让设备 A 给设备 B 发消息。

代码链接 👉 DatagramSocket

参考文献

1、OSI 模型 — 维基百科

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/27572.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

屹晶微EG3002 单通道功率MOSFET驱动芯片 贴片SOP8

EG3002作为一款功率MOSFET驱动芯片,它的应用领域主要取决于其技术参数和性能特点。根据之前提供的信息,EG3002可能适用于以下领域: 1. 电源管理:用于高效率电源转换器,如开关电源(SMPS)、电池充…

栈的实现详解

目录 1. 栈1.1 栈的概念及结构1.2 栈的实现方式1.3 栈的应用场景 2. 栈的实现2.1 结构体2.2 初始化2.3 销毁2.4 入栈2.5 出栈2.6 获取栈顶元素2.7 判空2.8 获取个数 3. test主函数4. Stack.c文件5. Stack.h文件6. 运行展示 1. 栈 1.1 栈的概念及结构 栈:一种特殊的…

【YashanDB知识库】PHP使用OCI接口使用数据库绑定参数功能异常

【问题分类】驱动使用 【关键字】OCI、驱动使用、PHP 【问题描述】 PHP使用OCI8连接yashan数据库,使用绑定参数获取数据时,出现报错 如果使用PDO_OCI接口连接数据库,未弹出异常,但是无法正确获取数据 【问题原因分析】 开启O…

张艺兴step新专开启自由驾驶新纪元

张艺兴《Step》新专,开启自由驾驶新纪元!当音乐与驾驶相遇,会碰撞出怎样的火花?当实力派艺人张艺兴遇上全新英文专辑《Step》,便为我们解锁了一种前所未有的出行体验!这不仅仅是一张音乐专辑,更…

Pandas AI:最棒的大模型数据分析神器!

暑期实习基本结束了,校招即将开启。 不同以往的是,当前职场环境已不再是那个双向奔赴时代了。求职者在变多,HC 在变少,岗位要求还更高了。 最近,我们又陆续整理了很多大厂的面试题,帮助一些球友解惑答疑&…

Java Opencv识别图片上的虫子

最近有个需求,希望识别图片上的虫子,对于java来说,图像识别不是很好做。在网上也搜索了很多,很多的代码都是不完整,或者下载下载报错,有的写的很长看不懂。所以自己试着用java的opencv写了一段代码。发现识…

Django+Vue.js怎么实现搜索功能

一.前言 类似这样的搜索功能 二.前端代码 <div class"form-container"><div class"form-group"><label for"departure-city">出发城市</label><select v-model"departureCity" id"departure-city&q…

把Vue项目从Window系统迁移到Mac系统的方案

不能启动vue ui 直接运行&#xff0c;会报错如下&#xff1a; failed to load config from /Users/xiaochen/IdeaProjects/ChatViewer-frontend/vite.config.tserror when starting dev server: Error: You installed esbuild for another platform than the one youre curre…

C++:STL容器-->set

使用set容器时需要导入头文件&#xff1a;#include <set> set和multiset区别&#xff1a; set不允许容器中有重复的元素 multiset允许容器中有重复的元素 1. 构造函数 set<T> st; set s(const &st); void printSet(set<int>& s) {for (set<int>…

Integer溢出问题

0. 背景 在刷 LeetCode 时&#xff0c;代码的执行结果与预期出现了偏差&#xff0c;原因是 Int 值超过了允许范围 [ − 2 31 , 2 31 − 1 ] [-2^{31},2^{31}-1 ] [−231,231−1]。工作中从来没有遇到过这种情况&#xff0c;之前的认知是如果 Int 中存储的值超过了允许范围也许…

【FreeRTOS】ARM架构汇编实例

目录 ARM架构简明教程1. ARM架构电脑的组成1.2 RISC1.2 提出问题1.3 CPU内部寄存器1.4 汇编指令 2. C函数的反汇编 学习视频 【FreeRTOS入门与工程实践 --由浅入深带你学习FreeRTOS&#xff08;FreeRTOS教程 基于STM32&#xff0c;以实际项目为导向&#xff09;】 https://www.…

Unity制作背包的格子

1.新建一个面板 2.点击面板并添加这个组件 3.点击UI创建一个原始图像&#xff0c;这样我们就会发现图像出现在了面板的左上角。 4.多复制几个并改变 Grid Layout Group的参数就可以实现下面的效果了

GraogGNSSLib学习

GraogGNSSLib学习 程序编译环境版本项目编译结果问题 程序编译 GraphGNSSLib 环境版本 程序开源是在ubuntu16.04-kinetic环境跑通的&#xff0c;但是我的环境是UBUNTU20.04&#xff0c;所以&#xff0c;先进行了ROS的安装&#xff0c;因为我的系统是ubuntu20.04所以&#xf…

Linux--MQTT(一)简介

一、简介 MQTT &#xff08; Message Queuing Telemetry Transport&#xff0c;消息队列遥测传输&#xff09;&#xff0c; 是一种基于客户端服务端架构的发布/订阅模式的消息传输协议。 与 HTTP 协议一样&#xff0c; MQTT 协议也是应用层协议&#xff0c;工作在 TCP/IP 四…

MOS开关电路应用于降低静态功耗

本文主要讲述MOS开关电路的应用,过了好久突然想整理一下&#xff0c;有错误的地方请多多指出&#xff0c;在做电池类产品&#xff0c;需要控制产品的静态功耗&#xff0c;即使让芯片进入休眠状态&#xff0c;依旧功率很大&#xff0c;所以在电路中加一组软开关&#xff0c;防止…

HTML静态网页成品作业(HTML+CSS)—— 零食商城网页(1个页面)

&#x1f389;不定期分享源码&#xff0c;关注不丢失哦 文章目录 一、作品介绍二、作品演示三、代码目录四、网站代码HTML部分代码 五、源码获取 一、作品介绍 &#x1f3f7;️本套采用HTMLCSS&#xff0c;未使用Javacsript代码&#xff0c;共有1个页面。 二、作品演示 三、代…

LeetCode 230.二叉搜索树中第K小的元素

各位看官们&#xff0c;大家好啊&#xff0c;今天这个题我用的方法时间复杂度比较高&#xff0c;但也是便于便于理解的一种方法&#xff0c;大家如果觉得的好的话&#xff0c;就给个免费的赞吧,谢谢大家了^ _ ^ 题目要求如图所示: 题目步骤&#xff1a; 1.我们可以一维数组来接…

使用Unsloth微调Llama3-Chinese-8B-Instruct中文开源大模型

微调Llama3-Chinese-8B-Instruct 微调是指在大规模预训练的基础模型上,使用特定领域或任务数据集进行少量迭代训练,以调整模型参数,提升其在特定任务上的表现。这种方法可以充分利用预训练模型的广泛知识,同时针对特定应用进行优化,达到更精准高效的效果。 Llama-3-Chinese-8B-…

刷题记录(240613)

aliyun0512 1. 小红定义一个数组是好数组&#xff0c;当且仅当所有奇数出现了奇数次&#xff0c;所有偶数出现了偶数次。现在小红拿到了一个数组&#xff0c;她希望取一个该数组的非空子序列(可以不连续)&#xff0c;使得子序列是好数组。你能帮小红求出子序列的方案数吗?由于…

【深度学习】stable-diffusion-3,SD3生图体验

stabilityai/stable-diffusion-3-medium 代码地址&#xff1a; https://huggingface.co/stabilityai/stable-diffusion-3-medium 可在这里体验&#xff1a; https://huggingface.co/spaces/ameerazam08/SD-3-Medium-GPU