udp客户端c代码

A. 有没有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}

B. 能否给我一个用纯C编写的UDP发送和接收的程序

UDP的，你看下

1.服务器端实现

程序在收到客户端发送来的消息后，给客户端发送消息，提示客户端收到了该消息

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>

int main(int argc, char *argv[])
{
int sock, length, fromlen, n;
struct sockaddr_in server;
struct sockaddr_in from;
char buf[1024];

//要求执行是输入端口信息
if (argc!= 2) {
printf( "Usage: %s port_num\n",argv[0]);
return 1;
}

//创建通信所需的套接字，并与地址和端口信息帮定
sock=socket(AF_INET, SOCK_DGRAM, 0);
if (sock < 0){
perror("cannot create communicating socket");
return 1;
}

length = sizeof(server);
bzero(&server,length);
server.sin_family=AF_INET;
server.sin_addr.s_addr=INADDR_ANY;
server.sin_port=htons(atoi(argv[1]));

if (bind(sock,(struct sockaddr *)&server,length)<0){
perror("cannot bind the socket");
close(sock);
return 1;
}

fromlen = sizeof(struct sockaddr_in);

//读取客户端发送来的信息，显示后，发回相关信息给客户端
while (1) {
n = recvfrom(sock,buf,sizeof(buf),0,(struct sockaddr *)&from,&fromlen);
if (n < 0) {
perror("cannot receive date from client");
break;
}
write(STDOUT_FILENO,"server: Received a datagram: ",29);
write(STDOUT_FILENO,buf,n);

n = sendto(sock,"send message to client\n",22,
0,(struct sockaddr *)&from,fromlen);
if (n < 0) {
perror("cannot send data to the client");
break;
}
}

close(sock);
return 0;
}

2.客户端实现

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>

int main(int argc, char *argv[])
{
int sock, length, n;
struct sockaddr_in server, from;
struct hostent *hp;
char buffer[256];

//判断输入参数是否符合要求
if (argc != 3) {
printf("Usage: %s server_ip port_num\n",argv[0]);
return 1;
}

//创建通信套接字
sock= socket(AF_INET, SOCK_DGRAM, 0);
if (sock < 0) {
perror("cannot create communicating socket");
return 1;
}

server.sin_family = AF_INET;
hp = gethostbyname(argv[1]);
if (hp==0) {
perror("cannot get the server ip address");
return 1;
}

b((char *)hp->h_addr,
(char *)&server.sin_addr,
hp->h_length);

server.sin_port = htons(atoi(argv[2]));
length=sizeof(struct sockaddr_in);

printf("(client) enter the message: ");
bzero(buffer,256);
fgets(buffer,255,stdin);

//发送数据给指定服务器
n=sendto(sock,buffer,strlen(buffer),0,&server,length);
if (n < 0){
perror("cannot get message from the client");
return 1;
}

//从服务器中接受数据
bzero(buffer,256);
n = recvfrom(sock,buffer,256,0,&from, &length);
if (n < 0) {
perror("cannot send message to the server");
return 1;
}

printf("client got message : %s\n",buffer);
close(sock);
return 0;
}

C. 请教C#WinForm下的UDP代码

UDP和WINFORM没有半毛钱关系，

UDP是一种网络通讯协议，常用于单片机通讯或者底层通讯，不需要握手，

至于代码，不明白你到底要什么代码，一般来讲UDP需要声明服务端和客户端 ，并接受和发送数据，

思路上就是服务端声明自己的IP、 端口， 然后开启监听，

客户端向指定的IP端口发送数据，

当然服务端也可以发送，客户端也可以监听，

最需要处理的一般是异步接收后的操作，

下面是个简单的UDP通讯的代码，服务端功能基本如下，客户端可以比葫芦画瓢，

