2023年分布式实验报告

华南理工大学《分布式计算技术》课程实验报告实验题目:_＿_Sｏｃｋet程序设计___＿_______＿姓名：__＿_______＿_＿学号：_＿__＿＿__＿_______班级:_____＿__＿＿____组别:_＿______合作者：__＿____＿＿____指导教师:__＿_＿_＿_＿＿实验概述【实验目的及规定】

１.在Uｉnx／Linux/Wiｎdoｗs环境下通过socket方式实现一个基于Ｃlienｔ／Server或是P2P模式的文献传输程序。

【实验原理】

1.拟定传输模式:通过sｏcket方式实现一个基于Cliｅnt/Ｓｅrver模式的文献传输程序。

2．客户端:用面向连接的方式实现通信。采用Socket类对象,接受服务器发送的文献并保存在特定的位置。3.服务器端：监听客户请求，读取磁盘文献并向客户端发送文献。【实验环境】

Wｉｎdoｗs环境，jdk１．６

实验过程（设计过程与程序演示）【实验方案设计】

服务端ｉmportjava.io.DａｔaInpｕｔSｔrｅam;imｐortｊava.io.File;ｉｍpｏrtjava．io．FｉleOutputＳtream;ｉmpoｒtｊava．ｎeｔ.SeｒvｅrＳocket;ｉmporｔjava.ｎet.Socket;/*＊*服务器*/ｐuｂlicｃｌａssHeｌloServｅrｅxteｎｄsＳerｖeｒＳｏcket{pｒivatestａticfｉnalintＰOＲＴ=2023;pｒivatｅＳerverSockｅtsｅrvｅr；privateSockeｔclｉent;pｒivateＤatａIｎｐuｔStreamdis;pｒivaｔeFileＯutputStｒeamfos;ｐｒiｖaｔeints=0；pubｌicＨeｌｌoＳerver()tｈｒowｓExceｐtｉon{trｙ{try{serveｒ=nｅwSｅrverSockeｔ(ＰＯRＴ）;whilｅ(true){ﻩＳｙstem.out.println("----正在等待客户请求连接－---")；clｉｅnt＝server．ａcｃept(）；Sｙstｅm．out.ｐrｉntｌn("-－－-连接成功---－"）;dis=newDataＩnｐｕtStｒeａm(client.geｔIｎpuｔStｒｅam())；/／文献名和长度SｔｒingfｉｌeNaｍe=dis．readUTＦ（）;ｌongｆｉleLeｎgｔｈ=dis.readLong（）;fos=neｗFｉｌｅOutputＳtrｅam（ｎｅwFｉｌe("Ｅ:/"+fｉleName)）；bｙte[]sendByｔeｓ=nｅwbyte[1024];inｔtransLen=0;Sysｔem．out.println("--－-开始接受文献<"+fileNamｅ+">,文献大小为<＂+ｆileLength＋＂＞－-－-");whiｌe(true){intreａd=0;ｒeａd＝dis.reaｄ(sendBytｅs);iｆ(reａｄ==-1)brｅak;tｒansＬen+=read;if(s=＝０)ﻩＳysｔem.ｏut.pｒinｔln("接受文献进度"+10０*transＬen/fｉleLength+"%...");ｓ=(s+1）%100；ｆos.wｒite(sendBytes,0,read);ｆｏs.flush();｝Systｅm．ｏｕｔ．ｐｒintln("----接受文献<"+fiｌeName+"＞成功-－--－-－");client.ｃlose（）;}}caｔch(Excｅｐtioｎe)｛ｅ.pｒｉntＳｔackＴraｃｅ();｝fｉnallｙ{if(dis!=null)dis.close();iｆ（fos！=nuｌl)fos.close();sｅrvｅr.clｏｓe（);}}catch（Ｅxｃｅptiｏne)｛ｅ.printＳtａｃkTraｃe()；}}publicｓｔaticｖoidｍａiｎ(String［]args)throwｓExｃeption{nｅwＨｅlｌoＳerｖer();}}客户端importjava.io．BｕffｅreｄReａｄｅr;impｏrtjaｖa．io.DataＯutputＳtｒeam;imｐoｒtjaｖa.io.File;imｐortｊavａ.iｏ．FiｌeInpｕtStｒｅaｍ;ｉｍpｏrｔｊava.io.ＩnｐutＳｔｒeａmReａdeｒ;ｉmｐoｒtjava.ｎｅt．Socｋet;/***客户端*／publｉccｌasｓHｅllｏＣlienｔｅｘtenｄsSockｅt｛prｉvateｓtaticfinａlStｒｉngＳERVEＲ＿ＩP="127.0．0.1";prｉvatｅstａticfinalｉｎtSERVＥＲ_ＰORＴ=2０23；ｐrｉvaｔeＳoｃketclient;privateＦｉlｅInputStｒeamfis;prｉvateDataOutpｕtＳtreamdos；ｐuｂliｃHeｌｌoClｉenｔ(){trｙ{ｔry{ｃlient＝newＳoｃkeｔ(ＳERＶER_IP,SERVＥＲ_PORＴ)；／/向服务端传送文献BufferｅdＲeａdｅrstｒｉn=newＢｕｆferedReadeｒ(neｗInｐutSｔrｅａmReader(Ｓyｓｔeｍ．iｎ））;Ｓystem.ouｔ．pｒintln("-－--连接成功-－--"）;Ｓystem.ｏut.println("－---请输入需要传输的文献途径名-－-－");ＳtrｉngfiｌeName=ｓtriｎ.readLinｅ();Fiｌefile=newFilｅ(filｅName)；fiｓ=neｗFiｌｅＩnｐuｔStｒeam(ｆiｌe)；dos=neｗDataOutｐｕtStrｅam(client.ｇｅｔOutputStream()）;／/文献名和长度ｄos．wｒiteUTF(ｆile.getName());ｄos．fｌuｓｈ(）;dｏｓ．ｗrｉteLｏng(file．lengtｈ()）;ｄｏs.fluｓh（)；/／传输文献ｂyte[］ｓeｎdＢyteｓ=newbｙte[1024];ｉｎtlengｔh=0;whｉlｅ((length=ｆis.read（sｅndBytes,０,ｓeｎdBytｅs.lengｔh))>0)｛dｏs．ｗrｉtｅ(sendBytes,0,length）;dos.fluｓｈ();}}ｃatch(Eｘceptione){e.printStaｃkTrａcｅ(）；｝ｆiｎalｌｙ{if(fiｓ!＝null)ｆis.ｃlose();if（doｓ!=nulｌ）doｓ.cｌose();client．closｅ();}}catｃｈ(Exｃeptioｎｅ){e．ｐrintStaｃkTrａce（);｝}ｐubliｃstａtｉcvoidｍaｉn(Sｔring[]argｓ)throwsExceptｉon{ｎewHellｏClｉｅnt（);｝}【实验过程】（实验环节、记录、数据、分析）１.服务器先启动，等待客户端连接2．客户端启动，连接到服务器3.客户端输入文献途径,回车,开始传输文献4.服务器接受文献。５.服务端接