05_TCP并发服务器

news2025/1/18 8:56:05

知识点1【TCP并发服务器】

1、多线程（常用）

2、解决上述问题：端口复用 仅仅是端口的复用

3、并发服务器 多进程实现

总结：

 知识点2【HTTP协议】 HTTP基于TCP

1、HTTP协议的概述

2、Webserver 通信过程

3、Web编程开发

知识点1【TCP并发服务器】

并发服务器：同时 服务于 多个客户端

TCP并发服务器:本质是TCP服务器，同时服务于多个客户端

TCP并发服务器的注意点：

TCP服务器、提取多个客户端、开启进程或线程处理每个客户端

1、多线程（常用）

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
#include<pthread.h>
//TCP并发ECHO服务器（并发回执服务器---客户端给服务器发啥 服务器就给客户端回啥）
void* deal_client_fun(void *arg)//arg = &new_fd
{
	//并发服务器的核心服务代码（各不相同）
	//通过arg获得已连接套接字
	int fd = *(int *)arg;
	while(1)//以下语句是服务器的核心代码
	{
		//获取客户端请求
		char buf[128]="";
		int len = recv(fd,buf,sizeof(buf), 0);
		if(len == 0)
			break;
		//回应客户端
		send(fd, buf, len, 0);
	}
	
	close(fd);
}
int main()
{
	//1、创建tcp监听套接字
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);
	if(sockfd < 0)
	{
		perror("socket");
	}
	int yes = 1;
     setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes,sizeof(yes));
     
	//2、给TCP监听套接字 bind固定的IP以及端口信息
	struct sockaddr_in my_addr;
	bzero(&my_addr,sizeof(my_addr));
	my_addr.sin_family = AF_INET;
	my_addr.sin_port = htons(8000);
	my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
	int ret = bind(sockfd, (struct sockaddr *)&my_addr,sizeof(my_addr));
	if(ret == -1)
	{
		perror("bind");
	}
	//3、调用listen 将sockfd主动变被动  同时创建链接队列
	listen(sockfd, 10);
	
	//4、提取完成链接的客户端 accept
	//accept调用一次 只能提取一个客户端
	while(1)
	{
		struct sockaddr_in cli_addr;
		socklen_t cli_len = sizeof(cli_addr);
		int new_fd = accept(sockfd,(struct sockaddr *)&cli_addr , &cli_len);
		
		//遍历客户端的信息ip port
		unsigned short port=ntohs(cli_addr.sin_port);
		char ip[16]="";
		inet_ntop(AF_INET,&cli_addr.sin_addr.s_addr, ip, 16);
		printf("已有客户端:%s:%hu连接上了服务器\n", ip, port);
		
		//对每一个客户端 开启一个线程 单独的服务器客户端
		pthread_t tid;
		pthread_create(&tid,NULL, deal_client_fun, (void *)&new_fd);
		//线程分离
		pthread_detach(tid);
	}	
	
	//关闭监听套接字
	close(sockfd);
	
	return 0;
}

 运行结果：

上述代码 如果客户端 正常退出 不会有啥影响，但是如果服务器 意外退出 绑定的端口信息来不及释放，就会造成 系统临时占用服务器上次bind的端口，如果在5~6分钟之内再次运行服务器 这是导致新运行的服务器 bind失败 

2、解决上述问题：端口复用 仅仅是端口的复用

服务器的进程网络资源 任然被占用 一般1分钟作用释放

int yes = 1;
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes,sizeof(yes));

将上面的两句话添加到socket只有 bind函数之前

