网络编程入门之UDP编程

欢迎各位帅哥美女来捧场,本文是介绍UDP网络编程。在这里,你会见到最详细的教程;细致到每一行代码,每一个api的由来和使用它的目的等。

目录

1.UDP相关API

1.1.两个类

1.2.两个类中的方法

2.UDP编程

2.1.大体框架

2.2.内容构造

2.3.方法总结


1.UDP相关API

想要实现UDP编程,肯定要掌握一些用来操作udp的api,主要两个类,多个方法。

1.1.两个类

这两个类包括:DatagramSocket和DatagramPacket,至于这两个类里面的方法,下一个小标题介绍。

(1)DatagramSocket类

这个类,是用来操作网卡的,也就是用来创造服务器/客户端。可以获取到操作网卡的一个流对象,用来发送数据、接收数据、关闭流对象

(2)DatagramPacket类

这个类用来表示udp数据报,也就是用来保存数据的。DatagramPacket对象可以保存请求、响应、ip/端口号等信息。

1.2.两个类中的方法

(1)DatagramSocket类

  • 构造方法
方法签名解释
DatagramSocket()无参构造。创造一个UDP数据报套接字的Socket,绑定到本机任意一个端口(一般用于客户端,系统会分配一个空闲的端口号)
DatagramSocket(int port)创造一个UDP数据报套接字的Socket,并且绑定到本机指定端口号上(一般用于服务器)

(1)无参构造方法一般用在客户端,不需要指定端口号,这种就是由系统随机分配空闲的端口号。(2)带参的构造方法,一般用在服务器,给服务器指定一个端口号;服务器需要在启动时就有端口号,方便客户端寻找。 

  • 普通方法
方法签名说明
void receive(DatagramPacket p)从这个套接字接收数据报,存到p中(如果没接收到,会阻塞等待)
void send(DatagramPacket p)从这个套接字发送数据报p(不会阻塞,都是直接发送)
void close()关闭这个数据报套接字(类似关闭流)

上面三个就是udp通信的三部曲:接收请求、(解析请求)、发送响应(服务器);发送请求、接收响应(客户端);最后都需要关闭流(一般socket流对象和客户端服务器的声明周期一样,就不需要我们去主动关闭)

(2)DatagramPacket类

这是一个描述数据报的类,用来保存数据报。

  • 构造方法
方法签名说明
DatagramPacket(byte[] bf,int length)构造一个数据报,并且使用字节数组接收数据,接受指定的长度
DatagramPacket(byte[] bf,int offset,int length,SocketAddress address,(port))用来发送数据报。发送的数据在字节数组中,从offset到length长度。address包含目的主机的IP和端口号

 (1)第一个构造方法:一般用于接收信息,像服务器接收请求和客户端接收响应;构造一个空的udp数据报对象,参数是指定一块存放数据的空间,后面的长度表示这一块空间的可用部分。(2)第二个构造方法:一般用于发送信息,像服务器发送响应和客户端发送请求;构造一个带有信息的udp数据报。具体信息存在第一个参数(请求或者响应),第二、三个参数表示信息的有效长度范围,第四个参数里面存放的是ip地址(也可以同时包含端口号),第五个参数表示端口号(当前面一个参数没有包含端口号时)。

  • 普通方法 
方法名解释
InetAddress getAddress()从接收/发送的数据报中,获取发送端的主机IP或者接收端的主机IP
int getPort()从接收的数据报中,获取发送端主机的端口号;或者获取发送端主机的端口号
byte[] getData()获取数据报中的数据

这些方法,就是用来获取udp数据报中的一些信息的,比如第一个获取ip地址,第二个获取端口号等,不过想要完成udp通信,掌握这几个方法还不够,但是现在先不介绍完,等到介绍完udp通信我们就一起介绍。

2.UDP编程

前置常识:接下来就是要编写一个关于udp的网络程序,就需要有服务器和客户端(两个不同的程序/进程),服务器是可以24*7h的处理请求的(我们写成死循环即可),客户端随意(我们也写成死循环,表示可以不断发送请求)。

而且我们这里的服务器暂时作为一个回响服务器,也就是不解析请求,发送什么再发送回去即可。接下来就开始编程我们的第一个简单网络程序吧。

2.1.大体框架

(1)服务器

