文件上传原理
1.【客户端】输入流,从硬盘读取文件数据到程序中。
2.【客户端】输出流,写出文件数据到服务端。
3.【服务端】输入流,读取文件数据到服务端程序。
4.【服务端】输出流,写出文件数据到服务器硬盘中。
文件上传的客户端
读取本地文件 上传到服务器 读取服务器回写的数据
实现步骤:
1.创建一个本地字节输入流FileInputstream对象 构造方法中绑定要读取的数据源
2.创建一个客户端Socket对象 构造方法中绑定服务器的IP地址和端口号
3.使用socket中的方法getOutputStream获取网络字节输出流OutputStream对象
4.使用本地字节输入流FileInputStram对象中的方法read 读取本地文件
5.使用网络字节输出流OutputStream对象中的方法 write 把读取到的文件上传到服务器
6.使用Socket中的方法geitInputStream 获取网络字节输入流InputStream对象
7.使用网络字节输入流InputStream对象中的方法read读取服务回写的数据
8.释放资源(FileInputStream,Socket)
代码:
public class FileUploadTCPlient { public static void main(String[] args) throws IOException { //创建一个本地字节输入流FileInputstream对象 构造方法中绑定要读取的数据源 FileInputStream fis = new FileInputStream("E:\\1.jpg"); //创建一个客户端Socket对象 构造方法中绑定服务器的IP地址和端口号 Socket socket = new Socket("127.0.0.1", 8888); //使用socket中的方法getOutputStream获取网络字节输出流OutputStream对象 OutputStream os = socket.getOutputStream(); //使用本地字节输入流FileInputStram对象中的方法read 读取本地文件 int len; byte[] bys = new byte[1024]; while ((len=fis.read(bys))!=-1){ //使用网络字节输出流OutputStream对象中的方法 write 把读取到的文件上传到服务器 os.write(bys,0,len); } //使用Socket中的方法geitInputStream 获取网络字节输入流InputStream对象(读) InputStream is = socket.getInputStream(); //使用网络字节输入流InputStream对象中的方法read读取服务回写的数据 while ((len=is.read(bys))!= -1){ System.out.println(new String(bys,0,len)); } //释放资源(FileInputStream,Socket) fis.close(); socket.close(); } }
文件上传的服务端
读取客户端上传的文件 保存到服务器的硬盘 给客户端回写“上传成功”
实现步骤:
1.创建一个服务器ServerSocket对象 和系统要指定的端口号
2.使用ServerSocket对象中的方法accept 获取请求的客户端Socket对象
3.使用Socket对象中的方法getInputStream 获取网络字节输入路InputStream对象
4.判断d:\\upload文件夹是否存在 不存在则创建
5.创建一个本地字节输出流FileOutputStream对象 构造方法中绑定要输出的目的地
6.使用网络字节输入流InputStream对象中的方法read 读取客户端上传的文件
7.使用本地字节输出流FileOutputStream对象中的方法write 把读取到的文件保存到服务器的硬盘上
8.使用Socket对象中的方法getOutputStream 获取网络字节输出流OutputStream对象
9.使用网络字节输出流OutputStream对象中的方法write 给客户端回写“上传成功”
10.释放资源(FileOutputStream,Socket,ServerSocket)
代码:
public class FileUploadTCPlient { public static void main(String[] args) throws IOException { //创建一个本地字节输入流FileInputstream对象 构造方法中绑定要读取的数据源 FileInputStream fis = new FileInputStream("E:\\1.jpg"); //创建一个客户端Socket对象 构造方法中绑定服务器的IP地址和端口号 Socket socket = new Socket("127.0.0.1", 8888); //使用socket中的方法getOutputStream获取网络字节输出流OutputStream对象 OutputStream os = socket.getOutputStream(); //使用本地字节输入流FileInputStram对象中的方法read 读取本地文件 int len; byte[] bys = new byte[1024]; while ((len=fis.read(bys))!=-1){ //使用网络字节输出流OutputStream对象中的方法 write 把读取到的文件上传到服务器 os.write(bys,0,len); } //使用Socket中的方法geitInputStream 获取网络字节输入流InputStream对象(读) InputStream is = socket.getInputStream(); //使用网络字节输入流InputStream对象中的方法read读取服务回写的数据 while ((len=is.read(bys))!= -1){ System.out.println(new String(bys,0,len)); } //释放资源(FileInputStream,Socket) fis.close(); socket.close(); } }
文件上传阻塞问题
解决:上传完成文件,给服务器写一个结束标记
- shutdownOutput():禁用此套接字的输出流。
对于TCP套接字,任何先前写入的数据将被发送,随后是TCP的正常连接终止序列。
客户端:
public class FileUploadTCPlient { public static void main(String[] args) throws IOException { //创建一个本地字节输入流FileInputstream对象 构造方法中绑定要读取的数据源 FileInputStream fis = new FileInputStream("E:\\1.jpg"); //创建一个客户端Socket对象 构造方法中绑定服务器的IP地址和端口号 Socket socket = new Socket("127.0.0.1", 8888); //使用socket中的方法getOutputStream获取网络字节输出流OutputStream对象 OutputStream os = socket.getOutputStream(); //使用本地字节输入流FileInputStram对象中的方法read 读取本地文件 int len; byte[] bys = new byte[1024]; while ((len=fis.read(bys))!=-1){ //使用网络字节输出流OutputStream对象中的方法 write 把读取到的文件上传到服务器 os.write(bys,0,len); } /* 解决:上传完成文件,给服务器写一个结束标记 shutdownOutput():禁用此套接字的输出流。 对于TCP套接字,任何先前写入的数据将被发送,随后是TCP的正常连接终止序列。 */ socket.shutdownOutput(); System.out.println("正在输送数据"); //使用Socket中的方法geitInputStream 获取网络字节输入流InputStream对象(读) InputStream is = socket.getInputStream(); //使用网络字节输入流InputStream对象中的方法read读取服务回写的数据 while ((len=is.read(bys))!= -1){ System.out.println(new String(bys,0,len)); } System.out.println("输送完成"); //释放资源(FileInputStream,Socket) fis.close(); socket.close(); } }
服务器:
public class TCPServer { public static void main(String[] args) throws IOException { //创建一个服务器ServerSocket对象 和系统要指定的端口号 ServerSocket socket = new ServerSocket(8888); //使用ServerSocket对象中的方法accept 获取请求的客户端Socket对象 Socket accept = socket.accept(); //使用Socket对象中的方法getInputStream 获取网络字节输入路InputStream对象 InputStream inputStream = accept.getInputStream(); //判断d:\\upload文件夹是否存在 不存在则创建 File file = new File("E:\\upload"); if (!file.exists()){ file.mkdirs();//,没有则创建 } //创建一个本地字节输出流FileOutputStream对象 构造方法中绑定要输出的目的地 FileOutputStream fileOutputStream = new FileOutputStream(file+"\\1.jpg"); System.out.println("接收文件中...."); //使用网络字节输入流InputStream对象中的方法read 读取客户端上传的文件 int len; byte[] bys = new byte[1024]; while ((len=inputStream.read(bys))!= -1){ //使用本地字节输出流FileOutputStream对象中的方法write 把读取到的文件保存到服务器的硬盘上 fileOutputStream.write(bys,0,len); } System.out.println("接收完毕"); //使用Socket对象中的方法getOutputStream 获取网络字节输出流OutputStream对象 //使用网络字节输出流OutputStream对象中的方法write 给客户端回写“上传成功” accept.getOutputStream().write("上传成功".getBytes()); //释放资源(FileOutputStream,Socket,ServerSocket) fileOutputStream.close(); accept.close(); socket.close(); } }
标签:读取,字节,对象,编程,bys,案例,socket,上传,Socket From: https://www.cnblogs.com/qihaokuan/p/16607243.html