分类

Java模拟客户端向服务器上传文件

JAVA学习网 2019-08-15 00:59:02

客户端与服务器Tcp通信的基本步骤：　

 

  1. 服务器端先启动，然后启动客户端向服务器端发送数据。
  2. 服务器端收到客户端发送的数据，服务器端会响应应客户端，向客户端发送响应结果。
  3. 客户端读取服务器发送的数据

客户端的代码实现

 1 public class fileClient {
 2     public static void main(String[] args) throws IOException {
 3         FileInputStream fis = new FileInputStream("D:\\1.jpg");//创建一个本地的输入流，用于指定上传数据的数据源
 4         Socket socket = new Socket("127.0.0.1",8888);//创建一个客户端对象，host是服务器名称或Ip地址
 5         OutputStream os = socket.getOutputStream();//使用socket中的方法，获取网络字节输出流对象
 6 
 7         byte[] bytes = new byte[1024];//把本地硬盘的数据通过网络字节输出流传递给客户端
 8         int len = 0;
 9         while ((len = fis.read(bytes))!=-1){
10             os.write(bytes,0,len);
11         }
12 
13         socket.shutdownOutput();//为了解决阻塞问题
14 
15         InputStream is = socket.getInputStream();//使用socket中的方法，获取网络字节输入流，用于读取客户端的数据
16         while((len = is.read(bytes))!=-1){//读取客户端的数据进行输出
17             System.out.println(new String(bytes,0,len));
18         }
19 
20         socket.close();//关闭流
21         fis.close();
22     }
23 }

 

服务器端代码实现

 1 public class fileServer {
 2     public static void main(String[] args) throws IOException {
 3         ServerSocket serverSocket = new ServerSocket(8888);//创建服务器端对象
 4 
 5 
 6 
 7         //while(true){//让服务器一直处于运行状态，保证客户端可以随时向服务器上传文件
 8             new Thread(new Runnable() {//为了提高文件上传效率，来一个客户端开一个线程
 9                 @Override
10                 public void run() {
11                     try{
12                         Socket socket = serverSocket.accept();//使用accept方法接收客户端的数据
13                         InputStream is = socket.getInputStream();//创建网络字节输入流
14 
15                         File file = new File("D:\\upload");//判断服务器硬盘中的文件夹是否存在，此文件夹用于存储客户端上传的内容
16                         if (!file.exists()){//判断服务器端的文件夹是否存在
17                             file.mkdirs();
18                         }
19 
20                         String fileName = "\\picture"+System.currentTimeMillis()+new Random().nextInt(99999)+".jpg";//自己随机生成文件名，防止重复
21 
22                         FileOutputStream fos = new FileOutputStream(file+fileName);//
23 
24                         int len;
25                         byte[] bytes = new byte[1024];
26                         while((len = is.read(bytes))!= -1 ){//将客户端的数据写入服务器硬盘中
27                             fos.write(bytes,0,len);
28                         }
29 
30                         OutputStream os = socket.getOutputStream();//向客户端回应
31                         os.write("上传成功".getBytes());
32 
33                         socket.close();
34                         fos.close();
35                     }catch (IOException e){//在这里只能使用try catch解决异常，因为run方法不支持抛出异常
36                         System.out.println(e);
37                     }
38 
39                 }
40             }).start();
41         //}
42 
43     }
44 }

 

阅读(3576) 评论(0)