循环服务器，并发服务器模型以及I/O多路转接模型

https://blog.csdn.net/xinianbuxiu/article/details/53455784

一、基于TCP/IP协议的基本循环服务器

tcp_server.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <netdb.h>
#define PORT 3333
#define MAX_SIZE 1024
int main()
{
int sockfd;
int new_fd;
struct sockaddr_in server_addr;
struct sockaddr_in client_addr;
int n_read;
int ser_size;
int opt = 1;
char buffer[MAX_SIZE];
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0)
{
perror("socket error!\n");
exit(1);
}
printf("socket success.............!\n");
if(setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt)) < 0)
{
perror("set socket option error!\n");
exit(1);
}
bzero(&server_addr,0);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr("192.168.1.10");
if(bind(sockfd,(struct sockaddr *)&server_addr,sizeof server_addr) < 0)
{
perror("bind error!\n");
exit(1);
}
printf("bind success.............!\n");
listen(sockfd,5);
printf("listen success.............!\n");
printf("accepting..................!\n");
while(1)
{
ser_size = sizeof client_addr;
if((new_fd = accept(sockfd,(struct sockaddr *)&client_addr,&ser_size)) < 0)
{
perror("accept error!\n");
exit(1);
}
printf("accept success.................!\n");
//read\recv
printf("reading............!\n");
n_read = read(new_fd,buffer,sizeof(buffer));
if(n_read < 0)
{
perror("read client msg error!\n");
exit(1);
}
buffer[n_read] = '\0';
printf("recv msg = %s\n",buffer);
}
return 0;
}

tcp_client.c

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#define PORT 3333
#define MAX_SIZE 1024
int main(int argc, char *argv[])
{
if(argc != 2)
{
printf("Please input server ip!\n");
exit(1);
}
int sockfd;
int n_write;
struct sockaddr_in server_addr;
char buffer[MAX_SIZE];
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0)
{
perror("client socket error!\n");
exit(1);
}
bzero(&server_addr,0);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr(argv[1]);
if(connect(sockfd,(struct sockaddr *)&server_addr,sizeof server_addr) < 0)
{
perror("connect server error!\n");
exit(1);
}
while(1)
{
memset(buffer,0,sizeof(buffer));
printf("Please input send msg:\n");
gets(buffer);
n_write = write(sockfd,buffer,strlen(buffer));
if(n_write == -1)
{
perror("send to server msg error!\n");
exit(1);
}
}
return 0;
}

循环服务器能不断地接收客户端发送过来的信息，但是在面对多个客户端时，服务器必须等待第一个客户端发送信息才能接受其他客户端发来的信息。

由此，我们使用并发服务器，通过创建子进程，使得多个客户端能随时发信息给服务器

并发服务器：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <netdb.h>
#define PORT 3333
#define MAX_SIZE 1024
void * read_msg(void *arg)
{
int n_read;
int new_fd = *((int *)arg);
char buffer[MAX_SIZE];
printf("new_fd = %d\n",new_fd);
while(1)
{
memset(buffer,0,sizeof(buffer));
n_read = read(new_fd,buffer,sizeof(buffer));
if(n_read < 0)
{
perror("recv client msg error!\n");
exit(1);
}
if(n_read == 0)
{
printf("client is close!!\n");
close(new_fd);
pthread_exit(NULL);
}
buffer[n_read] = '\0';
printf("recv msg:%s\n",buffer);
}
}
int main()
{
int sockfd;
int new_fd;
struct sockaddr_in server_addr;
struct sockaddr_in client_addr;
int n_read;
int ser_size;
int opt = 1;
char buffer[MAX_SIZE];
pthread_t id;
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0)
{
perror("socket error!\n");
exit(1);
}
printf("socket success.............!\n");
if(setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt)) < 0)
{
perror("set socket option error!\n");
exit(1);
}
bzero(&server_addr,0);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr("192.168.1.10");
if(bind(sockfd,(struct sockaddr *)&server_addr,sizeof server_addr) < 0)
{
perror("bind error!\n");
exit(1);
}
printf("bind success.............!\n");
listen(sockfd,5);
printf("listen success.............!\n");
printf("accepting..................!\n");
while(1)
{
ser_size = sizeof client_addr;
if((new_fd = accept(sockfd,(struct sockaddr *)&client_addr,&ser_size)) < 0)
{
perror("accept error!\n");
exit(1);
}
printf("accept success.................!\n");
pthread_create(&id,NULL,read_msg,&new_fd);
}
return 0;
}

