搜索
首页Javajava教程Java如何实现局域网文件传输代码案例分享

Java如何实现局域网文件传输代码案例分享

黄舟
黄舟
Jul 30, 2017 am 11:33 AM
java局域网文件

这篇文章主要介绍了java 实现局域网文件传输的实例的相关资料,这里提供了实现代码可以帮助大家理解TCP及文件读写的知识，需要的朋友可以参考下

java 实现局域网文件传输的实例

           本文主要实现局域网文件传输的实例，对java 的TCP知识，文件读写，Socket等知识的理解应用，很好的实例，大家参考下，

实现代码：

ClientFile.java


/**
 * 更多资料欢迎浏览凯哥学堂官网：http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

import javax.swing.JProgressBar;

public class ClientFile extends Thread {

  private static String ip;
  private static int port;
  private String filepath;
  private long size;
  private JProgressBar jprogressbar;
  public ClientFile(String ip, int port, String filepath, JProgressBar jprogressbar) {
    this.ip = ip;
    this.port = port;
    this.filepath = filepath;
    this.jprogressbar = jprogressbar;
  }
  public void run() {
    try {
      Socket socket = new Socket(ip, port);
      InputStream input = socket.getInputStream();
      OutputStream output = socket.getOutputStream();

      File file = new File(filepath);
      // 第一次传输文件名字and文件的大小
      String str1 = file.getName() + "\t" + file.length();
      output.write(str1.getBytes());
      output.flush();
      byte[] b = new byte[100];
      int len = input.read(b);
      String s = new String(b, 0, len);
      // 如果服务器传输过来的是ok那么就开始传输字节
      if (s.equalsIgnoreCase("ok")) {
        long size = 0;
        jprogressbar.setMaximum((int) (file.length() / 10000));// 设置进度条最大值
        FileInputStream fin = new FileInputStream(file);
        byte[] b1 = new byte[1024 * 1024 * 2];
        while (fin.available() != 0) {
          len = fin.read(b1);
          output.write(b1, 0, len);
          output.flush();
          size += len;
          jprogressbar.setValue((int) (size / 10000));
        }
        if (fin.available() == 0) {
          javax.swing.JOptionPane.showMessageDialog(null, "传输完毕！即将推出......");
          try {
            Thread.sleep(1500);
            System.exit(0);
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        output.close();
        fin.close();
        socket.close();
      } else {
        // 传输的不是ok那么就弹出个信息框对方拒绝
        javax.swing.JOptionPane.showMessageDialog(null, "对方拒绝接收此数据！");
      }
    } catch (IOException e) {
      javax.swing.JOptionPane.showMessageDialog(null, "IOException");
    }
  }

}

ServerFile.java


/**
 * 更多资料欢迎浏览凯哥学堂官网：http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

import java.io.*;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JFileChooser;
import javax.swing.JOptionPane;
import javax.swing.JProgressBar;

public class ServerFile extends Thread {

  private Socket socket;
  private JProgressBar jprogressbars;

  public ServerFile(Socket socket, JProgressBar jprogressbars) {
    this.socket = socket;
    this.jprogressbars = jprogressbars;
  }

  public void run() {
    try {
      InputStream input = socket.getInputStream();
      OutputStream output = socket.getOutputStream();

      byte[] b = new byte[100];
      int len = input.read(b);
      String ss = new String(b, 0, len);
      String[] str1 = ss.split("\t");// 把接收到的信息按制表符拆分
      String filename = str1[0];// 起始位文件名称
      String filesize = str1[1];// 下标1位文件的大小
      long size = Long.parseLong(filesize);

      InetAddress ip = socket.getInetAddress();// 得到发送端的IP
      int port = socket.getPort();// 得到发送端的端口

      long s = size / 1024 / 1024;
      String name = " M";
      if (s < 1) {
        s = (size / 1024);
        name = " K";
      } else if (s > 1024) {
        float s1 = size / 1024 / 1024;
        s = (size / 1024 / 1024 / 1024);
        name = " G多";
      }
      // 弹出确认款，显示对方的ip端口以及文件的名称和大小是否需要接收
      int i = JOptionPane.showConfirmDialog(null,
          "来自: " + ip + ":" + port + "\n文件名称: " + filename + "\n文件大小: " + s + name);

      // 如果点击确认
      if (i == JOptionPane.OK_OPTION) {
        // 那么传输ok给发送端示意可以接收
        output.write("ok".getBytes());
        output.flush();
        JFileChooser jf = new JFileChooser();
        // 存储到本地路径的夹子
        jf.setFileSelectionMode(JFileChooser.DIRECTORIES_ONLY);
        jf.showOpenDialog(null);
        jprogressbars.setMaximum((int) (size / 10000));
        FileOutputStream fout = new FileOutputStream(new File(jf.getSelectedFile(), filename));
        b = new byte[1024 * 1024 * 2];
        long size1 = 0;
        while ((len = input.read(b)) != -1) {
          fout.write(b, 0, len);
          size1 += len;
          jprogressbars.setValue((int) (size1 / 10000));
        }
        fout.close();
        input.close();
        socket.close();

      } else {
        // 否不接收此文件
        output.write("no".getBytes());
        output.flush();
      }
    } catch (IOException e) {
      javax.swing.JOptionPane.showMessageDialog(null, "IOException");
    }

  }
  private static ServerSocket server = null;
  // 启动服务器
  public static void openServer(int port, JProgressBar jprogressbar) throws Exception {
    new Thread() {
      public void run() {
        try {
          if (server != null && !server.isClosed()) {
            server.close();
          }
          server = new ServerSocket(port);
          new ServerFile(server.accept(), jprogressbar).start();
        } catch (IOException e) {
          javax.swing.JOptionPane.showMessageDialog(null, "IOException");
        }
      }
    }.start();
  }

  // 关闭服务器
  public static void closeServer() {
    try {
      server.close();
    } catch (IOException e) {
      javax.swing.JOptionPane.showMessageDialog(null, "IOException");
    }
  }

}

SocketFileJFrame.java


/**
 * 更多资料欢迎浏览凯哥学堂官网：http://kaige123.com
 * @author 小沫
 */
 package com.tcp.file;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.Image;
