java 實(shí)現(xiàn)局域網(wǎng)文件傳輸?shù)膶?shí)例
java 實(shí)現(xiàn)局域網(wǎng)文件傳輸?shù)膶?shí)例
本文主要實(shí)現(xiàn)局域網(wǎng)文件傳輸?shù)膶?shí)例,對(duì)java 的TCP知識(shí),文件讀寫(xiě),Socket等知識(shí)的理解應(yīng)用,很好的實(shí)例,大家參考下,
實(shí)現(xiàn)代碼:
ClientFile.java
/**
* 更多資料歡迎瀏覽凱哥學(xué)堂官網(wǎng):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);
// 如果服務(wù)器傳輸過(guò)來(lái)的是ok那么就開(kāi)始傳輸字節(jié)
if (s.equalsIgnoreCase("ok")) {
long size = 0;
jprogressbar.setMaximum((int) (file.length() / 10000));// 設(shè)置進(jìn)度條最大值
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 {
// 傳輸?shù)牟皇莖k那么就彈出個(gè)信息框?qū)Ψ骄芙^
javax.swing.JOptionPane.showMessageDialog(null, "對(duì)方拒絕接收此數(shù)據(jù)!");
}
} catch (IOException e) {
javax.swing.JOptionPane.showMessageDialog(null, "IOException");
}
}
}
ServerFile.java
/**
* 更多資料歡迎瀏覽凱哥學(xué)堂官網(wǎng):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];// 起始位文件名稱(chēng)
String filesize = str1[1];// 下標(biāo)1位文件的大小
long size = Long.parseLong(filesize);
InetAddress ip = socket.getInetAddress();// 得到發(fā)送端的IP
int port = socket.getPort();// 得到發(fā)送端的端口
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多";
}
// 彈出確認(rèn)款,顯示對(duì)方的ip端口以及文件的名稱(chēng)和大小是否需要接收
int i = JOptionPane.showConfirmDialog(null,
"來(lái)自: " + ip + ":" + port + "\n文件名稱(chēng): " + filename + "\n文件大小: " + s + name);
// 如果點(diǎn)擊確認(rèn)
if (i == JOptionPane.OK_OPTION) {
// 那么傳輸ok給發(fā)送端示意可以接收
output.write("ok".getBytes());
output.flush();
JFileChooser jf = new JFileChooser();
// 存儲(chǔ)到本地路徑的夾子
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;
// 啟動(dòng)服務(wù)器
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();
}
// 關(guān)閉服務(wù)器
public static void closeServer() {
try {
server.close();
} catch (IOException e) {
javax.swing.JOptionPane.showMessageDialog(null, "IOException");
}
}
}
SocketFileJFrame.java
/**
* 更多資料歡迎瀏覽凱哥學(xué)堂官網(wǎng):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("局域網(wǎng)文件傳輸 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);
//服務(wù)器關(guān)閉啟動(dòng)的按鈕
JToggleButton tglbtnNewToggleButton = new JToggleButton("\u542F\u52A8\u670D\u52A1\u5668");
tglbtnNewToggleButton.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
if (tglbtnNewToggleButton.isSelected()) {
//如果是按下顯示關(guān)閉服務(wù)器
tglbtnNewToggleButton.setText("關(guān)閉服務(wù)器");
textField.setEnabled(false);//按下之后 端口文本框要設(shè)置不能寫(xiě)入
try {
//啟動(dòng)服務(wù)器
ServerFile.openServer(Integer.parseInt(textField.getText())
, progressBar_2);
} catch (Exception e1) {
javax.swing.JOptionPane.showMessageDialog(null, "Exception");
}
} else {
//否啟動(dòng)服務(wù)器
tglbtnNewToggleButton.setText("啟動(dòng)服務(wù)器");
textField.setEnabled(true);////彈起之后 端口文本框要設(shè)置可寫(xiě)狀態(tài)
ServerFile.closeServer();//關(guān)閉服務(wù)器
}
}
});
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);
//文件接收端的進(jìn)度條
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);
//文件傳輸端的進(jìn)度條
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);
//打開(kāi)本地路徑的按鈕
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);
}
}
感謝閱讀,希望能幫助到大家,謝謝大家對(duì)本站的支持!
相關(guān)文章
多jdk環(huán)境下指定springboot外部配置文件詳解
這篇文章主要為大家介紹了多jdk環(huán)境下指定springboot外部配置文件詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-03-03
java連接SQL Server數(shù)據(jù)庫(kù)的方法
這篇文章主要為大家詳細(xì)介紹了java連接SQL Server數(shù)據(jù)庫(kù)的方法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-10-10
spring boot 監(jiān)控處理方案實(shí)例詳解
這篇文章主要介紹了spring boot 監(jiān)控處理方案的相關(guān)資料,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-07-07
在SpringBoot中通過(guò)jasypt進(jìn)行加密解密的方法
今天小編就為大家分享一篇關(guān)于在SpringBoot中通過(guò)jasypt進(jìn)行加密解密的方法,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧2019-01-01
java程序員自己的圖片轉(zhuǎn)文字OCR識(shí)圖工具分享
這篇文章主要介紹了java程序員自己的圖片轉(zhuǎn)文字OCR識(shí)圖工具,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-11-11
idea中使用Inputstream流導(dǎo)致中文亂碼解決方法
很多朋友遇到一個(gè)措手不及的問(wèn)題當(dāng)idea中使用Inputstream流導(dǎo)致中文亂碼及Java FileInputStream讀中文亂碼問(wèn)題,針對(duì)這兩個(gè)問(wèn)題很多朋友不知道該如何解決,下面小編把解決方案分享給大家供大家參考2021-05-05
Java學(xué)習(xí)之Lambda表達(dá)式的使用詳解
Lambda表達(dá)式是Java SE 8中一個(gè)重要的新特性,允許通過(guò)表達(dá)式來(lái)代替功能接口。本文將通過(guò)一些簡(jiǎn)單的示例和大家講講Lamda表達(dá)式的使用,感興趣的可以了解一下2022-12-12
Java中數(shù)學(xué)相關(guān)類(lèi)的使用教程
Java是一種廣泛使用的編程語(yǔ)言,它提供了許多數(shù)學(xué)運(yùn)算的函數(shù)和方法,使得開(kāi)發(fā)者可以輕松地進(jìn)行各種數(shù)學(xué)計(jì)算,下面這篇文章主要給大家介紹了關(guān)于Java中數(shù)學(xué)相關(guān)類(lèi)使用的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-05-05

