【网络编程】基于UDP数据报实现回显服务器程序

个人主页:兜里有颗棉花糖
欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 兜里有颗棉花糖 原创
收录于专栏【网络编程】【Java系列】
本专栏旨在分享学习网络编程的一点学习心得,欢迎大家在评论区交流讨论💌

前言

我们如果想让应用程序进行网络通信的话,就需要调用传输层为应用层提供的API。传输层提供的协议主要有两个:UDP和TCP,这两个协议提供了两套不同的API。操作系统给这些应用程序提供的这些用于网络通信的API起了一个名字,即socket api

目录

  • 一、UDP和TCP特点对比
  • 二、UDP数据报套接字编程
  • 三、DatagramSocket
  • 四、DatagramPacket
  • 五、通过UDP数据报实现回显服务器(echo server)
    • 5.1服务器端
    • 服务器端代码
    • 5.2客户端
    • 客户端代码

一、UDP和TCP特点对比

UDP特点:无连接、不可靠传输、面向数据报,全双工。
TCP特点:有连接、可靠传输、面向字节流,全双工。

  • 连接:我们知道JDBC编程中先创建DataSource,然后再通过DataSource创建Connection。对于TCP编程的话来存在像JDBC类似的连接方式。
  • 可靠传输/不可靠传输:可靠传输就是主机A尽可能的将消息传给zhujiB,并且当消息传输失败的时候主机A可以感知到,当然当消息传输成功的时候主机A可以得知自己发送的消息传输完毕。TCP是可靠传输但是与此同时TCP付出的代价就是TCP在进行信息传输的时候传输效率有所降低UDP是不可靠传输但是UDP在进行信息传输的时候,传输效率得到了提供。

网络安全方面(网络安指的是如果我们传输的数据被黑客):有的地方提出TCP比UDP更加安全,这种说法是错误的。

  • - 面向字节流:TCP和文件操作是类似的,都是流式的操作。这里传输的单位是字节,我们称之为字节流。TCP协议的数据传输可以传输任意长度的字节流数据,但是,一次读写的数据数量通常是由发送方和接收方的缓冲区大小决定的(比如我们可以一次性读写50字节的数据,可以一次性读写100字节的数据。)。
  • 面向数据报:UDP是面向数据报读写的基本单位,单位是一个UDP数据包。在UDP协议中,数据被封装在UDP数据报中,每个UDP数据报包含一些列的数据和属性。
  • 全双工:全双工即一个通道可以双向通信,而半双工意思就是一个通道只能偶单向通信。我们家里使用的网线就是全双工的。

二、UDP数据报套接字编程

UDP数据报套接字编程是使用UDP协议进行网络通信的一种编程方式。

在Java中,UDP是通过java.net.DatagramSocket类和java.net.DatagramPacket类来提供API的。

