1. #include "hl.h"
    2. #include<pthread.h>
    3. void cli_data_handle(void *arg);
    5. int main (int argc,char **argv)
    6. {
    8.     int fd = -1;
    9.     struct sockaddr_in sin;
    11.     /* 1. 创建socket fd */
    12.     if ((fd = socket (AF_INET, SOCK_STREAM, 0)) < 0) {
    13.         perror ("socket");
    14.         exit (1);
    15.     }
    16.     int b_reuse = 1;
    17.     setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&b_reuse,sizeof(int));
    19.     /*2. 绑定 */
    20.     /*2.1 填充struct sockaddr_in结构体变量 */
    21.     bzero (&sin, sizeof (sin));
    22.     sin.sin_family = AF_INET;
    23.     sin.sin_port = htons (SERV_PORT);    //网络字节序的端口号
    25.     /*优化1: 让服务器程序能绑定在任意的IP上 */
    26. #if 1
    27.     sin.sin_addr.s_addr = htonl (INADDR_ANY);
    28. #else
    29.     if (inet_pton (AF_INET, SERV_IP_ADDR, (void *) &sin.sin_addr) != 1) {
    30.         perror ("inet_pton");
    31.         exit (1);
    32.     }
    33. #endif
    34.     /*2.2 绑定 */
    35.     if (bind (fd, (struct sockaddr *) &sin, sizeof (sin)) < 0) {
    36.         perror ("bind");
    37.         exit (1);
    38.     }
    40.     /*3. 调用listen()把主动套接字变成被动套接字 */
    41.     if (listen (fd, BACKLOG) < 0) {
    42.         perror ("listen");
    43.         exit (1);
    44.     }
    45.     printf ("Server starting....OK!\n");
    46.     int newfd = -1;
    47.     /*4. 阻塞等待客户端连接请求 */
    48.     //pthread_t
    49.     pthread_t tid;
    50.     struct sockaddr_in cin;
    51.     socklen_t addrlen = sizeof (cin);
    52.     while(1)
    53.     {
    54.         if ((newfd = accept (fd, (struct sockaddr *) &cin, &addrlen)) < 0) {
    55.             perror ("accept");
    56.             exit (1);
    57.         }
    59.         char ipv4_addr[16];
    60.         if (!inet_ntop (AF_INET, (void *) &cin.sin_addr, ipv4_addr, sizeof (cin))) {
    61.             perror ("inet_ntop");
    62.             exit (1);
    63.         }
    65.         printf ("Clinet(%s:%d) is connected!\n", ipv4_addr, htons (cin.sin_port));
    66.         pthread_create(&tid,NULL,(void *)cli_data_handle,(void *)&newfd);
    67.     }
    68.     close (fd);
    69.     return 0;
    70. }
    72. void cli_data_handle(void * arg)
    73. {
    74.     int newfd = *(int *)arg;
    76.     printf("handler thread:newfd=%d\n",newfd);
    77.     //..和newfd进行数据读写
    78.     int ret = -1;
    79.     char buf[BUFSIZ];
    80.     while (1) {
    81.         bzero (buf, BUFSIZ);
    82.         do {
    83.             ret = read (newfd, buf, BUFSIZ - 1);
    84.         } while (ret < 0 && EINTR == errno);
    85.         if (ret < 0) {
    87.             perror ("read");
    88.             exit (1);
    89.         }
    90.         if (!ret) {                //对方已经关闭
    91.             break;
    92.         }
    93.         printf ("Receive data: %s\n", buf);
    95.         if (!strncasecmp (buf, QUIT_STR, strlen (QUIT_STR))) {    //用户输入了quit字符
    96.             printf ("Client(fd=%d) is exiting!\n",newfd);
    97.             break;
    98.         }
    99.     }
    100.     close (newfd);
    101. }