TCP协议原理与Java编程实战:从连接建立到断开的完整解析
1.TCP协议核心:面向连接的可靠通信基石
TCP(Transmission Control Protocol,传输控制协议)是互联网的“可靠信使”,属于传输层协议,其核心在于面向连接和可靠传输。它通过严谨的握手机制与数据控制逻辑,确保两端通信的稳定性,广泛应用于文件传输、网页浏览、即时通信等场景。
2.三次握手:建立连接的“三步曲”
在正式传输数据前,客户端与服务器需通过三次握手建立逻辑连接,流程如下:
1. 第一步(SYN:同步请求)
客户端向服务器发送带有 SYN 标志的数据包,请求建立连接,并携带初始序列号(如 Seq=X)。此时客户端进入 SYN_SENT 状态。
2. 第二步(SYN+ACK:同步确认)
服务器收到请求后,返回 SYN+ACK 包:
- 用 ACK=X+1 确认客户端的序列号,表明“已收到请求”;
- 同时发送自己的初始序列号 Seq=Y。
服务器进入 SYN_RCVD 状态。
3. 第三步(ACK:确认)
客户端收到服务器的确认后,发送 ACK 包确认服务器序列号(Ack=Y+1),连接正式建立。双方进入 ESTABLISHED 状态,开始数据传输。
3.四次挥手:优雅断开连接的“四部曲”
数据传输完毕后,双方通过四次挥手释放资源,避免“孤儿连接”占用系统资源。以客户端主动断开为例:
1. 第一步(FIN:结束请求)
客户端发送 FIN 包(Seq=U),表示“已发送完数据,请求断开连接”,进入 FIN_WAIT_1 状态。
2. 第二步(ACK:确认结束请求)
服务器收到 FIN 后,立即返回 ACK 包(Ack=U+1),进入 CLOSE_WAIT 状态。此时服务器处于半关闭状态,仍可发送剩余数据。
3. 第三步(FIN:服务器结束请求)
服务器发送完剩余数据后,向客户端发送 FIN 包(Seq=V),请求彻底断开连接,进入 LAST_ACK 状态。
4. 第四步(ACK:最终确认)
客户端收到服务器的 FIN 后,返回 ACK 包(Ack=V+1),并进入 TIME_WAIT 状态。等待 2倍最大段寿命(2MSL) 后,确认对方收到确认包,最终关闭连接。
关键点:
- 半关闭状态:第二步后,服务器仍可单向发送数据,直至自身也发送 FIN。
- TIME_WAIT的意义:防止旧连接的数据包干扰新连接,确保网络中所有旧数据段过期。
4.Java中的TCP编程:从Socket到数据交互
在Java中,TCP编程基于 java.net 包的 Socket(客户端)和 ServerSocket(服务器端)类,通过输入输出流实现数据传输。以下是一个完整的客户端-服务器通信示例。
1. 服务器端:监听端口并处理连接
import java.io.*;
import java.net.*; public class TCPServer { public static void main(String[] args) { try (ServerSocket serverSocket = new ServerSocket(8888)) { // 绑定端口8888 System.out.println("服务器启动,等待客户端连接..."); try (Socket clientSocket = serverSocket.accept()) { // 阻塞等待连接 // 获取输入输出流 BufferedReader in = new BufferedReader( new InputStreamReader(clientSocket.getInputStream()) ); PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true); // 接收客户端消息 String message = in.readLine(); System.out.println("客户端消息:" + message); // 回复客户端
out.println("服务器已收到消息:" + message); } } catch (IOException e) {
e.printStackTrace(); } }
}
2. 客户端:发起连接并传输数据
import java.io.*;
import java.net.*; public class TCPClient { public static void main(String[] args) { try (Socket socket = new Socket("localhost", 8888)) { // 连接本地服务器 // 获取输入输出流 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); // 发送消息 String request = "你好,TCP服务器!";
out.println(request); // 接收服务器回复 String response = in.readLine(); System.out.println("服务器回复:" + response); } catch (IOException e) {
e.printStackTrace(); } }
}
5.可靠性机制:TCP如何保证数据准确送达
1. 序列号与确认应答(ACK)
每个字节数据都有唯一序列号,接收方通过 ACK 告知发送方已收到的数据,未确认的数据将触发重传。
2. 超时重传
发送方设置超时时间(如 SO_TIMEOUT),未收到 ACK 时自动重发数据。
3. 流量控制与拥塞控制
- 滑动窗口:通过 Window Size 字段控制发送方速率,避免接收方缓冲区溢出;
- 拥塞算法:慢启动、拥塞避免等机制动态调整传输速率,防止网络拥堵。
6.连接管理的最佳实践
1. 资源释放
使用 try-with-resources 自动关闭 Socket 和流,确保四次挥手正常触发:
java
try (Socket socket = new Socket(...)) {
// 通信逻辑
} // 自动调用socket.close(),触发FIN包
2. 多线程处理并发连接
服务器端通过线程池处理多个客户端请求,避免单线程阻塞:
ExecutorService executor = Executors.newFixedThreadPool(10); while (true) { Socket clientSocket = serverSocket.accept();
executor.submit(() -> handleClient(clientSocket)); }
3. 异常处理
捕获 ConnectException(连接失败)、SocketTimeoutException(超时)等,增强程序鲁棒性。
7.总结:TCP协议的完整生命周期
阶段 | 核心机制 | Java 关键类 / 方法 | 典型场景 |
连接建立 | 三次握手 | ServerSocket.accept() | 客户端发起请求 |
数据传输 | 序列号 / ACK | InputStream.read() | 文件传输、API 接口调用 |
连接断开 | 四次挥手 | Socket.close() | 通信结束释放资源 |
可靠性保障 | 超时重传 | setSoTimeout(int) | 网络波动时的数据容错 |
TCP协议通过严谨的握手与挥手机制,结合Java简洁的Socket API,为开发者提供了一套高效可靠的网络通信方案。理解其底层原理,不仅能优化代码性能,更能在排查网络问题时快速定位根源,是构建高稳定性网络应用的必备技能。
相关文章:

