这篇文章主要介绍了java 实现局域网文件传输的实例的相关资料,这里提供了实现代码可以帮助大家理解tcp及文件读写的知识，需要的朋友可以参考下
java 实现局域网文件传输的实例
本文主要实现局域网文件传输的实例，对java 的TCP知识，文件读写，Socket等知识的理解应用，很好的实例，大家参考下，
实现代码：
ClientFile.java
立即学习“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);
}
} 
