当前位置: 首页 > news >正文

JavaEE|套接字编程之UDP数据报

文章目录

    • 一、DatagramSocket API
      • 构造方法
      • 常用方法
    • 二、DatagramPacket API
      • 构造方法
      • 常用方法
    • E1:回显服务器的实现
    • E2:带有业务逻辑的请求发送

一、DatagramSocket API

在操作系统中,把socket对象当成了一个文件处理。等价于是文件描述符表上的一项。

普通的文件,对应的硬件设备是硬盘,而socket文件,对应的硬件设备是网卡。

【网卡:是一块被设计用来允许计算机在计算机网络上进行通讯的计算机硬件。】

这也体现了计算机资源一切皆文件的理念。

如果要和多个不同的主机进行通信,就需要创建多个socket对象。

构造方法

方法签名说明
DatagramSocket()创建一个UDP数据报套接字的Socket,绑定到本机任意一个随机端口 (一般用于客户端)
DatagramSocket(int port)创建一个UDP数据报套接字的Socket,绑定到本机指定的端口(一般用 于服务端)

port是一个端口号,绑定了接收方进程。

那不指定端口号的构造方法呢?此时系统会自动分配一个空闲的端口。

本质上不是进程和端口号建立了联系,而是进程中的socket对象和端口建立了联系。

常用方法

方法签名方法说明
void receieve(DatagramSocket p)从当前套接字对象接受数据报。如果没有接收到会阻塞等待【输出形参数】
void send(DatagramSocket p)从当前套接字对象发送数据包。不会阻塞等待,直接发送
void close()关闭这个数据报套接字对象【类比文件对象关闭,释放资源】

二、DatagramPacket API

它是表示udp中传输的一个报文,构造这个对象,可以指定一些具体的数据进去。

构造方法

方法签名说明
DatagramPacket(byte[] buf,int length)构造接收数据报的对象,接受的数据保存在字节数组(buf)中,接收指定长度(len)
DatagramPacket(byte[] buf,int offset,int length,SocketAddress address)构造一个DatagramPacket以用来发送数据报的对象,发送的数据为字节数组(buf里),从0到指定长度(length)。address指定目的主机ip和端口号 【SocketAddress这个类表示ip+端口号】

常用方法

方法签名说明
InetAddress getAddress()从接收的数据报中,获取发送端主机IP地址;或从发送的数据报中,获取 接收端主机IP地址
int getPort()从接收的数据报中,获取发送端主机的端口号;或从发送的数据报中,取接收端主机端口号
byte[] getData()获取数据报中的数据

可以用一个线程receive,把数据放进阻塞队列中,另一个线程进行处理请求并响应。

手定指定,并不一定数组全部用,但是指定长度全部用,留微操空间。不过现在用的比较少了。

E1:回显服务器的实现

普通服务器和回响服务器的区别:

普通服务器,根据收到的请求个性化的返回对应的响应。

回显服务器,省略了其中的根据请求计算响应,请求是什么,就返回什么。

后者代码里边没有实际业务。而实际上最关键的是根据请求计算响应的环节。

注意事项:

  1. 端口号的设置:服务器可以显示指定,是因为是程序员手中的,是可控的,但是客户端一般是用户的,是不可控的E2:请求响应
  2. 个别参数的指定:①respose.length_字符的个数;respose.getBytes().length是字节的个数②offset是一个偏移量,相当于起始位置

UDP回响服务器代码