//各种包,这里先不写
//回显服务器
public class UdpEchoService {
    private  DatagramSocket socket = null;
    public UdpEchoService(int port) throws SocketException {
        socket = new DatagramSocket(port);//给服务器指定端口号
    }
    public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {//写成死循环,用于不断处理客户端发来的请求
           //1.接收请求
           //2.解析请求
           //3.发送响应(解析好的请求)  
        }
    }
    public String service(String request) {//这个方法用来解析请求
        return request;
    }
    public static void main(String[] args) throws IOException {
        UdpEchoService service = new UdpEchoService(1314);
        service.start();
    }
}

main方法用来启动服务器,会先调用构造方法,构造好一个服务器,然后里面会自动调用start方法,表示服务器真正的启动了(可以处理请求)

(2)客户端

//各种包,这里也暂时不写
public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String Ip;
    private int port;
    public UdpEchoClient(String Ip,int port) throws SocketException {
        socket = new DatagramSocket();//系统随机分配端口号
        this.Ip = Ip;//记录服务器的ip地址
        this.port = port;//记录服务器的端口号
    }
    public void start() throws IOException {
        System.out.println("客户端启动!");
        Scanner in = new Scanner(System.in);
        while (true) {
            //1.输入请求
            //2.发送请求
            //3.接收响应(服务器处理好请求后返回)
            //4.打印响应  
        }
    }
    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1",1314);//绑定本主机的服务器
        client.start();
    }
}

这里的客户端同理,构造方法只是做好了准备工作,等到start方法后,才能真正的开始发送请求(客户端启动)

2.2.内容构造

(1)服务器

接下来,我们分别完善服务器的三步曲:接收请求、解析请求、返回响应。

  • 接收请求

udp客户端发送过来的请求,是一个二进制/字节流数据,所以我们需要使用一个udp数据报对象来接收,也就是构造一个udp数据报对象

DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);

udp数据报对象中的参数相当于是一个“空盘子”,用来接收客户端发送过来的请求(udp数据报对象中没有实现,就需要我们自己指定一块空间)

当udp数据报对象构造完成后,就可以开始接收请求了

socket.receive(requestPacket);//接收请求,存放在requestPacket中

此时,我们就已经拿到客户端的请求了,但是此时是二进制信息,为了我们方便解析请求,所以我们打算将其转换成一个字符串请求

String request = new String(requestPacket.getData(),0,requestPacket.getLength());

这里就是需要使用到一些DatagramPacket类的方法了。

(1)第一个参数:前面介绍过多的,用来获取udp中的数据;(2)第二、三个参数,就是表示要获取udp中信息的范围,表示从0到二进制信息结尾(getLength()求的是什么长度?)(3)最后,String有提供相关的构造方法,用于将二进制数据转化成字符串数据

完整的接收请求代码:

//1.接收请求
DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);

socket.receive(requestPacket);

String request = new String(requestPacket.getData(),0,requestPacket.getLength());
  • 解析请求

这一步就比较简单了,因为是回显服务器,只需要发送什么就返回什么即可;但是还是要做做样子,假装经过方法解析,然后得到一个响应。

//2.计算响应
String response = service(request);

计算请求的方法:

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

这一步很简单

  • 返回响应

我们现在拿到的响应是一个string,返回时需要的是一个udp,所以也需要转化一下才行,我们这里需要使用到上面的udp数据报构造方法

socket.send(responsePacket);
DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),0,response.getBytes().length,
                    requestPacket.getSocketAddress());

这里有四个参数,需要解释一下:

(1)第一个参数:获取到字符串response中的数据;(2)第二、三个参数就是表示需要转化成的udp数据范围;(3)第四个参数:从前面接收的请求中获取客户端的ip地址(用来服务器确定响应是发给谁的)

通过上述的操作,此时responsePacket中就包含了响应和信息,接下来就可以返回响应了。

socket.send(responsePacket);

服务器的响应代码:

 public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {
            //1.接收请求并解析
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);//构造udp数据报
            socket.receive(requestPacket);//接收客户端的请求
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());//将二进制请求(udp数据报)转化成字符串(字符流)
            //2.计算响应
            String response = service(request);
            //3.返回响应
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),0,response.getBytes().length,
                    requestPacket.getSocketAddress());
            socket.send(responsePacket);
            System.out.printf("[%s:%d] req=%s,resp=%s\n",requestPacket.getAddress(),requestPacket.getPort(),request,response);
            //                                                客户端请求     返回的响应                  客户端ip     端口
        }
    }
    public String service(String request) {
        return request;
    }

最下面有一个打印客户端信息的代码:前面两个就是获取ip地址和端口号的方法

回响服务器完整代码:


import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

