欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

多进程

程序员文章站 2022-05-02 12:53:44
...

多进程:

    c不需要传递,因为fork之后,子进程可以直接通过c访问此链接,父进程创建子进程后,必须调用close( c );防止资源浪费,子进程结束后,也调用close( c ):

缺陷:

  创建一个进程,为一个客户端交互完成后,也会随之结束,会造成服务器系统担。
  如果客户端多很多,则服务器端创建的子进程也会很多。并日大部分子进程会阻塞在recv操作

sever

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <signal.h>

void ChildDealClient(int c,struct sockaddr_in cli)
{
	while(1)
	{
		char buff[128]={0};
		int n=recv(c,buff,127,0);//阻塞  有数据可读或者客户端退出都会返回
		if(n==0)
		{
			printf("client unlink\n");
			close(c);
			break;//要继续接收下一个连接
		}
		else if(n==-1)
		{
			printf("error\n");
			close(c);
			break;
		}

		printf("n==%d: %s",n,buff);
		send(c,"OK",2,0);
	}
}
int main()
{
	signal(SIGCHLD,SIG_IGN);
	int listenfd=socket(AF_INET,SOCK_STREAM,0);
	assert(-1!=listenfd);

	struct sockaddr_in ser,cli;
	memset(&ser,0,sizeof(ser));//清空
	ser.sin_family=AF_INET;//IPv4地址族
	ser.sin_port=htons(6000);//主机到网络的short型,给服务器指定端口号
	inet_aton("127,0,0,1",(struct in_addr*)&ser.sin_addr);//把字符型地址转换为整形

	int res=bind(listenfd,(struct sockaddr*)&ser,sizeof(ser));
	assert(-1!=res);

	listen(listenfd,5);
	while(1)
	{
		int len=sizeof(cli);
		//c特定客户端和服务器连接的文件描述符
		//accept函数只有在有客户端连接的情况下返回
		int c=accept(listenfd,(struct sockaddr*)&cli,&len);//阻塞运行
		assert(-1!=c);

		pid_t pid=fork();
		assert(pid!=-1);
		if(pid==0)
		{
			ChildDealClient(c,cli);
			exit(0);
		}
		else
		{
			close(c);
		}
	}
}

Cli

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <string.h>
#include <netinet/in.h>//字节序列转换函数所用
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>//地址转换函数所用

int main()
{
	int sockfd=socket(AF_INET,SOCK_STREAM,0);
	assert(-1!=sockfd);

	struct sockaddr_in ser;
	memset(&ser,0,sizeof(ser));
	ser.sin_family=AF_INET;
	ser.sin_port=htons(6000);
	inet_aton("127.0.0.1",(struct in_addr*)&ser.sin_addr);

	int res=connect(sockfd,(struct sockaddr*)&ser,sizeof(ser));
	assert(-1!=res);
	
	while(1)
	{
		printf("please input: ");
		char data[128]={0};
		fgets(data,128,stdin);
		if(strncmp(data,"bye",3)==0)
		{
			close(sockfd);
			break;
		}

		send(sockfd,data,strlen(data)+1,0);
		char buff[128]={0};
		int n=recv(sockfd,buff,127,0);
		if(n<=0)
		{
			printf("error\n");
			close(sockfd);
			break;
		}
		printf("n==%d: %s\n",n,buff);
	}
}

相关标签: 多进程