并发客户端：

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#define PORT 3333
#define MAX_SIZE 1024
int main(int argc, char *argv[])
{
if(argc != 2)
{
printf("Please input server ip!\n");
exit(1);
}
int sockfd;
int n_write;
struct sockaddr_in server_addr;
char buffer[MAX_SIZE];
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0)
{
perror("client socket error!\n");
exit(1);
}
bzero(&server_addr,0);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr(argv[1]);
if(connect(sockfd,(struct sockaddr *)&server_addr,sizeof server_addr) < 0)
{
perror("connect server error!\n");
exit(1);
}
while(1)
{
memset(buffer,0,sizeof(buffer));
printf("Please input send msg:\n");
gets(buffer);
n_write = write(sockfd,buffer,strlen(buffer));
if(n_write == -1)
{
perror("send to server msg error!\n");
exit(1);
}
}
return 0;
}

并发服务器模型的缺点是：客户端不再和服务器交互时，其多线程仍在工作，比较耗费CPU 的资源。

I/O多路转接模型：

利用一个“监听者”，当有客户端发出连接请求及客户端发送信息时，才会和服务器连接。

服务器代码：

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<ctype.h>
#define portnumber 8000
#define MAX_LINE 80
int main(void)
{
int lfd;
int cfd;
int sfd;
int rdy;
struct sockaddr_in sin;
struct sockaddr_in cin;
int client[FD_SETSIZE];
int maxi;
int maxfd;
fd_set rset;
fd_set allset;
socklen_t addr_len;
char buffer[MAX_LINE];
int i;
int n;
int len;
int opt = 1;
char addr_p[20];
bzero(&sin,sizeof(struct sockaddr_in));
sin.sin_family=AF_INET;
sin.sin_addr.s_addr=htonl(INADDR_ANY);
sin.sin_port=htons(portnumber);
if((lfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{
fprintf(stderr,"Socket error:%s\n\a",strerror(errno));
exit(1);
}
printf("socket!\n");

setsockopt(lfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
if(bind(lfd,(struct sockaddr *)(&sin),sizeof(struct sockaddr))==-1)
{
fprintf(stderr,"Bind error:%s\n\a",strerror(errno));
exit(1);
}
printf("bind!\n");
if(listen(lfd,20)==-1)
{
fprintf(stderr,"Listen error:%s\n\a",strerror(errno));
exit(1);
}
printf("listen!\n");
printf("Accepting connections .......\n");
maxfd = lfd;
maxi = -1;
for(i = 0;i < FD_SETSIZE;i++)
{
client[i] = -1;
}
FD_ZERO(&allset);
FD_SET(lfd,&allset);
while(1)
{
rset = allset;
printf("selecting!\n");
rdy = select(maxfd + 1, &rset, NULL, NULL, NULL);
printf("selected!\n");
if(FD_ISSET(lfd, &rset))
{
addr_len = sizeof(sin);
printf("accepting!\n");
if((cfd=accept(lfd,(struct sockaddr *)(&cin),&addr_len))==-1)
{
fprintf(stderr,"Accept error:%s\n\a",strerror(errno));
exit(1);
}
printf("accepted!\n");
for(i = 0; i<FD_SETSIZE; i++)
{ //printf("%d\t",client[i]);
if(client[i] <= 0)
{
client[i] = cfd;
break;
}
}
if(i == FD_SETSIZE)
{
printf("too many clients");
exit(1);
}
FD_SET(cfd, &allset);
if(cfd > maxfd)
{
maxfd = cfd;
}
if(i > maxi)
{
maxi = i;
}
if(--rdy <= 0)
{
continue;
}
}
for(i = 0;i< FD_SETSIZE;i++)
{
if((sfd = client[i]) < 0)
{
continue;
}
if(FD_ISSET(sfd, &rset))
{
printf("reading!\n");
n = read(sfd,buffer,MAX_LINE);
printf("%s\n",buffer);
printf("read!\n");
if(n == 0)
{
printf("the other side has been closed. \n");
fflush(stdout);
close(sfd);
FD_CLR(sfd, &allset);
client[i] = -1;
}
else
{
inet_ntop(AF_INET, &cin.sin_addr, addr_p, sizeof(addr_p));
addr_p[strlen(addr_p)] = '\0';
printf("Client Ip is %s, port is %d\n",addr_p,ntohs(cin.sin_port));
if(n == 1)
{
exit(1);
}
}
if(--rdy <= 0)
{
break;
}
}
}
close(lfd);
return 0;
}

多路转接客户端：

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#define portnumber 8000
int main(int argc, char *argv[])
{
int nbytes;
int sockfd;
char buffer[80];
char buffer_2[80];
struct sockaddr_in server_addr;
struct hostent *host;
if(argc!=2)
{
fprintf(stderr,"Usage:%s hostname \a\n",argv[0]);
exit(1);
}
if((host=gethostbyname(argv[1]))==NULL)
{
fprintf(stderr,"Gethostname error\n");
exit(1);
}
if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1) // AF_INET:Internet;SOCK_STREAM:TCP
{
fprintf(stderr,"Socket Error:%s\a\n",strerror(errno));
exit(1);
}
bzero(&server_addr,sizeof(server_addr)); //
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(portnumber);
server_addr.sin_addr = *((struct in_addr *)host->h_addr);//址
if(connect(sockfd,(struct sockaddr *)(&server_addr),sizeof(struct sockaddr))==-1)
{
fprintf(stderr,"Connect Error:%s\a\n",strerror(errno));
exit(1);
}
while(1){
printf("Please input char:\n");
fgets(buffer,1024,stdin);
write(sockfd,buffer,strlen(buffer));
#if 0
if((nbytes=read(sockfd,buffer_2,81))==-1)
{
fprintf(stderr,"Read Error:%s\n",strerror(errno));
exit(1);
}
buffer_2[nbytes]='\0';
printf("Client received from Server %s\n",buffer_2);
#endif
}
close(sockfd);
exit(0);
}

循环服务器，并发服务器模型以及I/O多路转接模型相关推荐

Linux征途——多路转接模型
文章目录 1. 简介 2. select 3. poll 3. epoll 3.1 相关系统调用 3.2 工作流程 3.3 回调机制 3.3.1 水平触发Level Triggered 3.3.2 边 ...
IO多路转接模型-----epoll
epoll: Linux下性能最高的多路转接模型 epoll 有3个相关的系统调用. epoll_create 功能:创建epoll,在内核中创建eventpoll结构体,size决定了epoll最多 ...
IO多路转接模型----（select的模型，select的优缺点，poll的模型，poll的优缺点）
IO多路转接模型:select/poll/epoll 对大量描述符进行事件监控(可读/可写/异常) select模型用户定义描述符的事件监控集合 fd_set(这是一个位图,用于存储要监控的描述符) ...
多路转接模型多路复用模型
多路转接模型&多路复用模型功能: 同时监控大量描述符,然后逐个针对就绪的描述符进行处理: 针对大量描述符进行IO事件监控,让进程可以只针对就绪的描述符进行IO操作,提高IO效率,避免针对未就 ...
高级IO--1 ---（五种典型IO，阻塞IO，非阻塞IO，信号驱动IO，异步IO， IO多路转接）
高级IO: 五种典型IO: 阻塞IO/非阻塞IO/信号驱动IO/异步IO/IO多路转接 IO多路转接模型:select/poll/epoll 五种典型IO 阻塞IO IO操作的流程:等待IO操作条件具 ...
多路转接IO模型：多路转接多路复用
IO模型:多路转接&多路复用一.多路转接IO模型 (一)作用 (二)IO就绪事件 1.可读 2.可写 3.异常二.技术实现 (一)select模型 1.select操作流程 2.Linux ...
Linux多路转接or多路复用模型
目录一.功能二.应用场景三.多路转接模型的实现 1.select模型 1.1操作流程 1.2相关接口 1.3示例 1.4常见使用方式 1.5优缺点 2.poll模型 2.1操作流程 2.2相关接 ...
多路转接select1
高级IO 通常情况下所有的 IO 都可以分为两步来完成, 第一步等待, 第二步数据搬迁, 为了提高 IO 效率通常所运用的方法就是减少等待的时间举个钓鱼的例子现在有五个人张三, 李四, 王五, 赵 ...
详解I/O多路转接之select
什么是多路转接IO 对大量的描述符进行I/O事件监控-可以告诉进程现在有哪些描述符就绪了,然后进行就可以只针对就绪了的描述符进行响应操作,避免对没有就绪的I/O操作所导致的效率降低和流程阻塞. IO事 ...

循环服务器，并发服务器模型以及I/O多路转接模型

循环服务器，并发服务器模型以及I/O多路转接模型相关推荐

最新文章

热门文章