3、并发服务器 多进程实现

 

 案例1：

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
#include<pthread.h>
#include<unistd.h>
//TCP并发ECHO服务器（并发回执服务器---客户端给服务器发啥 服务器就给客户端回啥）
void deal_client_fun(int fd)//fd = new_fd
{
	while(1)//以下语句是服务器的核心代码
	{
		//获取客户端请求
		char buf[128]="";
		int len = recv(fd,buf,sizeof(buf), 0);
		if(len == 0)
			break;
		//回应客户端
		send(fd, buf, len, 0);
	}
	
	return;
}
int main()
{
	//1、创建tcp监听套接字
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);
	if(sockfd < 0)
	{
		perror("socket");
	}
	//端口复用
	int yes = 1;
	setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes,sizeof(yes));
	
	//2、给TCP监听套接字 bind固定的IP以及端口信息
	struct sockaddr_in my_addr;
	bzero(&my_addr,sizeof(my_addr));
	my_addr.sin_family = AF_INET;
	my_addr.sin_port = htons(8000);
	my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
	int ret = bind(sockfd, (struct sockaddr *)&my_addr,sizeof(my_addr));
	if(ret == -1)
	{
		perror("bind");
	}
	//3、调用listen 将sockfd主动变被动  同时创建链接队列
	listen(sockfd, 10);
	
	//4、提取完成链接的客户端 accept
	//accept调用一次 只能提取一个客户端
	while(1)
	{
		struct sockaddr_in cli_addr;
		socklen_t cli_len = sizeof(cli_addr);
		int new_fd = accept(sockfd,(struct sockaddr *)&cli_addr , &cli_len);
		
		//遍历客户端的信息ip port
		unsigned short port=ntohs(cli_addr.sin_port);
		char ip[16]="";
		inet_ntop(AF_INET,&cli_addr.sin_addr.s_addr, ip, 16);
		printf("已有客户端:%s:%hu连接上了服务器\n", ip, port);
		
		pid_t pid;
		if(fork() == 0)//子进程  服务器客户端 不需要监听套接字
		{
			//关闭监听套接字
			close(sockfd);
			
			//服务于客户端
			deal_client_fun(new_fd);
			
			//关闭已连接套接字
			close(new_fd);
			_exit(-1);
		}
		else//父进程
		{
			//监听新的连接到来 不需要和客户端通信 必须关闭已连接套接字new_fd
			close(new_fd);
		}
	}	
	
	//关闭监听套接字
	close(sockfd);
	
	return 0;
}

运行结果：

总结：

TCP并发服务器 进程版：父子进程 资源独立 某个进程结束 不会影响已有的进程 服务器更加稳定 代价多进程 会消耗很多资源。

TCP并发服务器 线程版：线程共享进程资源 资源开销小 但是一旦主进程结束 所有线程都会结束 服务器先对进程 不是那么稳定

临时复习：已连接套接字 和 accpet中返回的客户端地址结构分析

 知识点2【HTTP协议】 HTTP基于TCP

1、HTTP协议的概述

4.7.1 web服务器简介

Web服务器又称WWW服务器、网站服务器等

特点

使用HTTP协议与客户机浏览器进行信息交流

不仅能存储信息，还能在用户通过web浏览器提供的信息的基础上运行脚本和程序

该服务器需可安装在UNIX、Linux或Windows等操作系统上

著名的服务器有Apache、Tomcat、 IIS等

4.7.2 HTTP协议

Webserver—HTTP协议

概念

一种详细规定了浏览器和万维网服务器之间互相通信的规则，通过因特网传送万维网文档的数据传送协议

特点

1、支持C/S架构

2、简单快速：客户向服务器请求服务时，只需传送请求方法和路径 ，常用方法:GET、POST

3、无连接：限制每次连接只处理一个请求

4、无状态：即如果后续处理需要前面的信息，它必须重传，这样可能导致每次连接传送的数据量会增大

2、Webserver 通信过程

我们写的是服务器端  必须是TCP并发服务器 客户端 由浏览器充当

3、Web编程开发

网页浏览（使用GET方式）

客户端浏览器请求：

 服务器收到的数据（浏览器发出的文件请求）

 服务器应答的格式：请求成功 服务器打开文件成功 给浏览器发送的报文

服务器应答的格式：请求失败 打开本地文件失败 给浏览器发报文

案例：webserver服务器

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
#include<pthread.h>
#include<unistd.h>
#include <sys/stat.h>
#include <fcntl.h>
char head[] = "HTTP/1.1 200 OK\r\n"						\
				  "Content-Type: text/html\r\n"				\
				  "\r\n";
char err[]=	"HTTP/1.1 404 Not Found\r\n"			\
					"Content-Type: text/html\r\n"			\
					"\r\n"								\
					"<HTML><BODY>File not found</BODY></HTML>";
