1、UDP客户/服务器套接字函数
UDP回射客户/服务器:
2、UDP服务器实现:
#include"unp.h"
void dg_echo(int sockfd, SA *pcliaddr, socklen_t clilen)
{
int n;
socklen_t len;
char mesg[MAXLINE];
//ssize_t recvfrom(int sockfd, void *buff, size_t nbytes, int flags, struct sockaddr *from, socklen_t *addrlen);
//ssize_t sendto(int sockfd, void *buff, size_t nbytes, int flags, struct sockaddr *to, socklen_t *addrlen);
for ( ; ; ) {
len = clilen;
n = Recvfrom(sockfd, mesg, MAXLINE, 0, pcliaddr, &len);
Sendto(sockfd, mesg, n, 0, pcliaddr, len);
//recvfrom返回时把客户的IP地址和端口号填入套接字结构,
//然后作为目的地址传递给sendto
//这样所接收的任何数据报就都会被“回射”给发送该数据报的客户
}
}
int main(int argc, char **argv)
{
intsockfd;
struct sockaddr_inservaddr, cliaddr;
sockfd = Socket(AF_INET, SOCK_DGRAM, 0); //指定SOCK_DGRAM,创建一个UDP套接字
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(SERV_PORT);
Bind(sockfd, (SA *) &servaddr, sizeof(servaddr));
dg_echo(sockfd, (SA *) &cliaddr, sizeof(cliaddr));
}
(1)两个客户连接TCP客户/服务器:(大多数TCP服务器是并发的)
服务器上建立两个已连接套接字,其中每一个都有各自自己的套接字接收缓冲区。
(2)两个客户连接UDP客户/服务器:(大多数UDP服务器是迭代的)
只有一个服务器进程,它只有一个套接字,该套接字有”一个接收缓冲区”用来存放所到达的数据报。
3、UDP客户实现:
#include"unp.h"注意:因为上面程序中recvfrom指定的第五个和第六个参数为空指针,也就是说没有指定应答数据报从哪来,发往本客户IP地址和端口号的数据报都将被客户读入并被认为是服务器的应答。
void dg_cli(FILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
while (Fgets(sendline, MAXLINE, fp) != NULL) { // fgets标准输入读入
Sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen); //发送
n = Recvfrom(sockfd, recvline, MAXLINE, 0, NULL, NULL); //读回回射
recvline[n] = 0; /* null terminate */
Fputs(recvline, stdout); // fputs标准输出显式
}
}
int main(int argc, char **argv)
{
intsockfd;
struct sockaddr_inservaddr;
if (argc != 2)
err_quit("usage: udpcli <IPaddress>");
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(SERV_PORT);
Inet_pton(AF_INET, argv[1], &servaddr.sin_addr); //把服务器的IP地址和端口号写入套接字结构,指明数据报发往何处
sockfd = Socket(AF_INET, SOCK_DGRAM, 0);
dg_cli(stdin, sockfd, (SA *) &servaddr, sizeof(servaddr));
exit(0);
}
修改:分配一个套接字用来存放recvfrom返回的套接字地址结构
void
dg_cli(FILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
intn;
charsendline[MAXLINE], recvline[MAXLINE + 1];
socklen_tlen;
struct sockaddr*preply_addr; // preply_addr:应答者信息
preply_addr = Malloc(servlen);
while (Fgets(sendline, MAXLINE, fp) != NULL) {
Sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen); // pservaddr:发送者信息
len = servlen;
n = Recvfrom(sockfd, recvline, MAXLINE, 0, preply_addr, &len); // 让内核返回应答者信息
if (len != servlen || memcmp(pservaddr, preply_addr, len) != 0) { // 把发送者和应答者进行比较
printf("reply from %s (ignored)\n",
Sock_ntop(preply_addr, len));
continue;
}
recvline[n] = 0;/* null terminate */
Fputs(recvline, stdout);
}
}
客户的IP地址和端口号一般都由内核自动选择,在这种由内核选择的情况下,客户的零时端口是在第一次调用sendto时一次性选定,不能改变;但是,客户的IP地址却可以随时随着客户发送的每个UDP数据报而变动(注意:我们在这说的是由内核选择,而不是捆绑一个具体的IP地址到套接字上)。也就是说,如果客户机是多宿的,客户就有可能在这两个目的地之间进行选择——有可能从左边的链路外出,也有可能从右边的链路外出。
4、udp的connect函数
UDP客户进程或服务器进程只有在使用自己的UDP套接字与确定的唯一的对端进行通信时,才可以调用connect。调用connect的通常是UDP客户。
UDP套接字调用connect后:
重写dg_cli.c:(仅仅是展示怎么调用connect)
void
dg_cli(FILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
intn;
charsendline[MAXLINE], recvline[MAXLINE + 1];
Connect(sockfd, (SA *) pservaddr, servlen); //调用connect
while (Fgets(sendline, MAXLINE, fp) != NULL) {
Write(sockfd, sendline, strlen(sendline)); //用write代替recvfrom
n = Read(sockfd, recvline, MAXLINE); //用read代替sendto
recvline[n] = 0;/* null terminate */
Fputs(recvline, stdout);
}
}