步驟
服務(wù)器
1 創(chuàng)建一個(gè)socket, 用函數(shù)socket()
2 綁定一個(gè)IP地址 端口等信息到socket, 用bind()函數(shù)
3 循環(huán)接受數(shù)據(jù), 用函數(shù)recvfrom()
4 關(guān)閉網(wǎng)絡(luò)連接

客戶端
1 創(chuàng)建一個(gè)socket, 用函數(shù)socket()
2 綁定一個(gè)IP地址 端口等信息到socket, 用bind()函數(shù)
3 設(shè)置對(duì)方的IP地址的端口等屬性
4 發(fā)送數(shù)據(jù) 用sendto()函數(shù)
5 關(guān)閉網(wǎng)絡(luò)連接



UDP服務(wù)器

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

#define SERVER_PORT 8888 
#define MAX_MSG_SIZE 1024 

void udps_respon(int sockfd) 
{ 
	struct sockaddr_in addr; 
	int addrlen,n; 
	char msg[MAX_MSG_SIZE]; 

	while(1) 
	{	/* 從網(wǎng)絡(luò)上讀,并寫到網(wǎng)絡(luò)上 */ 
		bzero(msg,sizeof(msg)); // 初始化,清零
		addrlen = sizeof(struct sockaddr); 
		n=recvfrom(sockfd,msg,MAX_MSG_SIZE,0,(struct sockaddr*)&addr,&addrlen); // 從客戶端接收消息
		msg[n]=0; 
		/* 顯示服務(wù)端已經(jīng)收到了信息 */ 
		fprintf(stdout,"Server have received %s",msg); // 顯示消息
	} 
} 

int main(void) 
{ 
	int sockfd; 
	struct sockaddr_in addr; 

	/* 服務(wù)器端開始建立socket描述符 */ 
	sockfd=socket(AF_INET,SOCK_DGRAM,0); 
	if(sockfd<0) 
	{ 
		fprintf(stderr,"Socket Error:%s\n",strerror(errno)); 
		exit(1); 
	} 

	/* 服務(wù)器端填充 sockaddr結(jié)構(gòu) */ 
	bzero(&addr,sizeof(struct sockaddr_in)); 
	addr.sin_family=AF_INET; 
	addr.sin_addr.s_addr=htonl(INADDR_ANY); 
	addr.sin_port=htons(SERVER_PORT); 

	/* 捆綁sockfd描述符 */ 
	if(bind(sockfd,(struct sockaddr *)&addr,sizeof(struct sockaddr_in))<0) 
	{ 
		fprintf(stderr,"Bind Error:%s\n",strerror(errno)); 
		exit(1); 
	} 

	udps_respon(sockfd); // 進(jìn)行讀寫操作
	close(sockfd); 
} 

  

UDP客戶端

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

#define SERVER_PORT 8888 
#define MAX_BUF_SIZE 1024 

void udpc_requ(int sockfd,const struct sockaddr_in *addr,int len) 
{ 
	char buffer[MAX_BUF_SIZE]; 
	int n; 
	while(1) 
	{ 	/* 從鍵盤讀入,寫到服務(wù)端 */ 
		printf("Please input char:\n");
		fgets(buffer,MAX_BUF_SIZE,stdin); 
		sendto(sockfd,buffer,strlen(buffer),0,addr,len); 
		bzero(buffer,MAX_BUF_SIZE); 
	} 
} 

int main(int argc,char **argv) 
{ 
	int sockfd; 
	struct sockaddr_in addr; 

	if(argc!=2) 
	{ 
		fprintf(stderr,"Usage:%s server_ip\n",argv[0]); 
		exit(1); 
	}

	/* 建立 sockfd描述符 */ 
	sockfd=socket(AF_INET,SOCK_DGRAM,0); 
	if(sockfd<0) 
	{ 
		fprintf(stderr,"Socket Error:%s\n",strerror(errno)); 
		exit(1); 
	} 

	/* 填充服務(wù)端的資料 */ 
	bzero(&addr,sizeof(struct sockaddr_in)); 
	addr.sin_family=AF_INET; 
	addr.sin_port=htons(SERVER_PORT);
	if(inet_aton(argv[1],&addr.sin_addr)<0)  /*inet_aton函數(shù)用于把字符串型的IP地址轉(zhuǎn)化成網(wǎng)絡(luò)2進(jìn)制數(shù)字*/ 
	{ 
		fprintf(stderr,"Ip error:%s\n",strerror(errno)); 
		exit(1); 
	} 

	udpc_requ(sockfd,&addr,sizeof(struct sockaddr_in)); // 進(jìn)行讀寫操作
	close(sockfd); 
} 


  

UDP程序設(shè)計(jì) 聽課筆記