局域网文件传输

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

​

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 194,457评论 5赞 459
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 81,837评论 2赞 371
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 141,696评论 0赞 319
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 52,183评论 1赞 263
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 61,057评论 4赞 355
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 46,105评论 1赞 272
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 36,520评论 3赞 381
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 35,211评论 0赞 253
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 39,482评论 1赞 290
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,574评论 2赞 309
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,353评论 1赞 326
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 32,213评论 3赞 312
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 37,576评论 3赞 298
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,897评论 0赞 17
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,174评论 1赞 250
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 41,489评论 2赞 341
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 40,683评论 2赞 335

推荐阅读更多精彩内容

  • Java笔记
    面向对象主要针对面向过程。 面向过程的基本单元是函数。 什么是对象：EVERYTHING IS OBJECT（万物...
    sinpi阅读 1,036评论 0赞 4
  • 计算机网络第二次作业
    题目要求： 1.编程作业，要求用一种自己擅长的语言实现ip地址的获取，及其详细信息的显示，要求用窗口显示。 2.生...
    linlan96阅读 329评论 0赞 0
  • Java
    1.import static是Java 5增加的功能,就是将Import类中的静态方法，可以作为本类的静态方法来...
    XLsn0w阅读 1,198评论 0赞 2
  • Java基础常见英语词汇
    Java基础常见英语词汇(共70个)['ɔbdʒekt] ['ɔ:rientid]导向的 ...
    今夜子辰阅读 3,239评论 1赞 34
  • Day 14 digital health care
    Digital health care is developing in a fast pace.It bring...
    苏凯薇阅读 217评论 0赞 0