十八、TCP多线程、多进程并发服务器

news2025/4/23 22:56:17

1、TCP多线程并发服务器

服务端：
#include<stdio.h>
#include <arpa/inet.h>
#include<stdlib.h>
#include<string.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <pthread.h>
#include <strings.h>
#define QUIT_STR "QUIT"
#define SERV_IP 5001
#define SERV_IP_ADDR "192.168.238.128" 
#define bufsize 1024
void* cilent_data_handle(void* arg)
{
	int newfd=*(int *)arg;
  char buf[bufsize];
  printf("thread handle:newfd = %d\n",newfd);
        int ret =-1;
        while(1)
        {
                do
                {
                        bzero(buf,bufsize);
                        ret=read(newfd,buf,bufsize-1);
                }while(ret<1);
                if(ret<0)
                {
                        exit(1);
                }
                if(!ret)
                {
                   break;
                }
                printf("recive data is %s\n",buf);
                if(!strncasecmp(buf,QUIT_STR,strlen(QUIT_STR)))
                                {
                                    printf("cilenr is exiting!\n");
                                    break;
                                    }
        }
        close(newfd);


}
int main()
{
	int fd=-1;
	fd=socket(AF_INET,SOCK_STREAM,0);
	if(fd == -1)
	{
		perror("socket");
			exit(1);
	}
	struct sockaddr_in sin;
	bzero(&sin,sizeof(sin));
	sin.sin_family=AF_INET;
	sin.sin_port = htons(SERV_IP);
	sin.sin_addr.s_addr = INADDR_ANY;
/*	if(inet_pton(AF_INET,SERV_IP_ADDR,(void*)&sin.sin_addr.s_addr)!=1)
	{
		perror("inet_pton");
		exit(1);
	}
	*/
	//2.bind
        if(bind(fd,(struct sockaddr *)&sin,sizeof(sin))<0)
	{
	   perror("bind");
	   exit(1);	   
	}
	//3.listen
	if(listen(fd,5)<0)
	{
		perror("listen");
		exit(1);
	}
	//4.accep
         int newfd=-1;
	 pthread_t tid;
	 struct sockaddr_in cin;
	 socklen_t addrlen=sizeof(cin);
	 while(1)
        {
	newfd= accept(fd,(struct sockaddr*)&cin,&addrlen);
	if(newfd<0)
	{
		perror("accept");
		exit(1);
	}
	char IPV4_addr[16];
	if(!inet_ntop(AF_INET,(void *)&cin.sin_addr,IPV4_addr,sizeof(cin)))
	{
		perror("inet_ntop");
		exit(1);
	}
	printf("cilent:(%s,%d)is connect\n",IPV4_addr,ntohs(cin.sin_port));
        pthread_create(&tid,NULL,cilent_data_handle,(void *)&newfd);
	}
	//read


	return 0;
}
客户端：
#include<stdio.h>
#include <arpa/inet.h>
#include<stdlib.h>
#include<string.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <strings.h>
#define QUIT_STR "QUIT"
#define SERV_IP 5001
#define SERV_IP_ADDR "192.168.238.128" 
#define bufsize 1024
int main(int arc,void **arg)
{
	if(arc!=3)
	{
		exit(1);
	}
	int port =-1;
	port=atoi(arg[2]);
	int fd=-1;
	fd = socket(AF_INET,SOCK_STREAM,0);
	if(fd == -1)
	{
		perror("socket");
		exit(1);
	}
	struct sockaddr_in sin;
	bzero(&sin,sizeof(sin));
	sin.sin_family = AF_INET;
	sin.sin_port=htons(port);
	sin.sin_addr.s_addr=inet_addr(arg[1]);
	if(connect(fd,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("connect");
		
		exit(1);
	}
	char buf[bufsize];
	while(1)
	{
		bzero(buf,strlen(buf));
		if(fgets(buf,bufsize-1,stdin)==NULL)
		{
		    continue;
		}
		write(fd,buf,strlen(buf));
		if(!strncasecmp(buf,QUIT_STR,strlen(QUIT_STR)))
		{
			break;
		}
		
	}
close(fd);

	return 0;
}

  代码示例：

2、TCP多进程并发服务器

服务端
#include<stdio.h>
#include <arpa/inet.h>
#include<stdlib.h>
#include<string.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <pthread.h>
#include <strings.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <unistd.h>
#define QUIT_STR "QUIT"
#define SERV_RESP_STR "SERVER:"
#define SERV_IP 5001
#define SERV_IP_ADDR "192.168.238.128" 
#define bufsize 1024
void child_data_handle(int signum)
{
	if(SIGCHLD==signum)
	{
		waitpid(-1,NULL,WNOHANG);
	}
}
void* cilent_data_handle(void* arg)
{
	int newfd=*(int *)arg;

  char buf[bufsize];
  printf("child process handle:newfd = %d\n",newfd);
        int ret =-1;
        while(1)
        {
                do
                {
                        bzero(buf,bufsize);
                        ret=read(newfd,buf,bufsize-1);
                }while(ret<1);
                if(ret<0)
                {
                        exit(1);
                }
                if(!ret)
                {
                   break;
                }
                printf("recive data is %s\n",buf);

                if(!strncasecmp(buf,QUIT_STR,strlen(QUIT_STR)))
                                {
                                    printf("cilenr is exiting!\n");
                                    break;
                                    }
        }
        close(newfd);


}
int main()
{
	int fd=-1;
	signal(SIGCHLD,child_data_handle);
	fd=socket(AF_INET,SOCK_STREAM,0);
	if(fd == -1)
	{
		perror("socket");
			exit(1);
	}
	struct sockaddr_in sin;
	bzero(&sin,sizeof(sin));
	sin.sin_family=AF_INET;
	sin.sin_port = htons(SERV_IP);
	sin.sin_addr.s_addr = INADDR_ANY;
/*	if(inet_pton(AF_INET,SERV_IP_ADDR,(void*)&sin.sin_addr.s_addr)!=1)
	{
		perror("inet_pton");
		exit(1);
	}
	*/
	//2.bind
        if(bind(fd,(struct sockaddr *)&sin,sizeof(sin))<0)
	{
	   perror("bind");
	   exit(1);	   
	}
	//3.listen
	if(listen(fd,5)<0)
	{
		perror("listen");
		exit(1);
	}
	//4.accep
         int newfd=-1;
	 pthread_t tid;
	 pid_t pid;
	 struct sockaddr_in cin;
	 socklen_t addrlen=sizeof(cin);
	 while(1)
        {

	newfd= accept(fd,(struct sockaddr*)&cin,&addrlen);
	if(newfd<0)
	{
		perror("accept");
		exit(1);
	}
        pid = fork();
	if(pid<0)
	{
		perror("fork");
		break;
	}
	if(pid == 0)
	{
	char IPV4_addr[16];
	if(!inet_ntop(AF_INET,(void *)&cin.sin_addr,IPV4_addr,sizeof(cin)))
	{
		perror("inet_ntop");
		exit(1);
	}
	printf("cilent:(%s,%d)is connect\n",IPV4_addr,ntohs(cin.sin_port));
	cilent_data_handle(&newfd);
        close(fd);
	}
	if(pid >0)
	{
	   close(newfd);
	}
	}
	//read


	return 0;
}

​
客户端：
#include<stdio.h>
#include <arpa/inet.h>
#include<stdlib.h>
#include<string.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <strings.h>
#define QUIT_STR "QUIT"
#define SERV_IP 5001
#define SERV_IP_ADDR "192.168.238.128" 
#define bufsize 1024
int main(int arc,void **arg)
{
	if(arc!=3)
	{
		exit(1);
	}
	int port =-1;
	port=atoi(arg[2]);
	int fd=-1;
	fd = socket(AF_INET,SOCK_STREAM,0);
	if(fd == -1)
	{
		perror("socket");
		exit(1);
	}
	struct sockaddr_in sin;
	bzero(&sin,sizeof(sin));
	sin.sin_family = AF_INET;
	sin.sin_port=htons(port);
	sin.sin_addr.s_addr=inet_addr(arg[1]);
	if(connect(fd,(struct sockaddr*)&sin,sizeof(sin))==-1)
	{
		perror("connect");
		
		exit(1);
	}
	char buf[bufsize];
	while(1)
	{
		bzero(buf,strlen(buf));
		if(fgets(buf,bufsize-1,stdin)==NULL)
		{
		    continue;
		}
		write(fd,buf,strlen(buf));
		if(!strncasecmp(buf,QUIT_STR,strlen(QUIT_STR)))
		{
			break;
		}
		
	}
close(fd);

	return 0;
}

​

 运行结果：

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

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

相关文章

AIGC-文生图与图生图

AIGC-文生图与图生图

在之前的文章中&#xff0c;我们知道了如何通过Web UI和Confy UI两种SD工具来进行图片生成&#xff0c;今天进一步地讲解其中的参数用处及如何调节。 文生图 参数详解 所谓文生图&#xff0c;就是通过文字描述我们想要图片包含的内容。初学的话&#xff0c;还是以Web UI为例…
阅读更多...
量化交易 - 聚宽joinquant - 多因子入门研究 - 源码开源

量化交易 - 聚宽joinquant - 多因子入门研究 - 源码开源

先看一下我们的收益&#xff1a; JoinQuant直达这里看看 下面讲解原理和代码。 目录 一、是否为st 二、是否停牌 三、市值小、roe大 四、编写回测代码 今天来研究一下多因子回测模型&#xff0c;这里以‘市值’、‘roe’作为例子。 几个标准&#xff1a;沪深300里选股&am…
阅读更多...
FPGA 37 ，FPGA千兆以太网设计实战：RGMII接口时序实现全解析（ RGMII接口时序设计，RGMII~GMII，GMII~RGMII 接口转换 ）

FPGA 37 ，FPGA千兆以太网设计实战：RGMII接口时序实现全解析（ RGMII接口时序设计，RGMII~GMII，GMII~RGMII 接口转换 ）

目录 前言 一、设计流程 1.1 需求理解 1.2 模块划分 1.3 测试验证 二、模块分工 2.1 RGMII→GMII&#xff08;接收方向&#xff0c;rgmii_rx 模块&#xff09; 2.2 GMII→RGMII&#xff08;发送方向&#xff0c;rgmii_tx 模块&#xff09; 三、代码实现 3.1 顶层模块 …
阅读更多...
上篇：《排序算法的奇妙世界：如何让数据井然有序？》

上篇：《排序算法的奇妙世界：如何让数据井然有序？》

个人主页&#xff1a;strive-debug 排序算法精讲&#xff1a;从理论到实践 一、排序概念及应用 1.1 基本概念 **排序**&#xff1a;将一组记录按照特定关键字&#xff08;如数值大小&#xff09;进行递增或递减排列的操作。 1.2 常见排序算法分类 - **简单低效型**&#xff…
阅读更多...
红宝书第三十四讲：零基础学会单元测试框架：Jest、Mocha、QUnit

红宝书第三十四讲：零基础学会单元测试框架：Jest、Mocha、QUnit

红宝书第三十四讲&#xff1a;零基础学会单元测试框架&#xff1a;Jest、Mocha、QUnit 资料取自《JavaScript高级程序设计&#xff08;第5版&#xff09;》。 查看总目录&#xff1a;红宝书学习大纲 一、单元测试是什么&#xff1f; 就像给代码做“体检”&#xff0c;帮你检查…
阅读更多...
CST1019.基于Spring Boot+Vue智能洗车管理系统

CST1019.基于Spring Boot+Vue智能洗车管理系统

计算机/JAVA毕业设计 【CST1019.基于Spring BootVue智能洗车管理系统】 【项目介绍】 智能洗车管理系统&#xff0c;基于 Spring Boot Vue 实现&#xff0c;功能丰富、界面精美 【业务模块】 系统共有三类用户&#xff0c;分别是&#xff1a;管理员用户、普通用户、工人用户&…
阅读更多...
HTTP：五.WEB服务器

HTTP：五.WEB服务器

web服务器 定义：实现提供资源或应答的提供者都可以谓之为服务器！web服务器工作内容 接受建立连接请求 接受请求 处理请求 访问报文中指定的资源 构建响应 发送响应 记录事务处理过程 Web应用开发用到的一般技术元素 静态元素：html， img，js，Css，SWF，MP4 动态元素：PHP，…
阅读更多...
0基础 | 硬件滤波 C、RC、LC、π型

0基础 | 硬件滤波 C、RC、LC、π型

一、滤波概念 &#xff08;一&#xff09;滤波定义 滤波是将信号中特定波段频率滤除的操作&#xff0c;是抑制和防止干扰的重要措施。通过滤波器实现对特定频率成分的筛选&#xff0c;确保目标信号的纯净度&#xff0c;提升系统稳定性。 &#xff08;二&#xff09;滤波器分…
阅读更多...
图论基础理论

图论基础理论

在我看来&#xff0c;想要掌握图的基础应用&#xff0c;仅需要三步走。 什么是图&#xff08;基本概念&#xff09;、图的构造&#xff08;打地基&#xff09;、图的遍历方式&#xff08;应用的基础&#xff09; 只要能OK的掌握这三步、就算图论入门了&#xff01;&#xff0…
阅读更多...
企业级低代码平台的架构范式转型研究

企业级低代码平台的架构范式转型研究

在快速迭代的数字时代&#xff0c;低代码平台如同一股清流&#xff0c;悄然成为开发者们的新宠。 它利用直观易用的拖拽式界面和丰富的预制组件&#xff0c;将应用程序的开发过程简化到了前所未有的程度。通过封装复杂的编程逻辑和提供强大的集成能力&#xff0c;低代码平台让…
阅读更多...
怎么免费下载GLTF/GLB格式模型文件，还可以在线编辑修改

怎么免费下载GLTF/GLB格式模型文件，还可以在线编辑修改

​ 现在非常流行glb格式模型&#xff0c;和gltf格式文件&#xff0c;可是之类模型网站非常非常少 1&#xff0c;咱们先直接打开http://glbxz.com 官方glb下载网站 glbxz.com 2 可以搜索&#xff0c;自己想要的模型关键词 3&#xff0c;到自己想下载素材页面 4&#xff0c;…
阅读更多...
大模型到底是怎么产生的？一文揭秘大模型诞生全过程

大模型到底是怎么产生的？一文揭秘大模型诞生全过程

前言 大模型到底是怎么产生的呢？ 本文将从最基础的概念开始，逐步深入，用通俗易懂的语言为大家揭开大模型的神秘面纱。 大家好，我是大 F，深耕AI算法十余年，互联网大厂核心技术岗。 知行合一，不写水文，喜欢可关注，分享AI算法干货、技术心得。 【专栏介绍】： 欢迎关注《…
阅读更多...
2025年3月 Scratch图形化三级 真题解析 中国电子学会全国青少年软件编程等级考试

2025年3月 Scratch图形化三级 真题解析 中国电子学会全国青少年软件编程等级考试

2025年3月Scratch图形化编程等级考试三级真题试卷 一、选择题 第 1 题 默认小猫角色&#xff0c;scratch运行程序后&#xff0c;下列说法正确的是&#xff1f;&#xff08; &#xff09; A.小猫的颜色、位置在一直变化 B.小猫在舞台中的位置在一直变化&#xff0c;颜色…
阅读更多...
【贪心之摆动序列】

【贪心之摆动序列】

题目&#xff1a; 分析&#xff1a; 这里我们使用题目中给的第二个实例来进行分析 题目中要求我们序列当中有多少个摆动序列&#xff0c;摆动序列满足一上一下&#xff0c;一下一上&#xff0c;这样是摆动序列&#xff0c;并且要输出摆动序列的最长长度 通过上面的图我们可以…
阅读更多...
0x25广度优先搜索+0x26广搜变形

0x25广度优先搜索+0x26广搜变形

1.一般bfs AcWing 172. 立体推箱子 #include<bits/stdc.h> using namespace std; int n,m; char s[505][505]; int vis[3][505][505]; int df[3][4]{{1,1, 2,2},{0,0,1,1}, {0,0,2,2}}; int dx[3][4]{{0,0,1,-2},{0,0,1,-1},{2,-1,0,0}}; int dy[3][4]{{1,-2,0,0},{2,…
阅读更多...
java面向对象02：回顾方法

java面向对象02：回顾方法

回顾方法及加深 定义方法 修饰符 返回类型 break&#xff1a;跳出switch和return的区别 方法名 参数列表 package com.oop.demo01;//Demo01类 public class Demo01 {//main方法public static void main(String[] args) {}/*修饰符 返回值类型 方法名(...){//方法体return…
阅读更多...
数据结构day05

数据结构day05

一 栈的应用&#xff08;括号匹配&#xff09; 各位同学大家好&#xff0c;在之前的小结中&#xff0c;我们学习了栈和队列这两种数据结构&#xff0c;那从这个小节开始&#xff0c;我们要学习几种栈和队列的典型应用。这个小节中&#xff0c;我们来看一下括号匹配问题&#xf…
阅读更多...
windows中搭建Ubuntu子系统

windows中搭建Ubuntu子系统

windows中搭建虚拟环境 1.配置2.windows中搭建Ubuntu子系统2.1windows配置2.1.1 确认启用私有化2.1.2 将wsl2设置为默认版本2.1.3 确认开启相关配置2.1.4重启windows以加载更改配置 2.2 搭建Ubuntu子系统2.2.1 下载Ubuntu2.2.2 迁移位置 3.Ubuntu子系统搭建docker环境3.1安装do…
阅读更多...
ImgTool_0.8.0：图片漂白去底处理优化工具

ImgTool_0.8.0：图片漂白去底处理优化工具

ImgTool_0.8.0 是一款专为Windows设计的‌免费、绿色便携式图片处理工具‌&#xff0c;支持 Windows 7/8/10/11 系统‌。其核心功能为‌漂白去底‌&#xff0c;可高效去除扫描件或手机拍摄图片中的泛黄、灰底及阴影&#xff0c;同时提供智能纠偏、透视校正等辅助功能&#xff0…
阅读更多...
BGP路由协议之对等体

BGP路由协议之对等体

IGP 可以通过组播报文发现直连链路上的邻居&#xff0c;而 BGP 是通过 TCP&#xff1a;179 来实现的。BGP 需要手工的方式去配置邻居。不需要直连&#xff0c;只要路由能通就可以建立邻居 IBGP 与 EBGP IBGP :(Internal BGP) :位于相同自治系统的 BGP 路由器之间的 BGP 邻接关…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023