【JavaEE初阶】深入理解网络编程—使用UDP协议API实现回显服务器

news2024/10/21 4:38:14

前言

🌟🌟本期讲解关于TCP/UDP协议的原理理解~~~

🌈感兴趣的小伙伴看一看小编主页:GGBondlctrl-CSDN博客

🔥 你的点赞就是小编不断更新的最大动力                                       

🎆那么废话不多说直接开整吧~~~

目录

1.UDP的API使用 

1.1DatagramSocket

1.2DatagramPacket 

2.实现回显服务器

2.1概念

2.2服务器的操作过程

1.初始化服务器

2.读取请求并解析

3.根据请求实现响应

4.把响应返回给客户端

5.客户端的IP和端口号打印

6.主函数的实现

2.3客户端的操作过程

1.初始化客户端

2.控制台输入请求

3.构造请求并且发送

4.读取服务器的响应

5.主函数的实现

2.4回显服务器基本流程

2.5打印日志分析

3.总结

 

1.UDP的API使用 

1.1DatagramSocket

这里负责对Socket进行读写,借助网卡进行数据的读写操作;

这里的初始化方法有以下几种:

DatagramSocket()创建一个UDP数据报套接字Socket,绑定到本机的随意的一个端口(客户端)
DatagramSocket(int port)创建一个UDP数据报套接字Socket,绑定到本机的指定的一个端口(服务器)

 还包括实现那套接字的方法:

receive(DatagramPacket p)使用套接字实现数据的读取
send(DatagramPacket p)使用套接字实现数据的写入

注意:这里的DatagramPacket就是一个输出型参数 

1.2DatagramPacket 

       接着上面,小编提到这里的DatagramPacket是一个输出型参数,和前面实现文件IO的操作类似的,这里的就是一个UDP数据报,是接收和发送数据的基本单位;

2.实现回显服务器

2.1概念

回显服务器:相当于我们之前学习的输出hello world,这里的回显服务器代表的是没有任何逻辑过程,即客户端请求啥就直接响应啥;

2.2服务器的操作过程

1.初始化服务器

代码如下:

public class UDPServer {
    //构造方法
     private DatagramSocket socket=null;
     public UDPServer(int port) throws SocketException {
        //通过socket对网卡进行数据的操作
        socket=new DatagramSocket(port);
    }

注意

1.我们所有的对于网卡的操作就是借用这里的socket实现,这里的port是一个端口号,服务器是可控的所以这里就要指定一个端口号;

2.抛出异常,当端口号被一个进程占用了,那么端口号就创建失败了,一个端口号只能被一个进程占用,但是一个进程可以占用多个端口号;

2.读取请求并解析

代码如下:

public void start() throws IOException {
        System.out.println("服务器启动!");
        while (true) {
            // 每次循环, 就是处理一个请求-响应过程.
            // 1. 读取请求并解析
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);
            socket.receive(requestPacket);
            // 读到的字节数组, 转成 String 方便后续的逻辑处理.
            String request = new String(requestPacket.getData(), 0, requestPacket.getLength());

注意:

1.这里的死循环是为了表示,服务器是24小时不间断的,所以没有必要进行退出的操作;

2.通过DatagramPacket设置保存这里的读取到的字节信息,这是一个输出型参数;

3.此时的receive就能读取到UDP数据报的的内容,存放到requestPacket字节数组中;并且这里还知道原IP端口是啥(即数据从哪里来的)

4.最后将这里的字节类型的数据转化为字符串类型的数据,字节数组里不一定就是二进制的数据,还可能是文本类型的数据,使用string保存恰到好处;

3.根据请求实现响应

代码如下:

 String response = process(request);


 public String process(String request) {
        return request;
    }

注意:

由于回显服务器是没有业务逻辑的,所以在实现对应的响应的时候,直接放回输出的请求即可

4.把响应返回给客户端

代码如下:

 // 3. 把响应返回到客户端.
 //    构造一个 DatagramPacket 作为响应对象
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.getBytes().length,
            requestPacket.getSocketAddress());
            socket.send(responsePacket);

注意

1.这里的实现对于字符串的操作,把string的字节数组给提取出来;

2.这里还使用了socketAddress实现,得到INetAddress对象,包含了客户端的的IP和端口号,即客户端的数据报;

5.客户端的IP和端口号打印

代码如下:

