[JavaEE -- 传输层中UDP和TCP的api实现原理]

传输层中UDP和TCP的api实现原理

  • 1. UDP和TCP协议特点
    • 1.1 TCP
    • 1.2 UDP
  • 2. UDP协议中socket api的使用
    • 2.1 服务器:
    • 2.2 客户端
    • 2.3 整个流程
  • 3. TCP协议中的api使用
    • 3.1 TCP服务器
    • 3.2 TCP客户端
    • 3.3 整个流程

1. UDP和TCP协议特点

1.1 TCP

  • 有连接:抽象,虚拟的连接(如打电话)
  • 可靠传输:尽可能的完成数据传输,虽然无法确保数据到达对方,至少可以知道,当前数据是不是收到了
  • 面向字节流:此处的字节流和文件中的字节流完全一致
  • 全双工:一个通信可以双向通信。(而半双工只能单向通信)

1.2 UDP

  • 无连接:无论是否同意都会发送
  • 不可靠传输:不确定数据是否能收到
  • 面向数据报:每次传输的基本单位是一个数据报(由一系列的字节构成的)特定结构
  • 全双工

2. UDP协议中socket api的使用

操作系统中有一类文件,就叫做socket文件,抽象表示了 网卡 这样的硬件设备。进行网络通信最核心的硬件设备网卡,通过网卡发送数据,就是写socket文件,通过网卡接收数据,就是读socket文件
核心的类有两个:

  1. DatagramSocket
    DatagramSocket(),创建一个UDP数据报套接字的Socket,绑定到本机任意一个随机接口(一般用于客户端)
    DatagramSocket(port),创建一个UDP数据报套接字的Socket,绑定本机指定的端口(一般用于服务器)
    void receive(DatagramPacket p) :从此套接字接收数据报(如果没有接收数据报,该方法会阻塞等待)
    void send(DatagramPacket p) :从此套接字发送数据报(不会阻塞等待,直接发送)

  2. DatagramPacket
    UDP面向数据报,每次发送数据报的基本单位,就是UDP数据报。表示了一个UDP数据报。

2.1 服务器:

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.Socket;
import java.net.SocketException;
import java.nio.charset.StandardCharsets;public class UdpEchoServer {//创建DatagramSocket对象private DatagramSocket socket = null;public UdpEchoServer(int port) throws SocketException { // 网络编程中常见的异常,通常表示socket创建失败,比如端口号已经被其他进程占用了,就会失败socket = new DatagramSocket(port);}// 服务器启动逻辑public void start() throws IOException {System.out.println("服务器启动!");// 对于服务器来说,需要不停的收到请求,返回响应while (true) {// 每次循环,就是处理一个请求-响应过程// 1. 读取请求并解析DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);// 通过这个字节数组保存收到的消息正文(应用层数据包)也就是UDP数据报载荷部分// receive接收从网卡读取到一个UDP数据报,放入requestPacket对象中socket.receive(requestPacket);// 读到的字节数组,转成String方便后续逻辑处理String request = new String(requestPacket.getData(),0,requestPacket.getLength());// 2. 根据请求计算响应(对于 回显服务器来说,这一步啥也不做)String response = process(request);// 3. 把响应返回到客户端//      构建一个DatagramPacket 作为响应对象// requestPacket.getSocketAddress()  从requestPacket客户端来的数据报,获得INetAddress对象这个对象就包含了ip和端口号(和服务器通信对端)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.getAddress().toString(),requestPacket.getPort(),request,response);}}public String process(String request) {return request;}public static void main(String[] args) throws IOException {UdpEchoServer udpEchoServer = new UdpEchoServer(9090);udpEchoServer.start();}
}

2.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使用的字符串,点分十进制,”192.168.2.100“ 不能直接使用serverIp,要InetAddress.getByName(serverIp)public UdpEchoClient(String serverIP,int serverPort) throws SocketException {this.serverIp = serverIP;this.serverPort = serverPort;// 客户端一般不要手动指定端口号,系统会自动分配一个空闲的端口号socket = new DatagramSocket();}public void start() throws IOException {System.out.println("启动客户端");Scanner scanner = new Scanner(System.in);while (true) {System.out.print("-> ");// 1. 从控制台读取要发送的请求数据if (!scanner.hasNext()) {break;}String request = scanner.next();// 2. 构造请求并发送  (把string里面的内容作为请求)DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),0,request.getBytes().length, InetAddress.getByName(serverIp),serverPort);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);}}public static void main(String[] args) throws IOException {UdpEchoClient client = new UdpEchoClient("127.0.0.1",9090);client.start();}
}

