Ⅰ 用c语言实现基于UDP协议的文件传输系统，其中服务端接受和发送文件需要用到哪些函数
可以参考TFTP源代码，TFTP就是基于UDP的，记得是使用socket的。
Ⅱ 有没有windows下c语言实现udp协议的代码
Windows下C语言的Socket编程例子（TCP和UDP）
一。<TCP>
server端：
复制代码
1#include"stdafx.h"
2#include<stdio.h>
3#include<winsock2.h>
4
5#pragmacomment(lib,"ws2_32.lib")
6
7intmain(intargc,char*argv[])
8{
9//初始化WSA
10WORDsockVersion=MAKEWORD(2,2);
11WSADATAwsaData;
12if(WSAStartup(sockVersion,&wsaData)!=0)
13{
14return0;
15}
16
17//创建套接字
18SOCKETslisten=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
19if(slisten==INVALID_SOCKET)
20{
21printf("socketerror!");
22return0;
23}
24
25//绑定IP和端口
26sockaddr_insin;
27sin.sin_family=AF_INET;
28sin.sin_port=htons(8888);
29sin.sin_addr.S_un.S_addr=INADDR_ANY;
30if(bind(slisten,(LPSOCKADDR)&sin,sizeof(sin))==SOCKET_ERROR)
31{
32printf("binderror!");
33}
34
35//开始监听
36if(listen(slisten,5)==SOCKET_ERROR)
37{
38printf("listenerror!");
39return0;
40}
41
42//循环接收数据
43SOCKETsClient;
44sockaddr_inremoteAddr;
45intnAddrlen=sizeof(remoteAddr);
46charrevData[255];
47while(true)
48{
49printf("等待连接... ");
50sClient=accept(slisten,(SOCKADDR*)&remoteAddr,&nAddrlen);
51if(sClient==INVALID_SOCKET)
52{
53printf("accepterror!");
54continue;
55}
56printf("接受到一个连接：%s ",inet_ntoa(remoteAddr.sin_addr));
57
58//接收数据
59intret=recv(sClient,revData,255,0);
60if(ret>0)
61{
62revData[ret]=0x00;
63printf(revData);
64}
65
66//发送数据
67char*sendData="你好，TCP客户端！ ";
68send(sClient,sendData,strlen(sendData),0);
69closesocket(sClient);
70}
71
72closesocket(slisten);
73WSACleanup();
74return0;
75}
复制代码
client端：
复制代码
1#include"stdafx.h"
2#include<WINSOCK2.H>
3#include<STDIO.H>
4
5#pragmacomment(lib,"ws2_32.lib")
6
7
8intmain(intargc,char*argv[])
9{
10WORDsockVersion=MAKEWORD(2,2);
11WSADATAdata;
12if(WSAStartup(sockVersion,&data)!=0)
13{
14return0;
15}
16
17SOCKETsclient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
18if(sclient==INVALID_SOCKET)
19{
20printf("invalidsocket!");
21return0;
22}
23
24sockaddr_inserAddr;
25serAddr.sin_family=AF_INET;
26serAddr.sin_port=htons(8888);
27serAddr.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");
28if(connect(sclient,(sockaddr*)&serAddr,sizeof(serAddr))==SOCKET_ERROR)
29{
30printf("connecterror!");
31closesocket(sclient);
32return0;
33}
34char*sendData="你好，TCP服务端，我是客户端! ";
35send(sclient,sendData,strlen(sendData),0);
36
37charrecData[255];
38intret=recv(sclient,recData,255,0);
39if(ret>0)
40{
41recData[ret]=0x00;
42printf(recData);
43}
44closesocket(sclient);
45WSACleanup();
46return0;
47}
复制代码
二.<UDP>
SERVER端
复制代码
1#include"stdafx.h"
2#include<stdio.h>
3#include<winsock2.h>
4
5#pragmacomment(lib,"ws2_32.lib")
6
7intmain(intargc,char*argv[])
8{
9WSADATAwsaData;
10WORDsockVersion=MAKEWORD(2,2);
11if(WSAStartup(sockVersion,&wsaData)!=0)
12{
13return0;
14}
15
16SOCKETserSocket=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
17if(serSocket==INVALID_SOCKET)
18{
19printf("socketerror!");
20return0;
21}
22
23sockaddr_inserAddr;
24serAddr.sin_family=AF_INET;
25serAddr.sin_port=htons(8888);
26serAddr.sin_addr.S_un.S_addr=INADDR_ANY;
27if(bind(serSocket,(sockaddr*)&serAddr,sizeof(serAddr))==SOCKET_ERROR)
28{
29printf("binderror!");
30closesocket(serSocket);
31return0;
32}
33
34sockaddr_inremoteAddr;
35intnAddrLen=sizeof(remoteAddr);
36while(true)
37{
38charrecvData[255];
39intret=recvfrom(serSocket,recvData,255,0,(sockaddr*)&remoteAddr,&nAddrLen);
40if(ret>0)
41{
42recvData[ret]=0x00;
43printf("接受到一个连接：%s ",inet_ntoa(remoteAddr.sin_addr));
44printf(recvData);
45}
46
47char*sendData="一个来自服务端的UDP数据包 ";
48sendto(serSocket,sendData,strlen(sendData),0,(sockaddr*)&remoteAddr,nAddrLen);
49
50}
51closesocket(serSocket);
52WSACleanup();
53return0;
54}
复制代码
CLIENT端
复制代码
1#include"stdafx.h"
2#include<stdio.h>
3#include<winsock2.h>
4
5#pragmacomment(lib,"ws2_32.lib")
6
7intmain(intargc,char*argv[])
8{
9WORDsocketVersion=MAKEWORD(2,2);
10WSADATAwsaData;
11if(WSAStartup(socketVersion,&wsaData)!=0)
12{
13return0;
14}
15SOCKETsclient=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
16
17sockaddr_insin;
18sin.sin_family=AF_INET;
19sin.sin_port=htons(8888);
20sin.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");
21intlen=sizeof(sin);
22
23char*sendData="来自客户端的数据包. ";
24sendto(sclient,sendData,strlen(sendData),0,(sockaddr*)&sin,len);
25
26charrecvData[255];
27intret=recvfrom(sclient,recvData,255,0,(sockaddr*)&sin,&len);
28if(ret>0)
29{
30recvData[ret]=0x00;
31printf(recvData);
32}
33
34closesocket(sclient);
35WSACleanup();
36return0;
37}
Ⅲ 请教用C语言编的借助UDP协议实现的文件传输的程序
本程序在 Windows 7 Visual Studio 2015 和 Linux Ubuntu 15.04 GCC 5.11 下均编译运行测试通过。
本程序支持 Windows 和 Linux 之间传送文件，如果要在 Windows 和 Linux 之间传送文件，文件名不能出现中文。
本程序支持无线 WiFi，支持 USB 收发器，但仅支持局域网内传送文件，传送文件需要输入对方的 IP 地址。
本程序包括服务器端和客户端，既可以发送文件又可以接收文件。如果要在同一台机器上测试需要同时打开两个程序。
Windows 下查看本机 IP 地址的命令是：
ipconfig
Linux 下查看本机 IP 地址的命令是：
ifconfig
以下是程序代码：
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<math.h>
#ifdef_MSC_VER
#include<winsock2.h>
#include<windows.h>
#pragmacomment(lib,"ws2_32.lib")
#else
#include<pthread.h>
#include<unistd.h>
#include<signal.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#endif
//存放发送接收字符数组大小
#defineSIZEA65501
//每次发送接收字节数
#defineSIZEB65500
typedefstructsockaddr_inSockAddrIn;
SockAddrInserverAddr,remoteAddr,clientAddr;
//端口号
intiServerPort,iClientPort;
//新建socket信息
intiUDP;
//字符串转整型
intstrToInt(char*acStr)
{
inti,iIndex=0,iNum=0,iSize=0;
if(acStr[0]=='+'||acStr[0]=='-')
iIndex=1;
for(iSize=iIndex;;iSize++)
if(acStr[iSize]<'0'||acStr[iSize]>'9')
break;
for(i=iIndex;i<iSize;i++)
iNum+=(int)pow(10,iSize-i-1)*(acStr[i]-48);
if(acStr[0]=='-')
iNum=-iNum;
returniNum;
}
//整型转字符串
voidintToStr(intiInt,char*acStr)
{
intiIndex=0,iSize,iNum,iBit,i,j;
if(iInt<0)
{
acStr[0]='-';
iInt=-iInt;
iIndex=1;
}
for(i=0;;i++)
if(iInt<pow(10,i))
break;
iSize=i;
for(i=0;i<iSize;i++)
{
iNum=pow(10,iSize-i-1);
iBit=iInt/iNum;
iInt-=iNum*iBit;
acStr[i+iIndex]=iBit+48;
}
if(iSize!=0)
acStr[iSize+iIndex]=' ';
else
{
acStr[0]='0';
acStr[1]=' ';
}
}
voidsleepUDP(intiSleep)
{
#ifdef_MSC_VER
Sleep(iSleep);
#else
usleep(iSleep*1000);
#endif
}
voidopenUDP(char*acIpAddr)
{
#ifdef_MSC_VER
//Winsows启用socket
WSADATAwsadata;
if(WSAStartup(MAKEWORD(1,1),&wsadata)==SOCKET_ERROR)
{
printf("启用socket失败 ");
exit(0);
}
#endif
//新建socket
if((iUDP=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP))==-1)
{
printf("新建socket失败 ");
exit(0);
}
//清零
memset(&serverAddr,0,sizeof(serverAddr));
memset(&clientAddr,0,sizeof(clientAddr));
//设置协议IP地址及Port
serverAddr.sin_family=AF_INET;
serverAddr.sin_port=htons(iServerPort);
serverAddr.sin_addr.s_addr=htonl(INADDR_ANY);
clientAddr.sin_family=AF_INET;
clientAddr.sin_port=htons(iClientPort);
clientAddr.sin_addr.s_addr=inet_addr(acIpAddr);
//绑定端口，监听端口
if(bind(iUDP,(structsockaddr*)&serverAddr,sizeof(serverAddr))==-1)
{
printf("绑定端口失败 ");
exit(0);
}
}
voidcloseUDP(void)
{
#ifdef_MSC_VER
//Winsows关闭socket
closesocket(iUDP);
WSACleanup();
#endif
}
//要发送的字符串
characSendStr[SIZEA];
//接收到的字符串
characRecvStr[SIZEA];
//请求信息
characReq[SIZEA];
//文件名字符串
characFileName[SIZEA];
//文件字节数字符串
characFileSize[SIZEA];
intiSize,iNameSize;
//接收文件名
#ifdef_MSC_VER
DWORDWINAPIrecvName(LPVOIDp)
#else
void*recvName(void*arg)
#endif
{
intiAddrSize=sizeof(remoteAddr);
acReq[0]='n';acReq[1]='a';acReq[2]='m';acReq[3]='e';acReq[4]=' ';
acRecvStr[0]=' ';
printf("%s ","正在发送请求信息！");
//发送请求信息
sendto(iUDP,acReq,strlen(acReq),0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
//每次发送请求信息后等待一段时间
sleepUDP(10);
//接收文件名
iSize=recvfrom(iUDP,acRecvStr,SIZEB,0,(structsockaddr*)&remoteAddr,&iAddrSize);
return0;
}
//接收文件
voidrecvFile(char*acDirName,char*acIpAddr)
{
FILE*pFile=NULL;
inti,iFileSize,iRecvNum,iAddrSize=sizeof(remoteAddr);
//路径文件名
characDirAndFileName[SIZEA];
openUDP(acIpAddr);
//接收文件名
for(;;)
{
//创建线程
#ifdef_MSC_VER
HANDLEhThread;
DWORDthreadId;
hThread=CreateThread(NULL,0,recvName,0,0,&threadId);
//每次发送后等待一段时间
sleepUDP(1000);
//强制终止线程
TerminateThread(hThread,0);
#else
pthread_tthread;
void*thread_arg=(pthread_t)0;
pthread_create(&thread,NULL,recvName,(void*)&thread_arg);
//每次发送后等待一段时间
sleepUDP(1000);
//强制终止线程
pthread_cancel(thread);
#endif
if(acRecvStr[0]!=' ')
{
acRecvStr[iSize]=' ';
printf("文件名为：%s ",acRecvStr);
break;
}
}
acDirAndFileName[0]=' ';
strcat(acDirAndFileName,acDirName);
//连接路径名和文件名
strcat(acDirAndFileName,acRecvStr);
//如果已经有这个文件了就清空文件内容
pFile=fopen(acDirAndFileName,"w");
fclose(pFile);
acReq[0]='s';acReq[1]='i';acReq[2]='z';acReq[3]='e';acReq[4]=' ';
//接收文件字节数
for(;;)
{
//发送请求信息
sendto(iUDP,acReq,strlen(acReq)+1,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
//每次发送请求信息后等待一段时间
sleepUDP(10);
//接收文件字节数
acRecvStr[0]=' ';
iSize=recvfrom(iUDP,acRecvStr,SIZEB,0,(structsockaddr*)&remoteAddr,&iAddrSize);
if(acRecvStr[0]!=' ')
{
acRecvStr[iSize]=' ';
iFileSize=strToInt(acRecvStr);
printf("文件字节数为：%d ",iFileSize);
break;
}
}
//以追加方式写入文件
pFile=fopen(acDirAndFileName,"ab");
//文件分几次接收
iRecvNum=iFileSize/SIZEB;
//接收文件
for(i=0;i<iRecvNum;i++)
{
intToStr(i,acReq);
for(;;)
{
//发送请求信息
sendto(iUDP,acReq,strlen(acReq)+1,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
printf("%s 正在接收文件的第%d段 ",acReq,i);
//每次发送请求信息后等待一段时间
sleepUDP(10);
//接收一段文件
iSize=recvfrom(iUDP,acRecvStr,SIZEB,0,(structsockaddr*)&remoteAddr,&iAddrSize);
if(iSize==SIZEB)
{
//以追加方式写入文件
fwrite(acRecvStr,sizeof(char),iSize,pFile);
break;
}
}
}
//接收文件剩余字节
iSize=iFileSize%SIZEB;
if(iSize>0)
{
acReq[0]='l';acReq[1]='a';acReq[2]='s';acReq[3]='t';acReq[4]=' ';
for(;;)
{
//发送请求信息
sendto(iUDP,acReq,strlen(acReq)+1,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
//每次发送请求信息后等待一段时间
sleepUDP(10);
//接收文件剩余字节
if(recvfrom(iUDP,acRecvStr,iSize,0,(structsockaddr*)&remoteAddr,&iAddrSize)==iSize)
{
//以追加方式写入文件
fwrite(acRecvStr,sizeof(char),iSize,pFile);
break;
}
}
}
printf("%s ","文件接收完毕！");
//关闭文件
fclose(pFile);
//关闭连接
closeUDP();
}
//发送文件名
#ifdef_MSC_VER
DWORDWINAPIsendName(LPVOIDp)
#else
void*sendName(void*arg)
#endif
{
intiAddrSize=sizeof(remoteAddr);
acRecvStr[0]=' ';
//接收请求
printf("%s ","正在接收请求信息！");
recvfrom(iUDP,acRecvStr,5,0,(structsockaddr*)&remoteAddr,&iAddrSize);
//每次接收请求信息后等待一段时间
sleepUDP(10);
//如果请求信息正确发送文件名
if(acRecvStr[0]=='n'&&acRecvStr[1]=='a'&&acRecvStr[2]=='m'&&acRecvStr[3]=='e'&&acRecvStr[4]==' ')
sendto(iUDP,acFileName,iNameSize,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
return0;
}
//发送文件
voidsendFile(char*acDirAndFileName,char*acIpAddr)
{
inti,j,iFileSize,iSendNum,iAddrSize=sizeof(remoteAddr);
FILE*pFile=NULL;
pFile=fopen(acDirAndFileName,"rb");
fseek(pFile,0,SEEK_END);
//文件字节数
iFileSize=ftell(pFile);
intToStr(iFileSize,acFileSize);
//printf("%s ",acDirAndFileName);
//获取文件名长度
iSize=strlen(acDirAndFileName);
for(i=iSize-1,iNameSize=0;i>=0;i--,iNameSize++)
if(acDirAndFileName[i]=='\'||acDirAndFileName[i]=='/')
break;
//printf("%d ",iNameSize);
//截取文件名
for(i=0;i<iNameSize;i++)
acFileName[i]=acDirAndFileName[iSize-iNameSize+i];
acFileName[iNameSize]=' ';
//printf("%s ",acFileName);
openUDP(acIpAddr);
//发送文件名
for(;;)
{
//创建线程
#ifdef_MSC_VER
HANDLEhThread;
DWORDthreadId;
hThread=CreateThread(NULL,0,sendName,0,0,&threadId);
//每次接收请求信息后等待一段时间
sleepUDP(1000);
//强制终止线程
TerminateThread(hThread,0);
#else
pthread_tthread;
void*thread_arg=(pthread_t)0;
pthread_create(&thread,NULL,sendName,(void*)&thread_arg);
//每次接收请求信息后等待一段时间
sleepUDP(1000);
//强制终止线程
pthread_cancel(thread);
#endif
//如果请求信息正确退出循环
if(acRecvStr[0]=='n'&&acRecvStr[1]=='a'&&acRecvStr[2]=='m'&&acRecvStr[3]=='e'&&acRecvStr[4]==' ')
break;
}
//发送文件字节数
for(;;)
{
acRecvStr[0]=' ';
//接收请求
recvfrom(iUDP,acRecvStr,5,0,(structsockaddr*)&remoteAddr,&iAddrSize);
//每次接收请求信息后等待一段时间
sleepUDP(10);
//如果请求信息正确
if(acRecvStr[0]=='s'&&acRecvStr[1]=='i'&&acRecvStr[2]=='z'&&acRecvStr[3]=='e'&&acRecvStr[4]==' ')
{
//发送文件字节数
sendto(iUDP,acFileSize,strlen(acFileSize),0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
break;
}
}
iSendNum=iFileSize/SIZEB;
//发送文件
if(iSendNum>0)
{
for(i=0;;i++)
{
acRecvStr[0]=' ';
//接收请求
recvfrom(iUDP,acRecvStr,SIZEB,0,(structsockaddr*)&remoteAddr,&iAddrSize);
printf("%s 正在发送文件的第%d段 ",acRecvStr,i);
//每次接收请求信息后等待一段时间
sleepUDP(10);
fseek(pFile,strToInt(acRecvStr)*SIZEB,SEEK_SET);
fread(acSendStr,1,SIZEB,pFile);
//printf("%s ",acSendStr);
//发送一段文件
sendto(iUDP,acSendStr,SIZEB,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
if(strToInt(acRecvStr)>=iSendNum-1)
break;
}
}
//发送文件剩余字节
iSize=iFileSize%SIZEB;
if(iSize>0)
{
for(;;)
{
acRecvStr[0]=' ';
//接收请求
recvfrom(iUDP,acRecvStr,5,0,(structsockaddr*)&remoteAddr,&iAddrSize);
//每次接收请求信息后等待一段时间
sleepUDP(10);
//如果请求信息正确
if(acRecvStr[0]=='l'&&acRecvStr[1]=='a'&&acRecvStr[2]=='s'&&acRecvStr[3]=='t'&&acRecvStr[4]==' ')
{
fseek(pFile,iSendNum*SIZEB,SEEK_SET);
fread(acSendStr,1,iSize,pFile);
//printf("%s ",acSendStr);
//发送文件剩余字节
sendto(iUDP,acSendStr,iSize,0,(structsockaddr*)&clientAddr,sizeof(clientAddr));
break;
}
}
}
printf("%s ","文件发送完毕！");
//关闭连接
closeUDP();
}
intmain(void)
{
characDirName[SIZEA];
characDirAndFileName[SIZEA];
characIpAddr[15];
inti,iOption=0,iSize=0;
FILE*pFile=NULL;
charcLast='\';
option:
printf("%s ","**************************************************** 本程序包括服务器端和客户端，既可以发送文件又可以接收文件。 支持无线WiFi，支持USB收发器，但仅支持局域网内传送文件。 如果要在Windows和Linux之间传送文件，文件名不能出现中文。 如果要在同一台机器上测试需要同时打开两个程序。 ****************************************************");
printf("%s ","请输入选项，1.发送文件、2.接收文件。");
scanf("%d",&iOption);
//发送文件
if(iOption==1)
{
iServerPort=1025;
iClientPort=1024;
fileName:
printf("%s ","请输入需要发送的路径文件名。 Windows路径文件名格式： C:\install.txt Linux路径文件名格式： /home/install.txt");
scanf("%s",acDirAndFileName);
pFile=fopen(acDirAndFileName,"rb");
if(pFile==NULL)
{
printf("%s ","读取文件失败，请重新输入文件名。");
gotofileName;
}
//关闭文件
fclose(pFile);
printf("%s ","请输入接收文件方的IP地址，不能有空格。 例如： 192.168.1.104");
scanf("%s",acIpAddr);
sendFile(acDirAndFileName,acIpAddr);
}
//接收文件
elseif(iOption==2)
{
iServerPort=1024;
iClientPort=1025;
dirName:
printf("%s ","请输入保存文件的路径名。 Windows路径名格式： C:\img\ Linux路径名格式： /home/");
scanf("%s",acDirName);
iSize=strlen(acDirName);
//检查是不是Linux路径名
for(i=0;i<iSize;i++)
{
if(acDirName[i]=='/')
{
cLast='/';
break;
}
}
//检查路径名最后一个字符是不是或/
if(acDirName[iSize-1]!=cLast)
{
acDirName[iSize]=cLast;
acDirName[iSize+1]=' ';
}
acDirAndFileName[0]=' ';
strcat(acDirAndFileName,acDirName);
strcat(acDirAndFileName,"a.txt");
//试探保存一个无关紧要的文件
pFile=fopen(acDirAndFileName,"w");
if(pFile==NULL)
{
printf("%s ","该路径无法创建文件，请重新输入路径名。");
gotodirName;
}
else
{
//关闭文件
fclose(pFile);
//删除文件
remove(acDirAndFileName);
}
printf("%s ","请输入发送文件方的IP地址，不能有空格。 例如： 192.168.2.249");
scanf("%s",acIpAddr);
recvFile(acDirName,acIpAddr);
}
else
{
printf("%s ","没有这个选项，请重新输入。");
gotooption;
}
return0;
}
Ⅳ 实现UDP协议传输的C语言程序。如被采纳，可追加悬赏，盼高手指教，不胜感激！！！
原型：
int WINAPI icePub_UdpSendAndReceive(char *sendBuffer,int bufferLen,char *strIP,int port,char *receiveBuffer,int timeoutSeconds,int retryCounts)
输入：sendBuffer 发送的数据
bufferLen sendBuffer的长度
strIP 服务端地址
port 端口
timeoutSeconds 超时时间，秒
retryCounts 接收失败重发次数
输出：receiveBuffer 接收的数据
返回码：接收数据的长度
char buff[1024],buff2[1024*10];
int receiveLen;
strcpy(buff,"tag:01\r\ncommand:reboot\r\ndata:none\r\n");
typedef int (WINAPI ICEPUB_UDPSENDANDRECEIVE)(char *sendBuffer,int bufferLen,char *strIP,int port,char *receiveBuffer,int timeoutSeconds,int retryCounts);
ICEPUB_UDPSENDANDRECEIVE *icePub_UdpSendAndReceive = 0;
HINSTANCE hDLLDrv = LoadLibrary("icePubDll.dll");
if(hDLLDrv)
icePub_UdpSendAndReceive=(ICEPUB_UDPSENDANDRECEIVE *)GetProcAddress(hDLLDrv,"icePub_UdpSendAndReceive");
if(icePub_UdpSendAndReceive)
receiveLen=icePub_UdpSendAndReceive(buff,strlen(buff),"192.168.1.111",6000,buff2,15,1);
if(hDLLDrv)
FreeLibrary(hDLLDrv);
AfxMessageBox(buff2);
Ⅳ 用c语言编程来计算基于udp的被动时延测量（gcc编译）其中如何判别μtp协议，求大神指点
前面右转C语言吧
Ⅵ 实现UDP协议传输的C语言程序。
我这有，留个邮箱先
Ⅶ C语言 UDP文件传输
void ThreadReceive(PVOID param)
{
static struct sockaddr_in server; // 绑定地址
static SOCKET ListenSocket; // 等待接收数据的socket
char buf[4096];
int len = sizeof(client);
int result;
ListenSocket = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
if (ListenSocket == INVALID_SOCKET)
{
perror("opening stream socket");
exit(0);
}
server.sin_family = PF_INET;
server.sin_addr.s_addr = htonl( INADDR_ANY ); // 任何地址
server.sin_port = htons(LOCAL_PORT);
if (SOCKET_ERROR == bind(ListenSocket, (struct sockaddr *)&server, sizeof(server)) )
{
printf("Error: 绑定失败\n");
exit(1);
closesocket( ListenSocket );
}
printf("socket port %d \n", ntohs(server.sin_port));
while(TRUE)
{
//接收数据
result = recvfrom(ListenSocket, buf, sizeof(buf)-1, 0, (struct sockaddr *)&client, &len);
if ( result > 0 )
{
buf[result] = 0;
inet_ntoa(client.sin_addr), ntohs(client.sin_port));
}
}
closesocket(ListenSocket);
}
Ⅷ C语言UDP怎么接收RTP流
实时传送协议（Real-time Transport Protocol或简写RTP，也可以写成RTTP）是一个网络传输协议，它是由IETF的多媒体传输工作小组1996年在RFC 1889中公布的。
RTP协议详细说明了在互联网上传递音频和视频的标准数据包格式。它一开始被设计为一个多播协议，但后来被用在很多单播应用中。RTP协议常用于流媒体系统（配合RTCP协议或者RTSP协议）。因为RTP自身具有Time stamp所以在ffmpeg 中被用做一种formate.
RTP协议格式：
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|V=2|P|X| CC |M| PT | sequence number |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| timestamp |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| synchronization source (SSRC) identifier |
+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
| contributing source (CSRC) identifiers |
| .... |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
上图引自rfc3550，由上图中可知道RTP报文由两个部分构成--RTP报头和RTP的负载：
RTP报文由两部分组成：报头和有效载荷。RTP报头格式如图6.7所示，其中：
1.V：RTP协议的版本号，占2位，当前协议版本号为2。
2. P：填充标志，占1位，如果P=1，则在该报文的尾部填充一个或多个额外的八位组，它们不是有效载荷的一部分。
3. X：神备扩展标志，占1位，如果X=1，则在RTP报头后跟有一个扩展报头。
4. CC：CSRC计数器，占4位，指示CSRC 标识符的个数。
5. M: 标记，占1位，不同的有效载荷有不同的含义，对于视频，标记一帧的结束；对于音频，标记会话的开始。
6. PT: 有效载荷类型，占7位，用于说明RTP报文中有效载荷的游桥毁类型，如GSM音频、JPEM图像等,在流媒体中大部分是用来区分音频流和视频流的，这样便于客户端进行解析。
7. 序列号：占16位，用于标识发送者所发送的RTP报文的序列号，每发送一个报文，序列号增1。这个字段当下层的承载协议用UDP的时候，消拆网络状况不好的时候可以用来检查丢包。同时出现网络抖动的情况可以用来对数据进行重新排序，在helix服务器中这个字段是从0开始的，同时音频包和视频包的sequence是分别记数的。
8. 时戳(Timestamp)：占32位，时戳反映了该RTP报文的第一个八位组的采样时刻。接收者使用时戳来计算延迟和延迟抖动，并进行同步控制。
9. 同步信源(SSRC)标识符：占32位，用于标识同步信源。该标识符是随机选择的，参加同一视频会议的两个同步信源不能有相同的SSRC。
10. 特约信源(CSRC)标识符：每个CSRC标识符占32位，可以有0～15个。每个CSRC标识了包含在该RTP报文有效载荷中的所有特约信源。
如果扩展标志被置位则说明紧跟在报头后面是一个头扩展，其格式如下：
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| defined by profile | length |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| header extension |
| .... |
RTP协议的用途：
概述中已经基本阐述了RTP协议的用途了，其主要用于在互联网上传递音频和视频的标准数据包。在当前三网融合中RTP可以用来承载TS流，进行电视媒体数据的传播。RTP可以用来传送像TS流这种自身已经具有formate的媒体流，同时也可以用来承载AVC，AAC等去除了fromate的媒体流，这时rtp协议可被看做为一种formate，这种形式最少常见于helix 流媒体服务器的rtp流。其控制流由RTSP协议来提供。
RTP协议的使用：
从中可以看出承载RTP的为UDP的数据流这个包中有x标志位为1则说明其有 header extensions.其header extensions为最下面。extension 的 profile为23128,长度为：2内容如上图最后两部分。
Ⅸ C语言UDP协议
简单的学习代码，仅供参考：
server.c
#include<stdlib.h>
#include<stdio.h>
#include<string.h>
#include<netdb.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#defineSERVICE_PORT 8080
#defineBUFSIZE2048
#defineHEAD4
intmain(intargc,char**argv)
{
structsockaddr_inmyaddr; /*ouraddress*/
structsockaddr_inremaddr; /*remoteaddress*/
socklen_taddrlen=sizeof(remaddr); /*lengthofaddresses*/
intrecvlen; /*#bytesreceived*/
intfd; /*oursocket*/
intmsgcnt=0; /*count#ofmessageswereceived*/
unsignedcharbuf[BUFSIZE]="ret_"; /*receivebuffer*/
/*createaUDPsocket*/
if((fd=socket(AF_INET,SOCK_DGRAM,0))<0){
perror("cannotcreatesocket ");
return0;
}
/**/
memset((char*)&myaddr,0,sizeof(myaddr));
myaddr.sin_family=AF_INET;
myaddr.sin_addr.s_addr=htonl(INADDR_ANY);
myaddr.sin_port=htons(SERVICE_PORT);
if(bind(fd,(structsockaddr*)&myaddr,sizeof(myaddr))<0){
perror("bindfailed");
return0;
}
/*nowloop,*/
for(;;)
{
printf("waitingonport%d ",SERVICE_PORT);
recvlen=recvfrom(fd,buf+HEAD,BUFSIZE,0,(structsockaddr*)&remaddr,&addrlen);
if(recvlen>0)
{
buf[HEAD+recvlen]=0;
printf("receivedmessage:"%s"(%dbytes) ",buf+HEAD,recvlen);
}
else
{
printf("uhoh-somethingwentwrong! ");
}
printf("sendingresponse"%s" ",buf);
if(sendto(fd,buf,strlen(buf),0,(structsockaddr*)&remaddr,addrlen)<0)
{
perror("sendto");
}
}
close(fd);
return0;
}
client.c
#include<stdlib.h>
#include<stdio.h>
#include<string.h>
#include<netdb.h>
#include<sys/socket.h>
#defineSERVICE_PORT 8080
#defineBUFLEN2048
intmain(intargc,char*argv[])
{
structsockaddr_inmyaddr,remaddr;
intfd,i,slen=sizeof(remaddr);
charsendbuf[BUFLEN]="hello"; /*messagebuffer*/
charreadbuf[BUFLEN]={0};
intrecvlen; /*#bytesinacknowledgementmessage*/
char*server="127.0.0.1"; /**/
/*createasocket*/
if((fd=socket(AF_INET,SOCK_DGRAM,0))==-1)
{
printf("socketcreated ");
}
/**/
memset((char*)&myaddr,0,sizeof(myaddr));
myaddr.sin_family=AF_INET;
myaddr.sin_addr.s_addr=htonl(INADDR_ANY);
myaddr.sin_port=htons(0);
if(bind(fd,(structsockaddr*)&myaddr,sizeof(myaddr))<0)
{
perror("bindfailed");
return0;
}
memset((char*)&remaddr,0,sizeof(remaddr));
remaddr.sin_family=AF_INET;
remaddr.sin_port=htons(SERVICE_PORT);
if(inet_aton(server,&remaddr.sin_addr)==0)
{
fprintf(stderr,"inet_aton()failed ");
exit(1);
}
printf("Sendingpacket%dto%sport%d ",i,server,SERVICE_PORT);
if(sendto(fd,sendbuf,strlen(sendbuf),0,(structsockaddr*)&remaddr,slen)==-1)
{
perror("sendto");
exit(1);
}
/**/
recvlen=recvfrom(fd,readbuf,BUFLEN,0,(structsockaddr*)&remaddr,&slen);
if(recvlen>=0)
{
readbuf[recvlen]=0; /*expectaprintablestring-terminateit*/
printf("receivedmessage:"%s" ",readbuf);
}
close(fd);
return0;
}
如果需要整个工程，可以联系我。