一、客户端和服务端操作流程

1. 服务器端

socket() --> bind() --> listen() --> accept() --> recv() --> close()
创建socket --> 绑定socket和端口号 --> 监听端口号 --> 接收来自客户端的连接请求 --> 从socket中读取字符 --> 关闭socket

2. 客户端

socket() --> connect() --> send() --> close()
创建socket --> 连接指定服务器的IP/端口号 --> 向socket中写入信息 --> 关闭socket

二、代码

1. 服务器端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>#define MAXLINE 4096int main() {int listenfd, connfd;struct sockaddr_in servaddr;char buff[4096];int n;// 创建一个TCP的socketif ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {printf("create socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}// 先把地址清空，检测任意IPmemset(&servaddr, 0, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_addr.s_addr = htonl(INADDR_ANY);servaddr.sin_port = htons(6666);// 地址绑定到listenfdif (bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1) {printf("bind socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}// 监听listenfdif (listen(listenfd, 10) == -1) {printf("listen socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}printf("====waiting for client's request=======\n");// accept和recv,注意接收字符串添加结束符'\0'while(1) {if ((connfd = accept(listenfd, (struct sockaddr *)NULL, NULL))  == -1) {printf("accpt socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}n = recv(connfd, buff, MAXLINE, 0);buff[n] = '\0';printf("recv msg from client:%s\n", buff);close(connfd);}close(listenfd);return 0;}

2. 客户端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>#define MAXLINE 4096int main(int argc, char **argv) {int sockfd, n;char recvline[4096], sendline[4096];struct sockaddr_in servaddr;if (argc != 2) {printf("usage: ./client <ipaddress>\n");return 0;}// 创建socketif ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {printf("create socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}memset(&servaddr, 0, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons(6666);// IP地址从“点分十进制”转换到“二进制整肃”if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) {printf("inet_pton error for %s\n", argv[1]);return 0;}// 连接if (connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) <0) {printf("connect socket error: %s(errno :%d)\n", strerror(errno), errno);return 0;}printf("send msg to server:\n");fgets(sendline, 4096, stdin);// send发送if (send(sockfd, sendline, strlen(sendline), 0) < 0) {printf("send msg error: %s(errno :%d)\n", strerror(errno), errno);return 0;}close(sockfd);return 0;}

3. 运行

g++ server.cpp -o server
g++ client.cpp -o client

分别打开两个终端窗口

（1）一个执行./server命令

（2）一个执行./client 1227.0.0.1命令

三、错误记录

在调试过程中发现错误：

socket error: Socket operation on non-socket(errno: 88)

经过仔细分析发现：

if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)

是优先级出现了问题，这里必须先复制，之后进行关系运算符的比较。

本文风格的代码非常容易在这里犯错误，特此记录。

四、多线程并发服务器

多线程和多进程的处理方式类似，都是创建一个新的线程，客户端有请求时，用新创建的线程处理。

这里参考文章：https://blog.csdn.net/taiyang1987912/article/details/49562909，对代码进行模块化封装。

和上文相比，将客户端修改为循环发送，直至输入q退出。

犯的一个错误是服务器printf打印忘记加\n，导致没有刷新缓冲区，只有客户端每次端开链接时才打印，汗~

1. 服务器端

