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;
}