2.3 整个流程

  1. 服务器启动,启动之后立即进入while循环,执行到receive,进入阻塞等待客户端的请求
  2. 客户端启动之后,阻塞在hasNext等待用户在控制台输入
  3. 用户在客户端输入之后,客户端就拿到字符串构造出一个(requestPacket)请求,send发送请求,然后创建responsePacket来执行receive接收操作并且等待响应返回。
  4. 服务器收到请求之后,就会从receive的阻塞中返回,之后就会根据读到的DatagramPacket对象,构造String request,通过process方法构造一个String response,再根据response构建一个DatagramPacket表示响应对象,再通过send来进行发送给客户端。(这个过程中,客户端在阻塞等待)。
  5. 客户端从receive中返回执行,就能得到服务器返回的响应,并且打印到控制台上,与此同时,服务器进入下一次循环,也要进入到第二次的receive阻塞。等待下一个请求。

3. TCP协议中的api使用

  • ServerSocket:这个socket类对应到网卡,但是这个类只能给服务器进行使用
  • Socket:对应到网卡,既可以给服务器使用,也可以给客户端使用。

TCP是面向字节流的,传输的基本单位是字节,是有连接的,通过accept来完成连接,accept也是可能会产生阻塞的操作,如果当前客户端还没有连接过来,此时accept就会阻塞。

3.1 TCP服务器

//  ServerSocket 这是Socket类对应到网卡,但是这个类只能给服务器使用
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoServer {private ServerSocket serverSocket = null;public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动!");while (true) {// 通过accept方法来”接听电话“,然后才能进行Socket clientSocket = serverSocket.accept();// 和客户端的交互processConnection(clientSocket);}}// 通过这个方法开处理一次连接,连接建立的过程中就会涉及到多次的请求响应交互private void processConnection(Socket clientSocket) {System.out.printf("[%s:%d] 客户端上线!\n",clientSocket.getInetAddress(),clientSocket.getPort());// 循环的读取客户端的请求并返回响应// 从网卡读/写数据,tcp是面向字节流和文件中的字节流完全一致try (InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {while (true) {Scanner scanner = new Scanner(inputStream);if (!scanner.hasNext()) {// 读取完毕,客户端断开连接,就会产生读取完毕System.out.printf("[%s:%d] 客户端下线!\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}// 1. 读取请求并解析,这里注意隐的约定,next读的时候要读到空白符才会结束//  因此就要求客户端发来的请求必须带有空白符结尾,比如 \n 或空格String request = scanner.next();// 2. 根据请求计算响应String response = process(request);// 3. 把响应返回给客户端//  通过这种方式可以写回,但是这种方式不方便给返回的响应添加 \n//outputStream.write(response.getBytes(),0,response.getBytes().length);// 也可以把outputStream 套上一层,完成更方便的写入PrintWriter printWriter = new PrintWriter(outputStream);printWriter.println(response);// PrintWriter 内置的缓冲区需要冲刷(刷新)// 冲刷缓冲区printWriter.flush();System.out.printf("[%s:%d] req:%s,resp: %s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);}} catch (IOException e) {throw new RuntimeException(e);}}public String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);tcpEchoServer.start();}
}

3.2 TCP客户端

