【JavaEE】_基于UDP实现网络通信

目录

1. 服务器

1.1 实现逻辑

1.2 代码

1.3 部分代码解释

2. 客户端

2.1 实现逻辑

2.2 代码

2.3 客户端部分代码解释

3. 程序运行结果

4. 服务器客户端交互逻辑


此篇内容为实现UDP版本的回显服务器echo server;

普通服务器:收到请求,根据请求计算响应,返回响应;

回显服务器:忽略计算,直接将收到的请求作为响应返回;

如需实现其他功能,修改响应计算方法process内容即可);

具体实现代码如下:

1. 服务器

1.1 实现逻辑

对于网络通信的服务器需要进行的工作为:

1. 读取请求并解析;

2. 根据请求计算响应;

3. 把响应写回客户端;

4. 打印交互详细信息;

1.2 代码

package TestDemo1;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;public class UDPEchoServer {// 创建一个DatagramSocket对象,作为后续操作网卡的基础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);// DatagramPacket对象用于承载从网卡读到的数据,收到数据时需要创建一个内存空间保存这个数据,// DatagramPacket内部不能自行分配内存空间,需要程序员手动创建socket.receive(requestPacket);// 完成receive之后,数据以二进制形式存储在DatagramPacket中// 需要将二进制数据转成字符串String request = new String(requestPacket.getData(),0, requestPacket.getLength());// 取0~requestPacket.getLength()区间内的字节构成一个String对象;//2. 根据请求计算响应String response = process(request);//3. 把响应写回客户端DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,requestPacket.getSocketAddress());socket.send(responsePacket);//4. 打印交互详细信息System.out.printf("[%s:%d] req=%s, resp=%s\n",requestPacket.getAddress().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);// 可以在1024~65535(临时端口)中任意选取端口号server.start();}
}

1.3 部分代码解释

1. 为方便计算请求,将请求的DatagramPacket对象构造成字符串时只需获取DatagramPacket对象中实际有效的部分数据,requestPacket.getLength()获取到的就是收到数据的真实长度而非4096这个最大长度:

2. 已经了解过UDP本身是无连接的,故而对于每一次通信过程,在构造数据报时都需要指定数据报要发给谁;

(1)对于构造的responsePacket对象有3个参数:

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

response.length()获取到的是响应对象字符串的字符个数,

response.getBytes().length获取到的是响应对象字符串的字节个数;

requestPacket.getSocketAddress()获取到的是请求发送方(即客户端)的IP与端口号

(2)注意response.getBytes.length(字节个数)与response.getlength()(字符个数)的区别:

如果response字符串都是英文字符则二者相等,如果包含中文则二者不同;

在进行网络传输时,必然是需要通过字节为单位进行通信的。

3. while(true)会使程序处于快速循环的状态,每循环一次就处理一次请求响应,

当客户端发出请求时,recerive就能顺利读取请求,客户端没有发出请求时,receive就会阻塞

如果客户端发出的请求过多,可以使用多线程冲动调动计算机硬件资源,也可以再多开机器,但多开机器又会涉及到分布式问题;

4. 使用格式化输出Packet的IP与端口号:

5. 前文已经提及socket也是一个文件,但在上文代码中并未进行close操作,却没有造成文件资源泄漏的原因是:

socket是文件描述符表中的一个表项,每次打开一个文件就会占用一个位置,文件描述符在pcb上,是跟随进程的。在上文代码中创建的socket对象在整个程序运行过程中都需要使用,不可以提前关闭,当socket不需要使用时,即代表程序结束了,进程结束了,文件描述符表也销毁了,伴随着销毁都被系统自动回收了。故而不会造成文件资源泄露问题

只有代码中频繁打开文件但不关闭,在一个进程的运行过程中,不断积累打开的文件,逐渐消耗掉文件描述符表中的内容,最后消耗殆尽,才会造成泄露。