public class Code01UDPEchoServer {private DatagramSocket socket=null;//OS提供操作网卡的socket对象//服务器一定要关联上一个端口号!!!不能让它随机分配,方便端口号定位public Code01UDPEchoServer(int port) throws SocketException {socket=new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动!!");//        //存取数据
//        byte[] bytes=new byte[4096];//2^12
//      这里是直接每次new 了
//        int length=0;//因为要服务很多客户端,所以服务器需要一直在就绪状态while (true) {//1.获取客户端发送过来的请求//  receive是一个输出型参数,所以我们需要先构造一个DatagramPacket的对象DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);//类似给人家一个空白的纸条,两个人说悄悄话socket.receive(requestPacket);//由于这里是一个特殊对象,所以一般把它拿出来做成字符串//offset是一个偏移量//这里指定范围,节省构造字符串的空间[指构造有效范围的]String request = new String(requestPacket.getData(), 0, requestPacket.getLength());//2.根据请求计算响应(请求与响应相同)String respose=process(request);//3.把响应写回客户端//将响应字符串转成字节数组//respose.length_字符的个数//respose.getBytes().length是字节的个数//怎么确定响应返回端口——通过getSocketAddressDatagramPacket answerPacket=new DatagramPacket(respose.getBytes(),respose.getBytes().length,requestPacket.getSocketAddress());socket.send(answerPacket);//4.打印本次请求的处理中间结果System.out.printf("[%s:%d] req:%s\n",requestPacket.getAddress().toString(),requestPacket.getPort(),request,respose);//获得ip和端口}}//根据请求计算响应public String process(String request){return request;}public static void main(String[] args) throws IOException {Code01UDPEchoServer udpEchoServer=new Code01UDPEchoServer(1200);udpEchoServer.start();}
}

UDP回响客户端

public class Code02UDPEchoClient {private DatagramSocket socket=null;public Code02UDPEchoClient(String serverip, int serverport) throws SocketException {socket=new DatagramSocket();//不需要显示绑定端口,os随机分配serverIp=serverip;serverPort=serverport;}private String serverIp=null;private Integer serverPort=null;//一次通信,需要有两个ip,两个端口,客户端的ip是环回ip,端口号是操作系统随机分配的;服务器的ip和端口号需要声明public void start() throws IOException {System.out.println("客户端启动!");Scanner scanner = new Scanner(System.in);while (true) {// 1. 从控制台读取要发送的数据System.out.print("> ");String request = scanner.next();if (request.equals("exit")) {System.out.println("bye");break;}// 2. 构造成 UDP 请求, 并发送//    构造这个 Packet 的时候, 需要把 serverIp 和 port 都传入过来. 但是此处 IP 地址需要填写的是一个 32位的整数形式.// 这里的 IP 地址是一个字符串. 需要使用 InetAddress.getByName 来进行一个转换.端口号一直都是integer没关系DatagramPacket requestPacket = new DatagramPacket(request.getBytes(), request.getBytes().length, InetAddress.getByName(serverIp), serverPort);socket.send(requestPacket);// 3. 读取服务器的 UDP 响应, 并解析DatagramPacket responsePacket = new DatagramPacket(new byte[4096], 4096);socket.receive(responsePacket);String response = new String(responsePacket.getData(), 0, responsePacket.getLength());// 4. 把解析好的结果显示出来.System.out.println(response);}}public static void main(String[] args) throws IOException {Code02UDPEchoClient client = new Code02UDPEchoClient("127.0.0.1", 1200);client.start();}
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-XSqYLyLp-1676721291836)(F:\typora插图\image-20230218194828403.png)]

默认情况下,是只允许运行一个客户端,但是我们可以通过设置同时运行两个客户端的

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-refFjdqY-1676721291838)(F:\typora插图\image-20230218195123652.png)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-glSfyeRD-1676721291839)(F:\typora插图\image-20230218195211579.png)]

E2:带有业务逻辑的请求发送

思路:复用之前的echoServer的代码,只需要重写process的逻辑,即修改业务内容。

public class Code03_UdpDictServer extends Code01UDPEchoServer {private Map<String,String> map=new HashMap<>();public Code03_UdpDictServer(int port) throws SocketException {super(port);map.put("dog","小狗");map.put("cat","小猫");map.put("pig","小猪");}public String process(String request){return map.getOrDefault(request,"尚未查出结果");}public static void main(String[] args) throws IOException {Code03_UdpDictServer udpDictServer=new Code03_UdpDictServer(1200);udpDictServer.start();}
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-LpoUcOGJ-1676721291840)(F:\typora插图\image-20230218194650960.png)]

当然,除了使用map,我们还可以把词存在硬盘上,通过文件io操作直接读到硬盘上,这里就需要修改udpechoserver的start方法了。

相关文章:

JavaEE|套接字编程之UDP数据报