//回显服务器
public class UdpEchoService {
    private  DatagramSocket socket = null;
    public UdpEchoService(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);//构造udp数据报
            socket.receive(requestPacket);//接收客户端的请求
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());//将二进制请求(udp数据报)转化成字符串(字符流)
            //2.计算响应
            String response = service(request);
            //3.返回响应
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),0,response.getBytes().length,
                    requestPacket.getSocketAddress());
            socket.send(responsePacket);
            System.out.printf("[%s:%d] req=%s,resp=%s\n",requestPacket.getAddress(),requestPacket.getPort(),request,response);
            //                                                 客户端ip          客户端端口号                  客户端请求     返回的响应
        }
    }
    public String service(String request) {
        return request;
    }
    public static void main(String[] args) throws IOException {
        UdpEchoService service = new UdpEchoService(1314);
        System.out.println("我是父类服务器");
        service.start();
    }
}

(2)客户端

现在只需要完成客户端的四部曲即可:输入请求、发送请求、接收响应、打印响应

  • 输入请求

我们这里直接使用字符串来接收请求即可

System.out.print("请输入你的请求:");
//1.输入请求
String request = in.nextLine();
  • 发送请求

因为我们输入的请求是一个字符串类型,而发送udp数据报是字节类型,也可以说是需要将字符串请求打包成一个udp数据报才能发送

打包请求:

DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),0,request.getBytes().length,InetAddress.getByName(Ip),port);

这里同理,打包成一个DatagramPacket数据报,里面需要包含:请求和服务器的ip和端口号;前面三个参数就不多介绍,第四个参数是一个新的方法:InetAddress.getByName(int port),用来……

发送请求:

socket.send(requestPacket);

发送请求完整代码:

//2.发送请求
DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),0,request.getBytes().length,
                    InetAddress.getByName(Ip),port);
socket.send(requestPacket);
  • 接收响应

当向服务器发送完请求后,就需要接收服务器返回回来的响应,类型是一个DatagramPacket数据报。

DatagramPacket responsePacket = new DatagramPacket(new byte[4096],4096);
socket.receive(responsePacket);

这里需要提前构造一个DatagramPacket数据报,然后再去接收。

  • 打印响应
//4.打印请求
String response = new String(responsePacket.getData(),0,responsePacket.getLength());
 System.out.println("响应为:"+response);

客户端完整代码:

//客户端
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.Scanner;

public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String Ip;
    private int port;
    public UdpEchoClient(String Ip,int port) throws SocketException {
        socket = new DatagramSocket();
        this.Ip = Ip;
        this.port = port;
    }
    public void start() throws IOException {
        System.out.println("客户端启动!");
        Scanner in = new Scanner(System.in);
        while (true) {
            System.out.print("请输入你的请求:");
            //1.输入请求
            String request = in.nextLine();
            //2.发送请求
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),0,request.getBytes().length,
                    InetAddress.getByName(Ip),port);
            socket.send(requestPacket);
            //3.接收响应
            DatagramPacket responsePacket = new DatagramPacket(new byte[4096],4096);
            socket.receive(responsePacket);
            //4.打印请求
            String response = new String(responsePacket.getData(),0,responsePacket.getLength());
            //System.out.println("中文翻译为:"+response);
            System.out.println("响应为:"+response);
        }
    }
    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1",1314);//绑定本主机的服务器
        client.start();
    }
}

客户端服务器也就都写好了,接下来实验一下。

先启动服务器:

在启动客户端:

客户端发送请求:

服务器日志:

至此,UDP服务器-客户端编码完成。

 执行流程图:

2.3.方法总结

在前面,我已经介绍过一次方法了,现在又准备介绍一次,是为了水字数吗?那当然不是,前面两个类中的一些方法,只是为了让你认识到这些类,和实例化了对象后该怎么去做。

接下来,我们再进一步结合代码来介绍方法,而且主要是和DatagramPacket有关的方法。

(1)获取ip地址和端口号

  • 直接调用方法分别获得
方法解释
InetAddress getAddress()获取ip地址
int getPort()获取端口号

在代码中的体现

(2)求数据长度

这里是什么意思呢?你一定看过这些代码

这些求数据长度的有什么区别?该怎么使用?为什么要这样写?就是我们接下来要介绍的

  • 字符和字节的区别

首先,字符>字节,一个字符可能包含多个字节。一个字符串,如果都是数字或者英文字母,那么它的字符数和字节数大概率是一样的;但是如果一个字符串中包含汉字等重量字符,那么字符数>字节数。

  • 求长度的区别

