UDP协议实现二进制文件传输(java)

./1.UDP概念UDP是UserDatagramProtocol的简称,中文名是用户数据包协议,是OSI参考模型中一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务,IETFRFC768是UDP的正式规。2.文件传输流程2.1在此使用UDP协议传送文件的程序中,先在服务器端设定监听端口号〔3666,在接收客户端发来的请求之前一直处于阻塞状态；在客户端则从本地读取二进制文件并封装成数据报,并发送到相应的服务器端〔ip:127.0.0.1,端口：3666；当服务器端接收到客户端发来的请求后,则对数据进行处理,即读取并保存数据,然后返回操作后的信息到客户端；当客户端接收到服务器端的信息后,则输出服务器端返回的信息,到此时就完成了客户端的请求和服务器端的应答；最后关闭DatagramSocket。3.程序流程图Receive<>Receive<>接收到来自客户端的数据writeFile<>Socket<>readFile<>sendTo<>Receive<>sendTo<>客户端服务器端YN显示返回的信息Close<>Socket<>数据应答发送文件4.程序部分源码4.1服务器端源码publicclassServerextendsThread{ DatagramSocketds=null; DatagramPacketdp=null; Filefile=null;Overridepublicvoidrun<>{//TODOAuto-generatedmethodstubtry{//设置端口为3666ds=newDatagramSocket<3666>;while<true>{byte[]buf=newbyte[1024*64];//用于接收长度为1024的数据包dp=newDatagramPacket<buf,buf.length>;//从此套接字接收数据报包,此方法在接收到数据之前处于阻塞状态ds.receive<dp>;//保存接收文件,文件名取系统当前时间longtemp=System.currentTimeMillis<>;this.saveFile<dp,temp+"">;//为使反馈过程效果明显,线程休眠2秒后发送回复信息 Thread.sleep<2000>; Stringmessage="serverhasreceivedit."; DatagramPacketpacket=newDatagramPacket<message.getBytes<>, message.length<>,InetAddress.getLocalHost<>,6666>;//发送回复数据包ds.send<packet>; } }catch<Exceptione>{ e.printStackTrace<>; } }/** *保存接收到的文件 * *paramdp *paramfilePath保存文件所在的路径 *throwsIOException */privatevoidsaveFile<DatagramPacketdp,StringfilePath>throwsIOException{ FileOutputStreamfileOutputStream=newFileOutputStream<newFile< filePath>>; fileOutputStream.write<dp.getData<>,0,dp.getData<>.length>; fileOutputStream.close<>; }｝4.2客户端源码publicclassClient{privateDatagramSocketds=null;privateDatagramPacketdp=null;/** *传输文件 *paramfilePath文件所在路径 */publicvoidTransmitFile<StringfilePath>{try{//从本地读取文件byte[]data=this.readFile<filePath>;ds=newDatagramSocket<6666>;//封装数据报dp=newDatagramPacket<data,<int>data.length, InetAddress.getLocalHost<>,3666>;//开始传输文件ds.send<dp>;//接收从服务器回复的信息byte[]buf=newbyte[1024];dp=newDatagramPacket<buf,buf.length>;ds.receive<dp>;byte[]server=dp.getData<>; System.out.println<"客户端-->收到服务器返回的信息:\n"+newString<server,0,dp.getLength<>>.trim<>>; }catch<Exceptione>{ e.printStackTrace<>; }finally{ds.close<>; } }/** *读取文件 * *paramfilePath *文件路径 *return *throwsIOException */publicbyte[]readFile<StringfilePath>throwsIOException{ Filefile=newFile<filePath>;if<!file.exists<>>{returnnull; } InputStreaminputStream=newFileInputStream<file>; ByteArrayOutputStreamout=newByteArrayOutputStream<1024>;byte[]data=newbyte[1024];intlen=0;while<<len=inputStream.read<data>>!=-1>{ out.write<dat