通过 socket 发送和接收文件

《通过 socket 发送和接收文件》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、这是一个简单的包含发送端和接收端的例子。发送端向接收端发送文件名和文件内容，接收端将收到的文件保存在磁盘上。接收端可以同时接收多个发送端传来的文件，但没有处理文件同名的情况。这个例子中设计了一个简单的协议。发送的内容是这样的：文件名长度（4字节）—文件名—文件内容长度（4字节）—文件内容。接收端也按照这个结构进行解析。建议先看Client类，再看Server类。viewplaincopytoclipboardprint?importjava.io.*;importjava.net.ServerSocket;importjava.net.Socke

2、t;/***简单的文件发送与接收示例*/publicclassFileTrasmission{//程序入口publicstaticvoidmain(String[]args)throwsException{intport=7788;newServer(port,"c:\save\").start();newClient().sendFile("127.0.0.1",port,"c:\迷失在康熙末年.txt");}}/***接收端。可同时接收多个发送端发来的文件。但如果发来的文件是同名的话那就乱了。*/classServer{privatei

3、ntlistenPort;privateStringsavePath;/***构造方法**@paramlistenPort侦听端口*@paramsavePath接收的文件要保存的路径**@throwsIOException如果创建保存路径失败*/Server(intlistenPort,StringsavePath)throwsIOException{this.listenPort=listenPort;this.savePath=savePath;Filefile=newFile(savePath);if(!file.exists()&&!fi

4、le.mkdirs()){thrownewIOException("无法创建文件夹"+savePath);}}//开始侦听publicvoidstart(){newListenThread().start();}//网上抄来的，将字节转成int。b长度不得小于4，且只会取前4位。publicstaticintb2i(byte[]b){intvalue=0;for(inti=0;i<4;i++){intshift=(4-1-i)*8;value+=(b[i]&0x000000FF)<

5、ivateclassListenThreadextendsThread{@Overridepublicvoidrun(){try{ServerSocketserver=newServerSocket(listenPort);//开始循环while(true){Socketsocket=server.accept();newHandleThread(socket).start();}}catch(IOExceptione){e.printStackTrace();}}}/***读取流并保存文件的线程*/privateclassHandleThrea

6、dextendsThread{privateSocketsocket;privateHandleThread(Socketsocket){this.socket=socket;}@Overridepublicvoidrun(){try{InputStreamis=socket.getInputStream();readAndSave(is);}catch(IOExceptione){e.printStackTrace();}finally{try{socket.close();}catch(IOExceptione){//nothingtodo}

7、}}//从流中读取内容并保存privatevoidreadAndSave(InputStreamis)throwsIOException{Stringfilename=getFileName(is);intfile_len=readInteger(is);System.out.println("接收文件："+filename+"，长度："+file_len);readAndSave0(is,savePath+filename,file_len);System.out.println("文件保存成功（"+file_len+"字节）。");}priv

8、atevoidreadAndSave0(InputStreamis,Stringpath,intfile_len)throwsIOExc