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

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

public class fileServer {
  public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = new ServerSocket(8888);//创建服务器端对象



    //while(true){//让服务器一直处于运行状态，保证客户端可以随时向服务器上传文件
      new Thread(new Runnable() {//为了提高文件上传效率，来一个客户端开一个线程
        @Override
        public void run() {
          try{
            Socket socket = serverSocket.accept();//使用accept方法接收客户端的数据
            InputStream is = socket.getInputStream();//创建网络字节输入流

            File file = new File("D:\\upload");//判断服务器硬盘中的文件夹是否存在，此文件夹用于存储客户端上传的内容
            if (!file.exists()){//判断服务器端的文件夹是否存在
              file.mkdirs();
            }

            String fileName = "\\picture"+System.currentTimeMillis()+new Random().nextInt(99999)+".jpg";//自己随机生成文件名，防止重复

            FileOutputStream fos = new FileOutputStream(file+fileName);//

            int len;
            byte[] bytes = new byte[1024];
            while((len = is.read(bytes))!= -1 ){//将客户端的数据写入服务器硬盘中
              fos.write(bytes,0,len);
            }

            OutputStream os = socket.getOutputStream();//向客户端回应
            os.write("上传成功".getBytes());

            socket.close();
            fos.close();
          }catch (IOException e){//在这里只能使用try catch解决异常，因为run方法不支持抛出异常
            System.out.println(e);
          }

        }
      }).start();
    //}

  }
}