package j2se.core.net.tcp.file;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 简单的传输文件范例(接受端)
*
*/
public class Server {
public static void main(String[] args) throws IOException {
// 在8888端口创建一个 ServerSocket
ServerSocket server = new ServerSocket(8888);
// 循环等待客户的连接
while (true) {
// 主线程会一直阻塞到客户连接的传入
Socket socket;
try {
socket = server.accept();
BufferedOutputStream output = new BufferedOutputStream(
new FileOutputStream(
new File(socket.getPort() + ".tmp")));
byte[] data = new byte[1024];
while (true) {
int i = socket.getInputStream().read(data);
if (i == -1)
break;
output.write(data, 0, i);
}
output.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
package j2se.core.net.tcp.file;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
/**
* 简单的传输文件范例(发送端)
*
*/
public class Client {
public static void main(String[] args) {
Scanner scan = new Scanner(System.in);
String ip = "127.0.0.1";
int port = 8888;
System.out.println("请输入文件名:");
String s = scan.nextLine();
try {
Socket socket = new Socket(ip, port);
BufferedOutputStream output = new BufferedOutputStream(socket
.getOutputStream());
BufferedInputStream input = new BufferedInputStream(
new FileInputStream(new File(s)));
try {
byte[] data = new byte[1024];
while (true) {
int i = input.read(data);
if (i == -1)
break;
output.write(data, 0, i);
}
output.flush();
} catch (Exception e) {
// 由于服务器主动断连接，所以会出现异常
} finally {
output.close();
input.close();
socket.close();
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}