import java.awt.Toolkit;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import java.awt.Color;
import javax.swing.JTabbedPane;
import java.awt.Panel;
import javax.swing.border.TitledBorder;
import javax.swing.UIManager;
import javax.swing.border.CompoundBorder;
import javax.swing.JLabel;
import java.awt.Font;
import javax.swing.JTextField;
import javax.swing.JToggleButton;
import javax.swing.JProgressBar;
import javax.swing.JButton;
import javax.swing.JFileChooser;
import javax.swing.event.AncestorListener;
import javax.swing.event.AncestorEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.awt.event.ActionEvent;

public class SocketFileJFrame extends JFrame {

  private JPanel contentPane;
  private JTextField textField;
  private JTextField textField_1;
  private JTextField textField_2;
  private JTextField textField_3;
  private JProgressBar progressBar_2;

  /**
   * Launch the application.
   */
  public static void main(String[] args) {
    EventQueue.invokeLater(new Runnable() {
      public void run() {
        try {
          SocketFileJFrame frame = new SocketFileJFrame();
          frame.setVisible(true);
        } catch (Exception e) {
          e.printStackTrace();
        }
      }
    });
  }

  /**
   * Create the frame.
   */
  public SocketFileJFrame() {
    setIconImage(Toolkit.getDefaultToolkit()
        .getImage(SocketFileJFrame.class.getResource("/javax/swing/plaf/metal/icons/ocean/newFolder.gif")));
    setForeground(Color.WHITE);

    setResizable(false);
    setTitle("局域网文件传输 V1.0");
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    int width = Toolkit.getDefaultToolkit().getScreenSize().width;//获取分辨率宽
    int heiht = Toolkit.getDefaultToolkit().getScreenSize().height;//获取分辨率高

    //分辨率宽高减去软件的宽高除以2把软件居中显示
    setBounds((width - 747) / 2, (heiht - 448) / 2, 738, 472);
    contentPane = new JPanel();
    contentPane.setBackground(Color.WHITE);
    contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
    setContentPane(contentPane);
    contentPane.setLayout(null);

    JPanel panel_1 = new JPanel();
    panel_1.setToolTipText("");
    panel_1.setBorder(new TitledBorder(UIManager.getBorder("TitledBorder.border"),
        "\u6587\u4EF6\u63A5\u6536\u670D\u52A1\u5668", TitledBorder.LEADING, TitledBorder.TOP, null,
        new Color(0, 0, 0)));
    panel_1.setBackground(Color.WHITE);
    panel_1.setBounds(39, 28, 652, 119);
    contentPane.add(panel_1);
    panel_1.setLayout(null);

    JLabel label = new JLabel("\u7AEF\u53E3:");
    label.setFont(new Font("新宋体", Font.PLAIN, 22));
    label.setBounds(26, 31, 66, 35);
    panel_1.add(label);

    //端口文本框
    textField = new JTextField();
    textField.setFont(new Font("宋体", Font.PLAIN, 19));
    textField.setText("8080");
    textField.setBounds(89, 36, 126, 26);
    panel_1.add(textField);
    textField.setColumns(10);

    //服务器关闭启动的按钮
    JToggleButton tglbtnNewToggleButton = new JToggleButton("\u542F\u52A8\u670D\u52A1\u5668");
    tglbtnNewToggleButton.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {

        if (tglbtnNewToggleButton.isSelected()) {
          //如果是按下显示关闭服务器
          tglbtnNewToggleButton.setText("关闭服务器");
          textField.setEnabled(false);//按下之后 端口文本框要设置不能写入
          try {
            //启动服务器
            ServerFile.openServer(Integer.parseInt(textField.getText())
                , progressBar_2);
          } catch (Exception e1) {
            javax.swing.JOptionPane.showMessageDialog(null, "Exception");
          }
        } else {
          //否启动服务器
          tglbtnNewToggleButton.setText("启动服务器");
          textField.setEnabled(true);////弹起之后 端口文本框要设置可写状态
          ServerFile.closeServer();//关闭服务器
        }

      }
    });
    tglbtnNewToggleButton.setFont(new Font("微软雅黑 Light", Font.PLAIN, 19));
    tglbtnNewToggleButton.setBackground(Color.WHITE);
    tglbtnNewToggleButton.setForeground(Color.DARK_GRAY);
    tglbtnNewToggleButton.setBounds(345, 34, 138, 28);
    panel_1.add(tglbtnNewToggleButton);

    //文件接收端的进度条
    progressBar_2 = new JProgressBar();
    progressBar_2.setBackground(Color.WHITE);
    progressBar_2.setForeground(new Color(255, 218, 185));
    progressBar_2.setStringPainted(true);
    progressBar_2.setBounds(460, 101, 190, 14);
    panel_1.add(progressBar_2);

    JPanel panel_2 = new JPanel();
    panel_2.setToolTipText("");
    panel_2.setBorder(new TitledBorder(UIManager.getBorder("TitledBorder.border"), "\u6587\u4EF6\u4F20\u8F93\u7AEF",
        TitledBorder.LEADING, TitledBorder.TOP, null, new Color(0, 0, 0)));
    panel_2.setBackground(Color.WHITE);
    panel_2.setBounds(39, 191, 652, 202);
    contentPane.add(panel_2);
    panel_2.setLayout(null);

    //文件传输端的进度条
    JProgressBar progressBar_1 = new JProgressBar();
    progressBar_1.setFont(new Font("宋体", Font.PLAIN, 18));
    progressBar_1.setStringPainted(true);
    progressBar_1.setForeground(new Color(240, 128, 128));
    progressBar_1.setBackground(Color.WHITE);
    progressBar_1.setBounds(96, 169, 472, 20);
    panel_2.add(progressBar_1);

    JLabel lblIp = new JLabel("IP\u5730\u5740:");
    lblIp.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
    lblIp.setBounds(26, 44, 70, 27);
    panel_2.add(lblIp);

    //IP地址文本框
    textField_1 = new JTextField();
    textField_1.setText("127.0.0.1");
    textField_1.setFont(new Font("新宋体", Font.PLAIN, 20));
    textField_1.setBounds(96, 44, 184, 30);
    panel_2.add(textField_1);
    textField_1.setColumns(10);

    JLabel label_1 = new JLabel("\u7AEF\u53E3:");
    label_1.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
    label_1.setBounds(308, 42, 80, 30);
    panel_2.add(label_1);

    //端口文本框
    textField_2 = new JTextField();
    textField_2.setText("8080");
    textField_2.setFont(new Font("新宋体", Font.PLAIN, 20));
    textField_2.setColumns(10);
    textField_2.setBounds(359, 44, 80, 30);
    panel_2.add(textField_2);

    //打开本地路径的按钮
    JButton button = new JButton("...");
    button.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {
        JFileChooser jf = new JFileChooser();
        jf.setFileSelectionMode(JFileChooser.FILES_ONLY);
        jf.showOpenDialog(SocketFileJFrame.this);
        textField_3.setText(jf.getSelectedFile().getPath());
      }
    });
    button.setBackground(Color.WHITE);
    button.setBounds(533, 51, 35, 20);
    panel_2.add(button);

    JLabel label_2 = new JLabel("\u8DEF\u5F84:");
    label_2.setFont(new Font("微软雅黑 Light", Font.PLAIN, 15));
    label_2.setBounds(489, 50, 44, 18);
    panel_2.add(label_2);

    //显示文件路径框
    textField_3 = new JTextField();
    textField_3.setEnabled(false);
    textField_3.setFont(new Font("微软雅黑 Light", Font.PLAIN, 20));
    textField_3.setBounds(96, 100, 343, 38);
    panel_2.add(textField_3);
    textField_3.setColumns(10);

    JLabel lblNewLabel = new JLabel("\u6587\u4EF6:");
    lblNewLabel.setFont(new Font("等线 Light", Font.PLAIN, 25));
    lblNewLabel.setBounds(33, 97, 56, 38);
    panel_2.add(lblNewLabel);
    //确定按钮
    JButton button_1 = new JButton("\u786E\u5B9A");
    button_1.addActionListener(new ActionListener() {
      public void actionPerformed(ActionEvent e) {

        ClientFile client = new ClientFile(
            textField_1.getText(), Integer.parseInt(textField_2.getText()), 
            textField_3.getText(), progressBar_1);
        client.start();
      }
    });
    button_1.setForeground(new Color(255, 255, 0));
    button_1.setBackground(new Color(233, 150, 122));
    button_1.setFont(new Font("微软雅黑 Light", Font.BOLD, 20));
    button_1.setBounds(475, 100, 91, 38);
    panel_2.add(button_1);
  }
}