// 使用pthread线程库
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>#define PORT 6666            // 服务器端口
#define BACKLOG 5            // listen队列等待的连接数
#define MAXDATASIZE 1024     // 缓冲区大小void process_cli(int connectfd, struct sockaddr_in client);    // 客户端请求处理函数
void* start_routine(void* arg);        // 线程函数typedef struct _ARG {int connfd;struct sockaddr_in client;
} ARG;                    	 // 客户端结构体void sys_err(const char * ptr_err) {perror(ptr_err);exit(EXIT_FAILURE);
}// 处理客户端链接的接收工作
void accept_conn(int listenfd) {int connectfd;       		   // socket描述符pthread_t connectthread;	   // 线程体变量ARG *arg;                     // 客户端结构体变量struct sockaddr_in client;    // 客户端地址信息结构体int sin_size = sizeof(struct sockaddr_in);while(1) {// 调用accept，返回与服务器连接的客户端描述符if ((connectfd = accept(listenfd, (struct sockaddr *)&client, (socklen_t *)&sin_size)) == -1) {sys_err("accept() error\n");}arg = new ARG;arg->connfd = connectfd;memcpy(&arg->client, &client, sizeof(client));// 创建线程，以客户端连接为参数，start_routine为线程执行函数if (pthread_create(&connectthread, NULL, start_routine, (void*)arg)) {sys_err("Pthread_create() error");}}}void tcp_server(uint16_t port) {int listenfd;				   // socket描述符struct sockaddr_in server;     // 服务器地址信息结构体// 调用socket，创建监听客户端的socketif ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {sys_err("Creating socket failed.");}// 设置socket属性，端口可以重用int opt = SO_REUSEADDR;setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));// 初始化服务器地址结构体bzero(&server, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(PORT);server.sin_addr.s_addr = htonl(INADDR_ANY);// 调用bind，绑定地址和端口if (bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) {sys_err("Bind error.");}// 调用listen，开始监听if (listen(listenfd,BACKLOG) == -1) {sys_err("listen() error\n");}// 处理客户端链接的接收工作accept_conn(listenfd);// 关闭监听socketclose(listenfd);}int main() {uint16_t port = 6666;tcp_server(port);
}void process_cli(int connectfd, sockaddr_in client) {int num;char recvbuf[MAXDATASIZE], sendbuf[MAXDATASIZE], cli_name[MAXDATASIZE];printf("You got a connection from %s.  \n", inet_ntoa(client.sin_addr));// MSG_WAITALLwhile ((num = recv(connectfd, recvbuf, MAXDATASIZE, 0)) > 0) {recvbuf[num] = '\0';printf("Received size( %d ) message: %s\n", num, recvbuf);}/* num = recv(connectfd, cli_name, MAXDATASIZE, 0);if (num == 0) {close(connectfd);return;}cli_name[num - 1] = '\0';printf("Client's content is: %s\n", cli_name);while (num = recv(connectfd, recvbuf, MAXDATASIZE, 0)) {recvbuf[num] = '\0';printf("Received client( %s ) message: %s", cli_name, recvbuf);for (int i = 0; i < num - 1; i ++) {sendbuf[i] = recvbuf[num - i -2];}sendbuf[num - 1] = '\0';send(connectfd, sendbuf, strlen(sendbuf), 0);}*/printf("Client disconnected.\n");close(connectfd);}void* start_routine(void* arg) {ARG *info = (ARG *)arg;process_cli(info->connfd, info->client);// 删除对应的堆内存delete info;pthread_exit(NULL);
}

2. 客户端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>#define MAXLINE 4096int main(int argc, char **argv) {int sockfd, n;char recvline[4096], sendline[4096];struct sockaddr_in servaddr;if (argc != 2) {printf("usage: ./client <ipaddress>\n");return 0;}// 创建socketif ((sockfd = socket(AF_INET,SOCK_STREAM, 0)) == -1) {printf("create socket error: %s (errno :%d)\n", strerror(errno), errno);return 0;}memset(&servaddr, 0, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons(6666);// IP地址从“点分十进制”转换到“二进制整肃”if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) {printf("inet_pton error for %s\n", argv[1]);return 0;}// 连接if (connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0) {printf("connect socket error: %s(errno :%d)\n", strerror(errno), errno);return 0;}printf("send msg to server:\n");while(1) {fgets(sendline,sizeof(sendline),stdin);sendline[strlen(sendline)-1] = '\0';if (strncasecmp(sendline, "q", 1) == 0) {printf("quit\n");break;}// send发送
//      if (send(sockfd, sendline, strlen(sendline), 0) < 0) {
//          printf("send msg error: %s(errno :%d)\n", strerror(errno), errno);
//          return 0;
//      }int sentbytes = send(sockfd, sendline, strlen(sendline), 0);printf("sent:%d\n", sentbytes);// bzero(sendline, strlen(sendline));}close(sockfd);return 0;}