// Socket 对应到网卡,既可以给服务器使用,又可以给客户端使用
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoClient {private Socket socket = null;public TcpEchoClient(String serverIP,int serverPort) throws IOException {// 此处可以把这里的ip和port直接传给socket对象// 由于tcp是有连接的,因此socket里面就会保存好这俩信息,因此此处TcpEchoClient类就不必保存socket = new Socket(serverIP,serverPort);}public void start() {System.out.println("客户端启动!\n");try (InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {Scanner scannerConsole = new Scanner(System.in);Scanner scannerNetwork = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream);while (true) {// 1. 从控制台读取输入的字符串System.out.print("-> ");if (!scannerConsole.hasNext()) {// 没有下一个break;}// 有下一个接着读取String request = scannerConsole.next();// 2. 把请求发给服务器  使用println 来发送的请求末尾带有\n//  这里是和服务器的scanner.next 呼应的writer.println(request);// 通过flush 主动刷新缓冲区,确保数据真的发出去了writer.flush();// 3.从服务器读取响应String response = scannerNetwork.next();// 4. 把响应显示出来System.out.println(response);}} catch (IOException e) {throw new RuntimeException(e);}}public static void main(String[] args) throws IOException {TcpEchoClient client = new TcpEchoClient("127.0.0.1",9090);client.start();}
}

3.3 整个流程

  1. 服务器启动,阻塞在accept,等待客户端连接
  2. 客户端启动,new Socket(ServerIP,ServerPort)操作会触发和服务器之间的建立连接的操作,此时服务器就会从accept中返回
  3. 服务器从accept返回,进入到processConnection方法,执行到hasNext这里,产生阻塞,此时虽然连接建立了,但是客户端还没有发送任何的请求,hasNext阻塞等待请求到达。
  4. 客户端继续执行到hasNext,等待用户向控制台写入内容。
  5. 用户输入之后,此时hasNext就返回了,继续执行这里的发送请求的逻辑,这里就会把请求真的发出去,同时客户端等待服务器的响应返回,next也会产生阻塞。
  6. 服务器从hasNext返回读取到请求内容进行处理,读取到请求,构造出响应,把响应写回到客户端。服务器结束这次循环,继续阻塞在hasNext等待下一个请求。
  7. 客户端读取响应,并且显示出来。结束这次循环,进行下一次循环,继续阻塞在hasNext等待用户输入第二个数据。

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

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

相关文章

ClickHouse--11--物化视图

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 1.物化视图什么是物化视图? 1.1 普通视图1.2 物化视图1.3 优缺点1.4 基本语法1.5 在生产环境中创建物化视图1.6 AggregatingMergeTree 表引擎3.1 概念3.2 Aggregat…

面试算法-87-分隔链表

题目 给你一个链表的头节点 head 和一个特定值 x ,请你对链表进行分隔,使得所有 小于 x 的节点都出现在 大于或等于 x 的节点之前。 你应当 保留 两个分区中每个节点的初始相对位置。 示例 1: 输入:head [1,4,3,2,5,2], x …

【JAVA】通过JAVA实现用户界面的登录

🌈个人主页: Aileen_0v0 🔥热门专栏: 华为鸿蒙系统学习|计算机网络|数据结构与算法|MySQL| ​💫个人格言:“没有罗马,那就自己创造罗马~” #mermaid-svg-wyCvaz0EBNwHcwsi {font-family:"trebuchet ms",verdana,arial,sans-serif;f…

NPM 国内镜像

一、修改成腾讯云镜像源 1. 设置命令 npm config set registry http://mirrors.cloud.tencent.com/npm/ 验证命令 npm config get registry 如果返回 http://mirrors.cloud.tencent.com/npm/,说明镜像配置成功。 二、修改成淘宝镜像源 设置命令 npm config set…

Linux系统——硬件命令

目录 一.网卡带宽 1.查看网卡速率——ethtool 网卡名 2.查看mac地址——ethtool -P 网卡名 二、内存相关 1.显示系统中内存使用情况——free -h 2.显示内存模块的详细信息——dmidecode -t memory 三、CPU相关 1.查看CPU架构信息——lscpu 2.性能模式 四、其他硬件命…

C语言字节对齐关键字#pragma pack(n)的使用

0 前言 在进行嵌入式开发的过程中,我们经常会见到对齐操作。这些对齐操作有些是为了便于实现指针操作,有些是为了加速对内存的访问。因此,学习如何使用对齐关键字是对于嵌入式开发是很有必要的。 1 对齐规则 1.0 什么叫做对齐 众所周知&a…

牛客NC170 最长不含重复字符的子字符串【高频 中等 map、滑动窗口 Java,Go,PHP】

题目 题目链接: https://www.nowcoder.com/practice/48d2ff79b8564c40a50fa79f9d5fa9c7 思路 用一个hashmap记录每个字母的index如果这个字母已经在map里了说明已经有重复了这样就更新看这个字母上次出现的index需要注意的是这种情况:“bacbca”这里的a…

PCB中常用电子器件封装学习——【一网打尽】

‘ 上图是这个世界上大概所有的封装种类,当然我们日常硬件电路设计肯定用不到这么多,接下来我将介绍几种工程上常用的封装,配以图片方便大家理解学习。在电子器件选型的时候,避免选择到一些非常难以焊接的封装电子器件。

使用amd架构的计算机部署其他架构的虚拟机(如:arm)

1 下载quem模拟器 https://qemu.weilnetz.de/w64/2 QEMU UEFI固件文件下载(引导文件) 推荐使用:https://releases.linaro.org/components/kernel/uefi-linaro/latest/release/qemu64/QEMU_EFI.fd3 QEMU 安装 安装完成之后,需要将安装目录添加到环境变…

android11 系统的启动流程 的面试题目

Android 11 系统的启动流程包括哪些阶段? 答:Android 11 系统的启动流程主要包括 Boot ROM、Bootloader、Linux Kernel、Init 进程、Zygote 进程等阶段。具体流程包括硬件初始化、引导加载程序加载 Linux 内核、Linux 内核初始化、启动 Init 进程等。 B…

‘pyrcc5‘ 不是内部或外部命令,也不是可运行的程序 或批处理文件。

在初次配置启动labelImg的时候遇到些问题,特地在此记录下: 报错信息 "pyrcc5 不是内部或外部命令、可运行程序或批处理文件" 表明系统无法识别 pyrcc5 命令。pyrcc5 是 PyQt5 的一部分,用于将 .qrc 文件(资源文件&#…

Jenkins的快速入门

文章目录 一、Jenkins是什么?二、Jenkins安装和持续集成环境配置1.持续集成流程说明2.Gitlab代码托管服务器安装Gitlab简介:Gitlab安装Gitlab的使用切换中文添加组创建用户将用户添加到组创建项目idea中代码上传Gitlab 3.Jenkins持续集成环境服务器安装J…

华为北向网管NCE开发教程(5)打包org.omg.CosNotification找不到

1问题描述 在IDE中,代码能正常运行,但是打包的时候,会抱不到一些类 2问题原因 导入的本地包中,能在IDE中找到,但是在使用maven打包时,maven找不到这些依赖包 3解决办法 将依赖包通过maven安装到maven…

5.87 BCC工具之tcpsubnet.py解读

一,工具简介 tcpsubnet工具根据目标子网统计吞吐量。 这个工具只在IPv4环境下工作,并允许用户指定特定的子网进行监控。通过使用tcpsubnet,用户可以实时地观察特定子网内TCP流量的变化和分布情况,从而帮助进行网络性能调优、故障排查和安全监控等工作。 二,代码示例 #…

通过 Socket 手动实现 HTTP 协议

你好,我是 shengjk1,多年大厂经验,努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注!你会有如下收益: 了解大厂经验拥有和大厂相匹配的技术等 希望看什么,评论或者私信告诉我! 文章目录 一…

[Python人工智能] 四十四.命名实体识别 (5)利用bert4keras构建Bert-CRF实体识别模型(实体位置)

从本专栏开始,作者正式研究Python深度学习、神经网络及人工智能相关知识。前文讲解如何实现中文命名实体识别研究,构建BiGRU-CRF模型实现。这篇文章将继续以中文语料为主,介绍融合Bert的实体识别研究,使用bert4keras和kears包来构建Bert+BiLSTM-CRF模型。然而,该代码最终结…

红外遥控器的使用和详细解释

infrared.c #include "infrared.h"/* 红外 --- PA8*/void Infrared_Init(void) {GPIO_InitTypeDef GPIO_InitStruct; EXTI_InitTypeDef EXTI_InitStruct;NVIC_InitTypeDef NVIC_InitStruct;//使能SYSCFG时钟RCC_APB2PeriphClockCmd(RCC_APB2Periph_SYSCFG, E…

34.网络游戏逆向分析与漏洞攻防-游戏网络通信数据解析-登录数据包的监视与模拟

免责声明:内容仅供学习参考,请合法利用知识,禁止进行违法犯罪活动! 如果看不懂、不知道现在做的什么,那就跟着做完看效果 内容参考于:易道云信息技术研究院VIP课 上一个内容:33.游戏登录数据…

c#绘制图形

窗体工具控件 如果选纹理 ,需要在ImageList中选择图像(点击添加选择图片路径) using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Drawing.Drawing2D; using System.Linq; using System.…

第二十章 TypeScript(webpack构建ts+vue3项目)

构建项目目录 src-- main.ts-- App.vue--shim.d.tswebpack.config.jsindex.htmlpackage.jsontsconfig.json 基础构建 npm install webpack -D npm install webpack-dev-server -D npm install webpack-cli -D package.json 添加打包命令和 启动服务的命令 {"scripts…