void *deal_client_fun(void *arg)//arg=new_fd
{
	int new_fd = (int)arg;
	
	//1、recv获取客户端的请求（只需要调用一次）
	unsigned char buf[512]="";
	recv(new_fd,buf,sizeof(buf), 0);
	
	//2、解析buf 提取所请求的文件名
	char file_name[128]="./html/";
	sscanf(buf,"GET /%[^ ]", file_name+7);
	if(file_name[7]=='\0')
		strcpy(file_name,"./html/index.html");
	
	//3、打开本地文件
	int fd = open(file_name, O_RDONLY);
	if(fd < 0)//打开文件失败
	{
		perror("open");
		//发送失败报文给客户端
		send(new_fd, err, strlen(err), 0);
	}
	else//打开本地文件成功
	{
		//发送成功报文 请准备接受
		send(new_fd, head, strlen(head), 0);
		
		//不停的给浏览器客户端 发送文件数据
		while(1)
		{
			//从本地文件读取数据
			unsigned char buf[1024]="";
			int ret = read(fd,buf,sizeof(buf));
			printf("ret=%d\n", ret);
			if(ret<1024)//文件末尾 将数据发送出去
			{
				send(new_fd,buf,ret,0);
				break;
			}
			send(new_fd,buf,ret,0);
		}
		
		//关闭本地文件描述符
		close(fd);
	}
	
	close(new_fd);
	return NULL;
}

//运行的方式：./a.out 8000
int main(int argc,char *argv[])
{
	if(argc != 2)
	{
		printf("./a.out 8000\n");
		return 0;
	}
	
	//1、创建TCP监听套接字
	int sockfd = socket(AF_INET, SOCK_STREAM, 0);
	if(sockfd < 0)
	{
		perror("socket");
		return 0;
	}
	
	//2、端口复用
	int yes = 1;
	setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes,sizeof(yes));
	
	//3、给服务器绑定固定的IP以及端口
	struct sockaddr_in my_addr;
	bzero(&my_addr,sizeof(my_addr));
	my_addr.sin_family = AF_INET;
	my_addr.sin_port = htons(atoi(argv[1]));
	my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
	int ret = bind(sockfd, (struct sockaddr *)&my_addr,sizeof(my_addr));
	if(ret == -1)
	{
		perror("bind");
	}
	
	//4、使用listen函数 将套接字 由主动变被动 创建连接队列
	listen(sockfd, 15);
	
	
	//5、while不停的提取客户端 产生已连接套接字
	while(1)
	{
		struct sockaddr_in cli_addr;
		socklen_t cli_len = sizeof(cli_addr);
		int new_fd = accept(sockfd,(struct sockaddr *)&cli_addr , &cli_len);
		
		//遍历客户端的信息ip port
		unsigned short port=ntohs(cli_addr.sin_port);
		char ip[16]="";
		inet_ntop(AF_INET,&cli_addr.sin_addr.s_addr, ip, 16);
		printf("已有客户端:%s:%hu连接上了服务器\n", ip, port);
		
		//创建线程 服务于客户端
		pthread_t tid;
		pthread_create(&tid,NULL, deal_client_fun, (void *)new_fd);
		pthread_detach(tid);
	}
	
	//关闭监听套接字
	close(sockfd);
	return 0;
}

 运行结果：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/18646.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Cadence orcad 批量设置原理图标题栏

Cadence orcad 批量设置原理图标题栏

前言 作为一份规范的原理图文件&#xff0c;必须要有Title Block&#xff0c;一般是在右下角的原理图信息&#xff0c;包括标题&#xff0c;图纸尺寸&#xff0c;设计师&#xff0c;时间&#xff0c;页码等等。 这里需要两个操作&#xff1a; 一、批量修改Title Block的信息 …
阅读更多...
Go语言进阶篇，单元测试、基准测试的性能测试、内存占用测试

Go语言进阶篇，单元测试、基准测试的性能测试、内存占用测试

在go语言中的单元测试比较有意思&#xff0c;比如测试一个函数是很方便的&#xff0c;只需要将文件名修改为_test.go这样的后缀即可&#xff0c;我们新建一个目录xxx&#xff0c;然后新建xxx_test.go文件&#xff0c;当然这个xxx的名字你可以按照功能来命名&#xff0c;如下&am…
阅读更多...
Java开发：多线程编程

