Java实现文件上传服务器和客户端

本文实例为大家分享了Java实现文件上传服务器和客户端的具体代码，供大家参考，具体内容如下

文件上传服务器端：

/**
 * 使用TCP协议实现上传功能的服务器端
 * 思路：
 * 新建ServerSocket
 * 等待客户端连接
 * 连接上后开启子线程，把连接获取的Socket传给子线程
 * 循环进行
 * @author yajun
 *
 */
public class UploadServer { 

 public static void main(String[] args) {
  UploadServer server=new UploadServer();
  UploadThread command=new UploadThread();
  server.start(command);
 } 

 /**
  * 功能：接受连接，开启子线程，循环
  * @param command 用于下载的子线程对象，该对象实现了Runnable接口
  */
 private void start(UploadThread command){
  //局部变量
  ServerSocket serverSocket = null;
  Socket transSocket;
  //业务逻辑
  try {
   serverSocket=new ServerSocket(55555);
   while(true){
    System.out.println("等待连接……");
    transSocket=serverSocket.accept();
    int i=0;
    i++;
    System.out.println("第"+i+"个连接");
    //用不用在下载完后关闭线程呢？？？
    command.setSocket(transSocket);
    Executors.newFixedThreadPool(5).execute(command);
   }
  //异常捕获
  } catch (IOException e) {
   e.printStackTrace();
  //关闭资源
  } finally{
   try {
    serverSocket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }//End of try
 }//End of connect
 @Test
 public void testConnect() {
  //测试任务：先运行服务器端，然后多次运行客户端，服务器段可以不断创建子线程，则测试成功
  //测试准备：构造一个线程，用于模拟下载线程
  UploadThread command=new UploadThread();
  start(command); 

 } 

 @Test
 public void testDown() throws IOException {
  byte[] buf;
  ByteArrayInputStream bis;
  String str="canglaoshi.avi\ncontent,content,content";
  buf=str.getBytes();
  bis=new ByteArrayInputStream(buf);
  UploadThread ut=new UploadThread();
  ut.down(bis);
 }
}
//完成各个传输任务的子线程
class UploadThread implements Runnable{ 

 Socket socket;
 public UploadThread(){}
 public UploadThread(Socket socket){
  this.socket=socket;
 }
 @Override
 public void run() {
  InputStream in;
  try { 

   in = socket.getInputStream();
   down(in); 

  //异常处理
  } catch (IOException e) {
   e.printStackTrace();
  } finally{
   try {
    socket.close();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
  //测试代码
  /*try {
   Thread.sleep(5000);
   System.out.println(Thread.currentThread().getName()+",复制完毕");
  } catch (InterruptedException e) {
   e.printStackTrace();
  }*/
 }//End of run
 public void setSocket(Socket socket){
  this.socket=socket;
 }
 //下载方法
 /**
  * 目标：把InputStream中的数据写入到本地
  * 思路：
  * 1.获取输入流,最好传入输入流，而不是直接从Socket获取，传入有利用单元测试
  * 2.从输入流中读到文件名
  * 3.新建文件和文件输出流
  * 4.从输入流中读到文件内容到文件输出流
  * 5.
  * @throws IOException
  */
 public void down(InputStream in) throws IOException{
  //局部变量
  char ch;
  char[] nameArr=new char[256];
  byte[] buf=new byte[1024];
  String name="";
  OutputStream out = null;
  //业务逻辑
  try {
   //第一步：获取文件名，构造文件输出流
   int i=0;
   while((ch=(char) in.read())!='\n'){
    nameArr[i++]= ch;
   }
   //name=nameArr.toString();//这句话无法将字符数组转换为字符串，需用下面的语句
   name=new String(nameArr);
   System.out.println("要下载的文件为："+name);
   out=new FileOutputStream("src\\down\\"+name);
   //第二步：将输入流中的其他内容写入到文件
   int len;
   while((len=in.read(buf))!=-1){
    out.write(buf,0,len);
   }
   out.flush();
  //异常捕获
  } catch (IOException e) {
   e.printStackTrace();
  //关闭资源
  }finally{
   //疑问：两个捕获可不可以放到一块呢，怎样处理关闭流时的异常最好呢？
   in.close();
   out.close();
  }
  //调试
  System.out.println(name);
 } 

}//End of UploadThread 

文件上传客户端：

/**
 * 使用TCP协议实现上传功能的客户端
 * @author yajun
 */
public class UploadClient { 

 public static void main(String[] args) {
  UploadClient client=new UploadClient();
  client.upload("src\\thursday\\AsListTest.java");
 } 

 /**
  * 作用：上传文件到服务器
  * 1.建立到服务器的连接
  * 2.获取输出流
  * 3.将文件内容写入到输出流
  * 4.获取服务器的响应
  */
 private void upload(String name){
  Socket socket=null;
  OutputStream out;
  try {
   socket=new Socket("127.0.0.1", 55555);
   out=socket.getOutputStream();
   write2OutputStream(name, out);
  //异常捕获
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
 @Test
 public void testUpload() {
  upload("src\\status.xml");
 }
 /**
  * 作用：传入文件名和输出流，将文件写入到输出流
  * @param path
  * @throws IOException
  */
 private void write2OutputStream(String path,OutputStream out) throws IOException{ 

  FileInputStream fis = null;
  byte[] buf=new byte[1024];
  String fileName="";
  //业务逻辑
  try { 

   //1.写入文件名
   fileName=path.substring(path.lastIndexOf('\\')+1);
   System.out.println("您要上传的文件名为："+fileName);
   out.write(fileName.getBytes());
   out.write('\n');
   //2.写入文件内容
   fis=new FileInputStream(path);
   int len;
   while((len=fis.read(buf))!=-1){
    out.write(buf, 0, len);
   }
   out.flush();
  //异常处理
  } catch (IOException e) {
   e.printStackTrace();
  //关闭资源
  } finally{
   fis.close();
   out.close();
  }
 }//End of upload
 @Test
 public void testWrite2OutputStream() throws IOException {
  ByteArrayOutputStream out = null;
  try {
   out=new ByteArrayOutputStream();
   write2OutputStream("src\\status.xml", out);
   System.out.println(out.toString("utf-8"));
  } catch (IOException e) {
   e.printStackTrace();
  } finally{
   out.close();
  } 

 } 

}

本文已被整理到了《Java上传操作技巧汇总》，欢迎大家学习阅读。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

您可能感兴趣的文章:

• java实现多文件上传至本地服务器功能
• Java实现文件上传至服务器的方法
• Java实现跨服务器上传文件功能
• java文件上传至ftp服务器的方法
• java实现上传文件到服务器和客户端
• Java上传文件到服务器端的方法
• Java上传文件图片到服务器的方法
• 基于HTML5+js+Java实现单文件文件上传到服务器功能
• Java实现图片上传到服务器并把上传的图片读取出来
• java实现客户端向服务器发送文件