最近学Socket学上瘾了，就写了一个简单的文件传输程序。

客户端设计思路：客户端与服务端建立连接，选择客户端本地文件，先将文件名及大小等属性发送给服务端，再将文件通过流的方式传输给服务端。传输的进度打印到控制台中，直到传输完成。

服务端设计思路：服务端接收客户端的请求（阻塞式），每接收到一个客户端请求连接后，就新开一个处理文件的线程，开始写入流，将文件到服务器的指定目录下，并与传输过来的文件同名。
下面是客户端和服务端的代码实现：

客户端代码：

import java.io.DataOutputStream; 
import java.io.File; 
import java.io.FileInputStream; 
import java.net.Socket; 
 
/** 
 * 文件传输Client端<br> 
 * 功能说明： 
 * 
 * @author 大智若愚的小懂 
 * @Date 2016年09月01日 
 * @version 1.0 
 */ 
public class FileTransferClient extends Socket { 
 
  private static final String SERVER_IP = "127.0.0.1"; // 服务端IP 
  private static final int SERVER_PORT = 8899; // 服务端端口 
 
  private Socket client; 
 
  private FileInputStream fis; 
 
  private DataOutputStream dos; 
 
  /** 
   * 构造函数<br/> 
   * 与服务器建立连接 
   * @throws Exception 
   */ 
  public FileTransferClient() throws Exception { 
    super(SERVER_IP, SERVER_PORT); 
    this.client = this; 
    System.out.println("Cliect[port:" + client.getLocalPort() + "] 成功连接服务端"); 
  } 
 
  /** 
   * 向服务端传输文件 
   * @throws Exception 
   */ 
  public void sendFile() throws Exception { 
    try { 
      File file = new File("E:\\JDK1.6中文参考手册(JDK_API_1_6_zh_CN).CHM"); 
      if(file.exists()) { 
        fis = new FileInputStream(file); 
        dos = new DataOutputStream(client.getOutputStream()); 
 
        // 文件名和长度 
        dos.writeUTF(file.getName()); 
        dos.flush(); 
        dos.writeLong(file.length()); 
        dos.flush(); 
 
        // 开始传输文件 
        System.out.println("======== 开始传输文件 ========"); 
        byte[] bytes = new byte[1024]; 
        int length = 0; 
        long progress = 0; 
        while((length = fis.read(bytes, 0, bytes.length)) != -1) { 
          dos.write(bytes, 0, length); 
          dos.flush(); 
          progress += length; 
          System.out.print("| " + (100*progress/file.length()) + "% |"); 
        } 
        System.out.println(); 
        System.out.println("======== 文件传输成功 ========"); 
      } 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      if(fis != null) 
        fis.close(); 
      if(dos != null) 
        dos.close(); 
      client.close(); 
    } 
  } 
 
  /** 
   * 入口 
   * @param args 
   */ 
  public static void main(String[] args) { 
    try { 
      FileTransferClient client = new FileTransferClient(); // 启动客户端连接 
      client.sendFile(); // 传输文件 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
  } 
 
} 

服务端代码：

import java.io.DataInputStream; 
import java.io.File; 
import java.io.FileOutputStream; 
import java.math.RoundingMode; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.text.DecimalFormat; 
 
/** 
 * 文件传输Server端<br> 
 * 功能说明： 
 * 
 * @author 大智若愚的小懂 
 * @Date 2016年09月01日 
 * @version 1.0 
 */ 
public class FileTransferServer extends ServerSocket { 
 
  private static final int SERVER_PORT = 8899; // 服务端端口 
 
  private static DecimalFormat df = null; 
 
  static { 
    // 设置数字格式，保留一位有效小数 
    df = new DecimalFormat("#0.0"); 
    df.setRoundingMode(RoundingMode.HALF_UP); 
    df.setMinimumFractionDigits(1); 
    df.setMaximumFractionDigits(1); 
  } 
 
  public FileTransferServer() throws Exception { 
    super(SERVER_PORT); 
  } 
 
  /** 
   * 使用线程处理每个客户端传输的文件 
   * @throws Exception 
   */ 
  public void load() throws Exception { 
    while (true) { 
      // server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的 
      Socket socket = this.accept(); 
      /** 
       * 我们的服务端处理客户端的连接请求是同步进行的， 每次接收到来自客户端的连接请求后， 
       * 都要先跟当前的客户端通信完之后才能再处理下一个连接请求。 这在并发比较多的情况下会严重影响程序的性能， 
       * 为此，我们可以把它改为如下这种异步处理与客户端通信的方式 
       */ 
      // 每接收到一个Socket就建立一个新的线程来处理它 
      new Thread(new Task(socket)).start(); 
    } 
  } 
 
  /** 
   * 处理客户端传输过来的文件线程类 
   */ 
  class Task implements Runnable { 
 
    private Socket socket; 
 
    private DataInputStream dis; 
 
    private FileOutputStream fos; 
 
    public Task(Socket socket) { 
      this.socket = socket; 
    } 
 