Java开发：多线程编程

本章篇幅主要记录多线程编程相关的知识&#xff0c;如有纰漏&#xff0c;望指出。 话不多说&#xff0c;正式开启多线程之旅... 目录 一、多线程使用方式 A、Thread B、Runnable&#xff08;推荐&#xff09; C、Callable 二、线程的五个状态 三、线程停止 四、线程休…
阅读更多...
LabVIEW性能和内存管理 7 LabVIEW中局部和全局变量的内存分配

LabVIEW性能和内存管理 7 LabVIEW中局部和全局变量的内存分配

LabVIEW性能和内存管理 7 LabVIEW中局部和全局变量的内存分配 本文介绍LabVIEW性能和内存管理的几个建议7。 LabVIEW Cleanup – LabVIEW cleans upmany references when the owning VI goes idle and others when the process closes – Manually closereferences t…
阅读更多...
Bean的作用域和生命周期

Bean的作用域和生命周期

1. Bean 的作用域 对于全局变量,局部变量等的作用域相信大家都已经很清楚了,但是对于对象作用域有点摸不着头脑,下面通过一个简单的案例,康康对象的作用域 1.1 案例引入 现有一个公共的 Bean 对象 package com.bean.model;import org.springframework.stereotype.Componen…
阅读更多...
【IEEE2017】RL：机器人库：一种面向对象的机器人应用程序的方法

【IEEE2017】RL：机器人库：一种面向对象的机器人应用程序的方法

RL&#xff1a;机器人库&#xff1a;一种面向对象的机器人应用程序的方法 摘要&#xff1a; 摘要&#xff1a;我们讨论了机器人库&#xff08;RL&#xff09;的架构和软件工程原理。在机器人系统、研究项目、工业应用和教育的需求的驱动下&#xff0c;我们确定了相关的设计需求…
阅读更多...
linux上如何搭建Java环境

linux上如何搭建Java环境

一 linux软件安装常用的方式对比 Linux下的软件安装&#xff0c;主要有如下三种&#xff0c;“正规”程度依次递减&#xff1a; 1、使用标准的yum/apt/yast包管理程序安装 2、使用标准rpm/deb或厂商自己的安装包&#xff08;比如nVidia的显卡驱动用的bin包&#xff09;安装 …
阅读更多...
黑*头条_第2章_文章列表前端成形与后端变身

黑*头条_第2章_文章列表前端成形与后端变身

黑*头条_第2章_文章列表前端成形与后端变身 文章目录黑*头条_第2章_文章列表前端成形与后端变身文章列表前端成形与后端变身学习目标1.前端工程结构1.1 环境准备1.1.1 导入工程1.1.2 测试运行1.2 weex 跨终端前端框架1.3 工程结构说明1.4 源码结构1.5 WEEX UI2.文章列表前端开发…
阅读更多...
算法实验题（涉外黄成老师！！！）

算法实验题（涉外黄成老师！！！）

日期 2022.11.19 目录 实验报告一 第一题 2 实验报告二 第二题 3 实验报告三 第三题 4 实验报告四 第四题 5 实验报告五 第五题 6 实验报告六 第六题 7 实验报告一 第一题 一、实验目的 由1&#xff0c;3&#xff0c;4&#xff0c;5&#xff0c;7&#xff0c;8这六个数字所组…
阅读更多...
剑指 Offer II 021. 删除链表的倒数第 n 个结点【链表】

剑指 Offer II 021. 删除链表的倒数第 n 个结点【链表】

难度等级&#xff1a;中等 上一篇算法&#xff1a; 82. 删除排序链表中的重复元素 II【链表】 力扣此题地址&#xff1a; 剑指 Offer II 021. 删除链表的倒数第 n 个结点 - 力扣&#xff08;LeetCode&#xff09; 1.题目&#xff1a;删除链表的倒数第 n 个结点 给定一个链表&a…
阅读更多...
DWGViewX Pro 2021.4.X Crack by Cracki

DWGViewX Pro 2021.4.X Crack by Cracki