usingSystem;
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Net.Sockets;
usingSystem.Net;
usingSystem.Threading;
usingSystem.IO;
namespaceUdpChatExample
{
///<summary>
///UDP服务器对象
///</summary>
publicclassUDPServerClass
{
(stringMessage);//定义委托事件
;
publicUDPServerClass()
{
//获取本机可用IP地址
IPAddress[]ips=Dns.GetHostAddresses(Dns.GetHostName());
foreach(IPAddressipainips)
{
if(ipa.AddressFamily==AddressFamily.InterNetwork)
{
MyIPAddress=ipa;//获取本地IP地址
break;
}
}
Note_StringBuilder=newStringBuilder();
PortName=8080;

}

;

///<summary>
///侦听端口名称
///</summary>
publicintPortName;

///<summary>
///本地地址
///</summary>
;

///<summary>
///日志记录
///</summary>
publicStringBuilderNote_StringBuilder;
///<summary>
///本地IP地址
///</summary>
publicIPAddressMyIPAddress;

publicvoidThread_Listen()
{
//创建一个线程接收远程主机发来的信息
ThreadmyThread=newThread(ReceiveData);
myThread.IsBackground=true;
myThread.Start();
}
///<summary>
///接收数据
///</summary>
privatevoidReceiveData()
{
IPEndPointlocal=newIPEndPoint(MyIPAddress,PortName);
ReceiveUdpClient=newUdpClient(local);
IPEndPointremote=newIPEndPoint(IPAddress.Any,0);
while(true)
{
try
{
//关闭udpClient时此句会产生异常
byte[]receiveBytes=ReceiveUdpClient.Receive(refremote);
stringreceiveMessage=Encoding.Default.GetString(receiveBytes,0,receiveBytes.Length);
//receiveMessage=ASCIIEncoding.ASCII.GetString(receiveBytes,0,receiveBytes.Length);
MessageArrived(string.Format("{0}来自{1}:{2}",DateTime.Now.ToString(),remote,receiveMessage));
//try
//{
//Byte[]sendBytes=Encoding.ASCII.GetBytes("Isanybodythere?");
//ReceiveUdpClient.Send(sendBytes,sendBytes.Length,local);
//}
//catch(Exceptione)
//{
//}
//break;

}
catch
{
break;
}
}
}

///<summary>
///添加日志信息到Note_StringBuilder
///</summary>
publicvoidAddMessage_Note_StringBuilder()
{

}
}
}

D. C语言 UDP socket 简单客户端 编程，急

提一下，你那个地址不好用，换成了127.0.0.1，端口可以用，完全按照要求写的，编译没错误，调试通过：
gcc server.c -o server
gcc client.c -o client
打开2个控制台：一个运行 ./server 另一个运行 ./client
server.c:
========================================
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <errno.h>

#define BUFFERSIZE 1024
typedef struct sockaddr SA;

int main(void)
{
char buf[BUFFERSIZE];
struct sockaddr_in addr_s;
struct sockaddr_in addr_c;
int sockfd;
socklen_t length;
int i;

if((sockfd = socket(AF_INET,SOCK_DGRAM,0)) == -1)
{
perror("socket fail");
return -1;
}

memset(&addr_s,0,sizeof(addr_s));
addr_s.sin_family = AF_INET;
addr_s.sin_addr.s_addr = inet_addr("127.0.0.1");
addr_s.sin_port = htons(31180);

if(bind(sockfd,(SA *)&addr_s,sizeof(addr_s)) == -1)
{
perror("bind fail");
return -1;
}

length = sizeof(addr_c);

memset(buf,'\0',sizeof(buf));
if(recvfrom(sockfd,buf,sizeof(buf),0
,(SA *)&addr_c,&length) == -1)
{
perror("recvfrom fail");
}
printf("recvfrom client:%s\n",buf);
sendto(sockfd,buf,sizeof(buf),0,(SA *)&addr_c,sizeof(addr_c));

close(sockfd);
}

====================================
client.c:
====================================
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <errno.h>

#define BUFFERSIZE 1024
typedef struct sockaddr SA;

