多线程做事器是对多进程做事器的改进，由于多进程做事器在创建进程时要花费较大的系统资源，以是用线程来取代进程，这样做事处理程序可以较快的创建。据统计，创建线程与创建进程要快 10100 倍，以是又把线程称为“轻量级”进程。线程与进程不同的是：一个进程内的所有线程共享相同的全局内存、全局变量等信息，这种机制又带来了同步问题。
tcp多线程并发做事器框架:
我们在利用多线程并发做事器时，直策应用以上框架，我们仅仅修正client_fun()里面的内容。
代码示例：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
/
函数名称： void client_fun(void arg)
函数功能： 线程函数,处理客户信息
函数参数： 已连接套接字
函数返回： 无
/
void client_fun(void arg)
{
int recv_len = 0;
char recv_buf[1024] = ""; // 吸收缓冲区
int connfd = (int)arg; // 传过来的已连接套接字
// 吸收数据
while((recv_len = recv(connfd, recv_buf, sizeof(recv_buf), 0)) > 0)
{
printf("recv_buf: %s\n", recv_buf); // 打印数据
send(connfd, recv_buf, recv_len, 0); // 给客户端回数据
}
printf("client closed!\n");
close(connfd); //关闭已连接套接字
return NULL;
}
//===============================================================
// 语法格式： void main(void)
// 实现功能： 主函数，建立一个TCP并发做事器
// 入口参数： 无
// 出口参数： 无
//===============================================================
int main(int argc, char argv[])
{
int sockfd = 0; // 套接字
int connfd = 0;
int err_log = 0;
struct sockaddr_in my_addr; // 做事器地址构造体
unsigned short port = 8080; // 监听端口
pthread_t thread_id;
printf("TCP Server Started at port %d!\n", port);
sockfd = socket(AF_INET, SOCK_STREAM, 0); // 创建TCP套接字
if(sockfd < 0)
{
perror("socket error");
exit(-1);
}
bzero(&my_addr, sizeof(my_addr)); // 初始化做事器地址
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(port);
my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
printf("Binding server to port %d\n", port);
// 绑定
err_log = bind(sockfd, (struct sockaddr)&my_addr, sizeof(my_addr));
if(err_log != 0)
{
perror("bind");
close(sockfd);
exit(-1);
}
// 监听，套接字变被动
err_log = listen(sockfd, 10);
if( err_log != 0)
{
perror("listen");
close(sockfd);
exit(-1);
}
printf("Waiting client...\n");
while(1)
{
char cli_ip[INET_ADDRSTRLEN] = ""; // 用于保存客户端IP地址
struct sockaddr_in client_addr; // 用于保存客户端地址
socklen_t cliaddr_len = sizeof(client_addr); // 必须初始化!!!
//得到一个已经建立的连接 connfd = accept(sockfd, (struct sockaddr)&client_addr, &cliaddr_len);
if(connfd < 0)
{
perror("accept this time");
continue;
}
// 打印客户真个 ip 和端口
inet_ntop(AF_INET, &client_addr.sin_addr, cli_ip, INET_ADDRSTRLEN);
printf("----------------------------------------------\n");
printf("client ip=%s,port=%d\n", cli_ip,ntohs(client_addr.sin_port));
if(connfd > 0)
{
//由于同一个进程内的所有线程共享内存和变量，因此在通报参数时需作分外处理，值通报。
pthread_create(&thread_id, NULL, (void )client_fun, (void )connfd); //创建线程
pthread_detach(thread_id); // 线程分离，结束时自动回收资源
}
}
close(sockfd);
return 0;
}
运行结果：
把稳：
1.上面pthread_create()函数的末了一个参数是void 类型，为啥可以传值connfd？
while(1)
{
int connfd = accept(sockfd, (struct sockaddr)&client_addr, &cliaddr_len);
pthread_create(&thread_id, NULL, (void )client_fun, (void )connfd);
pthread_detach(thread_id);
}
由于void 是4个字节，而connfd为int类型也是4个字节，故可以传值。如果connfd为char、short,上面传值就会出错
2.上面pthread_create()函数的末了一个参数是可以传地址吗？可以，但会对做事器造成不可预知的问题
while(1)
{
int connfd = accept(sockfd, (struct sockaddr)&client_addr, &cliaddr_len);
pthread_create(&thread_id, NULL, (void )client_fun, (void )&connfd);
pthread_detach(thread_id);
}
缘故原由：假如有多个客户端要连接这个做事器，正常的情形下，一个客户端连接对应一个 connfd，相互之间独立不受影响，但是，如果多个客户端同时连接这个做事器，A 客户真个连接套接字为 connfd，做事器正在用这个 connfd 处理数据，还没有处理完，溘然来了一个 B 客户端，accept()之后又天生一个 connfd, 由于是地址通报， A 客户真个连接套接字也变成 B 这个了，这样的话，做事器肯定不能再为 A 客户端做事器了
2.如果我们想将多个参数传给线程函数，我们首先考虑到便是构造体参数，而这时传值是行不通的，只能通报地址。
这时候，我们就须要考虑多任务的互斥或同步问题了，这里通过互斥锁来办理这个问题，确保这个构造体参数值被一个临时变量保存过后，才许可修正。
#include <pthread.h>
pthread_mutex_t mutex; // 定义互斥锁，全局变量
pthread_mutex_init(&mutex, NULL); // 初始化互斥锁，互斥锁默认是打开的
// 上锁，在没有解锁之前，pthread_mutex_lock()会壅塞
pthread_mutex_lock(&mutex);
int connfd = accept(sockfd, (struct sockaddr)&client_addr, &cliaddr_len);
//给回调函数传的参数，&connfd，地址通报
pthread_create(&thread_id, NULL, (void )client_process, (void )&connfd); //创建线程
// 线程回调函数
void client_process(void arg)
{
int connfd = (int )arg; // 传过来的已连接套接字
// 解锁，pthread_mutex_lock()唤醒，不壅塞 pthread_mutex_unlock(&mutex);
return NULL;
}
示例代码：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
pthread_mutex_t mutex; // 定义互斥锁，全局变量
/
函数名称： void client_process(void arg)
函数功能： 线程函数,处理客户信息
函数参数： 已连接套接字
函数返回： 无
/
void client_process(void arg)
{
int recv_len = 0;
char recv_buf[1024] = ""; // 吸收缓冲区
int connfd = (int )arg; // 传过来的已连接套接字
// 解锁，pthread_mutex_lock()唤醒，不壅塞
pthread_mutex_unlock(&mutex);
// 吸收数据
while((recv_len = recv(connfd, recv_buf, sizeof(recv_buf), 0)) > 0)
{
printf("recv_buf: %s\n", recv_buf); // 打印数据
send(connfd, recv_buf, recv_len, 0); // 给客户端回数据
}
printf("client closed!\n");
close(connfd); //关闭已连接套接字
return NULL;
}
//===============================================================
// 语法格式： void main(void)
// 实现功能： 主函数，建立一个TCP并发做事器
// 入口参数： 无
// 出口参数： 无
//===============================================================
int main(int argc, char argv[])
{
int sockfd = 0; // 套接字
int connfd = 0;
int err_log = 0;
struct sockaddr_in my_addr; // 做事器地址构造体
unsigned short port = 8080; // 监听端口
pthread_t thread_id;
pthread_mutex_init(&mutex, NULL); // 初始化互斥锁，互斥锁默认是打开的
printf("TCP Server Started at port %d!\n", port);
sockfd = socket(AF_INET, SOCK_STREAM, 0); // 创建TCP套接字
if(sockfd < 0)
{
perror("socket error");
exit(-1);
}
bzero(&my_addr, sizeof(my_addr)); // 初始化做事器地址
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(port);
my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
printf("Binding server to port %d\n", port);
// 绑定
err_log = bind(sockfd, (struct sockaddr)&my_addr, sizeof(my_addr));
if(err_log != 0)
{
perror("bind");
close(sockfd);
exit(-1);
}
// 监听，套接字变被动
err_log = listen(sockfd, 10);
if( err_log != 0)
{
perror("listen");
close(sockfd);
exit(-1);
}
printf("Waiting client...\n");
while(1)
{
char cli_ip[INET_ADDRSTRLEN] = ""; // 用于保存客户端IP地址
struct sockaddr_in client_addr; // 用于保存客户端地址
socklen_t cliaddr_len = sizeof(client_addr); // 必须初始化!!!
// 上锁，在没有解锁之前，pthread_mutex_lock()会壅塞
pthread_mutex_lock(&mutex);
//得到一个已经建立的连接
connfd = accept(sockfd, (struct sockaddr)&client_addr, &cliaddr_len);
if(connfd < 0)
{
perror("accept this time");
continue;
}
// 打印客户真个 ip 和端口
inet_ntop(AF_INET, &client_addr.sin_addr, cli_ip, INET_ADDRSTRLEN);
printf("----------------------------------------------\n");
printf("client ip=%s,port=%d\n", cli_ip,ntohs(client_addr.sin_port));
if(connfd > 0)
{
//给回调函数传的参数，&connfd，地址通报
pthread_create(&thread_id, NULL, (void )client_process, (void )&connfd); //创建线程
pthread_detach(thread_id); // 线程分离，结束时自动回收资源
}
}
close(sockfd);
return 0;
}
运行结果：
把稳：这种用互斥锁对做事器的运行效率有致命的影响
须要C/C++ Linux做事器开拓学习资料私信“资料”（资料包括C/C++，Linux，golang技能，Nginx，ZeroMQ，MySQL，Redis，fastdfs，MongoDB，ZK，流媒体，CDN，P2P，K8S，Docker，TCP/IP，协程，DPDK，ffmpeg等），免费分享