DWGViewX pro 2021.4.X --Ω578867473 DWGViewX 是一个 ActiveX 组件&#xff0c;可让您在一个查看器中管理和查看 DWG、DXF 和 DWF 工程图。查看 R14 到 2022 版本的 DWG、DXF 和 DWF。加载本地磁盘或网络网站上的图纸&#xff0c;并使用查看器缩放、平移、旋转图纸、打开/关闭…
阅读更多...
Java中的线程

Java中的线程

线程 什么是线程&#xff1a; 什么是多线程&#xff1a; 学习目的&#xff1a; 多线程的创建 方式一&#xff1a;继承Thread类 public class MyThread{public static void main(String[] args) {Thread thread01 new Thread01();thread01.start();for (int i 0; i < 5; …
阅读更多...
翻倍增长！C-V2X商业化“提速”，新一代模组加速“助跑”

翻倍增长！C-V2X商业化“提速”，新一代模组加速“助跑”

C-V2X正在逐步走向商业的规模化部署&#xff0c;由此也带动了C-V2X模组需求的高速增长。 高工智能汽车研究院监测数据显示&#xff0c;今年1-9月中国市场&#xff08;不含进出口&#xff09;乘用车前装标配搭载V2X技术新车交付上险为10.58万辆&#xff0c;同比增长283.33%&…
阅读更多...
计算机视觉|投影与三维视觉

计算机视觉|投影与三维视觉

这一篇将学习投影与三维视觉&#xff0c;沿用上一篇 计算机视觉|针孔成像&#xff0c;相机内外参及相机标定&#xff0c;矫正的重要性 摄像机内参数矩阵M、畸变参数、旋转矩阵R、平移向量T以及但影响矩阵H。回顾放射和投影变换&#xff0c;并使用POSIT算法从一幅图像中查找获得…
阅读更多...
基于stm32单片机有害气体监测检测Proteus仿真

基于stm32单片机有害气体监测检测Proteus仿真

资料编号&#xff1a;097 下面是相关功能视频演示&#xff1a; 97-基于stm32单片机有害气体监测检测Proteus仿真&#xff08;仿真源码全套资料&#xff09;功能介绍&#xff1a;检测当前的有害气体浓度&#xff0c;LCD1602显示&#xff0c;并且可以自动打开关闭风扇&#xff…
阅读更多...
Pulsar 各个Shedder分析及新的Shedder -- AvgShedder

Pulsar 各个Shedder分析及新的Shedder -- AvgShedder

看到今年Pulsar 峰会上挺多人分享负载均衡的内容&#xff0c;这里也整理分享一下相关的内容。 社区现有策略的分析 LoadSheddingStrategy pulsar进行shedding的时候&#xff0c;使用的是ThresholdShedder类&#xff0c;ThresholdShedder类是LoadSheddingStrategy接口的其中一…
阅读更多...
锐捷SuperVlan实验配置

锐捷SuperVlan实验配置

Super Vlan配置 创建Vlan vlan range 2,3,4,10,20 配置Vlan10为Super Vlan&#xff0c;Vlan 2,3,4为Sub Vlan vlan 10 supervlan subvlan 2,3,4 配置Sub Vlan的地址范围&#xff08;也可以不配置&#xff09; Vlan 2 subvlan-address-range 192.168.10.10 192.168.10.50 配置S…
阅读更多...
【数据结构】—时间复杂度or空间复杂度以及基础题目练习

【数据结构】—时间复杂度or空间复杂度以及基础题目练习

小菜坤日常上传gitee代码&#xff1a;https://gitee.com/qi-dunyan ❤❤❤ 个人简介&#xff1a;双一流非科班的一名小白&#xff0c;期待与各位大佬一起努力&#xff01; 推荐网站&#xff1a;cplusplus.com 目录前言算法与复杂度时间复杂度大O的渐进表示法时间复杂度计算练习…
阅读更多...
[附源码]java毕业设计社区疫情防控管理系统

[附源码]java毕业设计社区疫情防控管理系统

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
MySQL纯代码复习(上)

MySQL纯代码复习(上)

前言 本文章是用于总结尚硅谷MySQL教学视频的记录文章&#xff0c;主要用于复习&#xff0c;非商用 原视频连接&#xff1a;https://www.bilibili.com/video/BV1iq4y1u7vj/?p21&spm_id_frompageDriver&vd_sourcec4ecde834521bad789baa9ee29af1f6c https://www.bilib…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023