java.net.DatagramSocket类代表一个UDP套接字对象(Socket对象

操作系统使用文件这样的概念来管理软硬件资源(其实文件对于操作系统来说是一个非常广义的概念,不仅仅可以代表硬盘上的文件,也可以代表着其它情况的文件;文件这个概念其实有很多种含义:不仅仅是针对硬盘上的文件,也可以是其它的设备(比如键盘接入到计算机之后,计算机也是把键盘当作文件去进行处理,显示器接入到计算机之后,显示器也会被当作文件来处理))。
对于网卡来说操作系统也是使用文件的方式来管理网卡的,表示网卡的这类文件我们就称之为socket文件
在Java中,socker对象就对应系统中的socker文件,而socker文件又是用来管理网卡的(即最终依然是落到网卡,我们要想进行网络通信的话必须要通过socker对象把网卡关联起来,然后我们才能基于网卡来发送接收数据)

在java中,java.net.DatagramPacket用来表示UDP数据报。

DatagramPacket对象可以代表系统中设定的UDP数据报的二进制结构。

以上java.net.DatagramSocket类和java.net.DatagramPacket类是我们进行UDP编程中必不可少了两个类。

三、DatagramSocket

DatagramSocketUDP Socket,用于发送和接收UDP数据报。

DatagramSocket构造方法(分为有参和无参)如下:

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

在这里插入图片描述

DatagramSocket类方法

方法签名方法说明
void receive(DatagramPacket p)从此套接字接收数据报(如果没有接收到数据报,该方法会阻塞等待)
void send(DatagramPacket p)从此套接字发送数据报包(不会阻塞等待,直接发送)
void close()关闭此数据报套接字

我们可以看到前两个方法的参数都是DatagramPacket,UDP是一种面向数据报的传输层协议,传输数据的基本单位就是数据报,即DatagramPacket对象

四、DatagramPacket

DatagramPacket构造方法

方法签名方法说明
DatagramPacket(byte[] buf, int length)构造一个DatagramPacket以用来接收数据报,接收的数据保存在字节数组(第一个参数buf)中,接收指定长度(第二个参数length)
DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)构造一个DatagramPacket以用来发送数据报,发送的数据为字节数组(第一个参数buf)中,从0到指定长度(第二个参数length)。address指定目的主机的IP和端口号

DatagramPacket(byte[] buf, int offset, int length, SocketAddress address):我们知道DatagramPacket表示一个UDP数据报,则这个数据报就必须承载一定的数据,通过手动指定的byte[]数组来作为存储数据的空间,然后通过SocketAddress address来指定目的ip和目的端口。

DatagramPacket 方法

方法签名方法说明
InetAddress getAddress()从接收的数据报中,获取发送端主机IP地址;或从发送的数据报中,获取接收端主机IP地址
int getPort()从接收的数据报中,获取发送端主机的端口号;或从发送的数据报中,获取接收端主机端口号
byte[] getData()获取数据报中的数据,即获取的是UDP数据报中的载荷部分(即完整的应用层数据报)

五、通过UDP数据报实现回显服务器(echo server)

Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么

现在我们编写一个回显服务器程序:

5.1服务器端

先来看服务器端的代码编写:在这里插入图片描述
上图代码中有时候创建对象的时候会失败,最典型的创建对象失败的原因就是端口号被占用
关于端口号:端口号是用来区分主机上应用程序的,一个应用程序可以占据主机上多个端口,通常情况下一个端口只能被一个进程占用(当然这样说有些太过于绝对了,因为存在一些特殊情况,这里不展开讨论)。
所以当端口已经被别的进程占用时,此时如果我们再创建socket对象来占用此端口的话就会报错。

对于一个服务器来说要做的工作主要有三个主要环节:

  • 1.读取请求,并对请求进行解析
  • 2.根据请求计算出响应
  • 3.把相应返回给客户端

上述的三个环节对于第一步和第三步来说一般都是固定的流程和套路

  • 第一步:读取请求并对请求进行解析

在这里插入图片描述
DatagramSocket类方法中的receive(DatagramPacket p)方法中的参数DatagramPacket p是一个输出型参数,传入receive方法中的对象是一个空的对象,reveive内部就会对传入receive方法中的空的对象给填充上,当reveive方法执行完毕之后,就会得到一个充满内容的DatagramPacket

在这里插入图片描述
这里的DatagramPacker对象是用来保存数据的内存空间,其中这里内存空间的申请是需要我们手动进行申请的。
然后我们就可以将requestPacket传入到receive方法中,如下:
在这里插入图片描述
这里有异常直接抛出即可。
在这里插入图片描述
当服务器一旦启动之后并进入到while循环中,接着就会立即执行到receive方法。
我们知道,服务器并不知道什么时候发出请求,所以服务器要随时做好就接收来自客户端请求的信息。
但是当客户端的请求还没有达到服务器时。此时服务器这边就会进入到阻塞等待的状态,直到阻塞等待到有请求到达客户端。

