Java 基于TCP Socket 实现文件上传
文件上传过程一个单向Socket通信过程。客户端通过文件输入流读取文件，然后从Socket获取输出流写入数据。服务端从Socket中获得输入流，然后写入文件输出流，写入数据完成则上传完成。
服务端UploadServer：
publicclassUplaodServer{
publicstaticvoidmain(String[]args){
try(
//创建一个ServerSocket监听8080端口的请求
//ServerSocket实现了AutoCloseable接口,可以自动释放资源
ServerSocketserver=newServerSocket(8080);
//accept()会阻塞当前线程,等待客户端请求
Socketsocket=server.accept();
//获取输入流
BufferedInputStreamin=newBufferedInputStream(socket.getInputStream());
//由文件输出流创建缓冲输出流,写入本地upload.jpg文件
FileOutputStreamoutputStream=newFileOutputStream("./upload.jpg")
){
//缓冲区
byte[]buffer=newbyte[1024];
intlen=in.read(buffer);
while(len!=-1){
//写入数据到文件
outputStream.write(buffer,0,len);
//再次从Socket中读取数据
len=in.read(buffer);
}
System.out.println("文件已上传");
}catch(IOExceptione){
e.printStackTrace();
}
}
}
客户端UploadClient：
publicclassUploadClient{
publicstaticvoidmain(String[]args){
try(
//Socket实现了AutoCloseable接口可自动关闭资源
Socketsocket=newSocket("127.0.0.1",8080);
//又Socket获得输出流，并创建缓冲输出流
BufferedOutputStreamout=newBufferedOutputStream(socket.getOutputStream());
FileInputStreamfileInput=newFileInputStream("F:\file\oxx6j5.jpg");
//由文件输入流创建缓冲输入流
BufferedInputStreamin=newBufferedInputStream(fileInputStream);
){
//准备缓冲区
byte[]buffer=newbyte[1024];
intlen=in.read(buffer);
while(len!=-1){
//写入Socket
out.write(buffer,0,len);
//再次读取文件
len=in.read(buffer);
}
System.out.println("上传成功！");
}catch(ConnectExceptione){
System.out.println("服务器未启动");
e.printStackTrace();
}catch(IOExceptione){
e.printStackTrace();
}
}
}
注意
server.accept()会阻塞线程，所以最好把server.accept()语句放入子线程中。
以上就是Java基于TCPSocket实现文件上传的详细内容，更多关于Java文件上传的资料请关注毛票票其它相关文章！