以上是Java如何实现局域网文件传输代码案例分享的详细内容。更多信息请关注PHP中文网其他相关文章！

声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
相关文章
如何将Maven或Gradle用于高级Java项目管理，构建自动化和依赖性解决方案？如何将Maven或Gradle用于高级Java项目管理，构建自动化和依赖性解决方案？Mar 17, 2025 pm 05:46 PM

本文讨论了使用Maven和Gradle进行Java项目管理，构建自动化和依赖性解决方案，以比较其方法和优化策略。

如何使用适当的版本控制和依赖项管理创建和使用自定义Java库（JAR文件）？如何使用适当的版本控制和依赖项管理创建和使用自定义Java库（JAR文件）？Mar 17, 2025 pm 05:45 PM

本文使用Maven和Gradle之类的工具讨论了具有适当的版本控制和依赖关系管理的自定义Java库（JAR文件）的创建和使用。

如何使用咖啡因或Guava Cache等库在Java应用程序中实现多层缓存？如何使用咖啡因或Guava Cache等库在Java应用程序中实现多层缓存？Mar 17, 2025 pm 05:44 PM

本文讨论了使用咖啡因和Guava缓存在Java中实施多层缓存以提高应用程序性能。它涵盖设置，集成和绩效优势，以及配置和驱逐政策管理最佳PRA

