p12-20.c

SUN Solaris8平台下进程间通信

#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/select.h>
#include <sys/time.h>
#include <stdio.h>
int main(int argc,char **argv)
{
    int listenfd, connfd, n, justreadoob = 0;
    char buff[100];
    fd_set rset, xset;
    /* 检查参数并建立侦听套接字 */
    if(argc == 2) 
        listenfd = socket_listen(NULL,argv[1],NULL);
    else if(argc == 3)
        listenfd = socket_listen(argv[1],argv[2],NULL);
    else {
        printf("Usage: a.out <host> <port#>\n");
        exit(1);
    }
    /* 接收连接 */
    connfd = accept(listenfd, NULL, NULL);
     /* 描述字集合清空 */
    FD_ZERO(&rset);
    FD_ZERO(&xset);
    while(1){
        /* 将connfd加至描述字集合 */
        FD_SET(connfd,&rset);
        if (justreadoob == 0)
             FD_SET(connfd,&xset);
         /* 等待描述字connfd读就绪或出现例外条件，rset给出读就绪描述字，xset给出例外描述字 */  
        select(connfd+1, &rset, NULL, &xset, NULL);
        if (FD_ISSET(connfd, &xset)){ /* connfd出现例外，意味到达带外数据 */
        /* 读带外数据 */
            n = recv(connfd,buff,sizeof(buff-1,MSG_OOB));
            buff[n] = 0;
            printf("received %d OOB byte: %s\n",n,buff);
            justreadoob = 1;
            FD_CLR(connfd,&xset);  
        }
        if (FD_ISSET(connfd, &rset)){ /* connf读就绪 */
            if ((n = read(connfd, buff, sizeof(buff)-1)) == 0){
                printf("received EOF\n");
                exit(0);
            }
            buff[n] = 0;  /* 结束终止符 */
            printf("read %d bytes: %s\n",n,buff);
            justreadoob = 0;
        }
    }
}