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();    //}  }}