本文主要实现局域网文件传输的实例，对java 的TCP知识，文件读写，Socket等知识的理解应用，很好的实例，大家参考下，
实现代码：
ClientFile.java
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
/** * 更多资料欢迎浏览凯哥学堂官网：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
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
/** * 更多资料欢迎浏览凯哥学堂官网：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
|
1
|
|
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
|
/** * 更多资料欢迎浏览凯哥学堂官网：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); }} |
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
原文链接：http://l4432848.iteye.com/blog/2387042
