当前位置：首页 > news >正文

[特殊字符]【高并发实战】Java Socket + 线程池实现高性能文件上传服务器（附完整源码）[特殊字符]

news 来源：原创 2025/9/18 15:05:47

大家好！今天给大家分享一个 Java Socket + 线程池 实现的高性能文件上传服务器，支持 多客户端并发上传，代码可直接运行，适合 面试、项目实战、性能优化 学习！

📌 本文亮点：

✅ 完整可运行代码（附详细注释）
✅ 线程池优化（拒绝策略、队列控制）
✅ UUID 生成唯一文件名（避免冲突）
✅ 客户端/服务器完整交互流程
✅ 适合新手进阶 & 面试加分项

如果你对 Java网络编程、高并发、线程池 感兴趣，这篇一定要看！👇

🚀 1. 项目背景

在实际开发中，我们经常需要实现 文件上传 功能，比如：

用户上传头像
日志文件收集
分布式系统数据传输

如果直接用 单线程 Socket，服务器只能 一个一个处理请求，性能极差！

💡 解决方案：
✅ 多线程：每个客户端连接分配一个线程
✅ 线程池：避免频繁创建/销毁线程，提升性能
✅ 非阻塞IO（NIO）：更高性能（本文先讲基础版）

💻 2. 代码实现

📌 服务器端（支持多客户端并发上传）

