2. /*./client unix_domain_file */
    3. #include "net.h"
    5. void usage (char *s)
    6. {
    7.     printf ("\n%s unix_domain_file\n\n", s);
    8. }
    10. int main (int argc, char **argv)
    11. {
    12.     int fd = -1;
    14.     int port = -1;
    15.     struct sockaddr_un sun;
    17.     if (argc != 2) {
    18.         usage (argv[0]);
    19.         exit (1);
    20.     }
    21.     /* 1. 创建socket fd */
    22.     if ((fd = socket (AF_LOCAL, SOCK_STREAM, 0)) < 0) {
    23.         perror ("socket");
    24.         exit (1);
    25.     }
    27.     /*2.连接服务器 */
    29.     /*2.1 填充struct sockaddr_un结构体变量 */
    30.     bzero (&sun, sizeof (sun));
    32.     sun.sun_family = AF_LOCAL;
    35.     /*确保UNIX_DOMAIN_FILE要先存在并且可写，不存在则退出 */
    36.     if( access(UNIX_DOMAIN_FILE, F_OK| W_OK) < 0){
    37.         exit(1);
    38.     }
    39.     strncpy(sun.sun_path, UNIX_DOMAIN_FILE, strlen( UNIX_DOMAIN_FILE));
    42.     if (connect (fd, (struct sockaddr *) &sun, sizeof (sun)) < 0) {
    43.         perror ("connect");
    44.         exit (1);
    45.     }
    47.     printf ("Unix domain Client staring...OK!\n");
    49.     int ret = -1;
    50.     fd_set rset;
    51.     int maxfd = -1;
    52.     struct timeval tout;
    53.     char buf[BUFSIZ];
    55.     while (1) {
    56.         FD_ZERO (&rset);
    57.         FD_SET (0, &rset);
    58.         FD_SET (fd, &rset);
    59.         maxfd = fd;
    61.         tout.tv_sec = 5;
    62.         tout.tv_usec = 0;
    64.         select (maxfd + 1, &rset, NULL, NULL, &tout);
    65.         if (FD_ISSET (0, &rset)) {    //标准键盘上有输入
    66.             //读取键盘输入，发送到网络套接字fd
    67.             bzero (buf, BUFSIZ);
    68.             do {
    69.                 ret = read (0, buf, BUFSIZ - 1);
    70.             } while (ret < 0 && EINTR == errno);
    71.             if (ret < 0) {
    72.                 perror ("read");
    73.                 continue;
    74.             }
    75.             if (!ret)
    76.                 continue;
    78.             if (write (fd, buf, strlen (buf)) < 0) {
    79.                 perror ("write() to socket");
    80.                 continue;
    81.             }
    83.             if (!strncasecmp (buf, QUIT_STR, strlen (QUIT_STR))) {    //用户输入了quit字符
    84.                 printf ("Client is exiting!\n");
    85.                 break;
    86.             }
    87.         }
    89.         if (FD_ISSET (fd, &rset)) {    //服务器给发送过来了数据
    90.             //读取套接字数据，处理
    91.             bzero (buf, BUFSIZ);
    92.             do {
    93.                 ret = read (fd, buf, BUFSIZ - 1);
    94.             } while (ret < 0 && EINTR == errno);
    95.             if (ret < 0) {
    96.                 perror ("read from socket");
    97.                 continue;
    98.             }
    99.             if (!ret)
    100.                 break;            /* 服务器关闭 */
    102.             //There is a BUG,FIXME!!
    103.             printf ("server said: %s\n", buf);
    104.             if ((strlen(buf) > strlen(SERV_RESP_STR)) 
    105.                 && !strncasecmp (buf+strlen(SERV_RESP_STR), QUIT_STR, strlen (QUIT_STR))) {    //用户输入了quit字符
    106.                 printf ("Sender Client is exiting!\n");
    107.                 break;
    108.             }
    110.         }
    111.     }
    113.     /*4.关闭套接字 */
    114.     close (fd);
    115. }