java模拟客户端向服务器上传文件
本文实例为大家分享了java客户端向服务器上传文件的具体代码，供大家参考，具体内容如下
先来了解一下客户端与服务器Tcp通信的基本步骤：
- 服务器端先启动，然后启动客户端向服务器端发送数据。
- 服务器端收到客户端发送的数据，服务器端会响应应客户端，向客户端发送响应结果。
- 客户端读取服务器发送的数据
文件上传步骤：
客户端使用本地字节输入流，指定上传数据的数据源。
客户端使用网络字节输出流，把读取的本地文件上传到服务器。
服务器使用网络字节输入流，读取客户端上传的文件。
服务器使用本地字节输出流，把读取到的文件保存到服务器硬盘上。
服务器使用网络字节输出流，给客户端响应一个“上传成功”。
客户端使用网络字节输入流，读取服务器响应的数据。
客户端的代码实现
publicclassfileClient{
publicstaticvoidmain(String[]args)throwsIOException{
FileInputStreamfis=newFileInputStream("D:\\1.jpg");//创建一个本地的输入流，用于指定上传数据的数据源
Socketsocket=newSocket("127.0.0.1",8888);//创建一个客户端对象，host是服务器名称或Ip地址
OutputStreamos=socket.getOutputStream();//使用socket中的方法，获取网络字节输出流对象
byte[]bytes=newbyte[1024];//把本地硬盘的数据通过网络字节输出流传递给客户端
intlen=0;
while((len=fis.read(bytes))!=-1){
os.write(bytes,0,len);
}
socket.shutdownOutput();//为了解决阻塞问题
InputStreamis=socket.getInputStream();//使用socket中的方法，获取网络字节输入流，用于读取客户端的数据
while((len=is.read(bytes))!=-1){//读取客户端的数据进行输出
System.out.println(newString(bytes,0,len));
}
socket.close();//关闭流
fis.close();
}
}
服务器端代码实现
publicclassfileServer{
publicstaticvoidmain(String[]args)throwsIOException{
ServerSocketserverSocket=newServerSocket(8888);//创建服务器端对象
//while(true){//让服务器一直处于运行状态，保证客户端可以随时向服务器上传文件
newThread(newRunnable(){//为了提高文件上传效率，来一个客户端开一个线程
@Override
publicvoidrun(){
try{
Socketsocket=serverSocket.accept();//使用accept方法接收客户端的数据
InputStreamis=socket.getInputStream();//创建网络字节输入流
Filefile=newFile("D:\\upload");//判断服务器硬盘中的文件夹是否存在，此文件夹用于存储客户端上传的内容
if(!file.exists()){//判断服务器端的文件夹是否存在
file.mkdirs();
}
StringfileName="\\picture"+System.currentTimeMillis()+newRandom().nextInt(99999)+".jpg";//自己随机生成文件名，防止重复
FileOutputStreamfos=newFileOutputStream(file+fileName);//
intlen;
byte[]bytes=newbyte[1024];
while((len=is.read(bytes))!=-1){//将客户端的数据写入服务器硬盘中
fos.write(bytes,0,len);
}
OutputStreamos=socket.getOutputStream();//向客户端回应
os.write("上传成功".getBytes());
socket.close();
fos.close();
}catch(IOExceptione){//在这里只能使用trycatch解决异常，因为run方法不支持抛出异常
System.out.println(e);
}
}
}).start();
//}
}
}
注：在开启多线程的时候，因为run方法的父类并不支持throws解决异常，所以run也不支持，只能使用try…catch解决异常
解释一下为什么在上传数据的时候客户端和服务器会出现阻塞问题以及解决阻塞的方法
为什么会出现阻塞？
出现阻塞的根本问题是，客户端从本地硬盘读取文件给服务器的时候，因为用的是while循环，所以文件的结束符-1并没有被读取到服务器，这时上传到服务器的文件就没有结束符，服务器把读取到的文件保存到服务器硬盘上时就会一直执行while循环，导致阻塞。另外还有一个阻塞时服务器向客户端响应文件时候的阻塞。
解决阻塞问题的方法？
阻塞问题的根本原因就是因为在读取的时候没有结束符，用socket.shutdownOutput()给上传的文件一个中止序列。
API对shutdownOutput()的解释：对于TCP套接字，任何以前写入的数据都将被发送，并且后跟TCP的正常连接终止序列。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。