一、tcp并发服务器概述

一个好的服务器,一般都是并发服务器(同一时刻可以响应多个客户端的请求)。并发服务器设计技术一般有:多进程服务器、多线程服务器、I/O复用服务器等。

二、多进程并发服务器

在 Linux
环境下多进程的应用很多,其中最主要的就是网络/客户服务器。多进程服务器是当客户有请求时,服务器用一个子进程来处理客户请求。父进程继续等待其它客户的请求。
这种方法的优点是当客户有请求时,服务器能及时处理客户,特别是在客户服务器交互系统中。对于一个 TCP
服务器,客户与服务器的连接可能并不马上关闭,可能会等到客户提交某些数据后再关闭,这段时间服务器端的进程会阻塞,所以这时操作系统可能调度其它客户服务进程,
这比起循环服务器大大提高了服务性能。

发达

tcp多进程并发服务器

TCP 并发服务器的思想是每一个客户机的请求并不由服务器直接处理,而是由服务器创建一个子进程来处理。

tcp多进程并发服务器参考代码:
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h>
#include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h>
/************************************************************************ 函数名称:
void main(int argc, char *argv[]) 函数功能: 主函数,用进程建立一个TCP Echo Server 函数参数: 无
函数返回: 无
************************************************************************/ int
main(int argc, char *argv[]) { unsigned short port = 8080; // 本地端口 //1.创建tcp套接字
int sockfd = socket(AF_INET, SOCK_STREAM, 0); if(sockfd < 0) {
perror("socket"); exit(-1); } //配置本地网络信息 struct sockaddr_in my_addr;
bzero(&my_addr, sizeof(my_addr)); // 清空 my_addr.sin_family = AF_INET; // IPv4
my_addr.sin_port = htons(port); // 端口 my_addr.sin_addr.s_addr =
htonl(INADDR_ANY); // ip //2.绑定 int err_log = bind(sockfd, (struct
sockaddr*)&my_addr, sizeof(my_addr)); if( err_log != 0) { perror("binding");
close(sockfd); exit(-1); } //3.监听,套接字变被动 err_log = listen(sockfd, 10);
if(err_log != 0) { perror("listen"); close(sockfd); exit(-1); } while(1) //主进程
循环等待客户端的连接 { char cli_ip[INET_ADDRSTRLEN] = {0}; struct sockaddr_in
client_addr; socklen_t cliaddr_len = sizeof(client_addr); // 取出客户端已完成的连接 int
connfd = accept(sockfd, (struct sockaddr*)&client_addr, &cliaddr_len);
if(connfd < 0) { perror("accept"); close(sockfd); exit(-1); } pid_t pid =
fork(); if(pid < 0){ perror("fork"); _exit(-1); }else if(0 == pid){ //子进程
接收客户端的信息,并发还给客户端 /*关闭不需要的套接字可节省系统资源, 同时可避免父子进程共享这些套接字 可能带来的不可预计的后果 */
close(sockfd); // 关闭监听套接字,这个套接字是从父进程继承过来 char recv_buf[1024] = {0}; int
recv_len = 0; // 打印客户端的 ip 和端口 memset(cli_ip, 0, sizeof(cli_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)); // 接收数据 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_port %d closed!\n", ntohs(client_addr.sin_port)); close(connfd);
//关闭已连接套接字 exit(0); } else if(pid > 0){ // 父进程 close(connfd); //关闭已连接套接字 } }
close(sockfd); return 0; }

运行结果:

技术
©2019-2020 Toolsou All rights reserved,
用PyMC3进行贝叶斯统计分析(代码+实例)jmeter-while控制器使用总结Three.js - OrbitControls 轨道控件的围绕目标 target 参数vue使用THREE.js创建一个可以控制的立方体BugkuCTF-Web-计算器(随机数字运算验证码)Vue页面跳转传递参数及接收java几种常见运行时异常及简单例子SpringBoot JpaRepository 数据库增删改查线上问题排查之HTTP状态码——415和406关于Navicat for mysql 的2003错误