⭐ 欢迎来到虫虫下载站！ | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站
📤 上传资源

📄 83.htm

📁 unix高级编程原吗
💻 HTM
字号:
🔍 
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312">
<title>CTerm非常精华下载</title>
</head>
<body bgcolor="#FFFFFF">
<table border="0" width="100%" cellspacing="0" cellpadding="0" height="577">
<tr><td width="32%" rowspan="3" height="123"><img src="DDl_back.jpg" width="300" height="129" alt="DDl_back.jpg"></td><td width="30%" background="DDl_back2.jpg" height="35"><p align="center"><a href="http://apue.dhs.org"><font face="黑体"><big><big>123</big></big></font></a></td></tr>
<tr>
<td width="68%" background="DDl_back2.jpg" height="44"><big><big><font face="黑体"><p align="center">               ● UNIX网络编程                       (BM: clown)                </font></big></big></td></tr>
<tr>
<td width="68%" height="44" bgcolor="#000000"><font face="黑体"><big><big><p   align="center"></big></big><a href="http://cterm.163.net"><img src="banner.gif" width="400" height="60" alt="banner.gif"border="0"></a></font></td>
</tr>
<tr><td width="100%" colspan="2" height="100" align="center" valign="top"><br><p align="center">[<a href="index.htm">回到开始</a>][<a href="54.htm">上一层</a>][<a href="84.htm">下一篇</a>]
<hr><p align="left"><small>发信人: clown (梧桐叶), 信区: UNP <br>

标  题: 使用非阻塞connect函数的回射客户，服务器程序 <br>

发信站: UNIX编程 (2001年09月24日21:38:05 星期一), 站内信件 <br>

  <br>

//server <br>

#include <netinet/in.h> <br>

#include <sys/types.h> <br>

#include <sys/socket.h> <br>

#include <string.h> <br>

#include <signal.h> <br>

#include <sys/wait.h> <br>

  <br>

#define SERV_PORT 8000 <br>

  <br>

void sig_chld(int signo); <br>

void str_echo(int sockfd); <br>

  <br>

int main() <br>

{ <br>

    int listenfd, connfd; <br>

    pid_t childpid; <br>

    socklen_t clilen; <br>

    struct sockaddr_in cliaddr, servaddr; <br>



    int optval, optlen; <br>

    if((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { <br>

        printf("create socket error\n"); <br>

        exit(1); <br>

    } <br>

    memset(&servaddr, 0, sizeof(servaddr)); <br>

    servaddr.sin_family = AF_INET; <br>

    servaddr.sin_port = htons(SERV_PORT); <br>

    servaddr.sin_addr.s_addr = htonl(INADDR_ANY); <br>

  <br>

    optval = 1; <br>

    optlen = sizeof(int); <br>

    if(setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, (const void *)&optval,  o <br>

ptlen) == -1) { <br>

        printf("setsockopt error\n"); <br>

        exit(1); <br>

    } <br>

  <br>

    if(bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) { <br>

        printf("bind error\n"); <br>

        exit(1); <br>

    } <br>

    } <br>

    if(listen(listenfd, 5) < 0) { <br>

        printf("listen error\n"); <br>

        exit(1); <br>

    } <br>

    signal(SIGCHLD, sig_chld); <br>

    for( ; ; ) { <br>

        clilen = sizeof(cliaddr); <br>

        if((connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen)) < 0 <br>

) <br>

{ <br>

            printf("accept error\n"); <br>

            exit(1); <br>

        } <br>

        if((childpid = fork()) == 0) {  //child process <br>

            close(listenfd); <br>

            str_echo(connfd); <br>

            exit(0); <br>

        } <br>

        close(connfd);  //parent process <br>

    } <br>

    close(listenfd); <br>

    return 0; <br>

    return 0; <br>

} <br>

  <br>

void str_echo(int sockfd) <br>