TCP协议原理与Java编程实战:从连接建立到断开的完整解析
1.TCP协议核心:面向连接的可靠通信基石 TCP(Transmission Control Protocol,传输控制协议)是互联网的“可靠信使”,属于传输层协议,其核心在于面向连接和可靠传输。它通过严谨的握手机制与数据控制逻辑&am…...
Linux的top命令使用
Linux系统中top命令详解及使用技巧 一、基础功能 top命令用于实时监控系统性能和进程活动,可查看以下信息: - CPU使用率 - 内存使用情况 - 进程状态信息 - 系统负载数据 二、使用步骤 1. 打开终端输入命令:top 2. 查看实时更新的数据界面&a…...
Spring Cloud Gateway 限流实践:基于 Redis 令牌桶算法的网关层流量治理
一、引言 在微服务架构中,API 网关作为流量枢纽,需对进入系统的请求进行精细化限流,以保护下游服务免受流量冲击。Spring Cloud Gateway 结合 Redis 实现的令牌桶算法,为网关层限流提供了高效、分布式的解决方案。本文将深入解析其原理、配置及实践优化。 二、技术栈与原…...
可视化大屏实现全屏或非全屏
通过点击按钮实现全屏和非全屏效果展示 代码如下: <template> //点击icon图片进入全屏或非全屏<img :src"screenStatus ? /src/assets/noFull.png : /src/assets/full.png" alt"" click"enterFullScreen" /> </te…...
java8函数式接口(函数式接口的匿名实现类作为某些方法的入参)
文章目录 前置介绍通过 lambda 表达式,使用匿名类,实现函数式接口函数式接口和回调函数的关系函数式接口的应用 前置介绍 是 Java 8 引入的核心概念之一,指的是 仅包含一个抽象方法的接口。它可以被 FunctionalInterface 注解标记࿰…...
linux自有服务
文章目录 [TOC](文章目录)linux自有服务概述systemctl管理服务命令CentOS 7 之前CentOS 7 常用自有服务ntpd或systemd-timesyncd时间同步服务ntp同步服务器原理ntpd时间同步操作systemd-timesyncd同步原理systemd-timesyncd时间同步操作 firewalld防火墙计划任务crontab CentOS…...
UniApp网页版集成海康视频播放器
注意:本人全部集成好后使用最新的海康平台下载插件进行替换后就不能预览视频 使用Uni插件进行集成:海康视频H5播放器组件 - DCloud 插件市场 CSDN资源下载:https://download.csdn.net/download/wangdaoyin2010/90910975 注意:初…...
Filter和Interceptor详解(一文了解执行阶段及其流程)
Filter和Interceptor的区别 Filter(过滤器)和 Interceptor(拦截器)都是用于在请求处理前后插入额外逻辑的组件,下面依次介绍,并额外介绍Spring Gateway的过滤器(GlobalFilter/GatewayFilter&am…...

鸿蒙仓颉开发语言实战教程:实现商城应用详情页
昨天有朋友提到鸿蒙既然有了ArkTs开发语言,为什么还需要仓颉开发语言。其实这个不难理解,安卓有Java和Kotlin,iOS先后推出了Objective-C和Swift,鸿蒙有两种开发语言也就不奇怪了。而且仓颉是比ArkTs更加灵活的语言,虽然…...

GitAny - 無需登入的 GitHub 最新倉庫檢索工具
地址:https://github.com/MartinxMax/gitany GitAny - 無需登入的 GitHub 專案搜尋工具 GitAny 是一款基於 Python 的工具,允許你在無需登入的情況下搜尋當天最新的 GitHub 專案。它支援模糊搜尋、條件篩選以及倉庫資料的視覺化分析。 安裝依賴 $ pip…...

在飞牛nas系统上部署gitlab
在飞牛nas系统上部署gitlab需要使用docker进行部署,如下将介绍详细的部署流程。 文章目录 1. docker镜像2. 拉取镜像3. 运行容器4. 运行和访问gitlab5. 一些小配置5.1 url问题5.2 ssh端口5.3 其他配置 1. docker镜像 首先需要找一个gitlab的docker镜像地址&#x…...

深入理解 Redis 哨兵模式
Redis 哨兵模式深度解析:从原理到实践的全流程指南 在分布式系统架构中,Redis 作为高性能的内存数据库,其哨兵模式(Sentinel)是保障服务高可用性的核心方案。本文将从基础概念、运行机制出发,结合具体配置…...
SQL进阶之旅 Day 4:子查询与临时表优化
文章标题 【SQL进阶之旅 Day 4】子查询与临时表优化 文章内容 开篇:SQL进阶之旅的第4天 在“SQL进阶之旅”系列中,第4天的主题是子查询与临时表优化。这是SQL开发中不可或缺的一部分,尤其在处理复杂查询时,合理使用子查询和临…...

[特殊字符]《Qt实战:基于QCustomPlot的装药燃面动态曲线绘制(附右键菜单/样式美化/完整源码)》
1、将qcustomplot.cpp qcustomplot.h放入工程目录下引入qcustomplot 2、代码 .h #if defined(_MSC_VER) #pragma execution_character_set(...

力扣-最大连续一的个数
1.题目描述 2.题目链接 1004. 最大连续1的个数 III - 力扣(LeetCode) 3.代码解答 class Solution {public int longestOnes(int[] nums, int k) {int zero0,length0;for(int left0,right0;right<nums.length;right){if(nums[right]0){zero;}while…...

无人机避障——深蓝学院浙大栅格地图以及ESDF地图内容
Occupancy Grid Map & Euclidean Signed Distance Field: 【注意】:目的是为了将有噪声的传感器收集起来,用于实时的建图。 Occupancy Grid Map: 概率栅格: 【注意】:由于传感器带有噪声,在实际中基于…...

Postman基础操作
1.Postman是什么? Postman是接口测试的工具,简单来说它能模拟浏览器对服务器的某个接口发起请求并接收响应数据。 1.1 Postman工作原理 2.Postman发送请求 2.1 发送GET请求 我们知道GET请求是没用请求体的,所以我们需要将请求参数写在Param…...

【MPC控制 - 从ACC到自动驾驶】3 MPC控制器设计原理与参数配置:打造ACC的“最强大脑”
【MPC控制 - 从ACC到自动驾驶】MPC控制器设计原理与参数配置:打造ACC的“最强大脑” 在Day 1,我们认识了ACC自适应巡航和MPC这位“深谋远虑的棋手”。Day 2,我们一起给汽车“画像”,建立了它的纵向动力学模型,并把它翻…...

Unity3D仿星露谷物语开发52之菜单页面
1、目标 创建菜单页面,可通过Esc键开启或关闭。 当把鼠标悬停在上面时它会高亮,然后当点击按钮时标签页会被选择。 2、 创建PauseMenuCanvas (1)创建Canvas 在Hierarchy -> PersistentScene -> UI下创建新的Cavans命名为…...
待定事项之存储数据
#### 部署云服务器  ### 部署云服务器完整步骤 1. **连接到云服务器** bash ssh root<服务器IP> 2. **创建项目目录结构** bash mkdir -p /var/www/three/study/待办事项 3. **克隆项目仓库** bash cd /var/www…...
电脑装的数据越多,会不会越重
在这个数字化飞速发展的时代,有一个看似荒诞却又引人深思的问题:电脑装的数据越多,会不会越重? 先来说说大家的普遍认知,我们通常认为数据只是一些虚拟的代码和信息,存放在电脑的硬盘或其他存储设备中&…...
君正Ingenic webRTC P2P库libyangpeerconnection7编程指南
概述 libyangpeerconnection7是一个实现P2P媒体传输/数据通道的一个轻量级的webRTC库,基于metaRTC7.0的传输模块构建,支持H264/H265视频编码,通过 P2P 连接为用户提供高效、低延迟的音视频和数据通信。 君正版libyangpeerconnection7可适用…...

MySQL——复合查询表的内外连
目录 复合查询 回顾基本查询 多表查询 自连接 子查询 where 字句中使用子查询 单行子查询 多行子查询 多列子查询 from 字句中使用子查询 合并查询 实战OJ 查找所有员工入职时候的薪水情况 获取所有非manager的员工emp_no 获取所有员工当前的manager 表的内外…...

小米玄戒O1架构深度解析(一):十核异构设计与缓存层次详解
前言 这两天,小米的全新SOC玄戒O1横空出世,引发了科技数码圈的一次小地震,那么小米的这颗所谓的自研SOC,内部究竟有着什么不为人知的秘密呢?我们一起一探究竟。 目录 前言1 架构总览1.1 基本构成1.2 SLC缺席的原因探…...
Numba模块的用法(高性能计算)
文章目录 介绍核心装饰器与基础用法@jit(nopython=True):最常用的编译装饰器@njit的简写编译时指定类型签名并行加速(parallel=True)@cuda.jit: GPU 编程(CUDA)向量化函数(@vectorize)性能优化技巧调试与常见问题调试模式常见错误适用场景与局限性实例:加速蒙特卡洛模拟…...
Kafka自定义分区策略实战避坑指南
文章目录 概要代码示例小结 概要 kafka生产者发送消息默认根据总分区数和设置的key计算哈希取余数,key不变就默认存放在一个分区,没有key则随机数分区,明显默认的是最不好用的,那kafka也提供了一个轮询分区策略,我自己…...
PyTorch中cdist和sum函数使用示例详解
以下是PyTorch中cdist与sum函数的联合使用详解: 1. cdist函数解析 功能:计算两个张量间的成对距离矩阵 输入格式: X1:形状为(B, P, M)的张量X2:形状为(B, R, M)的张量p:距离类型(默认2表示欧式距离)输出:形状为(B, P, R)的距离矩阵,其中元素 d i j d_{ij} dij表示…...

[免费]微信小程序宠物医院管理系统(uni-app+SpringBoot后端+Vue管理端)【论文+源码+SQL脚本】
大家好,我是java1234_小锋老师,看到一个不错的微信小程序宠物医院管理系统(uni-appSpringBoot后端Vue管理端),分享下哈。 项目视频演示 【免费】微信小程序宠物医院管理系统(uni-appSpringBoot后端Vue管理端) Java毕业设计_哔哩哔哩_bilibi…...
centos7.9使用docker-compose安装kafka
docker-compose配置文件 services:zookeeper:image: confluentinc/cp-zookeeper:7.0.1hostname: zookeepercontainer_name: zookeeperports:- "2181:2181"environment:ZOOKEEPER_CLIENT_PORT: 2181ZOOKEEPER_TICK_TIME: 2000kafka:image: confluentinc/cp-kafka:7.0…...

ETL 工具与数据中台的关系与区别
ETL 工具和数据中台作为数据处理领域的关键概念,虽然存在一定的关联,但二者有着明显的区别。本文将深入剖析 ETL 工具与数据中台之不同。 一、ETL 工具概述 ETL 是数据仓库技术中的核心技术之一,其全称为 Extract(抽取ÿ…...