目录
服务器模型
在网络通信中，通常一个服务器要连接多个客户端
为了处理多个客户端的请求，通常有多种表现形式
循环服务器
一个服务器在同一时间只能处理一个客户端的请求
并发服务器
一个服务器在同一时间可以处理多个客户端的请求
多进程
每有一个客户端连接创建一个进程进行通信
为什么要创建进程？------》通信
什么时间创建进程？------》accept之后fork
子进程：通信
父进程：循环等待下一个客户端连接
进程资源回收----》子进程退出-----》客户端退出
wait(); waitpid();
SIGCHLD:当子进程退出给父进程发送的信号
#include <stdio.h>
#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <signal.h>
#include <sys/wait.h>
void handler(int sig)
{
wait(NULL);
}
int main(int argc, char const *argv[])
{
pid_t pid;
char buf[128] = {0};
int ret, acceptfd;
// 1.创建套接字（socket）---------------》有手机
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
{
perror("socket err");
return -1;
}
printf("sockfd:%d\n", sockfd); // 3
// 2.指定网络信息---------------------------》有号码
struct sockaddr_in saddr, caddr;
saddr.sin_family = AF_INET; // IPV4
saddr.sin_port = htons(atoi(argv[1])); // 端口号
// saddr.sin_addr.s_addr = inet_addr("192.168.50.13"); // 虚拟机IP
// saddr.sin_addr.s_addr = inet_addr("0.0.0.0");
saddr.sin_addr.s_addr = INADDR_ANY;
int len = sizeof(caddr);
// 3.绑定套接字（bind）------------------》绑定手机（插卡）
if (bind(sockfd, (struct sockaddr *)&saddr, sizeof(saddr)) < 0)
{
perror("bind err");
return -1;
}
printf("bind ok\n");
// 4.监听套接字（listen）-----------------》待机
if (listen(sockfd, 6) < 0)
{
perror("listen err");
return -1;
}
printf("listen ok\n");
// 5.接收客户端连接连接请求（accept）--》接电话
// tcp服务器一共有两类文件描述符,一类用于连接,一类用于通信
// socket函数返回值:用于连接的文件描述符
// accept函数返回值:用于通信的文件描述符
signal(SIGCHLD, handler);//设置信号处理方式 在哪设置皆可（作用：当接收到子进程退出的信号时，自动调用handler函数回收子进程）
while (1)
{
acceptfd = accept(sockfd, (struct sockaddr *)&caddr, &len);
if (acceptfd < 0)
{
perror("accept err");
return -1;
}
printf("port:%d ip:%s\n", ntohs(caddr.sin_port), inet_ntoa(caddr.sin_addr));
printf("acceptfd:%d\n", acceptfd);
pid = fork();
if (pid < 0)
{
perror("fork err");
return -1;
}
else if (pid == 0)
{
// 6.接收、发送数据（recv send）---》通话
while (1)
{
// read/write()
ret = recv(acceptfd, buf, sizeof(buf), 0);
if (ret < 0)
{
perror("recv err");
break;
}
else if (ret == 0)
{
printf("client exit\n");
break;
}
else
{
printf("buf:%s\n", buf);
memset(buf, 0, sizeof(buf));
}
}
// 7.关闭套接字（close）-----------------》挂电话
close(acceptfd);
exit(0);
}
else
close(acceptfd);
}
close(sockfd);
return 0;
}
多线程
每有一个客户端连接创建一个线程进行通信
为什么要创建线程-------》通信
什么时间创建线程-------》accept之后pthread_create
子线程：通信
主线程：循环等待下一个客户端连接
通信的文件描述符------》线程传参
#include <stdio.h>
#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <pthread.h>
void *handler(void *arg)
{
int ret, acceptfd;
acceptfd = *((int *)arg); //强转
char buf[128] = {0};
// 6.接收、发送数据（recv send）---》通话
while (1)
{
// read/write()
ret = recv(acceptfd, buf, sizeof(buf), 0);
if (ret < 0)
{
perror("recv err");
return NULL;
}
else if (ret == 0)
{
printf("client exit\n");
break;
}
else
{
printf("buf:%s\n", buf);
memset(buf, 0, sizeof(buf));
}
// 7.关闭套接字（close）-----------------》挂电话
}
close(acceptfd);
pthread_exit(NULL);
}
int main(int argc, char const *argv[])
{
int acceptfd;
pthread_t tid;
// 1.创建套接字（socket）---------------》有手机
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
{
perror("socket err");
return -1;
}
printf("sockfd:%d\n", sockfd); // 3
// 2.指定网络信息---------------------------》有号码
struct sockaddr_in saddr, caddr;
saddr.sin_family = AF_INET; // IPV4
saddr.sin_port = htons(atoi(argv[1])); // 端口号
// saddr.sin_addr.s_addr = inet_addr("192.168.50.13"); // 虚拟机IP
// saddr.sin_addr.s_addr = inet_addr("0.0.0.0");
saddr.sin_addr.s_addr = INADDR_ANY;
int len = sizeof(caddr);
// 3.绑定套接字（bind）------------------》绑定手机（插卡）
if (bind(sockfd, (struct sockaddr *)&saddr, sizeof(saddr)) < 0)
{
perror("bind err");
return -1;
}
printf("bind ok\n");
// 4.监听套接字（listen）-----------------》待机
if (listen(sockfd, 6) < 0)
{
perror("listen err");
return -1;
}
printf("listen ok\n");
// 5.接收客户端连接连接请求（accept）--》接电话
// tcp服务器一共有两类文件描述符,一类用于连接,一类用于通信
// socket函数返回值:用于连接的文件描述符
// accept函数返回值:用于通信的文件描述符
while (1)
{
acceptfd = accept(sockfd, (struct sockaddr *)&caddr, &len);
if (acceptfd < 0)
{
perror("accept err");
return -1;
}
printf("port:%d ip:%s\n", ntohs(caddr.sin_port), inet_ntoa(caddr.sin_addr));
printf("acceptfd:%d\n", acceptfd);
pthread_create(&tid, NULL, handler, &acceptfd);
pthread_detach(tid);
}
close(sockfd);
return 0;
}
IO多路复用
select poll epoll
并发服务器总结
多进程：
优点：服务器更稳定，父子进程资源独立，安全性高
缺点：需要开辟多个进程，大量消耗资源，系统开销大
多线程：
优点：相对于多进程，资源开销小，多个线程共享同一个进程的资源
缺点：需要开辟多个线程，安全性较差
IO多路复用：
优点：节省资源、系统开销小，性能高
缺点：代码复杂度高
标签：printf,day09,addr,编程,acceptfd,saddr,sockfd,服务器,include From： https://blog.csdn.net/QR70892/article/details/142187045