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

accept函数_TCP/IP编程之accept函数详解#include <sys/socket.h> int accept(int sockfd,struct sockaddr *cliaddr,socklen_t *addrlen); 返回:若成功返回非负描述符,若出错则返回-1 参数cliaddr和addrlen用来返回已连接的对端(客

#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); }

 

服务器运行:

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

客户连接服务器,服务器把客户发送的字符串回射给客户,并输出

(回射代码部分有问题,所以出现了?的那一行)

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

 

 

 

  

今天的文章accept函数_TCP/IP编程之accept函数详解分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:http://bianchenghao.cn/49834.html

(0)
编程小号编程小号
上一篇 2023-09-02 19:06
下一篇 2023-09-02 19:11

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注