Linux网络编程：socket实现client/server通信

一、问题引入

阅读UNIX网络编程 卷1：套接字联网API 第3版的前4个章节，觉得有必要对书籍上的源码案例进行复现，并推敲TCP的C/S通信过程。
二、解决过程

2-1 server

1. #include <sys/types.h>
2. #include <sys/socket.h>
3. #include <stdio.h>
4. #include <netinet/in.h>
5. #include <arpa/inet.h>
6. #include <unistd.h>
7. #include <string.h>
8. #include <stdlib.h>
9. #include <fcntl.h>
10. #include <sys/shm.h>
12. #define PORT 8887
13. #define QUEUE 20
14. #define BUFFER_SIZE 1024
16. int main()
17. {
18.     // 定义sockfd, AF_INET:IPv4协议，SOCK_STREAM：字节流套接字
19.     int server_sockfd = socket(AF_INET, SOCK_STREAM, 0);
21.     // 定义sockaddr_in
22.     struct sockaddr_in server_sockaddr;
23.     server_sockaddr.sin_family = AF_INET;
24.     server_sockaddr.sin_port = htons(PORT);
25.     server_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);
27.     // bind，成功返回0，出错返回-1
28.     if (bind(server_sockfd, (struct sockaddr *)&server_sockaddr, sizeof(server_sockaddr)) == -1)
29.     {
30.         perror("bind failure");
31.         exit(1);
32.     }
34.     // listen，成功返回0，出错返回-1
35.     if (listen(server_sockfd, QUEUE) == -1)
36.     {
37.         perror("listen failure");
38.         exit(1);
39.     }
41.     // 客户端套接字
42.     char buffer[BUFFER_SIZE];
43.     struct sockaddr_in client_addr;
44.     socklen_t length = sizeof(client_addr);
46.     // 成功返回非负描述字，出错返回-1
47.     // accept()被阻塞，等待客户端连接，一旦客户端和服务器完成TCP三次握手，accept()返回一个已连接描述值
48.     int conn = accept(server_sockfd, (struct sockaddr *)&client_addr, &length);
49.     if (conn < 0)
50.     {
51.         perror("connect failure");
52.         exit(1);
53.     }
55.     printf("**************************\n");
56.     printf("accept successful !!!\n");
57.     char ipbuf[64] = {0};
58.     printf("client || ip: %s, port: %d\n",
59.            inet_ntop(AF_INET, &client_addr.sin_addr.s_addr, ipbuf, sizeof(ipbuf)),
60.            ntohs(client_addr.sin_port));
61.     printf("**************************\n");
62.     while (1)
63.     {
64.         memset(buffer, 0, sizeof(buffer));
65.         // 接收
66.         int len = recv(conn, buffer, sizeof(buffer), 0);
67.         if (strcmp(buffer, "exit") == 0 || strcmp(buffer, "q") == 0)
68.             break;
69.         if(len > 0)
70.         {
71.             printf("Recv:%s (%d Byte)\n", buffer, strlen(buffer));
72.         }
73.     }
74.     close(conn);
75.     close(server_sockfd);
76.     return 0;
77. }

复制代码

2-2 client

1. #include <sys/types.h>
2. #include <sys/socket.h>
3. #include <stdio.h>
4. #include <netinet/in.h>
5. #include <arpa/inet.h>
6. #include <unistd.h>
7. #include <string.h>
8. #include <stdlib.h>
9. #include <fcntl.h>
10. #include <sys/shm.h>
12. #define PORT 8887
13. #define BUFFER_SIZE 1024
15. int main()
16. {
17.     int sockfd = socket(AF_INET, SOCK_STREAM, 0);
18.     struct sockaddr_in servaddr;
19.     memset(&servaddr, 0, sizeof(servaddr));
20.     servaddr.sin_family = AF_INET;
21.     servaddr.sin_port = htons(PORT);
22.     servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");
23.     /// 连接服务器，成功返回0，错误返回-1
24.     if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)
25.     {
26.         perror("connect");
27.         exit(1);
28.     }
29.     printf("**************************\n");
30.     printf("connect successful !!!\n");
31.     char ipbuf[64] = {0};
32.     printf("server || ip: %s, port: %d\n",
33.            inet_ntop(AF_INET, &servaddr.sin_addr.s_addr, ipbuf, sizeof(ipbuf)),
34.            ntohs(servaddr.sin_port));
35.     printf("now you can send message to server\n");
36.     printf("**************************\n");
37.     char sendbuf[BUFFER_SIZE];
38.     while (fgets(sendbuf, sizeof(sendbuf), stdin) != NULL)
39.     {
40.         if(sendbuf[strlen(sendbuf)-1] == '\n')
41.             sendbuf[strlen(sendbuf)-1] = '\0';
42.         // 发送
43.         send(sockfd, sendbuf, strlen(sendbuf), 0);
44.         if (strcmp(sendbuf, "exit") == 0 || strcmp(sendbuf, "q") == 0)
45.             break;
46.         memset(sendbuf, 0, sizeof(sendbuf));
47.     }
48.     close(sockfd);
49.     return 0;
50. }

复制代码

2-3 编译和运行测试



免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！