  System.out.printf("[%s:%d] req: %s, resp: %s\n", requestPacket.getAddress().toString(),
                    requestPacket.getPort(), request, respond);

注意:

这里代表的就是客户端的IP,端口号,以及请求和响应;

6.主函数的实现

代码如下:

public static void main(String[] args) throws IOException {
        UDPServer udpServer=new UDPServer(9090);
        udpServer.start();
    }

注意:

 这里的9090是我们程序员规定的服务器的端口号;

2.3客户端的操作过程

1.初始化客户端

代码如下:

public class UDPClient {
    private DatagramSocket socket=null;
    private String ServerIP;
    private int ServerPort;
    public UDPClient(String serverIP,int serverPort) throws SocketException {
        this.ServerIP= serverIP;
        this.ServerPort=serverPort;
        socket=new DatagramSocket();
    }

注意:

这里要设置要请求的服务器的IP和端口号,因为发起请求就是要知道服务器在哪里;这里和上面日志的打印是一致的,请求的IP是客户端的本机IP,客户端是系统随机分配的;

2.控制台输入请求

代码如下:

 public void start() throws IOException {
        System.out.println("客户端启动");
        Scanner sc=new Scanner(System.in);
        while (true){
            System.out.println("->");
            if (!sc.hasNext()){
                break;
            }

注意:

这里和服务器是一致的,都是24小时不间断的,这里的sc.hashnext是为了表示没有更多的的输入了,那么就返回false去反后就跳出循环;

3.构造请求并且发送

代码如下:

String request=sc.next();
            DatagramPacket requestPacket=new DatagramPacket(request.getBytes(),request.getBytes().length,
            InetAddress.getByName(ServerIP),ServerPort);
            //来自哪里的信息
            socket.send(requestPacket);

注意:

这里就是通过字符串转为字节数据,并且指定发送的端口号和IP地址,最后通过send进行发送数据,请求服务器;

4.读取服务器的响应

代码如下:

// 4. 读取服务器的响应.
            DatagramPacket respondPacket=new DatagramPacket(new byte[1024],1024);
            socket.receive(respondPacket);

            String respond=new String(respondPacket.getData(),0,respondPacket.getLength());

            System.out.println(respond);

注意:

这里就规定传输的数据单位,通过接收服务器传来的响应,保存到字节数组里面,最后转为string字符串类型的数据,在实现打印

5.主函数的实现
public static void main(String[] args) throws IOException {
        UDPClient udpClient=new UDPClient("127.0.0.1", 9090);
        udpClient.start();
    }

注意:

这里的“127.0.0.1”是本机的IP地址,9090是我们输入的服务器端口号;

2.4回显服务器基本流程

如下图片的实现过程:

小编这里由于宽度不够就无法完全分开,请见谅~~~以上就是具体的实现过程

第一步:服务器启动进入receive,发现没有请求,那么就直接进入阻塞;

具体代码:

 DatagramPacket requestPacket=new DatagramPacket(new byte[1024],1024);
            //通过接收的方法进行数据的传入
            socket.receive(requestPacket);

 第二步:客户端进入循环,执行到sc.hashnext进入阻塞,知道用户输入内容;

具体代码:

 System.out.println("->");
            if (!sc.hasNext()){
                break;
            }

第三步:输入请求的内容,转化为字节类型数据,指定服务器IP和端口号,发送请求

具体代码:

 String request=sc.next();
            DatagramPacket requestPacket=new DatagramPacket(request.getBytes(),request.getBytes().length,
                    InetAddress.getByName(ServerIP),ServerPort);
            //来自哪里的信息
            socket.send(requestPacket);

第四步:服务器解除阻塞,读取DatagramRocket对象,构造string需求,根据需求执行响应操作,最后返回构造响应对象,并进行send发送的操作;这个过程客户端阻塞

具体代码:

 String request=new String(requestPacket.getData(),0,requestPacket.getLength());
            //注意这里的长度是字节的长度,不是字符串的长度
            //进行响应的操作
            String respond=process(request);
            //发送响应,转化为面向数据包的类型
            DatagramPacket respondPacket=new DatagramPacket(respond.getBytes(),respond.getBytes().length,
                    requestPacket.getSocketAddress());
            //最后发送这个数据
            socket.send(respondPacket);

第五步:客户端接收服务器传来的数据,存储在字节数组中,然后转化为字符串数据类型,实现打印在控制台上;

具体代码:

 DatagramPacket respondPacket=new DatagramPacket(new byte[1024],1024);
            socket.receive(respondPacket);

            String respond=new String(respondPacket.getData(),0,respondPacket.getLength());

            System.out.println(respond);

2.5打印日志分析

这里我们启动服务器和客户端后,进行输入:

这里我们就可以看到输出一个nihao那么就返回一个nihao,那么我们可以看看服务器的打印日志

如下图:

此时注意前面两个第一个是“127.0.0.1”是我们自己的本机IP地址,并且后面这个就是请求的端口;

3.总结

 💬💬本期小编主要讲解了UDP的API的使用,并且通过UDP提供的API实现回显服务器的实现,当然这里设计到服务器和客户端两边的实现过程~~~

具体代码已上传gitee,代码在这里:network: 网络编程

🌅🌅🌅~~~~最后希望与诸君共勉,共同进步!! 


💪💪💪以上就是本期内容了, 感兴趣的话,就关注小编吧。

                             😊😊  期待你的关注~~~

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

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

相关文章

centors7安装docker启动ubuntu

在centors上升级glibc为2.18,使用yum最新源直接安装不行,使用源码安装还不行,因为必须使用2.18版本glic,采用先安装docker,在启动新的Ubuntu,在ubuntu里配置自己的环境 1. centors安装docker 查看docker的…

专业学习|马尔可夫链(概念、变体以及例题)

一、马尔可夫链的概念及组成 (一)学习资料分享 来源:024-一张图,但讲懂马尔可夫决策过程_哔哩哔哩_bilibili 马尔可夫链提供了一种建模随机过程的方法,具有广泛的应用。在实际问题中,通过转移概率矩阵及初…

NOIP2023题解

T1:词典 有一个好猜的结论:对于一个字符串,若它当中的最小字符大于等于某其他字符串中的最大字符,那么这个字符串一定不可行。 证明也很简单,若最小字符大于最大字符,显然一定不可行。若最小字符等于最大…

常用Python数据分析开源库:Numpy、Pandas、Matplotlib、Seaborn、Sklearn介绍

文章目录 1. 常用Python数据分析开源库介绍1.1 Numpy1.2 Pandas1.3 Matplotlib1.4 Seaborn1.5 Sklearn 1. 常用Python数据分析开源库介绍 1.1 Numpy Numpy(Numerical Python)是Python数据分析必不可少的第三方库,Numpy的出现一定程度上解决了Python运算性能不佳的…

解决VScode(Visual Studio Code)中的乱码问题. 2024-10-13

系统环境: win10 64bit , vscode 1.94.2 1.乱码原因 默认使用utf-8编码,导致非utf-8内容乱码 2.解决乱码问题 1)打开设置 点击左下角的齿轮,然后再点击设置 2)启用编码自动检测 在设置搜索框中输入 编码 ,然后启用 自动猜测编码选项 3.乱码问题解决 重新打开文件后,乱码问…

清空redo导致oracle故障恢复---惜分飞

客户由于空间不足,使用> redo命令清空了oracle的redo文件 数据库挂掉之后,启动报错 Fri Oct 04 10:32:57 2024 alter database open Beginning crash recovery of 1 threads parallel recovery started with 31 processes Started redo scan Errors in file /home/oracle…

各种查询sql介绍

1. 关联查询(JOIN) 关联查询用于从多个表中检索数据。它基于两个或多个表之间的共同字段(通常是主键和外键)来组合数据。 内连接(INNER JOIN): sql SELECT a.name, b.order_date FROM custome…

IO进程---day5

1、使用有名管道实现两个进程之间的相互通信 //管道文件 #include<myhead.h> int main(int argc, const char *argv[]) {//创建有名管道文件1if(mkfifo("./pipe1",0664)-1){perror("创建管道文件失败");return 0;}if(mkfifo("./pipe2",066…

upload-labs靶场Pass-03

upload-labs靶场Pass-03 分析源码 $is_upload false; $msg null; if (isset($_POST[submit])) {if (file_exists(UPLOAD_PATH)) {$deny_ext array(.asp,.aspx,.php,.jsp);$file_name trim($_FILES[upload_file][name]);$file_name deldot($file_name);//删除文件名末尾的…

Damn-Vulnerable-Drone:一款针对无人机安全研究与分析的靶机工具

关于Damn-Vulnerable-Drone Damn-Vulnerable-Drone是一款针对无人机安全研究与分析的靶机工具&#xff0c;广大研究人员可以利用该环境工具轻松学习、研究和分析针对无人机安全态势。 Damn Vulnerable Drone 基于流行的 ArduPilot/MAVLink 架构&#xff0c;其中故意留下了各种…

PDF 软件如何帮助您编辑、转换和保护文件

如何找到最好的 PDF 编辑器。 无论您是在为您的企业寻找更高效的 PDF 解决方案&#xff0c;还是尝试组织和编辑主文档&#xff0c;PDF 编辑器都可以在一个地方提供您需要的所有工具。市面上有很多 PDF 编辑器 — 在决定哪个最适合您时&#xff0c;请考虑这些因素。 1. 确定您的…

基于 Konva 实现Web PPT 编辑器(三)

完善公式 上一节我们简单讲述了公式的使用&#xff0c;并没有给出完整的样例&#xff0c;下面还是完善下相关步骤&#xff0c;我们是默认支持公式的编辑功能的哈&#xff0c;因此&#xff0c;我们只需要提供必要的符号即可&#xff1a; 符号所表达的含义是 mathlive 的command命…

从0开始深度学习(12)——多层感知机的逐步实现

依然以Fashion-MNIST图像分类数据集为例&#xff0c;手动实现多层感知机和激活函数的编写&#xff0c;大部分代码均在从0开始深度学习&#xff08;9&#xff09;——softmax回归的逐步实现中实现过 1 读取数据 import torch from torchvision import transforms import torchv…

JavaCove部署文档

1. 基础配置 1.1服务器&#xff1a; 2 核 2G 1.2. 一个域名 1.3. 项目地址&#xff1a; gitee:https://gitee.com/guo-_jun/JavaCove github:https://github.com/nansheng1212/JavaCove 2. CentOS 安装 Docker 官方网站上有各种环境下的 安装指南&#xff0c;这里主要介绍…

webpack自定义插件 ChangeScriptSrcPlugin

插件文件 class ChangeScriptSrcPlugin {apply(compiler) {const pluginName "ChangeScriptSrcPlugin";compiler.hooks.compilation.tap(pluginName, (compilation, callback) > {compilation.hooks.htmlWebpackPluginAlterAssetTags.tapAsync(pluginName,(html…

SpringCloudStream使用StreamBridge实现延时队列

利用RabbitMQ实现消息的延迟队列 一、安装RabbitMQ 1、安装rabbitmq 安装可以看https://blog.csdn.net/qq_38618691/article/details/118223851,进行安装。 2、安装插件 安装完毕后,exchange是不支持延迟类型的,需要手动安装插件,需要和安装的rabbitmq版本一致 https:…

动态规划:17.简单多状态 dp 问题_买卖股票的最佳时机III_C++

题目链接&#xff1a; 一、题目解析 题目&#xff1a;123. 买卖股票的最佳时机 III - 力扣&#xff08;LeetCode&#xff09; 解析&#xff1a; 拿示例1举例&#xff1a; 我们可以如图所示买入卖出股票&#xff0c;以求得最大利润&#xff0c;并且交易次数不超过2次 拿示…

基于SpringBoot设计模式之结构型设计模式·组合模式

文章目录 介绍开始架构图定义条目定义文件定义文件夹 测试样例 总结 介绍 能够使容器与内容具有一致性&#xff0c;创造出递归结构的模式就是 Composite 模式。Composite 在英文中是“混合物”“复合物”的意思。   以目录为例&#xff0c;在计算机中&#xff0c;某个目录下有…

在海外留学/工作,如何报考微软mos认证?

重点首先得强调的是&#xff0c;即使在海外也可以顺利地在国内获取微软MOS认证&#xff01; 01 微软mos认证简介 Microsoft Office Specialist 简称MOS。是微软公司和第三方国际认证机构、全球三大IT测验与教学中心之一的思递波/Certiport公司于1997年联合推出的&#xff0c;…

2009年国赛高教杯数学建模A题制动器试验台的控制方法分析解题全过程文档及程序

2009年国赛高教杯数学建模 A题 制动器试验台的控制方法分析 汽车的行车制动器&#xff08;以下简称制动器&#xff09;联接在车轮上&#xff0c;它的作用是在行驶时使车辆减速或者停止。制动器的设计是车辆设计中最重要的环节之一&#xff0c;直接影响着人身和车辆的安全。为了…