如果本身是一个字节类型的字符串数据,那么我们直接取长度就好;但是如果是一个String类型的字符串,要将它转化成udp数据报,就需要先转化成字节类型,再求其长度。

如果本身是字节类型,就不需要转换;如果是字符串类型,就需要。原因:只要转化成最小单位,就不会遗漏数据

(3)字符串ip地址转成点分十进制格式

在客户端程序里面,有这么一个方法:

所以通过InetAddress.getByName(String ip)方法就可以将String类型的ip转换成一个java可以识别的ip对象(也就是InetAddress对象)

InetAddress.getByName(String ip)将字符串类型的ip地址转成java可识别的

(4)同时获得ip地址和端口号

服务器中的一段代码

目的是:现在服务器需要将响应发回客户端,就需要知道客户端的ip地址和客户端。

getSocketAddress()获取ip和端口号

返回一个InetSocketAddress对象,里面就包含ip地址和端口号

(5)获取数据

  • 获取udp数据报中的数据
byte[] getData()将udp中的数据存入一个字节数组中

代码体现:

  • 获取字符串中的数据
byte[] getBytes()将字符串中的数据存入一个字节数组中

代码体现:

以上就是udp客户端-服务器编程中使用到的方法了。

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

修改el-checkbox样式

一定要在最外层; //未选中框/deep/ .el-checkbox__inner{border-color: #0862a3;}//选中框/deep/ .el-checkbox__input.is-checked .el-checkbox__inner{background-color: #0862a3;border-color: #0862a3;}//未选中框时右侧文字/deep/ .el-checkbox__label{}//选中…

企业做网站,如何设计才有创意?

企业做网站,如何设计才有创意?我们都希望能打造一个有创意的网站建设,能在众多网站中脱颖而出,能够营销推广公司的产品,为公司带来更多的经济效益收益。广州网站建设的时候,记住直观的设计可以让用户体验更…

Terrain —— Nodes

目录 Convert HeightField —— 转化高度场 HeightField —— 为地形创建初始高度场或遮罩场 HeightField Blur —— 模糊高度场或遮罩场 HeightField Clip —— 限制高度场的值 HeightField Combine Layers —— 将多个volume或VDB合并为一个新的volume或VDB HeightFiel…

C++浮点数format时的舍入问题

C浮点数format时的舍入问题 首先有这样一段代码&#xff1a; #include <iostream> #include <stdio.h> using namespace std;int main() {cout << " main begin : " << endl;printf("%.0f \r\n", 1.5);printf("%.0f \r\n&…

2024副业指南:年轻人热捧的七大赚钱副业,在家就能做!做得好的月入过万了

副业&#xff0c;听起来就像是在主业之外的“小打小闹”&#xff0c;但你知道吗&#xff1f;很多人通过副业实现了财务自由&#xff0c;甚至有的人副业收入超过了主业&#xff01; 今天&#xff0c;就让我们一起探索那些适合你的副业机会&#xff0c;让你在工作之余也能成为收入…

3D模型素材有哪些常见的用途?

3D模型素材已经成为了设计、游戏开发、电影制作和建筑等领域的重要工具。它们以其独特的形式和丰富的细节&#xff0c;为这些领域的专业人士提供了无尽的创作可能性。 1.建筑和室内设计&#xff1a;在建筑设计中&#xff0c;3D模型可以帮助建筑师更直观地展示设计方案&#xff…

oracle试用期过期,解决办法

过期重置方法&#xff0c;删除注册表&#xff0c;相当于无限试用&#xff0c;缺点每30天都要重置一次 1. window r 输入 regedit 确定&#xff0c;打开注册表 2.删除下图里的两个文件夹 3.重启 plsql,登录成功

二叉树的前序、中序、后序遍历的C++实现

二叉树的前序、中序、后序 遍历属于深度优先搜索方式&#xff0c;本文使用递归法实现前序、中序、后序的遍历方法&#xff0c;代码如下&#xff1a; #include <iostream> #include <vector>struct TreeNode{int val;TreeNode* left;TreeNode* right;TreeNode(int …

Windows基于WSL2安装Kali-linux

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、kali-linux是什么&#xff1f;二、简单使用1.下载2.打开1.通过应用列表2.通过Terminal 三、安装图形界面1.下载2.打开 四、重头戏总结 前言 kali-linux大家…

NERF++:Analyzing and Improving Neural Radiance Fields神经辐射场的分析与改进