    @Override 
    public void run() { 
      try { 
        dis = new DataInputStream(socket.getInputStream()); 
 
        // 文件名和长度 
        String fileName = dis.readUTF(); 
        long fileLength = dis.readLong(); 
        File directory = new File("D:\\FTCache"); 
        if(!directory.exists()) { 
          directory.mkdir(); 
        } 
        File file = new File(directory.getAbsolutePath() + File.separatorChar + fileName); 
        fos = new FileOutputStream(file); 
 
        // 开始接收文件 
        byte[] bytes = new byte[1024]; 
        int length = 0; 
        while((length = dis.read(bytes, 0, bytes.length)) != -1) { 
          fos.write(bytes, 0, length); 
          fos.flush(); 
        } 
        System.out.println("======== 文件接收成功 [File Name：" + fileName + "] [Size：" + getFormatFileSize(fileLength) + "] ========"); 
      } catch (Exception e) { 
        e.printStackTrace(); 
      } finally { 
        try { 
          if(fos != null) 
            fos.close(); 
          if(dis != null) 
            dis.close(); 
          socket.close(); 
        } catch (Exception e) {} 
      } 
    } 
  } 
 
  /** 
   * 格式化文件大小 
   * @param length 
   * @return 
   */ 
  private String getFormatFileSize(long length) { 
    double size = ((double) length) / (1 << 30); 
    if(size >= 1) { 
      return df.format(size) + "GB"; 
    } 
    size = ((double) length) / (1 << 20); 
    if(size >= 1) { 
      return df.format(size) + "MB"; 
    } 
    size = ((double) length) / (1 << 10); 
    if(size >= 1) { 
      return df.format(size) + "KB"; 
    } 
    return length + "B"; 
  } 
 
  /** 
   * 入口 
   * @param args 
   */ 
  public static void main(String[] args) { 
    try { 
      FileTransferServer server = new FileTransferServer(); // 启动服务端 
      server.load(); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
  } 
} 

测试的结果（客户端）：

测试的结果（服务端）：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java  # socket文件传输  # java实现文件传输  # socket  # 示例  # Java基于Socket的文件传输实现方法  # java 实现局域网文件传输的实例  # Java基于TCP方式的二进制文件传输  # Java IO流 文件传输基础  # Java生成PDF文件的实例代码  # java根据模板动态生成PDF实例  # 详解Java生成PDF文档方法  # Java实现Excel转PDF的两种方法详解  # Java实现Html转Pdf的方法  # Java实现高效PDF文件传输技巧  # 服务端  # 客户端  # 文件传输  # 传输文件  # 大智若愚  # 把它  # 我们可以  # 写了  # 新开  # 要先  # 这在  # 并与  # 建立一个  # 比较多  # 能再  # 先将  # 再将  # 大家多多  # 情况下  # 发送给 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel事件和监听器如何实现_Laravel Events & Listeners解耦应用的实战教程  JavaScript中的标签模板是什么_它如何扩展字符串功能  Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件  Laravel如何生成URL和重定向？（路由助手函数）  Laravel distinct去重查询_Laravel Eloquent去重方法  如何在云服务器上快速搭建个人网站？  php中::能调用final静态方法吗_final修饰静态方法调用规则【解答】  Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗？  Win11任务栏卡死怎么办 Windows11任务栏无反应解决方法【教程】  Laravel如何实现模型的全局作用域？（Global Scope示例）  电商网站制作价格怎么算,网上拍卖流程以及规则？  如何用VPS主机快速搭建个人网站？  北京网站制作的公司有哪些,北京白云观官方网站？  在centOS 7安装mysql 5.7的详细教程  如何正确选择百度移动适配建站域名？  高防服务器如何保障网站安全无虞？  详解jQuery中基本的动画方法  Laravel怎么使用Blade模板引擎_Laravel模板继承与Component组件复用【手册】  Laravel怎么进行浏览器测试_Laravel Dusk自动化浏览器测试入门  Java Adapter 适配器模式（类适配器，对象适配器）优缺点对比  免费网站制作appp,免费制作app哪个平台好？  SQL查询语句优化的实用方法总结  Laravel广播系统如何实现实时通信_Laravel Reverb与WebSockets实战教程  中山网站制作网页,中山新生登记系统登记流程？  高端智能建站公司优选：品牌定制与SEO优化一站式服务  香港服务器网站推广：SEO优化与外贸独立站搭建策略  javascript事件捕获机制【深入分析IE和DOM中的事件模型】  canvas 画布在主流浏览器中的尺寸限制详细介绍  韩国服务器如何优化跨境访问实现高效连接？  Laravel N+1查询问题如何解决_Eloquent预加载(Eager Loading)优化数据库查询  详解免费开源的DotNet二维码操作组件ThoughtWorks.QRCode（.NET组件介绍之四）  如何在万网主机上快速搭建网站？  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样？  ChatGPT回答中断怎么办 引导AI继续输出完整内容的方法  Laravel Seeder怎么填充数据_Laravel数据库填充器的使用方法与技巧  如何获取上海专业网站定制建站电话？  Laravel如何部署到服务器_线上部署Laravel项目的完整流程与步骤  网站优化排名时，需要考虑哪些问题呢？  Laravel Blade组件怎么用_Laravel可复用视图组件的创建与使用  如何为不同团队 ID 动态生成多个非值班状态按钮  Windows10怎样连接蓝牙设备_Windows10蓝牙连接步骤【教程】  Laravel怎么使用Intervention Image库处理图片上传和缩放  Laravel如何实现RSS订阅源功能_Laravel动态生成网站XML格式订阅内容【教程】  Laravel怎么生成二维码图片_Laravel集成Simple-QrCode扩展包与参数设置【实战】  广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  企业在线网站设计制作流程,想建设一个属于自己的企业网站，该如何去做？  东莞专业网站制作公司有哪些,东莞招聘网站哪个好？  大同网页,大同瑞慈医院官网？  佐糖AI抠图怎样调整抠图精度_佐糖AI精度调整与放大细化操作【攻略】