accept函数_TCP/IP编程之accept函数详解

#include <sys/socket.h>

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

　　　　　　　　　　　　　　　　　　　　返回：若成功返回非负描述符，若出错则返回-1

　　参数cliaddr和addrlen用来返回已连接的对端（客户）进程的协议地址。addrlen是值-结果参数：调用前，将由*addrlen所引用的整数值置为由cliaddr所指的套接字地址结构的长度，返回时，该整数值即为有内核放在该套接字地址结构内的确切字节数。

　　accept调用成功，返回一个全新的描述符，代表所返回客户的TCP连接。在讨论accept函数时，称第一个参数为监听套接字描述符，它的返回值为已连接套接字描述符。服务器通常仅仅创建一个监听套接字，它在该服务器的生命周期内一直存在。内核为每个服务器进程接受的客户连接创建一个已连接套接字。当服务器完成对某个给定客户的服务时，相应的已连接套接字就关闭。

　　下列服务器程序的代码中定义了len它将成为一个值-结果变量，cliaddr，它将存放客户的协议地址

/*unix.h 头文件*/
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <signal.h>
#include <pthread.h>
#include <sys/types.h>
#include "fun.c"
#define MAXLINE 124
#define SERV_PORT 5555
#define ip "127.0.0.1"

/*fun.c  函数c文件，目的是避免错误处理写在客户/服务器程序上，看起来缭乱，不易阅读*/

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#define MAXLINE 124
void err_sys(char *str)
{
    printf("%s\n",str);
    exit(1);
}
int Inet_pton(int domain,const char * str,void *addr)
{
    int fg;
    if((fg=inet_pton(domain,str,addr))==-1)
        err_sys("inet_pton error");
    return fg;
}
int Socket(int family,int type,int protocol)
{
    int  n;
    if((n=socket(family,type,protocol))<0)
        err_sys("socket error");
    return n;
}

void Bind(int sockfd,struct sockaddr_in *addr,socklen_t len)
{
    if(bind(sockfd,(struct sockaddr*)addr,len)==-1)
        err_sys("bind error");
}
void Connect(int sockfd,struct sockaddr_in *addr,socklen_t len)
{
    if(connect(sockfd,(struct sockaddr*)addr,len)==-1)
        err_sys("connect error");
}

void Listen(int fd,int bocklog)
{
    if(listen(fd,bocklog)==-1)
        err_sys("listen error");
}
int Accept(int sockfd,struct sockaddr_in *addr,socklen_t *len)
{
    int fd=accept(sockfd,(struct sockaddr*)addr,len);
    if(fd==-1)
        err_sys("accept error");
    return fd;
}
ssize_t Read(int fd,void *buf,size_t nbytes)
{
    int n;
    if((n=read(fd,buf,nbytes))==-1)
        err_sys("read error");
    return n; 
}
ssize_t Write(int fd,const void *buf,size_t nbytes)
{
    int n;
    if((n=write(fd,buf,nbytes))==-1)
        err_sys("write error");
    return n;
}

void str_echo(int sockfd)
{
    ssize_t n;
    char buf[MAXLINE];
again:
    while((n=read(sockfd,buf,MAXLINE))>0)
        Write(sockfd,buf,n);
    if(n < 0 && errno==EINTR)
        goto again;
    else if(n<0)
        err_sys("str_echo:read error");
}

char *Fgets(char *buf,int size,FILE *stream)
{
    if(fgets(buf,size,stream)==NULL)
        return NULL;
    return buf;
}
void Fputs(char *buf,FILE *stream)
{
    if(fputs(buf,stream)==-1)
        err_sys("fputs error");        
}
void str_cli(FILE *fp,int sockfd)
{
    char sendline[MAXLINE],recvline[MAXLINE];
    while(Fgets(sendline,MAXLINE,fp)!=NULL)
    {
        Write(sockfd,sendline,strlen(sendline));
        if(Read(sockfd,recvline,MAXLINE)==0)
            err_sys("str_cli:server terminated prematurely");
        Fputs(recvline,stdout);
    }
}

/*服务器程序*/
#include "unix.h"

char buf[124];
int main()
{
       int serv_fd,cli_fd;
       pid_t pro_cli;
        struct sockaddr_in serv_addr;
       serv_addr.sin_family=AF_INET;
       serv_addr.sin_port=htons(SERV_PORT);
       //Inet_pton(AF_INET,ip,&serv_addr.sin_addr.s_addr);
       serv_addr.sin_addr.s_addr=htonl(INADDR_ANY);
       serv_fd=Socket(AF_INET,SOCK_STREAM,0);
       Bind(serv_fd,&serv_addr,sizeof(serv_addr));
       Listen(serv_fd,9);
       struct sockaddr_in cliaddr;    
       socklen_t len=sizeof(cliaddr);
       while(1)
       {
          cli_fd=Accept(serv_fd,&cliaddr,&len);
           if((pro_cli=fork())==-1)
                   printf("fork error");
            else if(pro_cli==0)
         {
                str_echo(cli_fd);
                close(cli_fd);
         }
       }
       return 0;
}

/*客户端代码*/
#include "unix.h"
char buf[124];
int main()
{
    int fd;
    struct sockaddr_in addr;
    addr.sin_family=AF_INET;
    addr.sin_port=htons(SERV_PORT);
    Inet_pton(AF_INET,ip,&addr.sin_addr.s_addr);
    fd=Socket(AF_INET,SOCK_STREAM,0);
    Connect(fd,&addr,sizeof(addr));
    fgets(buf,sizeof(buf),stdin);
    Write(fd,buf,13);
    exit(0);
}