ABSTRACT 神经辐射场(NeRF)可以实现各种捕获设置的令人印象深刻的视图合成结果&#xff0c;包括360度捕获有界场景和前向捕获有界和无界场景。NeRF 将代表视图不变不透明度和视图相关颜色体积的多层感知器(MLPs)匹配到一组训练图像中&#xff0c;并基于立体渲染技术对新视图进…

力扣刷题--数组--第三天

今天再做两道二分查找的题目&#xff0c;关于二分查找的知识可看我前两篇博客。话不多说&#xff0c;直接开干&#xff01; 题目1&#xff1a;69.x 的平方根 题目详情&#xff1a;   给你一个非负整数 x &#xff0c;计算并返回 x 的 算术平方根 。由于返回类型是整数&#…

从零开始的软件测试学习之旅(九)jmeter直连数据库及jmeter断言,关联

jmeter直连数据库及断言,关联 jmeter直连数据库步骤jmeter断言jmeter逻辑控制器if控制器ForEach控制器循环控制器 Jmeter关联Jmeter关联XPath提取器Jmeter关联正则表达式提取器二者比较跨线程组关联 每日复习 jmeter直连数据库 概念 这不叫直连:Jmeter -> java/python 提供的…

单片机-点亮第一盏灯

原理图 需求&#xff1a;点亮或是熄灭LED 通过控制 P5.3引脚输出高电平时&#xff0c;LED灯就点亮&#xff0c;输出低电平时LED灯就熄灭 1.项目创建 新建项目 配置开发板信息 当前位STC芯片的开发板&#xff0c;选择STC MCU Database 搜素具体芯片型号&#xff0c;进行配置…

Spring-依赖注入的处理过程

前置知识 1 入口 DefaultListableBeanFactory#resolveDependency 2 每个依赖都有对应的DependencyDescriptor 3 自定绑定候选对象处理器AutowireCapableBeanFactory 注入处理 我们可以看到AutowireCapableBeanFactory中有两个方法&#xff1a; 第一个是单个注入&#xff1a;…

52页 | 2024大型语言模型行业图谱研究报告(免费下载)

【1】关注本公众号&#xff0c;转发当前文章到微信朋友圈 【2】私信发送 【2024大型语言模型行业图谱研究报告】 【3】获取本方案PDF下载链接&#xff0c;直接下载即可。 如需下载本方案PPT原格式&#xff0c;请加入微信扫描以下方案驿站知识星球&#xff0c;获取上万份PPT解…

【软考高项】三十六、资源管理6个过程

一、规划资源管理 1、定义、作用 定义&#xff1a;定义如何估算、获取、管理和利用团队以及实物资源的过程作用&#xff1a;根据项目类型和复杂程度确定适用于项目资源的管理方法和管理程度 2、输入 项目管理计划 质量管理计划、范围基准项目章程 项目文件 需求文件…

PostgreSQL和openGauss优化器对一个关联查询的SQL优化改写

PostgreSQL和openGauss数据库优化器在merge join关联查询的SQL优化改写 PostgreSQL 查询计划openGauss 查询计划拓展对比 看腻了文章就来听听视频讲解吧&#xff1a;https://www.bilibili.com/video/BV1oH4y137P7/ 数据库类型数据库版本PostgreSQL16.2openGauss6.0 创建测试表…

教你如何用VUE实现一个无缝横向滚动抽奖的效果

最近一位安卓端同事想要实现一个效果如下图&#xff0c;我们先看如下图&#xff1a; 我们看到上面想到如何实现呢&#xff1f; 先说下我的思路&#xff1a; 我先想到的是看能不能用轮播图swiper插件实现&#xff0c;试了下发现自己行不通&#xff0c;原因不是在于插件问题&am…

How Linux Works I - How Linux Start Up

目录 Linux如何启动&#xff1f; 启动信息 内核启动初始化与启动选项 写在前面&#xff1a;上一个专栏中我写完了内核源码层面看Linux&#xff0c;我们把抽象层拉高一点&#xff0c;看看Linux是如何工作的&#xff01; Linux如何启动&#xff1f; BIOS&#xff08;Basic Inpu…

05-08 周三 FastBuild FastAPI 引入并发支持和全局捕获异常

时间版本修改人描述2024年5月8日20:41:03V0.1宋全恒新建文档 简介 由于FastBuild之前花费了大概5天的时间优化&#xff0c;但最近重新部署&#xff0c;又发现了一些问题&#xff0c;就很痛苦&#xff0c;五一之后&#xff0c;自己又花了三天的时间系统的进行了优化。 上一波优…