实验报告
课程名称
课程名称 《数据库技术》
学生姓名 ***
学 号 ********
专业班级 电子信息工程
指导教师
成 绩
201５年6月 8 日
实验名称: 基于UＤＰ的文件传输
1．实验目的熟练掌握Soｃｋｅt编程;
分析UDP与TCP的异同。
2．实验设备和条件
硬件环境:PC机
操作系统: Ｗindowｓ 或者 Linｕｘ
语言环境: Viｓｕaｌ C＋+ ，ＶS，GＣC，Java均可
3．实验要求
参考ＴCP文件传输deｍｏ, 基于UＤＰ实现sｅｎd.mp３文件的传输，并测试接收到的文件与发送的文件是否一致。
请各位同学于第１5周星期三或星期四上课时将纸质版（双面打印)上交！
4．实验内容：测试数据与实验结果（可以抓图粘贴）
（1)发送端代码。
#iｎclude "stdafｘ．h"
＃ｉncludｅ <Winsoｃk2.h>
#ｉnclude <ｓtdiｏ．h>
#define MＡＸ_LENＧTH 102４
int _tmaｉn（ｉnt aｒgc, _TＣHＡR＊ aｒgｖ[]）
｛
?ＷORD wVｅrsionRequesｔed;
WSＡDATA wｓaDatａ；
?wＶersiｏnReqｕesteｄ = MAＫＥＷORD(2, 2);
?iｆ (WSＡStartｕｐ(ｗＶerｓionＲeｑｕeｓｔed, &wsaDａta)！= 0)//初始化ws2_32.dll动态库
{
?printf("WＳＡＳtartｕp() ｆailed!＼n")；//Winsｏck初始化错误
eｘit(－1);
?}
?if (wsaDatａ.wVersioｎ ！= wVersiｏｎReｑｕested)
?{
pｒintf(＂Thｅ vｅｒsｉon of Wiｎsocｋ is nｏｔ suited!\ｎ");／/Winsｏck版本不匹配
?WSACleaｎｕｐ（);//结束对ｗｓ2_３2.dll的调用
?ｅｘit(-2)；
}
?/／说明ws2＿32.dｌl正确加载
printf（"Lｏad ws２＿３2.dll ｓuccｅｓsｆullｙ!\n"）;
//创建套接字
?SOCKEＴ servsocｋ；
?priｎtf（"Cｒeaｔｅ Socｋet...\n＂);
?seｒvsｏck = socket(AF＿ＩＮET, ＳＯCK_DＧＲＡM, 0）;//数据报套接字
ｉnt ｓeｒvport ＝ 5555;
?ｉｎｔ iSｏｃkErr = 0;
/／定义服务器地址结构
?soｃｋａddr_iｎ udpaｄｄｒ；
inｔ ｌen ＝ sizeof(udｐaddr)；
memset(&udpaddr, 0， sizeof(udpaddｒ)）;
?ｕdpaｄdr.sin_famｉｌy = AＦ_INET;
uｄｐaddｒ.sin_ｐort ＝ htｏns(servｐort);
?／/将一个点分十进制ＩＰ地址字符串转换成32位数字表示的ＩP地址
ｕｄｐａｄdr.sin_aｄdｒ.s_addr = inet_addr("１７２.１6.4．9４"）;/／//INADＤR_ANY
?//读取mp3文件
FILE *fp ＝ NUＬＬ;
?errno_ｔ ｅrr；
err = ｆopeｎ_ｓ（&fp, "七里香.mp３", "rb＂);
if （fｐ =＝ NUＬL){
ｐrｉntf("Opeｎ !\n＂);
getchar(）;
?exiｔ(-5）;
?}
ｃhaｒ buffｅr[MAX＿ＬENGTH］ = ＂\0";
char *ｂufpｔr = buffer;
?int i = 0;
ｗhile （!ｆeof(ｆp))
?{
?iｎt ｉBytesRead = fｒeaｄ(ｂufptr, 1， ＭAX＿LEＮＧTH, ｆp);
inｔ ｉＲeｔ ＝ sendｔo（servsoｃk， ｂuffer, sizeof(buffer）, 0, (sｔrucｔ soｃkａddr*)＆udpaｄｄｒ, ｌen)；
if (iReｔ != SＯＣKＥT_ERＲOR)
? {
? ?iRet = recvfrom(ｓervsｏck, buffer, sizeoｆ(bｕfｆer)， 0， (sｔｒuct sockaddｒ*)＆ｕdｐａdｄr, &lｅn);
}
eｌse
?{
priｎtf("send！\n")；
ｂreaｋ;
｝
iｆ (iRet =＝ SＯCKET_EＲＲＯR）
?{
? //cｌosesocket(cｌｉsock）;
? printf("ｓend !\n"）;
? ｂreaｋ;
}
eｌse if （iRet == ０）
? ｛
ｐrintf(＂seｎd mp3！＼ｎ");
breａk;
? }
ｉｆ (iBｙtesRead ＝= 0)
? {
? printｆ（＂ｓｅnd ｍp３ !＼n");
? ?breａk;
}
? ／/prｉntf(＂%d", &leｎ);
?prｉｎtｆ("ｓend packet %d lenth： ％d＼n", i＋+, iByｔesReaｄ);
? Ｓｌeep(１０);
}
senｄtｏ（servｓock, ＂", 0， 0， （struct sｏckadｄr＊)&udpaddｒ, len）;
//关闭
?sｈutｄoｗn(sｅｒｖｓock, 2);
ｃｌｏｓesoｃｋet(servsｏck);
?WSACｌeanup（）；
?getｃhar(）;
?reｔurn ０;
}
（2）接收端代码。
#inｃlude "stdaｆｘ.h＂
#ｉnclｕde <Wｉnｓock2．h>
#incluｄe ＜stdｉo.h>
＃defiｎe ＭAX_LENＧTH １024＊１0
iｎｔ _tmaｉn(int argc, ＿TCHAR* argv［])
{
?WOＲD ｗVersionReｑuested;
?WSADＡＴＡ wsaDａta;
?wVeｒsiｏnＲequested ＝ MAKEWORD(2， 2）;
ｉｆ （WＳＡStａrtｕp(ｗＶeｒsionＲｅquｅｓteｄ, &wｓaＤaｔa) != ０)/／初始化wｓ２_32.dll动态库
｛
? ｐrｉnｔf(＂WSAＳtartup(） failed！\n＂）;//Winsoｃk初始化错误
eｘit(－1);
}
if (wsａDatａ.wVeｒsion！＝ wVｅrsionＲｅqueｓtｅd)
{
?pｒiｎtf("Ｔhe ｖerｓion ｏｆ Winsocｋ iｓ not ｓuited!\n");//Wｉｎsock版本不匹配
? WSＡCleａnuｐ();／／结束对ws2＿32.dlｌ的调用
?exｉt（-2）；
?}
//说明ws2_3２．dll正确加载
?printf(＂Lｏad ws2_32.dlｌ succesｓｆｕｌlｙ！\n")；
/／获取本机ＩＰ地址
?cｈａr ＰCnaｍe[１0０] ＝ { "" };
char ＊IPaｄdress = ＮUＬＬ;
?gethoｓtnａme(PCname, ｓizeoｆ（PCnamｅ));
ｐriｎtｆ(＂Ｌocal Hｏstｎame iｓ %s.\n", PCnaｍｅ);
?sｔrucｔ hoｓｔｅnt FＡR * lｐＨostEｎt = gｅｔhｏｓtbynaｍe（ＰCname）；
?if (lpHostEｎt == NULL)
{
//产生错误
? priｎｔf("gｅthostbynａme fａiled!\n"）;
ｒeｔurｎ -1；
｝
?／/获取ＩＰ
?LPSTＲ lpAddr = lpＨoｓtEnt-＞h＿aｄdr＿list［０];
if (lｐAddr)
?{
sｔrucｔ in_addr ｉnＡｄdr;
mｅmｍovｅ(&inAddr, ｌpAddr, ４);
//转换为标准格式
IPａdｄｒeｓs = ｉｎet_ntoa(inＡddr）;／／将一个32位数字表示的IP地址转换成点分十进制ＩP地址字符串
?iｆ (ｓｉzeof（IPａｄdress) == 0）
? prinｔｆ（＂get ｈｏsｔ IP faｉlｅd!\ｎ＂)；
? elsｅ
?pｒintf("Loｃal ＨｏｓtＩP ｉs %s.\n", IＰaｄdress)；
｝
/／创建套接字
?//SＯＣKＥT sｅrvsock， clｉsｏck;
SOＣKET serｖsock;
?pｒintf（"Ｃrｅａｔe Sockeｔ.．．\n");
serｖsｏcｋ ＝ ｓocket(AF_INEＴ, ＳOＣK_DGRAM, 0);//数据报套接字
?ｉnｔ sｅｒｖｐｏｒｔ ＝ 55５５；
?ｉnt ｉSockErr = 0；
/／定义服务器地址结构
soｃkａdｄｒ＿in ｕdpａdｄr， cｌｉａｄdr;
ｍｅｍset(&udpaddr, 0, siｚeoｆ(udｐａddr));
mｅmsｅt(&ｃliaddr, 0, sizｅof(cliaｄｄｒ）)；
?int ｃｌileｎ = sizeof(cliaddr）;
ｕｄｐadｄr．sin_family = AＦ_INET;
udpadｄr.ｓiｎ_porｔ = htonｓ(sｅrvｐort）;
/／将一个点分十进制IP地址字符串转换成32位数字表示的ＩP地址
udpaddr.ｓiｎ＿ａdｄr.s_aｄdｒ = inｅｔ_aｄdr(IPａddｒｅｓs);//"1２7.0.0．1"/／ＩNADDR_ANY
?//绑定套接字到服务器地址结构
pｒiｎtf(＂Bｉndiｎg．．．\n＂);
ｉSoｃkＥrr = ｂind（serｖsｏck， (ｓockadｄr *)&uｄpａddｒ, sizeｏf(ｕdｐaｄdｒ))；
if (iSockEｒr =＝ SOCKＥT_ＥRROR)
?{
? priｎｔf("Bindｉng ｆａｉled:%ｄ＼n", ＷSＡＧeｔLastErｒor（))；／/根据不同的错误类型进行不同的处理
?eｘiｔ(-3);
}
／/函数调用成功,进行其他处理
cｈａr ｂuff[256] ＝ "\0";
ｃhaｒ buffer[MＡＸ＿LENGTH] = ＂\０"；
iｎt ｌeｎ = ０;
?//接收欢迎词
?memset(ｂuffeｒ, 0, sｉzeof(bｕffer));
?FＩＬE *fp = NULL;
?eｒｒnｏ_t ｅrｒ；
erｒ = fopｅｎ_s(&ｆｐ, "七里香．mp3＂, "wｂ");
iｎt i = 0;
ｗhile (1)
?{
ｌen = ｒecvfrom(servｓocｋ， buffer， sizeof(buffeｒ), 0, (ｓtruｃｔ ｓockaddｒ＊）&ｃｌiaddr, &cｌilｅn);
if (len == SOCKET_EＲＲOR） {
priｎtf(＂recv eｒｒoｒ！＼n");
break;
}
?else if (leｎ ＝＝ 0)
｛
printf(＂rｅcv fiｎisｈed!\n＂）;
? bｒeak；
}
buffer[ｌen] = 0;
prinｔf("rｅcｅｉved ｐacket ％d lenth： %ｄ\n\n", i++, lｅn)；
? ｆwritｅ(bufｆｅr, 1, lｅn, fp);
?sendto(ｓervsｏck, buff, ｓizeｏf(ｂｕff）, 0, (sｔruct socｋaｄdr*）＆clｉaddｒ， clｉlｅn);
? Sleep(８)；
? //prinｔf(＂%d\n"，&lｅｎ);
?}
fclose(fp）;
?/／ｓhutｄown（cｌisock, 2);
?//?clｏｓesockｅt(clｉsock);
shｕｔｄｏwn(ｓｅrvsoｃk, 2)；
?ｃlosｅsocket(sｅrｖsock);
?ＷSACleaｎuｐ();
?getcｈａr()；
retｕｒｎ 0;
｝
(3)简单的代码移植后接收端是否能正确接收？如果不能请分析原因,并尝试调整发送端读取数据的大小和延迟时间，以及接收端缓冲区的大小来解决数据丢包问题。给出参数调整的理由。
答： 简单的代码移植可能不能正确接受，因为会出现丢包现象。丢包现象在UDP中是很常见的现象。在UDP文件传输中,文件将从cｌiｅｎt 端发向seｒｖeｒ端。与TCP不同的是，UＤＰ不需要链接,可以直接传输，但是稳定性不好，容易丢包。调整cｌiｅnt端中Sleep(10)的大小来解决这个问题,使clｉent的延迟时间大于server的延迟时间,例如server的sleep(８)。