在这里插入图片描述
requestPacket是一个DatagramPacket对象,它通过DatagramSocketreceive方法接收到的数据报会被存储在这个对象中。
requestPacket.getData()返回的是一个byte数组,代表接收到的数据报的内容。requestPacket.getLength()返回的是接收到的数据报的长度。
然后,通过String类的构造函数String(byte[] bytes, int offset, int length)将接收到的数据报的内容转换成字符串。在这个例子中,使用了读取到的数据报的内容作为字节数组,偏移量为0,长度为接收到的数据报的长度。
最终,request变量中存储的就是从数据报中提取出来的字符串内容。


requestPacket.getSocketAddress():当前我们要把数据报发送给客户端,所以此时我们就需要知道客户端的ip和端口是什么,此类信息均在DatagramPacket对象中包含着,即DatagramPacket中就包含着通信双方的ip和端口号(即客户端的ip、端口;服务器端的ip、端口均在DatagramPacket中保存着),所以我们就可以通过getSocketAddress()方法获取到当前客户端的ip和端口

服务器端代码

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;// Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么
public class UdpEchoServer {private DatagramSocket socket = null;// 构造方法public UdpEchoServer(int port) throws SocketException {socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动!!!");while(true) {// 服务器需要长期反复的执行针对客户端请求处理的逻辑// 对于一个服务器来说要做的工作主要有三个主要环节"// 1.读取请求,并对请求进行解析DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);socket.receive(requestPacket);// 可以将DatagramPacket对象中的字节数组转换成字符串,这样的转字符串的前提时后续客户端发送的数据是一个文本字符串// 如果客户端发送的数据是一个二进制,这里就不合适了// 大体梳理一下:通过DatagramSocket类中的receive方法来读取到requestPacket(数据报对象)中的内容,// 然后再进一步的将数据报中的载荷提取并转换为字符串String request = new String(requestPacket.getData(),0, requestPacket.getLength());// 2.根据请求计算出响应String response = process(request);// 3.把相应返回给客户端// 此时要告知网卡要发送的内容以及,要发给谁两部分内容DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,requestPacket.getSocketAddress());socket.send(responsePacket);// 而对于这里的回显服务器来说不需要关心具体的流程,因为回显服务器请求是什么返回的响应就是什么// 但是对于一个商业级的服务器来说,最主要的代码就是完成第二步的代码编写// 记录日志,方便观察System.out.printf("[%s:%d] req: %s, resp : %s\n",requestPacket.getSocketAddress().toString(),requestPacket.getPort(),request,response);}}// 第二步:根据请求计算响应,由于我们写的程序是一个回显服务器,所以响应内容和请求是一致的,即请求是什么响应就是什么public String process(String request) {return request;}public static void main(String[] args) throws IOException {UdpEchoServer server = new UdpEchoServer(9090);server.start();}
}

5.2客户端

在这里插入图片描述

客户端代码

import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UdpEchoClient {private DatagramSocket socket = null;private String serverIp;private int serverPort;// 服务器的ip和服务器的端口public UdpEchoClient(String ip,int port) throws SocketException {serverIp = ip;serverPort = port;// 下面的new操作就不需要再指定端口了,而是让系统随机分配一个空闲端口socket = new DatagramSocket();}// 让客户端反复的从控制台中读取用户输入的信息// 然后把这个内容构造成UDP请求发送给服务器,再读取服务器返回的UDP响应// 最终显示再客户端的屏幕上public void start() throws IOException {Scanner scanner = new Scanner(System.in);System.out.println("客户端启动!!!");while(true) {// 1.从控制台读取用户输入的用户输入的内容。System.out.printf("-->"); // 命令提示符来提示用户输入字符串String request = scanner.next();// 2.构造请求对象并发送给服务器DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,InetAddress.getByName(serverIp),serverPort);socket.send(requestPacket);// 3.读取服务器的响应,并解析出响应内容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) {}
}

