W. R. Stevens  : Глава 4

Элементарные сокеты TCP

Будут описаны параллельные серверы - когда множество клиентов соединяются с одним и тем же сервером. При этом сервер каждый раз будет выполнять функцию fork , порождающую новый серверный процесс.

Типичный сценарий взаимодействия между клиентом и сервером :

 								 TCP-сервер
 								------------
 								| socket() |
 								------------
 								     |
 								------------
 								|  bind()  |
 								------------
 								     |
 								------------
 								| listen() |
 								------------
 								     |
 								------------
 								| accept() |
    TCP-клиент							------------
   ------------							     |
   | socket() |						Блокировка для соединения
   ------------							с клиентом
        |     						 	     |   
   ------------	         Установка соединения            	     |
   | connect()|		<---------------------> 		     |
   ------------	       (3-этапное рукопожатие TCP)		     |
        |                                      			     |
   ------------         Данные(запрос)  			-------------
   | write()  | ---------------------------------------> 	| read()    |
   ------------                          			-------------
        |							     |
        |							     |	
   ------------         Данные (ответ)            		-------------
   |  read()  |    <------------------------------------------  | write()   |
   ------------                                			-------------
        |							     !	
        |							     !	
   ------------      Уведомление о конце файла       		-------------
   | close()  |   ------------------------------->  		| read()    |
   ------------                                      		-------------
 								     |
 								-------------
 								| close()   |
 								-------------
 

Функция socket

 	int socket(int family , int type , int protocol);

 	AF_INET
 	AF_INET6
 	AF_LOCAL
 	AF_ROUTE
 	AF_KEY

 	SOCK_STREAM
 	SOCK_DGRAM
 	SOCK_RAW

Не все сочетания family и type допустимы . Допустимые сочетания :

 	===========================================================================
 	 AF_INET          AF_INET6    AF_LOCAL     AF_ROUTE     AF_key
 	===========================================================================
 	SOCK_STREAM 	  TCP          TCP         Да           
 	SOCK_DGRAM        UDP          UDP         Да
 	SOCK_RAW          IPv6                     Да            Да
 	===========================================================================

Функция connect

 	int connect(int sockfd , const struct sockaddr *servaddr,socklen_t addrlen);

 	ETIMEOUT
 	ECONNREFUSED
 	EHOSTUNREACH
 	ENETUNREACH 
 

Функция bind

 	int bind(int sockfd , const struct sockaddr *myaddr,socklen_t addrlen);

Функция listen

  int listen(int sockfd , int backlog);

Функция accept

 	int accept(int sockfd , struct sockaddr *cliaddr,socklen_t addrlen);

  // intro/daytimetcpsrv1.c
 #include	"unp.h"
 #include	< time.h>
 
 int main(int argc, char **argv)
 {
 	int					listenfd, connfd;
 	socklen_t			len;
 	struct sockaddr_in	servaddr, cliaddr;
 	char				buff[MAXLINE];
 	time_t				ticks;
 
 	listenfd = Socket(AF_INET, SOCK_STREAM, 0);
 
 	bzero(&servaddr, sizeof(servaddr));
 	servaddr.sin_family      = AF_INET;
 	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
 	servaddr.sin_port        = htons(13);	/* daytime server */
 
 	Bind(listenfd, (SA *) &servaddr, sizeof(servaddr));
 
 	Listen(listenfd, LISTENQ);
 
 	for ( ; ; ) {
 		len = sizeof(cliaddr);
 		connfd = Accept(listenfd, (SA *) &cliaddr, &len);
 		printf("connection from %s, port %d\n",
 			   Inet_ntop(AF_INET, &cliaddr.sin_addr, buff, sizeof(buff)),
 			   ntohs(cliaddr.sin_port));
 
         ticks = time(NULL);
         snprintf(buff, sizeof(buff), "%.24s\r\n", ctime(&ticks));
         Write(connfd, buff, strlen(buff));
 
 		Close(connfd);
 	}
 }

Функции fork и exec

 	pid_t fork(void);
 

Параллельные серверы

 	pid_t pid;
 	int listenfd , connfd;
 	listenfd = Socket( ...);
 	Bind(listenfd , ...);
 	Listen(listenfd,LISTENQ);
 
 	for(;;) {
 		connfd = Accept(listenfd , ...);
 		if ((pid == Fork()) ==0) {
 			Close(listenfd);
 			doit(connfd);
 			Close(connfd);
 			exit(0);
 		}
 		Close(connfd);
 	}

Функции getsockname и getpeername

 	int getsockname(int sockfd, struct sockaddr *localadd, socklen_t *addrlen); 
     int getpeername(int sockfd, struct sockaddr *peeraddr, socklen_t *addrlen);
 

Оставьте свой комментарий !
Ваше имя: Комментарий: Оба поля являются обязательными  Автор   Комментарий к данной статье