如何将JPA（Java持久性API）用于具有高级功能（例如缓存和懒惰加载）的对象相关映射？如何将JPA（Java持久性API）用于具有高级功能（例如缓存和懒惰加载）的对象相关映射？Mar 17, 2025 pm 05:43 PM

本文讨论了使用JPA进行对象相关映射，并具有高级功能，例如缓存和懒惰加载。它涵盖了设置，实体映射和优化性能的最佳实践，同时突出潜在的陷阱。[159个字符]

Java的类负载机制如何起作用，包括不同的类载荷及其委托模型？Java的类负载机制如何起作用，包括不同的类载荷及其委托模型？Mar 17, 2025 pm 05:35 PM

Java的类上载涉及使用带有引导，扩展程序和应用程序类负载器的分层系统加载，链接和初始化类。父代授权模型确保首先加载核心类别，从而影响自定义类LOA

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序，用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

显示更多

热门文章

R.E.P.O.能量晶体解释及其做什么（黄色晶体）
3 周前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
3 周前By尊渡假赌尊渡假赌尊渡假赌
刺客信条阴影：贝壳谜语解决方案
2 周前ByDDD
R.E.P.O.如果您听不到任何人，如何修复音频
3 周前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25：如何解锁Myrise中的所有内容
4 周前By尊渡假赌尊渡假赌尊渡假赌
显示更多

热工具

SublimeText3 Linux新版

SublimeText3 Linux新版

SublimeText3 Linux最新版

EditPlus 中文破解版

EditPlus 中文破解版

体积小，语法高亮，不支持代码提示功能

PhpStorm Mac 版本

PhpStorm Mac 版本

最新（2018.2.1 ）专业的PHP集成开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

显示更多

热门话题

gmail邮箱登陆入口在哪里
7489
15
CakePHP 教程
1377
52
steam的账户名称是什么格式
77
11
win11激活密钥永久
52
19
NYT连接提示和答案
19
40
显示更多