对于生命周期很短的进程,无需考虑泄露,在客户端方一般来说影响不大。

2. 客户端

2.1 实现逻辑

对于网络通信的客户端,需要进行的工作是:

1. 从控制台读取数据作为客户端发出的请求;

2. 将请求字符串request构造成请求requestPacket对象,发送给服务器;

3. 尝试读取服务器返回的响应;

4. 将响应responsePacket对象构造成响应response字符串,显示出来;

2.2 代码

package TestDemo1;import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UDPEchoClient {private DatagramSocket socket = null;private String serverIp = "";private int serverPort = 0;public UDPEchoClient(String ip, int port) throws SocketException {// 客户端的socket对象需令系统自动分配socket = new DatagramSocket();// UDP本身不持有对端信息,需要在应用程序中记录对端信息(IP与端口)serverIp = ip;serverPort = port;}public void start() throws IOException {// 客户端启动方法System.out.println("客户端启动");Scanner scanner = new Scanner(System.in);while(true){// 1. 从控制台读取数据作为客户端发出的请求System.out.println("->");String request = scanner.next();// 2. 将请求字符串request构造成请求requestPacket对象,发送给服务器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);// 4. 将响应responsePacket对象转换为响应字符串response,显示出来String response = new String(responsePacket.getData(), 0, responsePacket.getLength());System.out.println(response);}}public static void main(String[] args) throws IOException {UDPEchoClient client = new UDPEchoClient("127.0.0.1", 9090);client.start();}
}

2.3 客户端部分代码解释

1.DatagramPacket的三个构造方法

第一种:只指定字节数组缓冲区,用于服务器接收请求与客户端接收响应时使用

第二种:指定字节数组缓冲区与InetAddress对象(同时包含IP与端口),用于服务器向客户端发回响应时使用

第三种:指定字节数组缓冲区,同时指定IP与端口号

2. 客户端对服务器发出请求的过程:

对于服务器端口必须是确定的:程序员可以手动分配空闲端口给当前服务器使用即可,

代码为:

socket = new DatagramSocket(port);

客户端一般都采取系统分配的方式:也可以指定端口,但不推荐。一方面,因为指定的端口可能被其他进程占用,如果被占用就会产生端口号冲突,运行就会抛出异常,提示绑定端口失败;另一方面,如果客户端出现了端口冲突,让客户手动解决也是不现实的。

代码为:

socket = new Datagramocket();

3. 端口与进程的关系:

端口号用于标识或区分一个进程,因此在同一台主机上,不允许一个端口同时被多个进程使用;

但是一个进程可以绑定多个端口;

socket和端口是一一对应的,进程与socket是一对多的

3. 程序运行结果

首先启动EchoServer,再启动EchoClient,在客户端输入请求字符串后查看运行结果:

客户端与服务器通信成功。

4. 服务器客户端交互逻辑

1. 服务器先启动,启动后进入循环,执行到receive处阻塞;

2. 客户端开始启动后,进入循环执行scanner.next(),在此处阻塞。

    当客户在控制台输入内容后,next返回作为请求,继而构造请求数据并发送给服务器;

3. 客户端发送数据后,

服务器从receive中返回,解析请求构造字符串,执行process操作计算响应,构造响应后执行send发回给客户端;

客户端执行到receive处等待服务器的响应;

4. 客户端获取到从服务器返回的数据后,从receive中返回,继而显示响应内容;

5. 服务器完成一次循环后又执行到receive处,客户端完成依次循环后又执行到scanner.next处,二者均进入阻塞状态;

注意:当服务器程序在普通私有ip计算机上运行时,若不在一个局域网中,无法实现跨主机访问。

如果服务器程序在特殊的计算机:云服务器上,就拥有了公有ip,可以实现跨主机访问。

此部分内容后续详解。

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

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

相关文章

《WebKit 技术内幕》之五(3): HTML解释器和DOM 模型

3 DOM的事件机制 基于 WebKit 的浏览器事件处理过程:首先检测事件发生处的元素有无监听者,如果网页的相关节点注册了事件的监听者则浏览器会将事件派发给 WebKit 内核来处理。另外浏览器可能也需要处理这样的事件(浏览器对于有些事件必须响应…

【Linux】nc 网络诊断 | 文件传输 命令详解

目录 一、命令简介 二、命令使用 2.1 测试服务器 2.2 端口连通性测试 2.2.1tcp端口连通性测试 2.2.2udp端口连通性测试 2.3 文件及目录的传输 2.3.1 文件传输(TCP端口) 2.3.2 文件传输(UDP端口) 相关文章: 【网络】抓包工具Wireshark下载安装和基本使用教…

力扣343. 整数拆分(动态规划)

Problem: 343. 整数拆分 文章目录 题目描述思路解题方法复杂度Code 题目描述 思路 该题目可以抽象成动态规划中的爬楼梯模型,将整数的拆分类比为上台阶: 1.每个阶段可以从整数中划分出1、2、…k的一个整数 2.int dp[n 1] dp[i]表示为i的整数划分的最大…

怎么提升搜狗网站排名

在当今数字化时代,网站排名对于品牌、企业以及个人都至关重要。而对于许多网站来说,搜狗搜索引擎是一个重要的流量来源。为了在搜狗上取得更好的排名,不仅需要优化网站内容,还需要巧妙运用一些工具和技巧。在本文中,我…

Labview局部变量、全局变量、引用、属性节点、调用节点用法理解及精讲

写本章前想起题主初学Labview时面对一个位移台程序,傻傻搞不清局部变量和属性节点值有什么区别,概念很模糊。所以更新这篇文章让大家更具象和深刻的去理解这几个概念,看完记得点赞加关注喔~ 本文程序源代码附在后面,大家可以自行下…

C语言第四弹---printf和scanf详解

✨个人主页: 熬夜学编程的小林 💗系列专栏: 【C语言详解】 【数据结构详解】 printf和scanf详解 1、printf和scanf详解介绍1.1 printf1.1.1 基本用法1.1.2 占位符1.1.3 占位符列举1.1.4 输出格式1.1.4.1 限定宽度1.1.4.2 总是显示正负号1.1…

Docker安装开源Blog(Typecho)

前言 首先这个镜像是centos7.9进行安装PHP环境,然后挂载目录去运行的,镜像大概300MB左右,没学过PHP,没办法给Dockerfile文件 参考文章:Docker安装Typecho | D-y Blog感知不强,图一乐https://www.wlul.top…

Vagrant创建Oracle RAC环境示例

利用Vagrant安装Oracle RAC(默认为non-CDB模式),生成2台虚机,耗时约1小时。 node1: -----------------------------------------------------------------node1: INFO: 2024-01-11 18:25:54: Make create database commandnode1: …

SpringBoot 更新业务场景下,如何区分null是清空属性值 还是null为vo属性默认值?

先看歧义现象 值为null 未传递此属性 所以此时如何区分null 时传递进来的的null,还是属性的默认值null? 引入方案 引入过滤器,中间截获requestBodyData并保存到HttpServletRequest,业务层从HttpServletRequest 获取到requestBodyData辅…

C语言算法赛——蓝桥杯(省赛试题)

一、十四届C/C程序设计C组试题 十四届程序C组试题A#include <stdio.h> int main() {long long sum 0;int n 20230408;int i 0;// 累加从1到n的所有整数for (i 1; i < n; i){sum i;}// 输出结果printf("%lld\n", sum);return 0; }//十四届程序C组试题B…

Cortex-M3/M4内核中断及HAL库函数详解(1):中断相关寄存器

0 工具准备 Keil uVision5 Cortex M3权威指南&#xff08;中文&#xff09; Cortex M3与M4权威指南 stm32f407的HAL库工程 STM32F4xx中文参考手册 1 NVIC相关寄存器介绍 在Cortex-M3/M4内核上搭载了一个异常响应系统&#xff0c;支持为数众多的系统异常和外部中断。其中&#…

关于C语言整型提升的讲解

目录 1.什么是整型提升 2.整型提升的意义 3.整型提升是怎么提升的 4.整型提升的实例 1.什么是整型提升 C语言中的整型算术运算总是以缺省&#xff08;默认&#xff09;整型类型的精度来进行的。为了获得这个精度&#xff0c;表达式中的字符和短整型操作数在使用之前会被转换…

3d渲染软件有哪些?3d云渲染推荐

目前市面上的3D渲染软件非常多&#xff0c;不同的建模软件都有自己的渲染方式&#xff0c;根据所处行业的不同和项目需要&#xff0c;设计师可以选择不同的软件帮助展示最终效果。 主流的渲染软件有&#xff1a;VRay和Corona&#xff1a;一般用于室内效果图渲染&#xff0c;与3…

Git学习笔记(第5章):Git团队协作机制

目录 5.1 团队内协作 5.2 跨团队协作 Git进行版本控制都是在本地库操作的。若想使用Git进行团队协作&#xff0c;就必须借助代码托管中心。 5.1 团队内协作 问题引入&#xff1a;成员1&#xff08;大佬&#xff09;利用Git在宿主机上初始化本地库&#xff0c;完成代码的整体…

MFC 序列化机制

目录 文件操作相关类 序列化机制相关类 序列化机制使用 序列化机制执行过程 序列化类对象 文件操作相关类 CFile&#xff1a;文件操作类&#xff0c;封装了关于文件读写等操作&#xff0c;常见的方法&#xff1a; CFile::Open&#xff1a;打开或者创建文件CFile::Write/…

经典目标检测YOLO系列(二)YOLOV2的复现(1)总体网络架构及前向推理过程

经典目标检测YOLO系列(二)YOLOV2的复现(1)总体网络架构及前向推理过程 和之前实现的YOLOv1一样&#xff0c;根据《YOLO目标检测》(ISBN:9787115627094)一书&#xff0c;在不脱离YOLOv2的大部分核心理念的前提下&#xff0c;重构一款较新的YOLOv2检测器&#xff0c;来对YOLOV2有…

k8s资源介绍

Kubernetes架构图 Kubernetes系统用于管理分布式节点集群中的微服务或容器化应用程序&#xff0c;并且其提供了零停机时间部署、自动回滚、缩放和容器的自愈&#xff08;其中包括自动配置、自动重启、自动复制的高弹性基础设施&#xff0c;以及容器的自动缩放等&#xff09;等…

SDL2 连续帧图像显示

QT使用SDL多窗口显示视频&#xff08;linux&#xff0c;ubuntu&#xff09;_linux qt sdl-CSDN博客 QT使用SDL播放YUV视频 - C - QT SDL调用OPENGL渲染图像 - C - 心得 C 使用SDL显示RGB图像数据_c sdl-CSDN博客 SDL库入门&#xff1a;掌握跨平台游戏开发和多媒体编程_sdl开…

【Python学习】Python学习21- 正则表达式(1)

目录 【Python学习】Python学习21- 正则表达式&#xff08;1&#xff09; 前言re.match函数实例 re.search方法re.match与re.search的区别参考 文章所属专区 Python学习 前言 本章节主要说明Python的正则表达式。 正则表达式是一个特殊的字符序列&#xff0c;它能帮助你方便的…

文心一言使用分享

ChatGPT 和文心一言哪个更好用&#xff1f; 一个直接可以用&#xff0c;一个还需要借助一些工具&#xff0c;还有可能账号会消失…… 没有可比性。 通用大模型用于特定功能的时候需要一些引导技巧。 import math import time def calculate_coordinate(c, d, e, f, g, h,…