Java实现文件上传服务器和客户端 Java实现文件上传服务器和客户端
追风- 人气:0想了解Java实现文件上传服务器和客户端的相关内容吗,追风-在本文为您仔细讲解Java实现文件上传服务器和客户端的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Java文件上传服务器,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上传操作技巧汇总》,欢迎大家学习阅读。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
加载全部内容