文章目录一、DatagramSocket API构造方法常用方法二、DatagramPacket API构造方法常用方法E1:回显服务器的实现E2:带有业务逻辑的请求发送一、DatagramSocket API 在操作系统中&#xff0c;把socket对象当成了一个文件处理。等价于是文件描述符表上的一项。 普通的文件&#xf…...

如何使用Python创建一个自定义视频播放器

目录 1、安装vlc的64位版本。 2、安装python的vlc模块。 3、编写如下代码&#xff0c;包含了播放&#xff0c;暂停&#xff0c;停止、音量控制功能。 4、来看一看运行结果。 5、如果遇到播放不了的问题&#xff0c;解决方式如下&#xff1a; 这个例子使用VLC作为视频播放器…...

Elasticsearch进行优化-使用索引拆分(Split)和索引收缩(shrink )

一、索引拆分和收缩的场景 在Elasticsearch集群部署的初期我们可能评估不到位&#xff0c;导致分配的主分片数量太少&#xff0c;单分片的数据量太大&#xff0c;导致搜索时性能下降&#xff0c;这时我们可以使用Elasticsearch提供的Split功能对当前的分片进行拆分&#xff0c…...

数论 —— 高斯记号(Gauss mark)

定义 数学上&#xff0c;高斯记号&#xff08;Gauss mark&#xff09;是指对取整符号和取小符号的统称&#xff0c;用于数论等领域。 设 x∈Rx \in \textbf{R}x∈R&#xff0c;用 [x][x][x] 表示不超过 xxx 的最大整数。也可记作 [x][x][x]。设 x∈Rx \in \textbf{R}x∈R&…...

【随笔】程序员眼中的 CPU,“没有灵魂的躯体”

引言 先引用一段比较有意思的论述&#xff1a; 现实中每个人是由两部分构成&#xff0c;灵魂和躯体&#xff0c;灵魂依附于躯体游走于世间&#xff0c;现实中我们面对的每个人其实面对的是其灵魂而非肉体&#xff0c;肉体不过是表象而已。 灵魂本性乃一恶物&#xff0c;寄生于…...

算法的时间复杂度

算法在编写成可执行程序后&#xff0c;运行时需要消耗时间资源和空间&#xff08;内存&#xff09;资源&#xff0c;因此衡量一个算法的好坏&#xff0c;一般是从时间和空间两个维度来衡量的。 时间复杂度主要衡量一个算法运行的快慢&#xff0c;而空间复杂度主要衡量一个算法运…...

华为OD机试 - 叠放书籍(Python) | 机试题算法思路 【2023】

最近更新的博客 华为OD机试 - 寻找路径 | 备考思路,刷题要点,答疑 【新解法】 华为OD机试 - 五键键盘 | 备考思路,刷题要点,答疑 【新解法】 华为OD机试 - IPv4 地址转换成整数 | 备考思路,刷题要点,答疑 【新解法】 华为OD机试 - 对称美学 | 备考思路,刷题要点,答疑 …...

进程间通信(重点)

概念 进程是一个独立的资源分配单元&#xff0c;不同进程之间的资源是独立的进程并非孤立的&#xff0c;不同进程需要进行信息的交互和状态的传递&#xff0c;因此需要进程之间的通信【IPC: Inter processes communication】 如qq聊天&#xff0c;qq在每个人的手机上是独立的…...

Reverse入门[不断记录]

