程序员经验分享-hwhale

基于LinuxC语言实现的TCP多线程/进程服务器

2023-11-06

多进程并发服务器

设计流程

框架一（使用信号回收僵尸进程）

void handler(int sig)
{
    while(waitpid(-1, NULL, WNOHANG) > 0);
}

int main()
{
    //回收僵尸进程
    siganl(17, handler);
    //创建服务器监听套接字 server
    server = socket();
    //给服务器地址信息结构体赋值，并绑定
    bind();
    //监听指定端口，设置监听队列
    listen();
    
    while(1)
    {
        //创建与客户端通信的套接字
        client = accept();
        //创建子进程
        if(fork() == 0)
        {
            //关闭拷贝的服务器套接字
            close(server);
            while(1)
            {
                //接收消息
                recv();
                //发送消息
                send();
            }
            //通信结束关闭套接字
            close(client);
            //退出进程
            exit(0);
        }
        //关闭父进程的通信套接字
        close(client);
    }
    
    //服务器关闭
    close(server);
}

实例

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <sys/wait.h>
#include <time.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <signal.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <errno.h>

#define LOG(s) printf("[%s] {%s:%d} %s \n", __DATE__, __FILE__, __LINE__, s);

void cil(int client, struct sockaddr_in caddr);

void handler(int sig)
{
	while(waitpid(-1, NULL, WNOHANG) > 0);
}

