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

 更新时间:2018年01月13日 11:12:20   作者:追风-  
这篇文章主要为大家详细介绍了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来测试JSON和Protocol Buffer的传输文件大小

    通过Java来测试JSON和Protocol Buffer的传输文件大小

    这篇文章主要介绍了通过Java来测试JSON和Protocol Buffer的传输文件大小,Protocol Buffer(文中简称Protobuffer)是谷歌开发的新的文件传输格式,需要的朋友可以参考下
    2015-12-12
  • SpringCloud实现Redis在各个微服务的Session共享问题

    SpringCloud实现Redis在各个微服务的Session共享问题

    Redis是运行在内存中,查取速度很快。本文重点给大家介绍SpringCloud实现Redis在各个微服务的Session共享,感兴趣的朋友一起看看吧
    2018-08-08
  • java获取指定开始时间与结束时间之间的所有日期

    java获取指定开始时间与结束时间之间的所有日期

    这篇文章主要为大家详细介绍了java获取指定开始时间与结束时间之间的所有日期,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-05-05
  • java 字段值为null,不返回该字段的问题

    java 字段值为null,不返回该字段的问题

    这篇文章主要介绍了java 字段值为null,不返回该字段的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • JVM内存区域划分相关原理详解

    JVM内存区域划分相关原理详解

    这篇文章主要介绍了JVM内存区域划分相关原理详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-10-10
  • springboot+rabbitmq实现智能家居实例详解

    springboot+rabbitmq实现智能家居实例详解

    这篇文章主要为大家介绍了springboot+rabbitmq实现智能家居的示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-07-07
  • mybatis批量插入返回主键失败的坑及解决

    mybatis批量插入返回主键失败的坑及解决

    这篇文章主要介绍了mybatis批量插入返回主键失败的坑及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-11-11
  • HashMap方法之Map.getOrDefault()解读及案例

    HashMap方法之Map.getOrDefault()解读及案例

    这篇文章主要介绍了HashMap方法之Map.getOrDefault()解读及案例,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-03-03
  • Java线程并发访问代码分析

    Java线程并发访问代码分析

    这篇文章主要介绍了Java线程并发访问代码分析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • Java实现入参数据批量数据校验详解

    Java实现入参数据批量数据校验详解

    在业务处理中一般入参是单条数据,这样数据校验比较容易,但是这种方法对于集合数据的校验不适用,下面我们就来看看如何对入参数据进行批量数据校验吧
    2024-02-02

最新评论