在这里插入图片描述在这里插入图片描述

以上就是回显服务器程序的所有代码。

程序运行结果如下(注意一定是服务器先开始运行):
在这里插入图片描述
在这里插入图片描述
如果我们启动多个客户端的话,此时服务器依然是可以应对的。
此时我们需要对我们的IDEA进行一些设置,请看:
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
可以看到两个客户端同时在跑。

本文到这里就结束了,希望友友们可以支持一下一键三连哈。嗯,就到这里吧,再见啦!!!

在这里插入图片描述

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

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

相关文章

互联网+建筑工地:技术革新引领建筑行业的未来

随着科技的飞速发展,互联网正日益渗透到建筑工地的方方面面。从设计、施工到管理,互联网建筑工地的深度融合不仅推动了建筑行业的数字化转型,还为工地管理、信息交流、安全监控等带来了全新的解决方案。本文将介绍互联网建筑工地的几个关键技…

java.lang.EnumConstantNotPresentException

枚举常量不存在异常。当应用试图通过名称和枚举类型访问一个枚举对象,但该枚举对象并不包含常量时,抛出该异常 1.遇到的问题是我删除了带有CustomAnnotation注解的类,启动服务器还是会抛出异常 2.首先全局搜索了相关的枚举名字 确认没有引用。后发现项目…

keras 人工智能之VGGNet神经网络的图片识别训练

上期文章我们分享了如何使用LetNet体系结构来搭建一个图片识别的神经网络: 人工智能Keras的第一个图像分类器(CNN卷积神经网络的图片识别) 本期我们基于VGGNet神经网络来进行图片的识别,且增加图片的识别种类,当然你也可以增加更多的种类,本期代码跟往期代码有很大的相…

【MySQL】:超详细MySQL完整安装和配置教程

🎥 屿小夏 : 个人主页 🔥个人专栏 : MySQL从入门到进阶 🌄 莫道桑榆晚,为霞尚满天! 文章目录 📑前言一. MySQL数据库1.1 版本1.2 下载1.3 安装1.4 客户端连接 🌤️全篇总…

LaTex设置标题页、修改文字颜色和文字高亮

目录 一、标题页 1)常用的代码 2)添加脚注 二、修改文字颜色和文字高亮 1)设置文本的颜色 2)添加文本高亮 3)给文本添加有颜色的方框 一、标题页 主要的代码: \begin{titlepage} \noindent\fonts…

如何实现https密钥对登录方式

先安装docker yum install -y yum-utils device-mapper-persistent-data lvm2 yum-config-manager --add-repo https://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo systemctl start docker.service systemctl enable docker.service yum install -y docker…

Kali Linux—借助 SET+MSF 进行网络钓鱼、生成木马、获主机shell、权限提升、远程监控、钓鱼邮件等完整渗透测试(一)

社会工程学—世界头号黑客凯文米特尼克在《欺骗的艺术》中曾提到,这是一种通过对受害者心理弱点、本能反应、好奇心、信任、贪婪等心理陷阱进行诸如欺骗、伤害等危害手段。 SET最常用的攻击方法有:用恶意附件对目标进行 E-mail 钓鱼攻击、Java Applet攻…

nosql-redis整合测试

nosql-redis整合测试 1、创建项目并导入redis2、配置redis3、写测试类4、在redis中创建key5、访问80826、在集成测试中测试方法 1、创建项目并导入redis 2、配置redis 3、写测试类 4、在redis中创建key 5、访问8082 6、在集成测试中测试方法 package com.example.boot3.redis;…

SpringMVC之跨域请求

系列文章目录 提示:这里可以添加系列文章的所有文章的目录,目录需要自己手动添加 SpringMVC之跨域请求 提示:写完文章后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 系列文章目录前言一、什么是同源策略…

doris基本操作,04-表结构的变更