文章目录前言一、[SWPUCTF 2021 新生赛]re1二、[SWPUCTF 2021 新生赛]re2三、[GFCTF 2021]wordy[花指令]四、[NSSRound#3 Team]jump_by_jump[花指令]五、[NSSRound#3 Team]jump_by_jump_revenge[花指令]前言 心血来潮&#xff0c;想接触点Reverse&#xff0c;感受下Reverse&am…...

如何实现外网访问内网ip?公网端口映射或内网映射来解决

本地搭建服务器应用&#xff0c;在局域网内可以访问&#xff0c;但在外网不能访问。如何实现外网访问内网ip&#xff1f;主要有两种方案&#xff1a;路由器端口映射和快解析内网映射。根据自己本地网络环境&#xff0c;结合是否有公网IP&#xff0c;是否有路由权限&#xff0c;…...

[acwing周赛复盘] 第 91 场周赛20230218

[acwing周赛复盘] 第 91 场周赛20230218 一、本周周赛总结二、 4861. 构造数列1. 题目描述2. 思路分析3. 代码实现三、4862. 浇花1. 题目描述2. 思路分析3. 代码实现四、4863. 构造新矩阵1. 题目描述2. 思路分析3. 代码实现六、参考链接一、本周周赛总结 这周挺难的。T1 贪心分…...

蓝桥12届

小蓝准备用 256MB 的内存空间开一个数组&#xff0c;数组的每个元素都是 32 位 二进制整数&#xff0c;如果不考虑程序占用的空间和维护内存需要的辅助空间&#xff0c;请问 256MB 的空间可以存储多少个 32 位二进制整数&#xff1f;1MB 1024KB 1KB 1024字节(byte) 1字节 8位…...

华为OD机试 - 斗地主(JS)

斗地主 题目 斗地主起源于湖北十堰房县, 据传是一位叫吴修全的年轻人根据当地流行的扑克玩法“跑得快”改编的, 如今已风靡整个中国,并流行于互联网上 牌型: 单顺,又称顺子,最少5张牌,最多12张牌(3...A),不能有2, 也不能有大小王,不计花色 例如:3-4-5-7-8,7-8-9-1…...

【MyBatis】| MyBatis的注解式开发

目录 一&#xff1a;MyBatis的注解式开发 1. Insert注解 2. Delete注解 3. Update注解 4. Select注解 5. Results注解 一&#xff1a;MyBatis的注解式开发 MyBatis中也提供了注解式开发⽅式&#xff0c;采⽤注解可以减少Sql映射⽂件的配置。 当然&#xff0c;使⽤注…...

python自制PDF转换.PNG格式图片(按每页生成图片完整源码)小工具!

使用PyQt5应用程序制作PDF转换成图片的小工具&#xff0c;可以导入PDF文档后一键生成对应的PNG图片。 PDF图片转换小工具使用的中间件&#xff1a; python版本&#xff1a;3.6.8 UI应用版本&#xff1a;PyQt5 PDF文件操作非标准库&#xff1a;PyPDF2 PNG图片生成库&#xff1…...

Go 数组和切片反思

切片的底层数据结构是数组&#xff0c;所以&#xff0c;切片是基于数组的上层封装&#xff0c;使用数组的场景&#xff0c;也完全可以使用切片。 类型比较 我看到 go 1.17 有对切片和数组转换的优化&#xff0c;禁不住纳闷&#xff0c;有什么场景是必须数组来完成的呢&#x…...

win10电脑性能优化设置

win10电脑性能优化设置 目录win10电脑性能优化设置1.桌面图标显示2.wini2.1 “系统”2.1.1专注助手 关2.1.2 电源和睡眠 设置为从不2.1.3 存储 开2.2 网络和Internet2.3 个性化2.4 应用2.5 账户2.6 游戏2.7 隐私墨迹书写和键入个性化&#xff1a;关活动历史记录&#xff1a;全部…...

作为初学者必须要了解的几种常用数据库!

现在已经存在了很多优秀的商业数据库&#xff0c;如甲骨文&#xff08;Oracle&#xff09;公司的 Oracle 数据库、IBM 公司的 DB2 数据库、微软公司的 SQL Server 数据库和 Access 数据库。同时&#xff0c;还有很多优秀的开源数据库&#xff0c;如 MySQL 数据库&#xff0c;Po…...

小红书日常实习一面面经

时间:2月13下午 平台&#xff1a;赛码网&#xff0c;视频面大概70分钟顺序大致是下面&#xff0c;讲到哪问到哪&#xff0c;基础知识最好要结合项目或者实际回答&#xff0c;没录音不完全&#xff0c;有错误请指正首先面试官人超级好&#xff0c;细心提问&#xff0c;耐心解答问…...

将Nginx 核心知识点扒了个底朝天(一)

什么是Nginx&#xff1f; Nginx是一个 轻量级/高性能的反向代理Web服务器&#xff0c;用于 HTTP、HTTPS、SMTP、POP3 和 IMAP 协议。他实现非常高效的反向代理、负载平衡&#xff0c;他可以处理2-3万并发连接数&#xff0c;官方监测能支持5万并发&#xff0c;现在中国使用ngin…...

遍历 Map 类型集合的方法汇总

1 方法一 先用方法 keySet() 获取集合中的所有键。再通过 gey(key) 方法用对应键获取值 import java.util.HashMap; import java.util.Set;public class Test {public static void main(String[] args) {HashMap hashMap new HashMap();hashMap.put("语文",99);has…...

ffmpeg(四):滤镜命令

FFmpeg 的滤镜命令是用于音视频处理中的强大工具&#xff0c;可以完成剪裁、缩放、加水印、调色、合成、旋转、模糊、叠加字幕等复杂的操作。其核心语法格式一般如下&#xff1a; ffmpeg -i input.mp4 -vf "滤镜参数" output.mp4或者带音频滤镜&#xff1a; ffmpeg…...

鱼香ros docker配置镜像报错:https://registry-1.docker.io/v2/

使用鱼香ros一件安装docker时的https://registry-1.docker.io/v2/问题 一键安装指令 wget http://fishros.com/install -O fishros && . fishros出现问题&#xff1a;docker pull 失败 网络不同&#xff0c;需要使用镜像源 按照如下步骤操作 sudo vi /etc/docker/dae…...

【论文阅读28】-CNN-BiLSTM-Attention-(2024)

本文把滑坡位移序列拆开、筛优质因子&#xff0c;再用 CNN-BiLSTM-Attention 来动态预测每个子序列&#xff0c;最后重构出总位移&#xff0c;预测效果超越传统模型。 文章目录 1 引言2 方法2.1 位移时间序列加性模型2.2 变分模态分解 (VMD) 具体步骤2.3.1 样本熵&#xff08;S…...

初探Service服务发现机制

1.Service简介 Service是将运行在一组Pod上的应用程序发布为网络服务的抽象方法。 主要功能&#xff1a;服务发现和负载均衡。 Service类型的包括ClusterIP类型、NodePort类型、LoadBalancer类型、ExternalName类型 2.Endpoints简介 Endpoints是一种Kubernetes资源&#xf…...

Mysql中select查询语句的执行过程

目录 1、介绍 1.1、组件介绍 1.2、Sql执行顺序 2、执行流程 2.1. 连接与认证 2.2. 查询缓存 2.3. 语法解析&#xff08;Parser&#xff09; 2.4、执行sql 1. 预处理&#xff08;Preprocessor&#xff09; 2. 查询优化器&#xff08;Optimizer&#xff09; 3. 执行器…...

【笔记】WSL 中 Rust 安装与测试完整记录

#工作记录 WSL 中 Rust 安装与测试完整记录 1. 运行环境 系统&#xff1a;Ubuntu 24.04 LTS (WSL2)架构&#xff1a;x86_64 (GNU/Linux)Rust 版本&#xff1a;rustc 1.87.0 (2025-05-09)Cargo 版本&#xff1a;cargo 1.87.0 (2025-05-06) 2. 安装 Rust 2.1 使用 Rust 官方安…...

三分算法与DeepSeek辅助证明是单峰函数

前置 单峰函数有唯一的最大值&#xff0c;最大值左侧的数值严格单调递增&#xff0c;最大值右侧的数值严格单调递减。 单谷函数有唯一的最小值&#xff0c;最小值左侧的数值严格单调递减&#xff0c;最小值右侧的数值严格单调递增。 三分的本质 三分和二分一样都是通过不断缩…...

多模态图像修复系统:基于深度学习的图片修复实现

多模态图像修复系统:基于深度学习的图片修复实现 1. 系统概述 本系统使用多模态大模型(Stable Diffusion Inpainting)实现图像修复功能,结合文本描述和图片输入,对指定区域进行内容修复。系统包含完整的数据处理、模型训练、推理部署流程。 import torch import numpy …...

比较数据迁移后MySQL数据库和OceanBase数据仓库中的表

设计一个MySQL数据库和OceanBase数据仓库的表数据比较的详细程序流程,两张表是相同的结构,都有整型主键id字段,需要每次从数据库分批取得2000条数据,用于比较,比较操作的同时可以再取2000条数据,等上一次比较完成之后,开始比较,直到比较完所有的数据。比较操作需要比较…...