文件上传案例

TCP通信文件上传案例

原理：客户读取本地文件，把文件上传到服务器，服务器把上传的文件保存到服务器硬盘上

步骤

客户端使用本地的字节输出流，读取要上传的文件

客户端使用网络字节输出流，把读取到的文件上传到服务器

服务器使用网络字节输入流，读取客户端上传文件

服务器使用本地字节输出流，把读取到的文件，保存到服务器硬盘上

服务器使用网络字节输出流给客户端回写上传成功

客户端使用网络字节输入流读取服务器回写的数据

释放资源

注意事项：客户端和服务器和本地硬盘进行读写，需要使用自己创建的字节对象（本地流）

客户端和服务器之间进行读写，必须使用Socket中提供的字节流对象（网络流）

文件上传的原理就是文件复制

客户端代码

明确： 数据源：D:\lianxi\lianxi1\1.jpg

数据目的地：服务器

实现步骤：

创建一个本地字节输出流FileInputStream对象，构造方法中绑定要读取的数据源

创建一个客户端Socket对象，构造方法中绑定服务器的IP地址和端口号

使用Socket中的方法getOutputStream,获得网络字节输出流OutputStream对象

使用本地字节输入流FileInputStream对象中的方法read，读取本地文件

使用网络字节输出流OutputStream对象中的方法write 把读取到的文件上传到服务器

使用Socket中的方法getinputStream 获取网络字节输入流InputStream对象

使用网络字节输入流InputStream对象中的方法read读取服务器回写数据

释放资源

FileInputStream fis = new FileInputStream("D:\\lianxi\\lianxi1\\1.jpg");
Socket socket = new Socket("192.168.0.111",8888);
OutputStream ops = socket.getOutputStream();
int len = 0;
byte[] bytes = new byte[1024];
while ((len = fis.read(bytes))!=-1){
    ops.write(bytes);
}
InputStream ips = socket.getInputStream();
while ((len = ips.read(bytes))!=-1){
    System.out.println(new String(bytes,0,len));
}
fis.close();
socket.close();

服务器端

读取客户端上传文件，保存到服务器的硬盘，给客户回写上传成功

明确：

数据源：客户端上传的文件

目的地：服务器的硬盘：D:\lianxi1

实现步骤：

创建一个服务器ServerSocket对象，和系统要指定的端口号

使用ServerSocket对象中的方法accept,获取请求的客户端Socker对象

使用ServerSocket对象中的方法getIputStream，获取网络字节输入流InputStream对象

判断D:\lianxi1文件夹是否存在，不存在就创建

创建一个本地字节输出流FileOutputStream对象，构造方法中绑定要输出的目的地

使用网络字节输入流InputStream对象中的方法read读取客户端上传的文件

使用本地字节输出流FileOutputStream对象中的方法write，把读取到的文件保存到服务器硬盘上

使用Socket对象中的方法getOutputStream,获取到网络字节输出流OutputStream对象

使用网络字节输出流OutputStream对象中的方法write给客户端回写成功

释放资源

ServerSocket server = new ServerSocket(8888);
Socket socket = server.accept();
InputStream is = socket.getInputStream();
File file = new File("D:\\lianxi1");
if (!file.exists()){
    file.mkdir();
}
FileOutputStream fos = new FileOutputStream(file+"\\1.jpg");
int len = 0;
byte[] bytes = new byte[1024];
while ((len = is.read(bytes))!=-1){
    fos.write(bytes,0,len);
}
socket.getOutputStream().write("上传成功".getBytes());
fos.close();
socket.close();
server.close();

结束运行语句

socket.shutdownOutput();