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文件上传的资料请关注毛票票其它相关文章!