{ <br>

    ssize_t n; <br>

    char line[32]; <br>

    for( ; ; ) { <br>

        if((n = recv(sockfd, line, 31, 0)) == 0) <br>

            return; //connection closed <br>

        else if( n < 0) { <br>

            printf("receive error\n"); <br>

            return; <br>

        } <br>

        line[n] = '\0'; <br>

        printf("%s", line); <br>

        if(send(sockfd, line, strlen(line), 0) < 0) { <br>

            printf("send error\n"); <br>

            return; <br>

        } <br>

    } <br>

} <br>

  <br>

  <br>

void sig_chld(int signo) <br>

{ <br>

    pid_t pid; <br>

    int stat; <br>

    while((pid = waitpid(-1, &stat, WNOHANG)) > 0) <br>

        printf("child %d terminated\n", pid); <br>

    return; <br>

} <br>

  <br>

//*************************************************// <br>

//clinet <br>

#include <fcntl.h> <br>

#include <unistd.h> <br>

#include <errno.h> <br>

#include <stdio.h> <br>

#include <netinet/in.h> <br>

#include <arpa/inet.h> <br>

#include <sys/types.h> <br>

#include <sys/socket.h> <br>

#include <string.h> <br>

#include <sys/select.h> <br>

#include <sys/time.h> <br>



#define PORT 8000 <br>

  <br>

int nonb_connect(int sockfd, const struct sockaddr *saddr, int slen, int nse <br>

c) <br>

//该函数中的nsec为connect的超时时间，单位为微秒 <br>

  <br>

