搜尋
首頁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
41
顯示更多