int main(void)
{
int sockfd;
char buf[BUFFERSIZE];
struct sockaddr_in addr_s;

if((sockfd = socket(AF_INET,SOCK_DGRAM,0)) == -1)
{
perror("socket fail");
return -1;
}

memset(&addr_s,0,sizeof(addr_s));
addr_s.sin_family = AF_INET;
addr_s.sin_addr.s_addr = inet_addr("127.0.0.1");
addr_s.sin_port = htons(31180);

memset(buf,'\0',sizeof(buf));
sprintf(buf,"abcde");
if(sendto(sockfd,buf,sizeof(buf)
,0,(SA *)&addr_s,sizeof(addr_s)) < 0)
{
perror("sendto fail");
}
memset(buf,'\0',sizeof(buf));
recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);
printf("recvfrom server:%s\n",buf);

close(sockfd);
}

E. 基于UDP的PING程序的C语言（或c++）代码谁有！跪求！

#include<stdio.h>
#include<stdlib.h>
#include<signal.h>
#include<unistd.h>
#include<netinet/ip_icmp.h>
#include<netdb.h>
#include<string.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/time.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<pthread.h>

structsockaddr_indst_addr;
structsockaddr_inrecv_addr;
structtimevaltvrecv;
charicmp_pkt[1024]={0};
charrecv_pkt[1024]={0};
intsockfd=0,bytes=56,nsend_pkt=0,nrecv_pkt=0;
pid_tpid;

voidstatistics();
intin_chksum(unsignedshort*buf,intsize);
intpack(intsend_pkt);
void*send_ping();
intunpack(char*recv_pkt,intsize);
void*recv_ping();
voidtv_sub(structtimeval*out,structtimeval*in);