import java.io.*;
import java.net.*;
import java.util.UUID;
import java.util.concurrent.*;public class FileUploadServer {public static void main(String[] args) throws IOException {// 创建线程池（核心3线程，最大16线程，队列容量2，60秒空闲回收）ThreadPoolExecutor pool = new ThreadPoolExecutor(3, 16, 60, TimeUnit.SECONDS,new ArrayBlockingQueue<>(2),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy()  // 队列满时拒绝新任务);ServerSocket server = new ServerSocket(10086);System.out.println("⚡服务器启动，等待客户端连接...");while (true) {Socket socket = server.accept();  // 阻塞等待客户端连接pool.submit(new FileUploadHandler(socket));  // 提交任务到线程池System.out.println("🔗 客户端连接: " + socket.getInetAddress());}}
}class FileUploadHandler implements Runnable {private final Socket socket;public FileUploadHandler(Socket socket) {this.socket = socket;}@Overridepublic void run() {try (InputStream is = socket.getInputStream();OutputStream os = socket.getOutputStream();) {// 生成唯一文件名（避免冲突）String fileName = UUID.randomUUID() + ".jpg";// 写入本地文件try (FileOutputStream fos = new FileOutputStream(fileName)) {byte[] buffer = new byte[1024];int len;while ((len = is.read(buffer)) != -1) {fos.write(buffer, 0, len);}System.out.println("📁 文件保存成功: " + fileName);}// 返回响应给客户端os.write("✅ 上传成功！".getBytes());os.flush();} catch (IOException e) {System.err.println("❌ 处理异常: " + e.getMessage());} finally {try {socket.close();  // 关闭连接} catch (IOException e) {e.printStackTrace();}}}
}

📌 客户端（上传文件）

import java.io.*;
import java.net.*;public class FileUploadClient {public static void main(String[] args) throws IOException {Socket socket = new Socket("localhost", 10086);  // 连接服务器System.out.println("🚀 连接服务器成功！");// 读取本地文件并发送try (FileInputStream fis = new FileInputStream("test.jpg");OutputStream os = socket.getOutputStream();InputStream is = socket.getInputStream();) {byte[] buffer = new byte[1024];int len;while ((len = fis.read(buffer)) != -1) {os.write(buffer, 0, len);}System.out.println("📤 文件发送完成！");// 接收服务器响应byte[] response = new byte[1024];int responseLen = is.read(response);System.out.println("📥 服务器响应: " + new String(response, 0, responseLen));} finally {socket.close();}}
}

📊 3. 关键优化点

✅ 1. 线程池管理

核心线程数 = 3（保持活跃）
最大线程数 = 16（应对突发流量）
队列容量 = 2（防止资源耗尽）
拒绝策略 = AbortPolicy（队列满时直接拒绝）

✅ 2. 唯一文件名生成

String fileName = UUID.randomUUID() + ".jpg";  // 避免文件名冲突

✅ 3. 资源自动关闭

使用 try-with-resources，确保 Socket、FileOutputStream 等资源自动释放，避免内存泄漏！

🚀 4. 如何运行？

启动服务器：
```
java FileUploadServer
```
启动客户端（可开多个）：
```
java FileUploadClient
```
查看结果：
- 服务器控制台显示客户端连接和文件保存路径
- 客户端收到 上传成功 响应

💡 5. 扩展优化

NIO（Non-blocking IO）：更高性能（Netty 底层实现）
断点续传：记录文件偏移量
加密传输：SSL/TLS 安全传输
分布式存储：上传到云存储（OSS）

📌 6. 总结

本文实现了一个高并发文件上传服务器，适合 面试、项目实战
关键点：线程池、Socket、资源管理、UUID 文件名
优化方向：NIO、断点续传、加密传输

如果觉得有用，点赞 👍 + 关注 ➕，后续更新更多 Java 高并发实战！

📢 互动话题：
你在项目中遇到过文件上传的问题吗？欢迎评论区讨论！👇

#Java #Socket #多线程 #高并发 #文件上传 #面试必备

public class MyRunable implements Runnable{Socket socket;public MyRunable(Socket socket){this.socket=socket;}@Overridepublic void run() {try {// 接收文件BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());String name = UUID.randomUUID().toString().replace("-", "");BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(name + ".jpg"));byte[] bytes = new byte[1024];int len;while ((len = bis.read(bytes)) != -1) {bos.write(bytes, 0, len);}bos.flush();bos.close();  // 关闭文件输出流// 发送响应给客户端BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();// 先关闭输出流，再关闭socketsocket.shutdownOutput();} catch (IOException e) {throw new RuntimeException(e);} finally {if (socket != null) {try {socket.close();} catch (IOException e) {throw new RuntimeException(e);}}}}}public class reserve {public static void main(String[] args) throws IOException {ThreadPoolExecutor pool=new ThreadPoolExecutor(3,//核心线程数量16,//线程池总大小60,//空闲时间TimeUnit.SECONDS,//空闲时间单位new ArrayBlockingQueue<>(2),//队列Executors.defaultThreadFactory(),//线程工场，让线程池如何创建对象new ThreadPoolExecutor.AbortPolicy()//阻塞队列);ServerSocket ss = new ServerSocket(10086);while (true) {Socket socket = ss.accept();
pool.submit(new MyRunable(socket));}}
}public class Main {public static void main(String[] args) throws IOException {Socket socket = new Socket("192.168.129.132", 10086);// 发送文件BufferedInputStream bis = new BufferedInputStream(new FileInputStream("微信图片_20250303192811.jpg"));BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());byte[] bytes = new byte[1024];int len;while ((len = bis.read(bytes)) != -1) {bos.write(bytes, 0, len);}bos.flush();socket.shutdownOutput();  // 告诉服务器数据发送完毕// 接收服务器响应BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String response = br.readLine();System.out.println("服务器响应: " + response);// 关闭资源bis.close();br.close();socket.close();}
}

[特殊字符]【高并发实战】Java Socket + 线程池实现高性能文件上传服务器（附完整源码）[特殊字符]

大家好！今天给大家分享一个 Java Socket 线程池实现的高性能文件上传服务器，支持多客户端并发上传，代码可直接运行，适合面试、项目实战、性能优化学习！ 📌 本文亮点： ✅ 完整可运行代码&a…...

编程日记 2025/9/18 15:05:47

2025 年天津消防设施操作员考试攻略：深挖地区特色考点

天津作为重要的港口城市与工业基地，消防安全形势复杂多样，其消防设施操作员考试也带有鲜明的地区特色。地区特色考点解析：天津化工产业发达，涉及众多危化品场所。因此，危化品储存场所的消防设施配置与应急处置成为…...

编程日记 2025/9/18 2:26:51

chrome extension开发框架WXT之Browser.runtime

以下是对 Browser.runtime API 中主要方法的参数、返回值、作用及运用场景的详细解释： 1. 连接与通信方法 connect(connectInfo?: ConnectInfo) / connect(extensionId: string, connectInfo?: ConnectInfo) 参数： extensionId（可选）：目标扩展的 ID，未指定时默认连接当…...

编程日记 2025/9/13 14:55:03

dav_1_MySQL数据库排查cpu消耗高的sql

CPU消耗高sql定位以下从2个维度进行分析，一个是当前cpu高占用排查，一个是历史sql占用高排查一.当前cpu占用高排查 1 从os资源消耗逐步到mysql查询 1.1 输入top 然后按大P 使之进程按照消耗cpu排序比如3889为mysql进程ID，接下来再用它查…...

编程日记 2025/9/18 13:15:56

数据结构刷题之贪心算法

贪心算法（Greedy Algorithm） 是一种在每个步骤中都选择当前最优解的算法设计策略。它通常用于解决优化问题，例如最小化成本或最大化收益。贪心算法的核心思想是：在每一步选择中，都做出局部最优的选择，希望…...

编程日记 2025/9/12 1:46:12

每日一题（小白）暴力娱乐篇23

由题意得知给我们一串数字，我们每次交换两位，最少交换多少次成功得到有顺序的数组。我们以平常的思维去思考，加入给你一串数字获得最少的交换次数，意味着你的交换后续基本不会变，比如说2 1 3 5 4 中1与2交换后不变&…...

编程日记 2025/9/18 12:46:58

回归预测 | Matlab实现RIME-CNN-GRU-Attention霜冰优化卷积门控循环单元注意力机制多变量回归预测

回归预测 | Matlab实现RIME-CNN-GRU-Attention霜冰优化卷积门控循环单元注意力机制多变量回归预测目录回归预测 | Matlab实现RIME-CNN-GRU-Attention霜冰优化卷积门控循环单元注意力机制多变量回归预测预测效果基本介绍程序设计参考资料预测效果基本介绍 1.Matlab实现RIME…...

编程日记 2025/9/14 1:05:47

第1章对大型语言模型的介绍

人类正处在一个关键转折点。自2012年起，基于深度神经网络的人工智能系统研发进入快速通道，将这一技术推向了新高度：至2019年底，首个能够撰写与人类文章真假难辨的软件系统问世，这个名为GPT-2（生成型预训练变…...

编程日记 2025/9/18 15:05:16

PGA 简介

PGA（Programmable Gain Amplifier，可编程增益放大器）是一种可以通过外部控制信号改变增益大小的放大器，常用于需要灵活调节信号放大倍数的应用中，比如在模拟信号采集、数据转换（如 ADC 之前）、传…...

编程日记 2025/9/15 1:09:53

2025年CCF-C NCA：导航变量多目标粒子群算法NMOPSO，深度解析+性能实测

目录 1.摘要2.运动学模型和约束3.路径规划目标函数3.多目标粒子群算法4.结果展示5.参考文献6.代码获取 1.摘要路径规划是无人机（UAV）任务执行的核心，因为它决定了无人机完成任务所需的飞行路径。为了解决这一问题，本文提出了一种…...

编程日记 2025/9/15 20:49:35

FFMpeg音视频解码实战

音频解码一、初始化阶段 avformat_open_input 打开输入媒体文件。avformat_find_stream_info 读取媒体流信息，查找音频流。avcodec_find_decoder 查找对应的解码器（如 AAC、MP3 解码器）。avcodec_alloc_context3 分配解码器上下文。avcodec…...

编程日记 2025/9/10 0:24:30

day25学习Pandas库

文章目录三、Pandas库4.函数计算7.合并8.随机抽样9.空值处理9.1检测空值9.2填充空值9.3删除空值行/列 5.读取CSV文件5.1 to_csv()5.2 read_csv() 6.绘图三、Pandas库 4.函数计算 7.合并 merge 函数用于将两个 DataFrame 对象根据一个或多个键进行合并函数： …...

编程日记 2025/9/10 19:31:03

去除Mysql表中的空格、回车、换行符和特殊字符

系列文章目录文章目录系列文章目录前言一、示例1.sql层面2.java层面前言一、示例 1.sql层面参考 ## 例子1 ## CHAR(10) 表示换行符 ## CHAR(13) 表示回车UPDATE 表名 SET 列名 REPLACE(REPLACE(列名, CHAR(10), ), CHAR(13), )## 例子2 ## 删除字段中的空格、换行符、…...

编程日记 2025/9/9 4:12:07

以普通用户身份启动pure-ftpd服务端

Pureftp的优点包括 : 高性能，适用于大容量数据传输。安全性强，通过SSL/TLS加密和身份验证机制保证文件传输安全。易用性高，具有直观的用户界面。灵活性强，支持多种文件存储方式。没有漏洞，便于维护基于Centos 9的pu…...

编程日记 2025/9/11 0:43:58

国内下载不了镜像，可以用国外机器下载完成，打成tar文件，在国内机器上重新加载

可以在已经拉取过镜像的机器上打包（导出）镜像文件，然后拷贝到另一台机器上导入使用。这是离线部署 Docker 镜像的常用方法，非常适合网络受限的环境。 🛠️ 步骤如下： ✅ 1. 在已有镜像的机器上打包镜像 …...

编程日记 2025/9/10 1:28:07

【Java】Java 中不同类型的类详解

目录 Java 中不同类型的类详解一、基础类类型1. 普通类（Concrete Class）2. 抽象类（Abstract Class）3. 接口（Interface）4. 枚举类（Enum Class） 二、嵌套类与特殊类5. 内部类&#xff…...

编程日记 2025/9/13 7:55:46

Cadence学习笔记之---热风焊盘制作

编程日记 2025/9/13 9:50:03

518. Coin Change II

这是完全背包问题。由于求的是组合数，所以外层循环只能是对硬币遍历，内层循环只能是对总金额的遍历。另外，虽然题目数据保证结果符合 32 位带符号整数。但是第28个测试用例，dp[j]dp[j-conis[i]]中间结果会整数溢出&#xff0c…...

编程日记 2025/9/16 1:58:40

GPIO子系统与Pinctrl子系统的交互

我们前面呢，已经讲过GPIO子系统的数据结构以及他的设备树信息是怎么转换成我们的C代码存储在结构体里面了，我们知道，如果想去使用一个GPIO，避免不了得把这个引脚复用成GPIO功能，那么就避不开Pinctrl子系统，…...

编程日记 2025/9/13 8:49:05

DeepSeek实用操作及行业应用系列2

DeepSeek的本地化部署与AI通识教育之未来 DeepSeek之火，可以燎原面向审计行业DeepSeek大模型操作指南v1.0 DeepSeek提示词设计、幻觉避免与应用（大数据百家讲坛） DeepSeek 搞钱教程（0基础入门） DeepSeek基础知识…...

编程日记 2025/8/25 21:20:50

面向数据库场景的大模型交互微调数据集

关键要点研究表明，面向数据库场景的大模型交互微调数据集通常包括数据库模式、自然语言查询和对应的SQL查询。证据倾向于认为，数据集应以JSON格式组织，覆盖多种查询类型，并确保高质量和多样性。对于自定义数据库，建议…...

编程日记 2025/9/8 11:27:24

解锁ChatGPT-4o文生图潜力：精选提示词收集整理更新中

示例一：按元素和描述要求生成图片示例二：“吉卜力”风格示例三：3D Q版风格示例四：生成指定布局和主题图片具体的提示词参考，陆续更新中：https://blog.luler.top/d/25...

编程日记 2025/8/18 0:54:39

WHAT - React 进一步学习推荐

书籍 adevnadia 的《Advanced React》TejasKumar_ 的《Fluent React》addyosmani 和 djirdehh 的《Building Large Scale Web Apps》面试准备 reactjs-interview-questions 文章：最佳实践如果你想了解最佳实践并学习技巧，请务必关注以下专家&…...

编程日记 2025/9/10 1:05:35

有关串口的知识点

轻微了解一般都是前这俩01 Ren1才能接受开局T1 R1要给0 所以就是0x50的起手终端服务是接受的 ———————————————————————————— 进入实际引用使用的时候1 初始化 2要给个500ms的延时函数即可...

编程日记 2025/8/17 22:37:25

无线插卡话机如何接入呼叫中心系统？

一、接入原理与技术架构无线插卡话机通过内置SIM卡模块（支持GSM/CDMA/4G/5G等网络制式），将移动网络信号转化为语音通信信号，再通过SIP协议或专用网关与呼叫中心系统对接。其核心流程包括： 1、网络信号…...

编程日记 2025/9/15 11:30:26

prometheus有几种数据类型

Prometheus 数据类型主要有以下四种： Counter（计数器）： 单调递增的数值，表示某个事件发生的次数。计数器的值只会增加，除非被重置为0（例如在系统重启时）。示例：HTTP 请求…...

编程日记 2025/9/17 9:54:03

C++设计模式+异常处理

#include <iostream> #include <cstring> #include <cstdlib> #include <unistd.h> #include <sstream> #include <vector> #include <memory> #include <stdexcept> // 包含异常类using namespace std;// 该作业要求各位写一…...

编程日记 2025/9/11 10:09:26

字符串替换（模拟）神奇数（数学）DNA序列（固定长度的滑动窗口）

⭐️个人主页：小羊 ⭐️所属专栏：每日两三题很荣幸您能阅读我的文章，诚请评论指点，欢迎欢迎 ~ 目录字符串替换 （模拟）神奇数 （数学）DNA序列 （固定长度的滑动窗口&am…...

编程日记 2025/9/12 0:58:33

echarts地图详解

获取地图坐标json数据 <template><div id"china-map" style"width:500px;height:500px"></div> </template> <script>import * as echarts from echarts;// 坐标jsonimport chinaJson from "/assets/china.json" …...

编程日记 2025/9/12 0:58:29

Redis 哨兵模式：告别手动故障转移！

目录前言一、 Redis哨兵模式是啥？🤔二、为什么需要哨兵模式？🤷‍♀️三、哨兵模式的原理是什么？🤝1. 监控（Monitoring）2. 信息共享与客观下线判断3. 哨兵领导者选举4. 故障转移5.…...

编程日记 2025/9/12 9:28:14

地理数据输出

为了便于数据共享和交换，可以将地理数据库中的要素数据输出为Shapefiles或者Coverage，将相应的属性表输出为Info或者dBase格式的数据文件。 1.输出为 Shapefile (1)在AreCatalog目录树或者内容栏中，右键点击需要输出的地理要素类，…...

编程日记 2025/9/16 8:07:15

springboot + security + redis + jwt 实现验证登录上

前言： 通过实践而发现真理，又通过实践而证实真理和发展真理。从感性认识而能动地发展到理性认识，又从理性认识而能动地指导革命实践，改造主观世界和客观世界。实践、认识、再实践、再认识，这种形式，循环往…...

编程日记 2025/9/9 2:21:14

SomeIP通讯机制

在SOME/IP协议中，通讯方式主要围绕服务的交互模式进行的设计，核心机制包括Event（时间）、Method（方法）以及其变种Fire-and-Forget（FF）。以下是SOME/IP中所有通信方式的总结&#xff1…...

编程日记 2025/9/11 7:49:47

线代第三课：n阶行列式

引言行标取自然排列不同行不同列的3个元素相乘列标取排列的所有可能列标排列的逆序数的奇偶性决定符号，- n阶行列式第一种：按行展开 (1) 行标取自然排列 (2) 列标取排列的所有可能 （PS：可以理解为随意取） (3) 从…...

编程日记 2025/9/14 5:58:10

人工智能在高中教育中的应用现状剖析与挑战应对

第一章：绪论 1.1 研究背景与意义随着全球化的加速和科技的飞速发展，高中教育在培养未来社会所需人才方面的重要性日益凸显。高中阶段是学生知识体系构建和思维能力发展的关键时期，然而，当前高中教育面临着诸多挑战，…...

编程日记 2025/9/9 12:00:26

如何在powerbi使用自定义SQL

我们在刚使用到powerbi的时候发现当直接连接到数据库的时候我们只能使用数据库中已存在的表，我们没有办法使用自定义SQL来准备数据，这给我们的开发造成很大的困扰；我目前使用的是vertica数据库，首先我们需要在本地有vertica的驱动…...

编程日记 2025/9/13 8:56:51

边缘计算盒子是什么？

边缘计算盒子是一种小型的硬件设备，通常集成了处理器、存储器和网络接口等关键组件，具备一定的计算能力和存储资源，并能够连接到网络。它与传统的云计算不同，数据处理和分析直接在设备本地完成，而不是上传到云端&#…...

编程日记 2025/9/17 10:35:20

【C++面向对象】封装(上)：探寻构造函数的幽微之境

每文一诗 💪🏼 我本将心向明月，奈何明月照沟渠 —— 元/高明《琵琶记》译文：我本是以真诚的心来对待你，就像明月一样纯洁无瑕；然而，你却像沟渠里的污水一样，对这份心意无动于衷&a…...

编程日记 2025/9/15 21:42:34

物联网|无人自助台球厅源码|哪些框架支持多设备连接？

在无人自助台球厅的智能化管理中，物联网（IoT）技术是核心支撑。如何实现不同设备（如智能门锁、环境传感器、支付终端、灯光控制系统等）的高效连接与协同工作，是系统开发的关键挑战。本文将带大家探讨支持多设…...

编程日记 2025/9/9 18:42:35

单旋翼无人机(直升机)和四旋翼无人机优势对比

以下是无人机直升机（单旋翼无人机）与四旋翼无人机的优势对比分析，分场景阐述两者的核心差异： ‌一、无人机直升机（单旋翼无人机）的优势‌ ‌1. 高能量效率，长续航‌ ‌动力设计‌：单…...

编程日记 2025/9/6 22:57:33

微服务之间调用外键“翻译”的方法概述

写在前面的话：减少strean流操作，减少多层嵌套for循环。使用普通for循环和map的方式进行转换， 第一步查询数据 List<Student> findList studentDao.findList(findMap); 第二步准备遍历和赋值 if(CollectionUtil.isNotEmpty(findLis…...

编程日记 2025/9/8 10:59:41

Java学习——day25（多线程基础与线程创建方式）

文章目录 1. 多线程基础1.1 线程的概念1.2 线程的生命周期 2. 创建线程的方式2.1 继承 Thread 类2.2 实现 Runnable 接口 3. 实践：编写简单多线程程序4. 总结与思考 1. 多线程基础 1.1 线程的概念线程 (Thread)： 程序执行的最小单元，一个进…...

编程日记 2025/9/16 14:12:16

2025前端面试题

Vue 3 比 Vue 2 更快的原因 Vue 3 使用 JavaScript 的 Proxy 替代了 Vue 2 中的 Object.defineProperty 来实现响应式系统。Proxy 可以拦截对象的所有操作，无需像 Object.defineProperty 那样单独定义每个属性的 getter 和 setterVue 3 还引入了静态树提升&#xf…...

编程日记 2025/9/17 20:20:38

2025-04-09 吴恩达机器学习6——神经网络(1)：介绍

文章目录 1 神经网络介绍1.1 起源与发展1.2 生物神经元 vs. 人工神经元1.3 学习建议 2 案例：T 恤预测2.1 基础概念2.2 需求预测示例2.3 多隐藏层神经网络2.4 神经网络的优势 3 案例：图像感知3.1 计算机视觉任务3.2 神经网络架构 1 神经网络介绍 1.1 起源…...

编程日记 2025/9/14 10:03:17