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

LINUX网络编程----TCP----一服务器对多客户端(多进程处理)

程序员文章站 2024-03-22 15:13:10
...

一对多,服务器使用多进程

##服务器代码

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

typedef struct   sockaddr    SA;			//通用地址信息结构
typedef struct   sockaddr_in SIN;			//基于网络层的地址信息结构
#define PORT_NUM   10000						//端口号
#define SERVER_IP  "192.168.1.22"				//IP地址

/*多进程服务器*/
int main(int argc, const char *argv[])
{
	int serfd;//服务器套接字描述符
	SIN seraddr;//存放服务器地址信息
	int ret;
	int clifd;//连接上的客户端的套接字描述符
	SIN cliaddr;//存放连接上的客户端的地址信息
	socklen_t addrlen;//指向客户端地址信息长度的指针
	char r_buf[1024] = {0};//接受缓存区
	int recv_len;//实际接收到的数据长度
	pid_t p_ret;
	int reuse = 1;

	/*创建一个套接字*/
	serfd = socket(AF_INET,SOCK_STREAM,0);//返回套接字描述符
	if(serfd == -1)
	{
		perror("socket fail");
		exit(-1);
	}	

	/*服务器地址信息*/
	bzero(&seraddr,sizeof(SIN));
	seraddr.sin_family = AF_INET;//表示IPv4
	seraddr.sin_port = htons(PORT_NUM);//主机端口号转成网络无符号短整型字节
	seraddr.sin_addr.s_addr = inet_addr(SERVER_IP);//将IP转换成二进制

	/*设置地址可以重复使用*/
	ret = setsockopt(serfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse));
	if(ret == -1)
	{
		perror("setsockopt fail");
		exit(-1);
	}

	/*将服务器地址信息与套接字绑定*/
	ret = bind(serfd,(SA*)&seraddr,sizeof(SA));
	if(ret == -1)
	{
		perror("bind fail");
		exit(-1);
	}

	/*将套接字设置为监听模式*/
	ret = listen(serfd,10);//等待连接的客户端个数
	if(ret == -1)
	{
		perror("listen fail");
		exit(-1);
	}

	while(1)
	{
		/*等待一个客户端的连接*/
		clifd = accept(serfd,(SA*)&cliaddr,&addrlen);//成功就返回本次连接的客户端套接字描述符
		if(clifd == -1)
		{
			perror("accept fail");
			exit(-1);
		}
		printf("connect with clifd_%d successfully\n",clifd);//成功与客户端连接
		
		p_ret = fork();
		if(p_ret == 0)
		{
			while(1)
			{
				/*等待接受来自客户端的内容*/
				bzero(r_buf,sizeof(r_buf));
				recv_len = recv(clifd,r_buf,sizeof(r_buf),0);
				if(recv_len == -1)
				{
					perror("recv fail");
					exit(-1);
				}
				else if(recv_len == 0)
				{
					printf("clifd_%d offline\n",clifd);
					close(serfd);
					close(clifd);
					exit(0);
				}
				printf("recv from clifd_%d:%s\n",clifd,r_buf);
			}
		}
	}

	close(serfd);
	close(clifd);

	return 0;
}

## 客户端代码```

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

typedef struct sockaddr SA;
typedef struct sockaddr_in SIN;
#define PORT_NUM 10000
#define SERVER_IP "192.168.1.22"


int main(int argc, const char *argv[])
{
	int sockfd;//要连接的服务器的套接字标识符
	SIN seraddr;
	int ret;
	char t_buf[1024] = {0};
	int send_len;

	sockfd = socket(AF_INET,SOCK_STREAM,0);//SOCK_STREAM表示TCP
	if(sockfd == -1)
	{
		perror("socket fail");
		exit(-1);
	}

	/*编写服务器地址信息*/
	bzero(&seraddr,sizeof(SIN));
	seraddr.sin_family = AF_INET;//IPv4
	seraddr.sin_port = htons(PORT_NUM);
	seraddr.sin_addr.s_addr = inet_addr(SERVER_IP);

	/*连接服务器*/
	ret = connect(sockfd,(SA*)&seraddr,sizeof(SA));
	if(ret == -1)
	{
		perror("connect fail");
		exit(-1);
	}
	printf("connect with SERVER_%d successfully\n",sockfd);

	while(1)
	{
		fflush(stdin);//更新缓冲区
		bzero(t_buf,sizeof(t_buf));
		/*发送信息*/
		printf("Please enter your messages:");
		scanf("%s",t_buf);
		send_len = send(sockfd,t_buf,sizeof(t_buf),0);
		if(send_len == -1)
		{
			perror("send fail");
			exit(-1);
		}
	}

	close(sockfd);
	return 0;
}