intmain(intargc,char**argv)
{
	intsize=50*1024;
	interrno=-1;
	intttl=64;
	void*tret;
	pthread_tsend_id,recv_id;
	structin_addripv4_addr;
	structhostent*ipv4_host;
	structprotoent*protocol=NULL;

	if(argc<2)
	{
		printf("usage:./ping<host>
");
		return-1;
	}
	if((protocol=getprotobyname("icmp"))==NULL)
	{
		printf("unkownprotocol
");
		return-1;
	}

	if((sockfd=socket(AF_INET,SOCK_RAW,protocol->p_proto))<0)
	{
		printf("socketfail
");
		return-1;
	}
	setsockopt(sockfd,SOL_SOCKET,SO_RCVBUF,&size,sizeof(size));
	setsockopt(sockfd,IPPROTO_IP,IP_MULTICAST_TTL,&ttl,sizeof(ttl));
	setsockopt(sockfd,IPPROTO_IP,IP_TTL,&ttl,sizeof(ttl));

	memset(&dst_addr,0,sizeof(dst_addr));
	dst_addr.sin_family=AF_INET;
	errno=inet_aton(argv[1],&ipv4_addr);
	if(errno==0)
	{
		ipv4_host=gethostbyname(argv[1]);
		if(NULL==ipv4_host)
		{
			printf("connect:Invalidargument
");
			return-1;
		}
		memcpy(&(dst_addr.sin_addr),ipv4_host->h_addr,sizeof(structin_addr));
	}
	else
	{
		memcpy(&(dst_addr.sin_addr),&(ipv4_addr.s_addr),sizeof(structin_addr));
	}

	pid=getpid();
	printf("PING%s(%s)%dbytesofdata.
",argv[1],inet_ntoa(dst_addr.sin_addr),bytes);
	signal(SIGINT,statistics);
	
	errno=pthread_create(&send_id,NULL,send_ping,NULL);
	if(errno!=0)
	{
		printf("send_pingthreadfail
");
		return-1;
	}
	errno=pthread_create(&recv_id,NULL,recv_ping,NULL);
	if(errno!=0)
	{
		printf("recv_pingthreadfail
");
		return-1;
	}
	pthread_join(send_id,&tret);
	pthread_join(recv_id,&tret);

	return0;
}

voidstatistics()
{
	printf("
---%spingstatistics---
",inet_ntoa(dst_addr.sin_addr));
	printf("%dpacketstransmitted,%dreceived,%.3f%cpacketloss
",
		nsend_pkt,nrecv_pkt,(float)100*(nsend_pkt-nrecv_pkt)/nsend_pkt,'%');
	close(sockfd);

	exit(0);
}

intin_chksum(unsignedshort*buf,intsize)
{
	intnleft=size;
	intsum=0;
	unsignedshort*w=buf;
	unsignedshortans=0;

	while(nleft>1)
	{
		sum+=*w++;
		nleft-=2;
	}
	if(nleft==1)
	{
		*(unsignedchar*)(&ans)=*(unsignedchar*)w;
		sum+=ans;
	}
	sum=(sum>>16)+(sum&0xFFFF);
	sum+=(sum>>16);
	ans=~sum;
	returnans;
}

intpack(intsend_pkt)
{
	structicmp*pkt=(structicmp*)icmp_pkt;
	structtimeval*time=NULL;

	pkt->icmp_type=ICMP_ECHO;
	pkt->icmp_cksum=0;
	pkt->icmp_seq=htons(nsend_pkt);
	pkt->icmp_id=pid;
	time=(structtimeval*)pkt->icmp_data;
	gettimeofday(time,NULL);
	pkt->icmp_cksum=in_chksum((unsignedshort*)pkt,bytes+8);

	returnbytes+8;
}

void*send_ping()
{
	intsend_bytes=0;
	intret=-1;

	while(1)
	{
		nsend_pkt++;
		send_bytes=pack(nsend_pkt);

		ret=sendto(sockfd,icmp_pkt,send_bytes,0,(structsockaddr*)&dst_addr,sizeof(dst_addr));
		if(ret==-1)
		{
			printf("sendfail
");
			sleep(1);
			continue;
		}
		sleep(1);
	}
}

voidtv_sub(structtimeval*out,structtimeval*in)
{
	if((out->tv_usec-=in->tv_usec)<0)
	{
		--out->tv_sec;
		out->tv_usec+=1000000;
	}

	out->tv_sec-=in->tv_sec;
}

intunpack(char*recv_pkt,intsize)
{
	structiphdr*ip=NULL;
	intiphdrlen;
	structicmp*icmp;
	structtimeval*tvsend;
	doublertt;

	ip=(structiphdr*)recv_pkt;
	iphdrlen=ip->ihl<<2;
	icmp=(structicmp*)(recv_pkt+iphdrlen);

	size-=iphdrlen;
	if(size<8)
	{
		printf("ICMPsizeislessthan8
");
		return-1;
	}

	if((icmp->icmp_type==ICMP_ECHOREPLY)&&(icmp->icmp_id==pid))
	{
		tvsend=(structtimeval*)icmp->icmp_data;
		tv_sub(&tvrecv,tvsend);
		rtt=tvrecv.tv_sec*1000+(double)tvrecv.tv_usec/(double)1000;
		printf("%dbytefrom%s:icmp_seq=%dttl=%drtt=%.3fms
",
			size,inet_ntoa(recv_addr.sin_addr),ntohs(icmp->icmp_seq),ip->ttl,rtt);
	}
	else
	{
		return-1;
	}
	return0;
}

void*recv_ping()
{
	fd_setrd_set;
	structtimevaltime;
	time.tv_sec=5;
	time.tv_usec=0;
	intret=0,nread=0,recv_len=0;
	
	recv_len=sizeof(recv_addr);
	while(1)
	{
		FD_ZERO(&rd_set);
		FD_SET(sockfd,&rd_set);
		ret=select(sockfd+1,&rd_set,NULL,NULL,&time);
		if(ret<=0)
		{
			continue;
		}
		elseif(FD_ISSET(sockfd,&rd_set))
		{
			nread=recvfrom(sockfd,recv_pkt,sizeof(recv_pkt),0,(structsockaddr*)&recv_addr,(socklen_t*)&recv_len);
			if(nread<0)
			{
				continue;
			}
			gettimeofday(&tvrecv,NULL);

			if(unpack(recv_pkt,nread)==-1)
			{
				continue;
			}
			nrecv_pkt++;
		}
	}
}

F. VC实现最简单的UDP通信

http://hi..com/ypxmaomao/blog/item/1bd9ba95e3aa224cd0135ebf.html
[文章信息] 作者:张晓明 杨建华 钱名海时间: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]。此外，应该指出的是，以上程序片断中的消息框主要是为程序调试方便而设置的，而在正式产品中不再出现。同时，按照程序容错误设计，应建立一个专门的容错处理函数。程序中可能出现的各种错误都将由该函数进行处理，依据错误的危害程度不同，建立几种不同的处理措施。这样，才能保证双方通话的顺利和可靠。

四、结论

本文是多媒体网络传输项目的重要内容之一，目前，结合硬件全双工语音卡等设备，已经成功地实现了话音的全双工的通信。有关整个多媒体传输系统设计的内容，将有另文叙述。

G. 求用udp发广播消息的C代码。

//发送端程序

#include <stdio.h>
#include <winsock.h>

int main(int argc, char* argv[])
{
WSADATA wsaData; //指向WinSocket信息结构的指针
SOCKET sockListener;
SOCKADDR_IN sin,saUdpServ;
BOOL fBroadcast = TRUE;
char sendBuff[1024];
int nSize;
int ncount=0;
if(WSAStartup(MAKEWORD( 1, 1 ), &wsaData )!=0)//进行WinSocket的初始化
{
printf("Can't initiates windows socket!Program stop.\n");//初始化失败返回-1
return -1;
}
sockListener=socket(PF_INET,SOCK_DGRAM,0);
setsockopt ( sockListener,SOL_SOCKET,SO_BROADCAST,

(CHAR *)&fBroadcast,sizeof ( BOOL ));
sin.sin_family = AF_INET;
sin.sin_port = htons(0);
sin.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind( sockListener, (SOCKADDR *)&sin, sizeof(sin))!=0)
{
printf("Can't bind socket to local port!Program stop.\n");//初始化失败返回-1
return -1;
}
saUdpServ.sin_family = AF_INET;
saUdpServ.sin_addr.s_addr = htonl ( INADDR_BROADCAST );
saUdpServ.sin_port = htons (7001);//发送用的端口，可以根据需要更改
nSize = sizeof ( SOCKADDR_IN );
while(1)
{
sprintf(sendBuff,"Message %d",ncount++);
sendto ( sockListener,sendBuff,
lstrlen (sendBuff),
0,
(SOCKADDR *) &saUdpServ,
sizeof ( SOCKADDR_IN ));
printf("%s\n",sendBuff);
}
return 0;
}

/////////////////////

//接收

#include <stdio.h>
#include <winsock.h>
#include <conio.h>

int main(int argc, char* argv[])
{
WSADATA wsaData; //指向WinSocket信息结构的指针
SOCKET sockListener;
SOCKADDR_IN sin,saClient;
char cRecvBuff[1024];
int nSize,nbSize;
int iAddrLen=sizeof(saClient);
if(WSAStartup(MAKEWORD( 1, 1 ), &wsaData )!=0)//进行WinSocket的初始化
{
printf("Can't initiates windows socket!Program stop.\n");//初始化失败返回-1
return -1;
}
sockListener=socket(AF_INET, SOCK_DGRAM,0);
sin.sin_family = AF_INET;
sin.sin_port = htons(7001);//发送端使用的发送端口，可以根据需要更改
sin.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind( sockListener, (SOCKADDR FAR *)&sin, sizeof(sin))!=0)
{
printf("Can't bind socket to local port!Program stop.\n");//初始化失败返回-1
return -1;
}
while(1)
{
nSize = sizeof ( SOCKADDR_IN );
if((nbSize=recvfrom (sockListener,cRecvBuff,1024,0,

(SOCKADDR FAR *) &saClient,&nSize))==SOCKET_ERROR)
{
printf("Recive Error");
break;
}
cRecvBuff[nbSize] = '\0';
printf("%s\n",cRecvBuff);

}
return 0;
}