C/S架构学习之TCP服务器

• TCP服务器的实现流程：
• 一、创建套接字（socket函数）：
• 通信域选择IPV4网络协议、套接字类型选择流式；

	int sockfd = socket(AF_INET,SOCK_STREAM,0); //通信域选择IPV4、套接字类型选择流式
1

• 二、填充服务器的网络信息结构体：
• 1.定义网络信息结构体变量；
• 2.求出结构体变量的内存空间大小；
• 3.结构体清零；
• 4.使用IPV4网络协议；
• 5.预留给在终端输入的网络字节序的端口号；
• 6.预留给在终端输入的IP地址；

	struct sockaddr_in serveraddr; //定义网络信息结构体变量
    socklen_t serveraddrlen = sizeof(serveraddr);//求出结构体变量的内存空间大小

    memset(&serveraddr,0,serveraddrlen); //结构体清零

    serveraddr.sin_family = AF_INET;  //使用IPV4网络协议
    serveraddr.sin_addr.s_addr = inet_addr(argv[1]);  //IP地址
    serveraddr.sin_port = htons(atoi(argv[2]));//网络字节序的端口号
1
2
3
4
5
6
7
8

• 三、套接字和服务器的网络信息结构体进行绑定（bind函数）：

	int ret = bind(sockfd,(struct sockaddr *)&serveraddr,serveraddrlen);
1

• 四、套接字设置成被动监听（listen函数）：

	int ret1 = listen(sockfd, 5);
1

• 五、阻塞等待客户端的连接（accept函数）：

	int acceptfd = accept(sockfd, (struct sockaddr *)&clientaddr, &clientaddr_len);
1

• 六、接收来自客户端的数据（recv函数）和给客户端发送应答消息（send函数）：

	int nbytes = recv(acceptfd,buf,sizeof(buf),0);
	printf("客户端发来数据[%s]\n",buf);
	
	strcat(buf,"----k"); //组装应答消息
	int ret2 = send(acceptfd,buf,sizeof(buf),0);
1
2
3
4
5

• 七、关闭套接字（close函数）：

	close(acceptfd);
	close(sockfd);
1
2

• 综合应用实例代码如下所示：

//tcp服务器

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 

#define ERRLOG(msg) do{\
                        printf("%s:%s:%d\n", __FILE__, __func__, __LINE__);\
                        perror(msg);\
                        exit(-1);\
                }while(0)
                
int main(int argc, char const *argv[])
{
    //入参合理性检查
    if(3 != argc)
    {
        printf("Usage : %s  \n",argv[0]);
        exit(-1);
    }

    //创建套接字
    int sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(-1 == sockfd)
    {
        ERRLOG("socket error");
    }
    printf("sockfd = %d\n",sockfd);

    //填充服务器网络信息结构体

    struct sockaddr_in serveraddr;
    socklen_t serveraddrlen = sizeof(serveraddr);

    memset(&serveraddr,0,serveraddrlen);

    serveraddr.sin_family = AF_INET;
    serveraddr.sin_addr.s_addr = inet_addr(argv[1]);
    serveraddr.sin_port = htons(atoi(argv[2]));

    
    //将套接字与服务器网络信息结构体绑定
    if(-1 == bind(sockfd,(struct sockaddr *)&serveraddr,serveraddrlen))
    {
        ERRLOG("bind error");
    }

    //将套接字设置成被监听状态
    if(-1 == listen(sockfd,5))
    {
        ERRLOG("listen error");
    }

    //定义一个结构体来保存客户端的信息
    struct sockaddr_in clientaddr;
    memset(&clientaddr,0,sizeof(clientaddr));
    socklen_t clientaddr_len = sizeof(clientaddr);

    int acceptfd = 0;
    char buf[128] = {0};
    int nbytes = 0;

    while(1)
    {
        printf("正在等待客户机连接服务器\n");

        //阻塞等待客户机连接
        if(-1 == (acceptfd = accept(sockfd,(struct sockaddr *)&clientaddr,&clientaddr_len)))
        {
            ERRLOG("accept error");
        }
        printf("客户端[%s:%d]连接到了服务器\n",inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port));

        //收发数据
        while(1)
        {
            memset(buf,0,sizeof(buf));
            if(-1 == (nbytes = recv(acceptfd,buf,128,0)))
            {
                ERRLOG("recv error");
            }else if(0 == nbytes){

                printf("客户端[%s:%d]断开了服务器\n",inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port));
                break;

            }
            if(!strncmp(buf,"quit",4))
            {
                printf("客户端[%s:%d]退出了\n",inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port));
                break;
            }
            printf("客户端[%s:%d]发来数据[%s]\n",inet_ntoa(clientaddr.sin_addr),ntohs(clientaddr.sin_port),buf);
            //组装应答消息
            strcat(buf,"----k");
            //给客户端发送应答消息
            if(-1 == send(acceptfd,buf,sizeof(buf),0))
            {
                ERRLOG("send error");
            }

        }
        close(acceptfd);
    }
    //关闭套接字
    close(sockfd);

    return 0;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

• 本示例代码，仅供参考；