該函數提供的是一個迭代服務器,而不是像TCP服務器那樣可以提供一個並發服務器。其中沒有對fork的調用,因此單個服務器進程就得處理所有客戶。一般來說,大多數TCP服務器是並發的,而大多數UDP服務器是迭代的。
對於本套接字,UDP層中隱含有排隊發生。事實上每個UDP套接字都有一個接收緩沖區,到達該套接字的每個數據報都進入這個套接字接收緩沖區。當進程調用recvfrom時,緩沖區中的下一個數據報以FIFO(先入先出)順序返回給進程。
服務器程序:
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<string.h>
#define SERV_PORT 3333
#define MAXLINE 1024
#define ERR_EXIT(m) \
do { \
perror(m); \
exit(EXIT_FAILURE); \
} while (0)
typedef struct sockaddr SA;
void dg_echo(int sockfd, SA *pcliaddr, socklen_t clilen)
{
int n;
socklen_t len;
char mesg[MAXLINE];
for ( ; ; ) {
len = clilen;
n = recvfrom(sockfd, mesg, MAXLINE, 0, pcliaddr, &len);
sendto(sockfd, mesg, n, 0, pcliaddr, len);
}
}
int
main(int argc, char **argv)
{
int sockfd;
struct sockaddr_in servaddr, cliaddr;
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
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));
}
查看本欄目更多精彩內容:http://www.bianceng.cn/OS/unix/
客戶端程序:
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#define SERV_PORT 3333
#define MAXLINE 1024
#define ERR_EXIT(m) \
do \
{ \
perror(m); \
exit(EXIT_FAILURE); \
} while(0)
typedef struct sockaddr SA;
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) {
sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen);
n = recvfrom(sockfd, recvline, MAXLINE, 0, NULL, NULL);
recvline[n] = 0; /* null terminate */
fputs(recvline, stdout);
}
}
int main(int argc, char **argv)
{
int sockfd;
struct sockaddr_in servaddr;
if (argc != 2)
ERR_EXIT("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);
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
dg_cli(stdin, sockfd, (SA *) &servaddr, sizeof(servaddr));
exit(0);
}
1.數據報的丟失
我們的UDP客戶/服務器例子是不可靠的。如果一個客戶數據報丟失(譬如說,被客戶主機與服務器主機之間的某個路由器丟失),客戶將永遠阻塞於dg_cli函數中的recvfrom調用,等待一個永遠不會達到的服務器應答。類似的,如果客戶數據報到達服務器,但是服務器的應答丟失了,客戶也將永遠阻塞於recvfrom調用。防止這樣永遠阻塞的一般方法是給客戶的recvfrom調用設置一個超時。
僅僅給recvfrom調用設置超時並不是完整的解決辦法。舉例來說,如果確實超時了,我們將無從判定超時原因是我們的數據報沒有到達服務器,還是服務器的應答沒有回到客戶。所以我們可以增加UDP客戶/服務器程序的可靠性。(後面會有講解)
2.服務器進程未運行
我們下一個要檢查的情形是在不啟動服務器的前提下啟動客戶。如果我們這麼做後在客戶上鍵入一行文本,那麼什麼也不發生。客戶永遠阻塞於它的recvfrom調用,等待一個永遠不出現的服務器應答。
經過抓包分析,服務器主機響應的是一個“port unreachable”(端口不可達)ICMP消息。不過這個ICMP錯誤不返回給客戶進程。我們稱這個ICMP錯誤為異步錯誤。該錯誤由sendto引起,但是sendto本身卻成功返回。我們知道從UDP輸出操作成功返回僅僅表示在輸出隊列中具有存放所形成IP數據報的空間。該ICMP錯誤直到後來才返回,這就是稱其為異步的原因。
一個基本規則是:對於一個UDP套接字,由它引發的異步錯誤卻並不返回給它,除非它已連接。僅在進程已將其UDP套接字連接到恰恰一個對端後,這些異步錯誤才返回給進程。
注:只要SO_BSDCOMPAT 套接字選項沒有開啟,linux甚至對未連接的套接字也返回大多數ICMP(目的地不可達)錯誤。
查看本欄目更多精彩內容:http://www.bianceng.cn/OS/unix/
3.驗證接收到的響應
知道客戶臨時端口號的任何進程都可往客戶發送數據報,而且這些數據報會與正常的服務器應答混雜。
我們的解決辦法是修改recvfrom調用以返回數據報發送者的IP地址和端口號,保留來自數據報所發往服務器的應答,而忽略任何其他數據報。
void dg_cli(FILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
socklen_t len;
struct sockaddr_in *preply_addr;
preply_addr = malloc(servlen);
while (fgets(sendline, MAXLINE, fp) != NULL) {
sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen);
len = servlen;
n = recvfrom(sockfd, recvline, MAXLINE, 0, (SA*)preply_addr, &len);
if (len != servlen || memcmp(pservaddr, (SA*)preply_addr, len) != 0) {
printf("reply from %s (ignored)\n",inet_ntoa(preply_addr->sin_addr));
continue;
}
recvline[n] = 0; /* null terminate */
fputs(recvline, stdout);
}
}
然而這樣做照樣存在一些缺陷,如果服務器運行在一個只有單個IP地址的主機上,那麼這個版本的客戶工作正常。然而如果服務器主機是多宿的(多個IP地址),該客戶就有可能失敗。例如服務器有2個IP地址(172.24.37.94和135.197.17.100),客戶連接服務器(135.197.17.100),但是服務器響應的IP地址是(172.24.37.94),這樣我們的程序就出問題。
一個解決辦法是:得到由recvfrom返回的IP地址後,客戶通過在DNS中查找服務器主機的名字來驗證該主機的域名(而不是它的IP地址)。
另一個解決辦法是:UDP服務器給服務器主機上配置的每個IP地址創建一個套接字,用bind捆綁每個IP地址到各自的套接字,然後再所有這些套接字上使用select(等待其中任何一個變得可讀),再從可讀的套接字給出應答。既然用於給出應答的套接字上綁定的IP地址就是客戶請求的目的IP地址(否則該數據報不會被投遞到達該套接字),這就保證應答的源地址與請求的目的地址相同。
作者:csdn博客 ctthuangcheng