int main(int argc, char *argv[])
{

	//回收僵尸进程
	signal(17, handler);
	//创建服务器
	int server = -1;
	if((server = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		LOG("socket error");
		return -1;
	}

	//给服务器地址信息结构体赋值，并绑定
	struct sockaddr_in saddr = {0};
	saddr.sin_family = AF_INET;
	saddr.sin_port = htons(8888);
	saddr.sin_addr.s_addr = htonl(INADDR_ANY);
	
	if(bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1)
	{
		LOG("bind error");
		return -1;
	}

	//监听指定端口，设置监听队列
	if(listen(server, 5) == -1)
	{
		LOG("listen error");
		return -1;
	}

	puts("Tcp server start success");

	int client = -1;
	struct sockaddr_in caddr = {0};
	socklen_t len = sizeof(caddr);
	pid_t pid = -1;
	while(1)
	{
		//创建与客户端通信的套接字
		if((client = accept(server, (struct sockaddr*)&caddr, &len)) == -1)
		{
			LOG("accpet error");
			return -1;
		}

		printf("[%s/%d] client已上线\n", inet_ntoa(caddr.sin_addr), ntohl(caddr.sin_port));
		//创建子进程
		if((pid = fork()) < 0)
		{
			LOG("fork error");
			return -1;
		}
		else if(pid == 0)
		{
			cil(client, caddr);
			exit(0);
		}
		close(client);
	}

	close(server);

    return 0;
}

void cil(int client, struct sockaddr_in caddr)
{
	char buf[128] = "";
	int res = 0;
	while(1)
	{
		bzero(buf, sizeof(buf));
		if((res = read(client, buf, sizeof(buf))) < 0)
		{
			LOG("read error");
			break;
		}
		else if(res == 0)
		{
			printf("[%s/%d] client已下线\n", inet_ntoa(caddr.sin_addr), ntohl(caddr.sin_port));
			close(client);
			break;
		}
		printf("[%s/%d] client: %s\n", inet_ntoa(caddr.sin_addr), ntohl(caddr.sin_port), buf);
		
		bzero(buf, sizeof(buf));
		strcpy(buf, "ok");
		if(write(client, buf, sizeof(buf)) < 0)
		{
			LOG("write error");
			break;
		}
	}

}

框架二（使用孤儿进程机制避免僵尸进程产生）

int main()
{
    //创建服务器监听套接字 server
    server = socket();
    //给服务器地址信息结构体赋值，并绑定
    bind();
    //监听指定端口，设置监听队列
    listen();
    
    while(1)
    {
        //创建子进程
        if((pid = fork()) == 0)
        {
            //子进程创建用于与客户端通信的client
            client = accept();
            
            //创建孙进程
            if(pid = fork() == 0)
            {
                while(1)
                {
                    //孙进程负责与客户端通信
                    recv();
                    send();
                }
                //通信结束关闭套接字
                close(client);
                //退出进程
                exit(0);
            }
            //子进程
            else if(pid > 0)
            {
                //关闭多余的文件描述符
                close(server);
                close(client);
                //退出子进程
                exit(0);
            }
        }
        //父进程
        else if(pid > 0)
        {
            //回收子进程
            while(waitpid() == pid)
        }
    }
    //关闭文件描述符
    close(server);
}

实例

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <sys/wait.h>
#include <time.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <signal.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <errno.h>

#define LOG(s) printf("[%s] {%s:%d} %s\n", __DATE__, __FILE__, __LINE__, s);

void deal_cil_msg(int client, struct sockaddr_in caddr);

int main(int argc, char *argv[])
{
	//创建服务器socket
	int server = 0;
	if((server = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		LOG("socket error");
		return -1;
	}

	//绑定服务器IP和端口号
	//给地址信息结构体赋值
	struct sockaddr_in saddr = {0};
	saddr.sin_family = AF_INET;
	saddr.sin_port = htons(8888);
	saddr.sin_addr.s_addr = htonl(INADDR_ANY);

	if(bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1)
	{
		LOG("bind error");
		return -1;
	}

	//监听对应的端口号
	if(listen(server, 5) == -1)
	{
		LOG("listen error");
		return -1;
	}

	puts("server start success");

	//创建用于与客户端通信的socket
	struct sockaddr_in caddr = {0};
	int client = 0;
	socklen_t asize = sizeof(caddr);


	pid_t pid = -1;
	int status = 0;
	while(1)
	{
		//父进程只负责生儿子
		pid = fork();
		if(pid < 0)
		{
			LOG("fork error");
			return -1;
		}
		//子进程负责创建通信socket
		if(pid == 0)
		{
			//创建用于与客户端通信的socket
			if((client = accept(server, (struct sockaddr*)&caddr, &asize)) == -1)
			{
				LOG("accept error");
				return -1;
			}
			printf("[%s/%d]client已上线\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port));

			//孙进程负责通信
			pid = fork();
			if(pid < 0)
			{
				LOG("fork error");
				return -1;
			}
			else if(pid == 0)
			{
				deal_cil_msg(client, caddr);
				close(client);
				exit(0);
			}
			else if(pid > 0)
			{
				close(server);
				close(client);
				//退出子进程
				exit(0);
			}
		}
		else if(pid > 0)
		{
			printf("wait child = %d\n", pid);
			//父进程等待子进程结束，准备收尸
			while(waitpid(pid, &status, 0) == pid)
			{
				printf("Parent is over - child: %d, status = %x\n", pid, status);
			}
		}
	}

	//关闭文件描述符
	close(server);
	
	return 0;
}


void deal_cil_msg(int client, struct sockaddr_in caddr)
{
	//接收消息
	char buf[128] = " ";

	while(1)
	{
		int len = 0;
		bzero(buf, sizeof(buf));
		if((len = recv(client, buf, sizeof(buf), 0)) < 0)
		{	
			LOG("recv error");
		}
		else if(len == 0)
		{
			printf("[%s/%d]client已下线\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port));
			break;
		}
		printf("[%s/%d]client: %s\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port), buf);

		bzero(buf, sizeof(buf));
		//发送消息
		strcpy(buf, "ok");
		write(client, buf, len);

	}


}

多线程并发服务器

设计流程

//线程参数结构体
typedef struct
{
	int client;
	struct sockaddr_in caddr;
} Client_msg;

int main()
{
    //创建服务器监听套接字 server
    server = socket();
    //给服务器地址信息结构体赋值，并绑定
    bind();
    //监听指定端口，设置监听队列
    listen();
    
    while(1)
    {
        //创建用于与客户端通信的套接字
        client = accpet();
        //创建线程
        pthread_create();
        while(1)
        {
            //读写
            //关闭文件描述符
            //退出线程
        }
        //解离线程
        pthread_detach();
    }
    //关闭文件描述符
    close(server);
}

实例

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <sys/wait.h>
#include <time.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <signal.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <errno.h>

#define LOG(s) printf("[%s] {%s:%d} %s \n", __DATE__, __FILE__, __LINE__, s);

void* cil(void* arg);

//线程参数结构体
typedef struct
{
	int client;
	struct sockaddr_in caddr;
} Cli_msg;

int main(int argc, char *argv[])
{
	//创建服务器监听分套接字 server
	int server = -1;
	if((server = socket(AF_INET, SOCK_STREAM, 0)) == -1)
	{
		LOG("socket error");
		return -1;
	}

	//给服务器地址信息结构体赋值，并绑定
	struct sockaddr_in saddr = {0};
	saddr.sin_family = AF_INET;
	saddr.sin_port = htons(8899);
	saddr.sin_addr.s_addr = htonl(INADDR_ANY);

	if(bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1)
	{
		LOG("bind error");
		return -1;
	}

	//监听端口
	if(listen(server, 5) == -1)
	{
		LOG("listen error");
		return -1;
	}
	
	puts("tcp server start success");

	struct sockaddr_in caddr = {0};
	socklen_t len = sizeof(caddr);
	pthread_t tid = -1;
	int client = -1;
	Cli_msg cli_msg;
	while(1)
	{
		//创建用于与客户端通信的套接字 client
		if((client = accept(server, (struct sockaddr*)&caddr, &len)) == -1)
		{
			LOG("accept error");
			return -1;
		}

		printf("[%s/%d]client已上线\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port));
		cli_msg.client = client;
		cli_msg.caddr = caddr;
		//创建线程
		if(pthread_create(&tid, NULL, cil, &cli_msg) != 0)
		{
			LOG("pthread_create error");
			return -1;
		}
		pthread_detach(tid);
	}

	close(server);
	return 0;
}

void* cil(void* arg)
{
	int client = ((Cli_msg*)arg)->client;
	struct sockaddr_in caddr = ((Cli_msg*)arg)->caddr;

	char buf[128] = "";
	int res = 0;

	while(1)
	{
		bzero(buf, sizeof(buf));
		if((res = read(client, buf, sizeof(buf))) < 0)
		{
			LOG("read error");
			break;
		}
		else if(res == 0)
		{
			printf("[%s/%d]client已下线\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port));
			close(client);
			pthread_exit(NULL);
		}
		printf("[%s/%d]client: %s\n", inet_ntoa(caddr.sin_addr), ntohs(caddr.sin_port), buf);

		bzero(buf, sizeof(buf));
		strcpy(buf, "ok");

		if(write(client, buf, sizeof(buf)) < 0)
		{
			LOG("write error");
			break;
		}
	}

}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

网络

tcpip

Linux

网络协议

基于LinuxC语言实现的TCP多线程/进程服务器 的相关文章

随机推荐

  • mysql连接字最多查询_MySQL中应该多表连接查询一次取数据库还是多次查询取数据？...

    MySQL中应该多表连接查询一次取数据库还是多次查询取数据 具体的case在下面 三个表的字段如下 webcast cast表 id organizerId title startDate endDate number date等 webc

  • undefined reference to 问题的一种解决方法

    问题描述 今天在移植mcal中的部分代码时 然后进行编译 在链接的步骤里面 遇见了报错 undefined reference to xxx 未定义的函数被引用的问题 实际上那个函数是被定义了的 不过那个函数比较特殊 是一个被extern

  • qt day3

    1 gt 登录框实现注册功能 将注册的结果放入文件中 君子作业 2 gt 完成文本编辑器的保存工作 widget h ifndef WIDGET H define WIDGET H include

  • Vue只弹一次的弹框cookie

  • .Net 中的托管函数 Delegate

    1 什么是托管函数 托管函数是一个对类里面的某个函数的一个引用 它自己并没有具体的函数定义 只是指向某个函数实现 2 与C Delphi的横向比较 在C 和Delphi中与托管函数对应的类型是函数指针 形式如下 C typedef int

  • aaaadafdsafdashfhdskhk

    aaaadafdsafdashfhdskhksdfdsfd

  • DirectSound播放PCM(可播放实时采集的音频数据)

    前言 该篇整理的原始来源为http blog csdn net leixiaohua1020 article details 40540147 非常感谢该博主的无私奉献 写了不少关于不同多媒体库的博文 让我这个小白学习到不少 现在将其整理是

  • Labview+Hsl通讯（与欧姆龙NX1P2通讯）

    通过和欧姆龙客服沟通 NX1P2不支持fins tcp与OPC UA 但是支持FINS UDP通讯 没办将就用吧 这里PLC IP 192 168 250 0 1 端口 9600 下面是测试图 PC端的端口随意填就行 不要和PLC端口重复就

  • [1150]Linux服务器上使用rz命令上传文件报:Segmentation Fault

    使用rz命令上传一张几十KB的图片 一直上传不了服务器 试了sz命令却是没问题 一直在排查是否Linux服务器对上传命令有所限制 最终未果 接着想到是否是硬盘空间不足了 使用df h命令一看 果然硬盘没空间了 使用率达到了100 接着使用

  • tf.nn 激活函数

    tf nn sigmoid tf nn tanh tanh函数解决了Sigmoid函数的不是zero centered输出问题 但梯度消失 gradient vanishing 的问题和幂运算的问题仍然存在 tf nn relu tf nn

  • 访问数据库_常用的数据库访问方式是什么？

    常用的数据库访问方式是什么 ASP 访问数据库的方式有哪些 在 ASP 中可以通过三种方式访问数据库 1 IDC Internet Database Connector 方式 2 ADO ActiveX Data Objects 方式 3

  • 如何跳出ajax,让AJAX运作中跳出来Loading

    CSS部分 CSS一部分 div loadingdiv height 100 width 100 100 遮盖网页页面 防止user在loading时开展别的实际操作 position fixed z index 99999 须超过网页页面

  • flink架构

    JobManager控制应用执行的主进程 jobMaster处理单独的job ResuorseManager分配task slots Dispatcher提交应用 Web UI展示监控执行信息 TaskManager包含task slots

  • 技术人员要拿百万年薪，必须要经历这9个段位

    很多人都问 技术人员如何成长 每个阶段又是怎样的 如何才能走出当前的迷茫 实现自我的突破 所以我结合我自己10多年的从业经验 总结了技术人员成长的9个段位 希望对大家的职业生涯 有所帮助 1 刚接触编程的时候 会觉得这是个很神奇东西 平淡的

  • 认识计算机性能指标

    计算机性能指标 存储器的容量 MAR 的位数反应存储单元的数量 MDR 的位数反应每个存储单元的大小 cpu性能指标 高电平1代表1个数字脉冲 低电平0也代表1个数字脉冲 1个cpu时钟周期 1个数字脉冲信号 通常单位微秒 纳秒 cpu主频

  • Python 的简洁表达：for语句，if语句，3变量值互换

    Python 语句遵循的是简洁为美的原则 所以有很多表达方式非常简洁 同时在熟练以后也不会牺牲可读性 一 for 语句 比如我们要求 n 2 n 2 n2 的值的列表 其中 n n

  • IntelliJ Plugin-Gradle 配置

    Step 1 使用Gradle构建IntelliJ plugin工程 Step 2 调整配置信息 plugins id java id org jetbrains intellij version 0 4 8 group xxx versi

  • 模拟人脑：迄今最大规模4个实验，人工智能的救赎之路？(附PDF公号发“模拟人脑”下载)

    模拟人脑 迄今最大规模4个实验 人工智能的救赎之路 附PDF公号发 模拟人脑 下载 许铁 科学Sciences 今天 科学Sciences导读 公众最早了解模拟大脑的事件是 1997年 电脑 深蓝 击败世界象棋冠军 2011年 计算机 沃森

  • Windows PostgreSql创建服务

    一 创建服务 使用管理员cmd命令窗口在bin目录下 执行命令 pg ctl exe register N 服务名称 D 安装data数据目录 二 删除服务 执行命令 sc delete 服务名 三 启动服务 执行命令 sc start 服

  • 基于LinuxC语言实现的TCP多线程/进程服务器

    多进程并发服务器 设计流程 框架一 使用信号回收僵尸进程 void handler int sig while waitpid 1 NULL WNOHANG gt 0 int main 回收僵尸进程 siganl 17 handler 创建

热门标签