{ <br>

    int n, error, len; <br>

    long flags; <br>

    fd_set rset, wset; <br>

    struct timeval tval; <br>

    error = 0; <br>

    if((flags = fcntl(sockfd, F_GETFL, 0)) < 0) { <br>

        printf("get file control error\n"); <br>

        return -1; <br>

    } <br>

    if(fcntl(sockfd, F_SETFL, flags | O_NONBLOCK) < 0) { <br>

        printf("set file control error\n"); <br>

        return -1; <br>

    } <br>

    if((n = connect(sockfd, saddr, slen)) == 0) { <br>

        //connect succeed immidiately <br>



        fcntl(sockfd, F_SETFL, flags); <br>

        return 0; <br>

    } else { <br>

        if(errno != EINPROGRESS) { <br>

            printf("nonblock connect error\n"); <br>

            return -1; <br>

        } <br>

        //do whatever you want to deal with <br>

        FD_ZERO(&rset); <br>

        FD_ZERO(&wset); <br>

        FD_SET(sockfd, &rset); <br>

        FD_SET(sockfd, &wset); <br>

        tval.tv_sec = 0; <br>

        tval.tv_usec = nsec; <br>

        if(select(sockfd+1, &rset, &wset, NULL, nsec ? &tval : NULL) == 0) { <br>

            //timeout <br>

            close(sockfd); <br>

            printf("connect time out\n"); <br>

            errno = ETIMEDOUT; <br>

            return -1; <br>

        } <br>

        //connect succeed? <br>



        if(FD_ISSET(sockfd, &rset) || FD_ISSET(sockfd, &wset)) { <br>

            len = sizeof(error); <br>

            if(getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &error, &len) < 0) { <br>

                printf("connection failed, Linux is the same as Solaris but not <br>

Berkeley <br>

\n"); <br>

                errno = error; <br>

                return -1; <br>

            } <br>

        } else { <br>

            printf("select error: sockfd not set\n"); <br>

            return -1; <br>

        } <br>

    } <br>

    fcntl(sockfd, F_SETFL, flags); <br>

    if(error) { //set in getsockopt, is connection failed? <br>

        close(sockfd); <br>

        printf("connection failed, Linux is the same as Berkeley but not Solaris <br>

\n <br>

"); <br>

        errno = error; <br>

        return -1; <br>



    } <br>

    return 0; <br>

} <br>

  <br>

void str_cli(FILE *fp, int sockfd) <br>

{ <br>

    int maxfd1; <br>

        fd_set rset; <br>

        char sendline[32], recvline[32]; <br>

        int n; <br>

  <br>

            FD_ZERO(&rset); <br>

        for( ; ;) { <br>

        FD_SET(fileno(fp), &rset); <br>

                FD_SET(sockfd, &rset); <br>

                maxfd1 = fileno(fp) > sockfd ? fileno(fp)+1 : sockfd+1; <br>

                if(select(maxfd1, &rset, NULL, NULL, NULL) > 0) { <br>

            if(FD_ISSET(sockfd, &rset)) {  //socket is readable <br>

                            if((n = recv(sockfd, recvline, 31, 0)) == 0) { <br>

                    printf("socket closed\n"); <br>

                    return; <br>

                } else if( n < 0) { <br>



                    printf("recv error\n"); <br>

                    return; <br>

                } <br>

                recvline[n] = '\0'; <br>

                fputs(recvline, stdout); <br>

            } <br>

            if(FD_ISSET(fileno(fp), &rset)) {  //input is readable <br>

                if(fgets(sendline, 32, fp) != NULL) { <br>

                    if(send(sockfd, sendline, strlen(sendline), 0) < 0) { <br>

                        printf("send error\n"); <br>

                        return; <br>

                    } <br>

                } else { <br>

                    printf("send end, return.\n"); <br>

                    return; <br>

                } <br>

            } <br>

        }  //end of select <br>

    }  //end of for <br>

} <br>

  <br>

int main(int argc, char **argv) <br>



{ <br>

        int i, sockfd, nsec; <br>

        struct sockaddr_in servaddr; <br>

    if(argc != 3) { <br>

        printf("usage: %s <ip> <mircosecond>\n", argv[0]); <br>

        exit(1); <br>

    } <br>

  <br>

    nsec = atoi(argv[2]); <br>

    printf("timeout: %d\n", nsec); <br>

    errno = 0; <br>

    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { <br>

        printf("create socket error\n"); <br>

                exit(1); <br>

        } <br>

        memset(&servaddr, 0, sizeof(servaddr)); <br>

        servaddr.sin_family = AF_INET; <br>

    if(inet_pton(AF_INET, argv[1], &servaddr.sin_addr) == 0) { <br>

        printf("%s is not valid ip address\n", argv[1]); <br>

        exit(1); <br>

    } <br>

    servaddr.sin_port = htons(PORT); <br>



        if(nonb_connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servadd <br>

r), nsec) < 0) { <br>

         perror("nonb_connect"); <br>

             exit(1); <br>

        } <br>

        printf("connect succeed\n"); <br>

    str_cli(stdin, sockfd); <br>

    close(sockfd); <br>

    return 0; <br>

} <br>

  <br>

执行结果： <br>

//The server is closed, so connect will fail surely. :) <br>

timeout: 100 <br>

connection failed, Linux is the same as Berkeley but not Solaris <br>

nonb_connect: Connection refused <br>

  <br>

  <br>

-- <br>

易朽的是生命，似那转瞬即谢的花朵；然而永存的，是对未来的渴望， <br>

是那生生世世传递下来的，不朽的，生的激情。每一朵勇敢开放的花， <br>

都是一个死亡唇边的微笑。 <br>



※ 修改:·clown 於 09月24日21:39:46 修改本文·[FROM: 211.69.205.23] <br>

※ 来源:·UNIX编程 www.tiaozhan.com/unixbbs/·[FROM: 211.69.205.23] <br>

</small><hr>
<p align="center">[<a href="index.htm">回到开始</a>][<a href="54.htm">上一层</a>][<a href="84.htm">下一篇</a>]
<p align="center"><a href="http://cterm.163.net">欢迎访问Cterm主页</a></p>
</table>
</body>
</html>

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -