Socket编程实现文件上传.pdf

《Socket编程实现文件上传.pdf》由会员分享，可在线阅读，更多相关《Socket编程实现文件上传.pdf（6页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、 Socket 编程实现文件上传编程实现文件上传 1.情景描述 Server 端监听指定端口，接受 Client 端连接请求。Client 通过发送 connect 请求与 Server端建立 Socket 连接，然后向 Server 发送一个简单文件，Server 接受该文件后存储到指定目录。完成上传后 Server 端主动断开连接。2.Socket 文件上传的编程实现(1)服务器端的实现代码 package server;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io

2、.DataInputStream;import java.io.DataOutputStream;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import .BindException;import .ServerSocket;import .Socket;import java.text.SimpleDateFormat;import java.util.Date;/*author 苑仁群 *since 2012.6.5 */public class ServerUpload i

3、nt listenPort=11113;/监听端口号 public static void main(String arg)throws Exception ServerUpload server=new ServerUpload();server.acceptConnections();/处理客户端的socket请求 public void acceptConnections()throws Exception try ServerSocket server=new ServerSocket(listenPort);System.out.println(启动服务开始监听);while(tru

4、e)Socket socketConnection=server.accept();/允许连接 handleConnection(socketConnection);/处理客户端请求 catch(BindException e)System.out.println(无法侦听端口:+listenPort);catch(IOException e)System.out.println(无法在端口上创建实例:+listenPort);/对接收文件进行处理 private void handleConnection(Socket socketConnection)throws Exception St

5、ring fileName=null;String thisDateStr=null;try DataOutputStream sendMsg=new DataOutputStream(socketConnection .getOutputStream();String randomId=getResourceId();Date thisDate=new Date();SimpleDateFormat dayFormat=new SimpleDateFormat(MMDD);thisDateStr=dayFormat.format(thisDate);fileName=thisDateStr+

6、randomId;sendMsg.writeUTF(fileName);sendMsg.flush();catch(Exception e)System.out.println(发送消息错误+n);return;DataInputStream inputStream=null;try inputStream=new DataInputStream(new BufferedInputStream(socketConnection.getInputStream();catch(Exception e)e.printStackTrace();if(inputStream!=null)inputStr

7、eam.close();System.out.print(接收消息缓存错误n);throw e;try String savePath=C:uploadFile;int bufferSize=8192;byte buf=new bytebufferSize;int passedlen=0;long len=0;String passFileName=inputStream.readUTF();int lastIndex=passFileName.lastIndexOf(.);String exName=passFileName.substring(lastIndex,passFileName

8、.length();File thePath=new File(savePath+thisDateStr);if(!thePath.exists()thePath.mkdir();savePath+=thisDateStr+fileName+exName;DataOutputStream fileOut=new DataOutputStream(new BufferedOutputStream(new BufferedOutputStream(new FileOutputStream(savePath);len=inputStream.readLong();System.out.println

9、(接收文件的长度为:+len+n);System.out.println(开始接收文件!+n);while(true)int read=0;if(inputStream!=null)read=inputStream.read(buf);passedlen+=read;if(read=-1)break;System.out.println(文件接收了+(passedlen*100/len)+%n);fileOut.write(buf,0,read);System.out.println(接收完成，文件保存在：+savePath+n);fileOut.close();catch(Exception

10、 e)System.out.println(接收消息错误!+n);return;/随机产生文件名字的方法，用来对接收的文件进行重命名 private String getResourceId()StringBuffer sb=new StringBuffer();for(int i=0;i 5;i+)int j=(int)(Math.random()*26);char c=(char)(a+j);sb.append(c);return sb.toString();(2)客户端的实现代码 package client;import java.io.BufferedInputStream;impo

11、rt java.io.DataInputStream;import java.io.DataOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import .Socket;import .UnknownHostException;/*author 苑仁群 *since 2012.6.5 */public class ClientUpload private String ip=127.0.0.1;/服务器的IP地址 private int port=11113;p

12、rivate String sendMessage=C:testFile.txt;Socket socketConnection=null;DataOutputStream sendMsg=null;DataInputStream getMsg=null;public static void main(String arg)throws Exception ClientUpload clientTest=new ClientUpload();clientTest.setUpConnection();clientTest.getMessage();clientTest.sendMessage()

13、;public void setUpConnection()try socketConnection=new Socket(ip,port);sendMsg=new DataOutputStream(socketConnection.getOutputStream();getMsg=new DataInputStream(new BufferedInputStream(socketConnection.getInputStream();catch(UnknownHostException e)System.out.println(连接错误:未知主机 +sendMessage+:+port);c

14、atch(IOException e)System.out.println(连接时出错:+e);private void sendMessage()throws Exception try File fi=new File(sendMessage);System.out.println(文件长度:+(int)fi.length();DataInputStream fis=new DataInputStream(new BufferedInputStream(new FileInputStream(sendMessage);sendMsg.writeUTF(fi.getName();sendMs

15、g.flush();sendMsg.writeLong(long)fi.length();sendMsg.flush();int bufferSize=8192;byte buf=new bytebufferSize;while(true)int read=0;if(fis!=null)read=fis.read(buf);if(read=-1)break;sendMsg.write(buf,0,read);sendMsg.flush();fis.close();socketConnection.close();System.out.println(文件传输完成!);catch(Excepti

16、on e)e.printStackTrace();if(sendMsg!=null)sendMsg.close();throw e;finally private void getMessage()throws Exception try getMsg=new DataInputStream(new BufferedInputStream(socketConnection.getInputStream();catch(Exception e)e.printStackTrace();if(getMsg!=null)getMsg.close();System.out.print(接收消息缓存错误!n);throw e;3.运行截图 在本程序中，客户端默认上传的文件为：C:testFile.txt。上传到的目录默认为：C:uploadFile。服务器端将接收到的文件保存在由程序产生的子文件目录中，并把接收到的文件进行重命名，例如本次运行后，文件被保存在：C:uploadFile0615706157hzqqk.txt。运行的截图如下：