[文章信息] 作者:张晓明 杨建华 钱名海时间:2003-06-28出处:PCVC责任编辑:方舟 [文章导读] 在Windows 95环境下，基于TCP/IP协议，用Winsock完成了话音的一端—端传输
摘要：在Windows 95环境下，基于TCP/IP协议，用Winsock完成了话音的端到端传输。采用双套接字技术，阐述了主要函数的使用要点，以及基于异步选择机制的应用方法。同时，给出了相应的实例程序。
一、引言
Windows 95作为微机的 *** 作系统，已经完全融入了网络与通信功能，不仅可以建立纯Windows 95环境下的“对等网络”，而且支持多种协议，如TCP/IP、IPX/SPX、NETBUI等。在TCP/IP协议组中，TPC是一种面向连接的协义，为用户提供可靠的、全双工的字节流服务，具有确认、流控制、多路复用和同步等功能，适于数据传输。UDP协议则是无连接的，每个分组都携带完整的目的地址，各分组在系统中独立传送。它不能保证分组的先后顺序，不进行分组出错的恢复与重传，因此不保证传输的可靠性，但是，它提供高传输效率的数据报服务，适于实时的语音、图像传输、广播消息等网络传输。
Winsock接口为进程间通信提供了一种新的手段，它不但能用于同一机器中的进程之间通信，而且支持网络通信功能。随着Windows 95的推出。Winsock已经被正式集成到了Windows系统中，同时包括了16位和32位的编扮巧程接口。而Winsock的开发工具也可以在Borland C++4.0、Visual C++2.0这些C编译器中找到，主要由一个名为winsock.h的头文件和动态连接库winsock.dll或wsodk32.dll组成，这两种动态连接库分别用于Win16和Win32的应用程序。
本文针对话音的全双工传输要求，采用UDP协议实现了实时网络通信。使用VisualC++2.0编译环境，其动态连接库名为wsock32.dll。
二、主要函数的使用要点
通过建立双套接字，可以很方搏缺敬便地实现全双工网络通信。
1.套接字建立函数：
SOCKET socket(int family,int type,int protocol)
对于UDP协议，写为：
SOCKRET s
s=socket(AF_INET,SOCK_DGRAM,0)
或s=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP)
为了建立两个套接字，必须实现地址的重复绑定，即，当一个套接字已经绑定到某本地地址后，为了让另一个套接字重复使用该地址，必须为调用bind()函数绑定第二个套接字之前，通过函数setsockopt()为该套接字设置SO_REUSEADDR套接字选项。通过函数getsockopt()可获得套接字选项设置状态。需要注意的是，两个套接字所对应的端口号不能相同。 此外，还涉及到套接字缓冲区的设置问题，按规定，每个区的设置范围是：不小于512个字节，大大于8k字节，根据需要，文中选用了4k字节。
2.套接字绑定函数
int bind(SOCKET s,struct sockaddr_in*name,int namelen)
s是刚才创建好的套接字，name指向描述通讯对象的结构体的指针，namelen是该结构体的长度。该结构体中的分量包括：IP地址(对应name.sin_addr.s_addr)、端口号(name.sin_port)、地址类型(name.sin_family，一般都赋成AF_INET，表示是internet地址)。
(1)IP地址的填写方法：在全双工通信中，要把用户名对应的点分表示法地基慎址转换成32位长整数格式的IP地址，使用inet_addr()函数。
(2)端口号是用于表示同一台计算机不同的进程(应用程序)，其分配方法有两种：1)进程可以让系统为套接字自动分配一端口号，只要在调用bind前将端口号指定为0即可。由系统自动分配的端口号位于1024~5000之间，而1~1023之间的任一TCP或UDP端口都是保留的，系统不允许任一进程使用保留端口，除非其有效用户ID是零(超级用户)。
2)进程可为套接字指定一特定端口。这对于需要给套接字分配一众所端口的服务器是很有用的。指定范围为1024和65536之间。可任意指定。
在本程序中，对两个套接字的端口号规定为2000和2001，前者对应发送套接字，后者对应接收套接字。
端口号要从一个16位无符号数(u_short类型数)从主机字节顺序转换成网络字节顺序，使用htons()函数。
根据以上两个函数，可以给出双套接字建立与绑定的程序片断。
//设置有关的全局变量
SOCKET sr,ss
HPSTR sockBufferS,sockBufferR
HANDLE hSendData,hReceiveData
DWROD dwDataSize=1024*4
struct sockaddr_in therel.there2
#DEFINE LOCAL_HOST_ADDR 200.200.200.201
#DEFINE REMOTE_HOST-ADDR 200.200.200.202
#DEFINE LOCAL_HOST_PORT 2000
#DEFINE LOCAL_HOST_PORT 2001
//套接字建立函数
BOOL make_skt(HWND hwnd)
{
struct sockaddr_in here,here1
ss=socket(AF_INET,SOCK_DGRAM,0)
sr=socket(AF_INET,SOCK_DGRAM,0)
if((ss==INVALID_SOCKET)||(sr==INVALID_SOCKET))
{
MessageBox(hwnd,“套接字建立失败!”，“”,MB_OK)
return(FALSE)
}
here.sin_family=AF_INET
here.sin_addr.s_addr=inet_addr(LOCAL_HOST_ADDR)
here.sin_port=htons(LICAL_HOST_PORT)
//another socket
herel.sin_family=AF_INET
herel.sin_addr.s_addr(LOCAL_HOST_ADDR)
herel.sin_port=htons(LOCAL_HOST_PORT1)
SocketBuffer()//套接字缓冲区的锁定设置
setsockopt(ss,SOL_SOCKET,SO_SNDBUF,(char FAR*)sockBufferS,dwDataSize)
if(bind(ss,(LPSOCKADDR)&here,sizeof(here)))
{
MessageBox(hwnd,“发送套接字绑定失败!”，“”，MB_OK)
return(FALSE)
}
setsockopt(sr SQL_SOCKET,SO_RCVBUF|SO_REUSEADDR,(char FAR*)
sockBufferR,dwDataSize)
if(bind(sr,(LPSOCKADDR)&here1,sizeof(here1)))
{
MessageBox(hwnd,“接收套接字绑定失败!”，“”，MB_OK)
return(FALSE)
}
return(TRUE)
}
//套接字缓冲区设置
void sockBuffer(void)
{
hSendData=GlobalAlloc(GMEM_MOVEABLE|GMEM_SHARE,dwDataSize)
if(!hSendData)
{
MessageBox(hwnd,“发送套接字缓冲区定位失败!”，NULL,
MB_OK|MB_ICONEXCLAMATION)
return
}
if((sockBufferS=GlobalLock(hSendData)==NULL)
{
MessageBox(hwnd,“发送套接字缓冲区锁定失败!”，NULL,
MB_OK|MB_ICONEXCLAMATION)
GlobalFree(hRecordData[0]
return
}
hReceiveData=globalAlloc(GMEM_MOVEABLE|GMEM_SHARE,dwDataSize)
if(!hReceiveData)
{
MessageBox(hwnd,"“接收套接字缓冲区定位败!”，NULL
MB_OK|MB_ICONEXCLAMATION)
return
}
if((sockBufferT=Globallock(hReceiveData))=NULL)
MessageBox(hwnd,"发送套接字缓冲区锁定失败!”，NULL,
MB_OK|MB_ICONEXCLAMATION)
GlobalFree(hRecordData[0])
return
}
{
3.数据发送与接收函数；
int sendto(SOCKET s.char*buf,int len,int flags,struct sockaddr_in to,int
tolen)
int recvfrom(SOCKET s.char*buf,int len,int flags,struct sockaddr_in
fron,int*fromlen)
其中，参数flags一般取0。
recvfrom()函数实际上是读取sendto()函数发过来的一个数据包，当读到的数据字节少于规定接收的数目时，就把数据全部接收，并返回实际接收到的字节数；当读到的数据多于规定值时，在数据报文方式下，多余的数据将被丢弃。而在流方式下，剩余的数据由下recvfrom()读出。为了发送和接收数据，必须建立数据发送缓冲区和数据接收缓冲区。规定：IP层的一个数据报最大不超过64K(含数据报头)。当缓冲区设置得过多、过大时，常因内存不够而导致套接字建立失败。在减小缓冲区后，该错误消失。经过实验，文中选用了4K字节。
此外，还应注意这两个函数中最后参数的写法，给sendto()的最后参数是一个整数值，而recvfrom()的则是指向一整数值的指针。
4.套接字关闭函数：closesocket(SOCKET s)
通讯结束时，应关闭指定的套接字，以释与之相关的资源。
在关闭套接字时，应先对锁定的各种缓冲区加以释放。其程序片断为：
void CloseSocket(void)
{
GlobalUnlock(hSendData)
GlobalFree(hSenddata)
GlobalUnlock(hReceiveData)
GlobalFree(hReceiveDava)
if(WSAAysncSelect(ss,hwnd,0,0)=SOCKET_ERROR)
{
MessageBos(hwnd,“发送套接字关闭失败!”，“”，MB_OK)
return
}
if(WSAAysncSelect(sr,hwnd,0,0)==SOCKET_ERROR)
{
MessageBox(hwnd,“接收套接字关闭失败!”，“”，MB_OK)
return
}
WSACleanup()
closesockent(ss)
closesockent(sr)
return
}
三、Winsock的编程特点与异步选择机制
1 阻塞及其处理方式
在网络通讯中，由于网络拥挤或一次发送的数据量过大等原因，经常会发生交换的数据在短时间内不能传送完，收发数据的函数因此不能返回，这种现象叫做阻塞。Winsock对有可能阻塞的函数提供了两种处理方式：阻塞和非阻塞方式。在阻塞方式下，收发数据的函数在被调用后一直要到传送完毕或者出错才能返回。在阻塞期间，被阻的函数不会断调用系统函数GetMessage()来保持消息循环的正常进行。对于非阻塞方式，函数被调用后立即返回，当传送完成后由Winsock给程序发一个事先约定好的消息。
在编程时，应尽量使用非阻塞方式。因为在阻塞方式下，用户可能会长时间的等待过程中试图关闭程序，因为消息循环还在起作用，所以程序的窗口可能被关闭，这样当函数从Winsock的动态连接库中返回时，主程序已经从内存中删除，这显然是极其危险的。
2 异步选择函数WSAAsyncSelect()的使用
Winsock通过WSAAsyncSelect()自动地设置套接字处于非阻塞方式。使用WindowsSockets实现Windows网络程序设计的关键就是它提供了对网络事件基于消息的异步存取，用于注册应用程序感兴趣的网络事件。它请求Windows Sockets DLL在检测到套接字上发生的网络事件时，向窗口发送一个消息。对UDP协议，这些网络事件主要为：
FD_READ 期望在套接字收到数据(即读准备好)时接收通知；
FD_WRITE 期望在套接字可发送数(即写准备好)时接收通知；
FD_CLOSE 期望在套接字关闭时接电通知
消息变量wParam指示发生网络事件的套接字，变量1Param的低字节描述发生的网络事件，高字包含错误码。如在窗口函数的消息循环中均加一个分支：
int ok=sizeof(SOCKADDR)
case wMsg
switch(1Param)
{
case FD_READ:
//套接字上读数据
if(recvfrom(sr.lpPlayData[j],dwDataSize,0,(struct sockaddr FAR*)&there1,
(int FAR*)&ok)==SOCKET_ERROR0
{
MessageBox)hwnd,“数据接收失败!”，“”，MB_OK)
return(FALSE)
}
case FD_WRITE:
//套接字上写数据
}
break；
在程序的编制中，应根据需要灵活地将WSAAsyncSelect()函灵敏放在相应的消息循环之中，其它说明可参见文献[1]。此外，应该指出的是，以上程序片断中的消息框主要是为程序调试方便而设置的，而在正式产品中不再出现。同时，按照程序容错误设计，应建立一个专门的容错处理函数。程序中可能出现的各种错误都将由该函数进行处理，依据错误的危害程度不同，建立几种不同的处理措施。这样，才能保证双方通话的顺利和可靠。
四、结论
本文是多媒体网络传输项目的重要内容之一，目前，结合硬件全双工语音卡等设备，已经成功地实现了话音的全双工的通信。有关整个多媒体传输系统设计的内容，将有另文叙述。
本程序在 Windows 7 Visual Studio 2015 和 Linux Ubuntu 15.04 GCC 5.11 下均编译运行测试通过。
本程序支持 Windows 和 Linux 之间传送文件，如果要在 Windows 和 Linux 之间传送文件，文件名不能出现中文。
本程序支持无线 WiFi，支持 USB 收发器，但仅支持局域网内传送文件，传送文件需要输入对方的 IP 地址。
本程序包括服务器端和客户端，既可以发送文件又可以接收文件。如果要在同一台机器上测试需要同时打开两个程序。
Windows 下查看本机 IP 地址的命令是：
ipconfigLinux 下查看本机 IP 地址的命令是：
ifconfig以下是程序代码：
#include<stdio.h>#include<stdlib.h>
#include<string.h>
#include<math.h>
#ifdef _MSC_VER
#include<winsock2.h>
#include<windows.h>
#pragma comment(lib, "ws2_32.lib")
#else
#include<pthread.h>
#include<unistd.h>
#include<signal.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#endif
// 存放发送接收字符锋改数组大小
#define SIZEA 65501
// 每次发送接收字节数
#define SIZEB 65500
typedef struct sockaddr_in SockAddrIn
SockAddrIn serverAddr, remoteAddr, clientAddr
// 端口号
int iServerPort, iClientPort
// 新建 socket 信息
int iUDP
// 字符串转整型
int strToInt(char* acStr)
{
int i, 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
return iNum
}
// 整型转字符串
void intToStr(int iInt, char* acStr)
{
int iIndex = 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] = '\0'
else
{
acStr[0] = '0'
acStr[1] = '\0'
}
}
void sleepUDP(int iSleep)
{
#ifdef _MSC_VER
Sleep(iSleep)
#else
usleep(iSleep*1000)
#endif
}
void openUDP(char* acIpAddr)
{
#ifdef _MSC_VER
// Winsows 启用 socket
WSADATA wsadata
if(WSAStartup(MAKEWORD(1, 1), &wsadata) == SOCKET_ERROR)
{
printf("启用 socket 失败\n")
exit(0)
}
#endif
// 新建 socket
if((iUDP = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)
{
printf("新建 socket 失败\n")
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, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == -1)
{
printf("绑定端口失败\n")
exit(0)
}
}
void closeUDP(void)
{
#ifdef _MSC_VER
// Winsows 关闭 socket
closesocket(iUDP)
WSACleanup()
#endif
}
// 要发送的字符串
char acSendStr[SIZEA]
// 接收到的字符串
char acRecvStr[SIZEA]
// 请求信息
char acReq[SIZEA]
// 文件名字符串
char acFileName[SIZEA]
// 文件字节数字符串
char acFileSize[SIZEA]
int iSize, iNameSize
// 接收文件名
#ifdef _MSC_VER
DWORD WINAPI recvName(LPVOID p)
#else
void* recvName(void* arg)
#endif
{
int iAddrSize = sizeof(remoteAddr)
acReq[0] = 'n' acReq[1] = 'a' acReq[2] = 'm' acReq[3] = 'e' acReq[4] = '\0'
acRecvStr[0] = '\0'
printf("%s\n", "正在发送请求信息！")
// 发送请求信息
sendto(iUDP, acReq, strlen(acReq), 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
// 每次发送请求信息后等待一段时间
sleepUDP(10)
// 接收文件名
iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
return 0
}
// 接收文件
void recvFile(char* acDirName, char* acIpAddr)
{
FILE* pFile = NULL
int i, iFileSize, iRecvNum, iAddrSize = sizeof(remoteAddr)
// 路径文件名
char acDirAndFileName[SIZEA]
openUDP(acIpAddr)
// 接收文件名
for()
{
// 创建线程
#ifdef _MSC_VER
HANDLE hThread
DWORD threadId
hThread = CreateThread(NULL, 0, recvName, 0, 0, &threadId)
// 每次发送后等待一段时间
sleepUDP(1000)
// 强制终止线程
TerminateThread(hThread, 0)
#else
pthread_t thread
void* thread_arg = (pthread_t)0
pthread_create(&thread, NULL, recvName, (void*)&thread_arg)
// 每次发送后等待一段时间
sleepUDP(1000)
// 强制终止线程
pthread_cancel(thread)
#endif
if(acRecvStr[0] != '\0')
{
acRecvStr[iSize] = '\0'
printf("文件名为：%s\n", acRecvStr)
break
}
}
acDirAndFileName[0] = '\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] = '\0'
// 接收文件字节数
for()
{
// 发送请求信息
sendto(iUDP, acReq, strlen(acReq) + 1, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
// 每次发送请求信息后等待一段时间
sleepUDP(10)
// 接收文件字节数
acRecvStr[0] = '\0'
iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
if(acRecvStr[0] != '\0')
{
acRecvStr[iSize] = '\0'
iFileSize = strToInt(acRecvStr)
printf("文件字节数为：%d\n", 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, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
printf("%s\t正在接收文件的第 %d 段\n", acReq, i)
// 每次发送请求信息后等待一段时间
sleepUDP(10)
// 接收一段文件
iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&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] = '\0'
for()
{
// 发送请求信息
sendto(iUDP, acReq, strlen(acReq) + 1, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
// 每次发送请求信息后等待一段时间
sleepUDP(10)
// 接收文件剩余字节
if(recvfrom(iUDP, acRecvStr, iSize, 0, (struct sockaddr*)&remoteAddr, &iAddrSize) == iSize)
{
// 以追加方式写入文件
fwrite(acRecvStr, sizeof(char), iSize, pFile)
break
}
}
}
printf("%s\n", "文件接收完毕！")
// 关闭文件
fclose(pFile)
// 关闭连接
closeUDP()
}
// 发送文件名
#ifdef _MSC_VER
DWORD WINAPI sendName(LPVOID p)
#else
void* sendName(void* arg)
#endif
{
int iAddrSize = sizeof(remoteAddr)
acRecvStr[0] = '\0'
// 接收请求
printf("%s\n", "正在接收请求信息！")
recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
// 每次接收请求信息后等待一段时间
sleepUDP(10)
// 如果请求信息正确发送文件名
if(acRecvStr[0] == 'n' && acRecvStr[1] == 'a' && acRecvStr[2] == 'm' && acRecvStr[3] == 'e' && acRecvStr[4] == '\0')
sendto(iUDP, acFileName, iNameSize, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
return 0
}
// 发送文件
void sendFile(char* acDirAndFileName, char* acIpAddr)
{
int i, 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\n", acDirAndFileName)
// 获取文件名长度
iSize = strlen(acDirAndFileName)
for(i=iSize-1, iNameSize=0 i>=0 i--,iNameSize++)
if(acDirAndFileName[i] == '\\' || acDirAndFileName[i] == '/')
break
//printf("%d\n", iNameSize)
// 截取文件名
for(i=0 i<iNameSize i++)
acFileName[i] = acDirAndFileName[iSize - iNameSize + i]
acFileName[iNameSize] = '\0'
//printf("%s\n", acFileName)
openUDP(acIpAddr)
// 发送文件名
for()
{
// 创建线程
#ifdef _MSC_VER
HANDLE hThread
DWORD threadId
hThread = CreateThread(NULL, 0, sendName, 0, 0, &threadId)
// 每次接收请求信息后等待一段时间
sleepUDP(1000)
// 强制终止线程
TerminateThread(hThread, 0)
#else
pthread_t thread
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] == '\0')
break
}
// 发送文件字节数
for()
{
acRecvStr[0] = '\0'
// 接收请求
recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
// 每次接收请求信息后等待一段时间
sleepUDP(10)
// 如果请求信息正确
if(acRecvStr[0] == 's' && acRecvStr[1] == 'i' && acRecvStr[2] == 'z' && acRecvStr[3] == 'e' && acRecvStr[4] == '\0')
{
// 发送文件字节数
sendto(iUDP, acFileSize, strlen(acFileSize), 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
break
}
}
iSendNum = iFileSize/SIZEB
// 发送文件
if(iSendNum > 0)
{
for(i=0i++)
{
acRecvStr[0] = '\0'
// 接收请求
recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
printf("%s\t正在发送文件的第 %d 段\n", acRecvStr, i)
// 每次接收请求信息后等待一段时间
sleepUDP(10)
fseek(pFile, strToInt(acRecvStr)*SIZEB, SEEK_SET)
fread(acSendStr, 1, SIZEB, pFile)
//printf("%s\n", acSendStr)
// 发送一段文件
sendto(iUDP, acSendStr, SIZEB, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
if(strToInt(acRecvStr) >= iSendNum - 1)
break
}
}
// 发送文件剩余字节
iSize = iFileSize%SIZEB
if(iSize > 0)
{
for()
{
acRecvStr[0] = '\0'
// 接收请求
recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)
// 每次接收请求信息后等待一段时间
sleepUDP(10)
// 如果请求信息正确
if(acRecvStr[0] == 'l' && acRecvStr[1] == 'a' && acRecvStr[2] == 's' && acRecvStr[3] == 't' && acRecvStr[4] == '\0')
{
fseek(pFile, iSendNum*SIZEB, SEEK_SET)
fread(acSendStr, 1, iSize, pFile)
//printf("%s\n", acSendStr)
// 发送文件剩余字节
sendto(iUDP, acSendStr, iSize, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))
break
}
}
}
printf("%s\n", "文件发送完毕！")
// 关闭连接
closeUDP()
}
int main(void)
{
char acDirName[SIZEA]
char acDirAndFileName[SIZEA]
char acIpAddr[15]
int i, iOption = 0, iSize = 0
FILE* pFile = NULL
char cLast = '\\'
option:
printf("%s\n", "****************************************************\n本程序包括服务器端和客户端，既可以发送文件又可以接收文件。\n支持无线 WiFi，支持 USB 收发器，但仅支持局域网内传送文件。\n如果要在 Windows 和 Linux 之间传送文件，文件名不能出现中文。\n如果要在同一台机器上测试需要同时打开两个程序。\n****************************************************")
printf("%s\n", "请输入选项，1.发送文件、2.接收文件。")
scanf("%d", &iOption)
// 发送文件
if(iOption == 1)
{
iServerPort = 1025
iClientPort = 1024
fileName:
printf("%s\n", "请输入需要发送的路径文件名。\nWindows 路径文件名格式：\t\tC:\\install.txt\nLinux 路径文件名格式：\t\t/home/install.txt")
scanf("%s", acDirAndFileName)
pFile = fopen(acDirAndFileName, "rb")
if(pFile == NULL)
{
printf("%s\n", "读取文件失败，请重新输入文件名。")
goto fileName
}
// 关闭文件
fclose(pFile)
printf("%s\n", "请输入接收文件方的 IP 地址，不能有空格。\n例如：\n192.168.1.104")
scanf("%s", acIpAddr)
sendFile(acDirAndFileName, acIpAddr)
}
// 接收文件
else if(iOption == 2)
{
iServerPort = 1024
iClientPort = 1025
dirName:
printf("%s\n", "请输入保存文件的路径名。\nWindows 路径名格式：\t\tC:\\img\\\nLinux 路径名格式：\t\t/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] = '\0'
}
acDirAndFileName[0] = '\0'
strcat(acDirAndFileName, acDirName)
strcat(acDirAndFileName, "a.txt")
// 试探保存一个无关紧要的文件
pFile = fopen(acDirAndFileName, "w")
if(pFile == NULL)
{
printf("%s\n", "该路径无法创建文件，请重新输入路径名。")
goto dirName
}
else
{
// 关闭文件
fclose(pFile)
// 删除文件
remove(acDirAndFileName)
}
printf("%s\n", "请输入发送文件方的 IP 地址，不能有空格。\n例如：\n192.168.2.249")
scanf("%s", acIpAddr)
recvFile(acDirName, acIpAddr)
}
else
{
printf("%s\n", "没有这个选项，请重新输入。")
goto option
}
return 0
}
61KByte/S。Internet 协议集支持一个无连接的传输协议，该协议称为用户数据报协议（UDP，User Datagram Protocol）。
UDP 为应用程序提供了一种无需建立连接就可以发送封明老装的 IP 数据包的方法。
Internet 的传输层有两个主要协议，互为补充。
无连接的是激渗升 UDP，它除了给应用程序发送数据包功能并喊升允许它们在所需的层次上架构自己的协议之外，几乎没有做什么特别的事情。
面向连接的是 TCP，该协议几乎做了所有的事情。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）