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

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, JProgFQyrkKhuressBar 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.sFQyrkKhuhowOpenDialog(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);

progFQyrkKhuressBar_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);

}

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

Flask接口签名sign原理与实例代码浅析

291 2023-04-25

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

Flask接口签名sign原理与实例代码浅析

java中的接口是类吗

zookeeper python接口实例详解

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！