整体思路 因为doris完全兼容mysql协议,因此操作上基本与mysql没有太大区别, 之需要注意与doris相关的关键字即可,如:预聚合,key等 当前表结构 create table table1 {siteid int default 10,citycode smallint,usern…

HarmonyOS 签名打包Hap(s)、App(s)

1. 基本概念 HarmonyOS应用通过数字证书(.cer文件)和Profile文件(.p7b文件)来保证应用的完整性,数字证书和Profile文件可通过申请发布证书和Profile文件获取。   申请数字证书和Profile文件前,首先需要通…

渗透测试——1.2被动扫描

一、概念 目标无法觉察的情况下进行的信息收集。公开渠道可获得的信息,与目标系统不产生直接交互,尽量避免留下一切痕迹。 二、CDN(content delivery netword内容分发网路) 多台边缘服务器提供网络服务, 三、WAF&am…

docker-compose 安装Sonar并集成gitlab

文章目录 1. 前置条件2. 编写docker-compose-sonar.yml文件3. 集成 gitlab4. Sonar Login with GitLab 1. 前置条件 安装docker-compose 安装docker 创建容器运行的特有网络 创建挂载目录 2. 编写docker-compose-sonar.yml文件 version: "3" services:sonar-postgre…

地图导航测试点总结

地图导航是我们经常使用的工具,能帮助我们指引前进的方向。 接下来,会从功能测试、UI测试、兼容测试、安全测试、网络测试、性能测试、易用性测试、文档和国际化语言测试8个方面来编写地图导航测试用例。 一、功能测试 1. 输入起点和终点,…

CSS样式斜切边

html部分 <div class"rectangle"></div> 样式一&#xff1a; .rectangle { width: 251px; height: 75px; background: linear-gradient(-135deg, transparent 52px, #ffffff 0) top right; background-size: 100% 100%; background-repeat: no-repeat; b…

德思特分享丨V2X在做什么?连接未来智能出行的车联网(下)

来源&#xff1a;德思特测试测量 德思特分享丨V2X在做什么&#xff1f;连接未来智能出行的车联网&#xff08;下&#xff09; 原文链接&#xff1a;https://mp.weixin.qq.com/s/yEoCrLls-xuaF4CvVT2_zQ 欢迎关注虹科&#xff0c;为您提供最新资讯&#xff01; 在之前的文章中…

pytorch 踩坑

pytorch 踩坑 在pytorch中&#xff0c;如果你定义了没用的组件&#xff0c;同样也会影响你的模型(我也不知道从哪里影响的)&#xff0c;看一个例子 def _make_layer(self, block, planes, blocks, stride1, dilateFalse):norm_layer self._norm_layer#downsample Noneprevio…

外卖系统开发:构建高效、安全的外卖平台

在当今数字化时代&#xff0c;外卖系统成为了餐饮行业不可或缺的一部分。本文将介绍如何使用一些主流的技术和代码片段来开发一个简单而功能强大的外卖系统。 1. 技术选择 在开始外卖系统的开发之前&#xff0c;首先需要选择合适的技术栈。以下是一个常见的技术栈&#xff1…

新型智慧城市解决方案:PPT全文56页,附下载

关键词&#xff1a;智慧城市解决方案&#xff0c;智慧城市管理技术&#xff0c;智慧城市建设&#xff0c;数字城市建设 一、智慧城市宏观形势 1、政策支持&#xff1a;出台了一系列政策&#xff0c;鼓励和支持智慧城市的发展。这些政策为智慧城市的建设提供了政策保障和资金支…

小区物业大数据监控服务平台(PSD文件资料)

现分享简约物业大数据平台页面、小区物业大数据监控服务平台模版的UI源文件&#xff0c;供设计师们快速获取PS源文件完成工作。 若需 更多行业 相关的大屏&#xff0c;请移步小7的另一篇文章&#xff1a;200套精选数据可视化大屏&#xff0c;大屏PSD设计&#xff08;各行业大屏…