企业网站功能是什么,wordpress pdf 预览,yellow免费观看完整,怎样优古网络公司网站后台前言 之前找工作的之后写了一些网络编程的笔记和代码#xff0c;然后现在放到csdn上保存一下。有几个版本的#xff0c;看看就好。就是简单的实现一下服务端和客户端之间的交互的#xff0c;还没有我之前上linux编程课写的代码复杂。 哦对了#xff0c;这个网络编程的代码对…前言 之前找工作的之后写了一些网络编程的笔记和代码然后现在放到csdn上保存一下。有几个版本的看看就好。就是简单的实现一下服务端和客户端之间的交互的还没有我之前上linux编程课写的代码复杂。 哦对了这个网络编程的代码对错误处理函数进行了一些封装就是将select、accept等函数进一步封装了一下问题不大。要是有朋友看到这篇博客想学习啥的有问题可以问我。这个其实是在b站上看视频写的代码嗯其实没必要看我的代码的。 最后客户端的代码都是一样的不用客户端的代码其实也可以启动服务端后直接用nc命令进行测试就行。
使用环境 makefile文件 直接将所有文件复制到同一个目录下然后打开终端使用make命令就全部编译好了。
# 定义编译器
CXXgcc# 定义编译选项-Wall表示将所有警告打开这里注释掉
# CFLAGS-Wall# 定义多个目标文件
TARGETclient
TARGET1server1
TARGET2server2
TARGET3server3
TARGET4server4
TARGET5server5
TARGET6server6# 定义多个源文件
SRCclient.c wrap.c
SRC1server1.c wrap.c
SRC2server2.c wrap.c
SRC3server3.c wrap.c
SRC4server4.c wrap.c
SRC5server5.c wrap.c
SRC6server6.c wrap.c# 默认目标
all: $(TARGET) $(TARGET1) $(TARGET2) $(TARGET3) $(TARGET4) $(TARGET5) $(TARGET6)# 编译第一个文件
$(TARGET): $(SRC)$(CXX) -o $(TARGET) $(SRC)
# 编译其他文件
$(TARGET1): $(SRC1)$(CXX) -o $(TARGET1) $(SRC1)
$(TARGET2): $(SRC2)$(CXX) -o $(TARGET2) $(SRC2)
$(TARGET3): $(SRC3)$(CXX) -o $(TARGET3) $(SRC3) -pthread
$(TARGET4): $(SRC4)$(CXX) -o $(TARGET4) $(SRC4)
$(TARGET5): $(SRC5)$(CXX) -o $(TARGET5) $(SRC5)
$(TARGET6): $(SRC6)$(CXX) -o $(TARGET6) $(SRC6)# 清理编译生成的文件
.PHONY: clean
clean:rm -f $(TARGET) $(TARGET1) $(TARGET2) $(TARGET3) $(TARGET4) $(TARGET5) $(TARGET6)
错误处理函数封装头文件wrap.h
#ifndef __WRAP_H_
#define __WRAP_H_
void perr_exit(const char *s);
int Accept(int fd, struct sockaddr *sa, socklen_t *salenptr);
int Bind(int fd, const struct sockaddr *sa, socklen_t salen);
int Connect(int fd, const struct sockaddr *sa, socklen_t salen);
int Listen(int fd, int backlog);
int Socket(int family, int type, int protocol);
ssize_t Read(int fd, void *ptr, size_t nbytes);
ssize_t Write(int fd, const void *ptr, size_t nbytes);
int Close(int fd);
ssize_t Readn(int fd, void *vptr, size_t n);
ssize_t Writen(int fd, const void *vptr, size_t n);
ssize_t my_read(int fd, char *ptr);
ssize_t Readline(int fd, void *vptr, size_t maxlen);
#endif
错误处理函数封装wrap.c
#include stdlib.h
#include errno.h
#include sys/socket.h
void perr_exit(const char *s)
{perror(s);exit(1);
}
int Accept(int fd, struct sockaddr *sa, socklen_t *salenptr)
{int n;again:if ( (n accept(fd, sa, salenptr)) 0) {if ((errno ECONNABORTED) || (errno EINTR))goto again;elseperr_exit(accept error);}return n;
}
int Bind(int fd, const struct sockaddr *sa, socklen_t salen)
{int n;if ((n bind(fd, sa, salen)) 0)perr_exit(bind error);return n;
}
int Connect(int fd, const struct sockaddr *sa, socklen_t salen)
{int n;if ((n connect(fd, sa, salen)) 0)perr_exit(connect error);return n;
}
int Listen(int fd, int backlog)
{int n;if ((n listen(fd, backlog)) 0)perr_exit(listen error);return n;
}
int Socket(int family, int type, int protocol)
{int n;if ( (n socket(family, type, protocol)) 0)perr_exit(socket error);return n;
}
ssize_t Read(int fd, void *ptr, size_t nbytes)
{ssize_t n;
again:if ( (n read(fd, ptr, nbytes)) -1) {if (errno EINTR)goto again;elsereturn -1;}return n;
}
ssize_t Write(int fd, const void *ptr, size_t nbytes)
{ssize_t n;
again:if ( (n write(fd, ptr, nbytes)) -1) {if (errno EINTR)goto again;elsereturn -1;}return n;
}
int Close(int fd)
{int n;if ((n close(fd)) -1)perr_exit(close error);return n;
}
ssize_t Readn(int fd, void *vptr, size_t n)
{size_t nleft;ssize_t nread;char *ptr;ptr vptr;nleft n;while (nleft 0) {if ( (nread read(fd, ptr, nleft)) 0) {if (errno EINTR)nread 0;elsereturn -1;} else if (nread 0)break;nleft - nread;ptr nread;}return n - nleft;
}ssize_t Writen(int fd, const void *vptr, size_t n)
{size_t nleft;ssize_t nwritten;const char *ptr;ptr vptr;nleft n;while (nleft 0) {if ( (nwritten write(fd, ptr, nleft)) 0) {if (nwritten 0 errno EINTR)nwritten 0;elsereturn -1;}nleft - nwritten;ptr nwritten;}return n;
}static ssize_t my_read(int fd, char *ptr)
{static int read_cnt;static char *read_ptr;static char read_buf[100];if (read_cnt 0) {
again:if ((read_cnt read(fd, read_buf, sizeof(read_buf))) 0) {if (errno EINTR)goto again;return -1; } else if (read_cnt 0)return 0;read_ptr read_buf;}read_cnt--;*ptr *read_ptr;return 1;
}ssize_t Readline(int fd, void *vptr, size_t maxlen)
{ssize_t n, rc;char c, *ptr;ptr vptr;for (n 1; n maxlen; n) {if ( (rc my_read(fd, c)) 1) {*ptr c;if (c \n)break;} else if (rc 0) {*ptr 0;return n - 1;} elsereturn -1;}*ptr 0;return n;
}客户端代码client.c
#include stdio.h
#include string.h
#include netinet/in.h
#include arpa/inet.h
#include signal.h
#include sys/wait.h
#include sys/types.h
#include wrap.h#define SERVER_PORT 8888 //需要与服务器相同int main(int argc, char *argv[])
{int sc0,err0,slen0;char message[1024]{0};struct sockaddr_in server_addr;bzero(server_addr,sizeof(server_addr));server_addr.sin_familyAF_INET;server_addr.sin_porthtons(SERVER_PORT);server_addr.sin_addr.s_addrhtonl(INADDR_ANY);//或inet_pton(AF_INET,127.0.0.1,server_addr.sin_addr.s_addr);scSocket(AF_INET,SOCK_STREAM,0);err Connect(sc,(struct sockaddr*)server_addr,sizeof(struct sockaddr));while(1){//持续进行通信slenRead(0,message,sizeof(message));slenWrite(sc,message,slen);slenRead(sc,message,slen);slenWrite(1,message,slen);}Close(sc);return 0;
}
第一版服务器直接发送接受只能一次且一个客户端server1.c
#include stdio.h
#include string.h
#include netinet/in.h
#include arpa/inet.h
#include signal.h
#include sys/wait.h
#include sys/types.h
#include wrap.h//宏定义
#define MAXLEN 100 //设置监听上限
#define SERVER_PORT 8888 //绑定的端口int main(int argc, char *argv[])
{int ss0,sc0,slen0,err0;//创建套接字char message[1024]{0},client_ip[1024]{0};//创建字符串来作为缓冲区,或用BUFSIZ4096struct sockaddr_in server_addr,client_addr;//创建服务器端和客户端的地址结构socklen_t addrlen;//地址结构的长度bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPss Socket(AF_INET,SOCK_STREAM,0);int opt1;setsockopt(ss,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用err Bind(ss,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构err Listen(ss,MAXLEN);//设置监听上限addrlen sizeof(struct sockaddr);scAccept(ss,(struct sockaddr*)client_addr,addrlen);printf(client ip:%s,port:%d\n,inet_ntop(AF_INET,client_addr.sin_addr.s_addr,client_ip,sizeof(client_ip)),ntohs(client_addr.sin_port));//inet_ntop:将网络字节序转为本地字节序//ntohs:将网络端口转为本地端口while(1){slen Read(sc,message,1024);//接收信息Write(1,message,slen);//将收到的信息输出STDOUT_FILENO1,STDIN_FILENO0;for(int i0;islen;i)//进行大小写转换if(message[i]amessage[i]z)message[i]message[i]-aA;//message[i]toupper(message[i]);slenWrite(sc,message,slen);//将转换后的信息发回给客户端}Close(sc);//关闭文件描述符Close(ss);return 0;
}
第二版服务器多进程多并发服务器直接用fork创建子进程处理客户端请求server2.c
#include stdio.h
#include string.h
#include strings.h
#include netinet/in.h
#include arpa/inet.h
#include signal.h
#include sys/wait.h
#include sys/types.h
#include wrap.h//宏定义
#define MAXLEN 100 //设置监听上限
#define SERVER_PORT 8888 //绑定的端口void catch_child(int signum){while(waitpid(0, NULL,WNOHANG)0);return ;
}int main(int argc, char *argv[])
{int lfd0,cfd0,slen0,ret;//创建套接字pid_t pid;//创建子进程char message[1024]{0},client_ip[1024]{0};//创建字符串来作为缓冲区,或用BUFSIZ4096struct sockaddr_in server_addr,client_addr;//创建服务器端和客户端的地址结构socklen_t addrlen;//地址结构的长度bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPint opt1;setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用lfd Socket(AF_INET,SOCK_STREAM,0);Bind(lfd,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构Listen(lfd,MAXLEN);//设置监听上限addrlen sizeof(struct sockaddr);printf(Accepting connections ...\n);while(1){cfd Accept(lfd,(struct sockaddr*)client_addr,addrlen);printf(client ip:%s,port:%d 进入\n,inet_ntop(AF_INET,client_addr.sin_addr.s_addr,client_ip,sizeof(client_ip)),ntohs(client_addr.sin_port));//inet_ntop:将网络字节序转为本地字节序//ntohs:将网络端口转为本地端口pidfork();if(pid0){Close(lfd);while(1){slen Read(cfd,message,1024);//接收信息if(slen0){Close(cfd);exit(1);}Write(1,message,slen);//将收到的信息输出STDOUT_FILENO1,STDIN_FILENO0;for(int i0;islen;i)//进行大小写转换if(message[i]amessage[i]z)message[i]message[i]-aA;//message[i]toupper(message[i]);slenWrite(cfd,message,slen);//将转换后的信息发回给客户端}Close(cfd);break;}else if(pid 0) perr_exit(fork error);else{struct sigaction act;//-----还不知道这是在干嘛act.sa_handlercatch_child;sigemptyset(act.sa_mask);act.sa_flags 0;ret sigaction(SIGCHLD,act,NULL);if(ret!0) perr_exit(sigaction error);Close(cfd);continue; }}Close(lfd);//关闭文件描述符return 0;
}
第三版服务器多线程多并发服务器创建子线程处理客户端请求多线程在编译时要加-pthread,在makefile文件中加上即可server3.c
#include stdio.h
#include string.h
#include strings.h
#include netinet/in.h
#include arpa/inet.h
#include signal.h
#include sys/wait.h
#include sys/types.h
#include pthread.h
#include wrap.h#define MAXLISTEN 100 //设置监听上限
#define MAXLINE 80 //缓冲区大小
#define SERVER_PORT 8888 //绑定的端口
#define MAXCLIENT 256 //最大客户端数量struct client_info{struct sockaddr_in client_addr;int connfd;
};
void *do_work(void *arg){int slen;struct client_info *temp (struct client_info*)arg;char buf[MAXLINE],client_ip[1024];char str[INET_ADDRSTRLEN];pthread_detach(pthread_self());while(1){slenRead(temp-connfd, buf, MAXLINE);if(slen 0){printf(client ip:%s quit\n,inet_ntop(AF_INET,(*temp).client_addr.sin_addr,client_ip,sizeof(client_ip)));break;}Write(1,buf,slen);//输出到本地printf( received ip:%s at port:%d :,inet_ntop(AF_INET,(*temp).client_addr.sin_addr,client_ip,sizeof(client_ip)),ntohs((*temp).client_addr.sin_port));//进行处理for(int i0;islen;i)if(buf[i]abuf[i]z)buf[i]buf[i]-aA;Write(temp-connfd,buf,slen);//将改好的信息发回客户端}Close(temp-connfd);return (void*)0;
}
int main(int argc, char *argv[])
{int lfd0,cfd0;//创建套接字int i0;//i为线程编号struct sockaddr_in server_addr,client_addr;//创建服务器端的地址结构socklen_t addrlen;//地址结构的长度char client_ip[1024];pthread_t tid;struct client_info client[MAXCLIENT];//创建客户端地址结构bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPint opt1;setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用lfd Socket(AF_INET,SOCK_STREAM,0);Bind(lfd,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构Listen(lfd,MAXLISTEN);//设置监听上限addrlen sizeof(struct sockaddr);printf(Accepting connections ...\n);while(1){cfd Accept(lfd,(struct sockaddr*)client_addr,addrlen);printf(client ip:%s,port:%d 进入\n,inet_ntop(AF_INET,client_addr.sin_addr.s_addr,client_ip,sizeof(client_ip)),ntohs(client_addr.sin_port));client[i].client_addrclient_addr;client[i].connfdcfd;/*达到线程最大数时pthread_create出错处理增加服务器稳定性*/pthread_create(tid, NULL, do_work, (void*)client[i]);i;}Close(lfd);return 0;
}
第四版服务器使用select多路IO转接借助内核select用来监听客户端请求server4.c
#include stdio.h
#include stdlib.h
#include string.h
#include netinet/in.h
#include arpa/inet.h
#include wrap.h#define MAXLISTEN 100 //设置监听上限
#define MAXLINE 80 //缓冲区大小
#define SERVER_PORT 8888 //设置服务端的端口int main(int argc, char *argv[])
{int lfd,cfd,sockfd,slen,ret,i;//创建套接字int maxi;//用来保存最大的文件描述符int maxfd,client[FD_SETSIZE];//最大文件描述符、客户端文件描述符集合,FD_SETSIZE默认为1024pid_t pid;//创建子进程char buf[MAXLINE],str[INET_ADDRSTRLEN];//创建字符串来作为缓冲区,或用BUFSIZ4096,str用来使用inet_ntop函数struct sockaddr_in server_addr,client_addr;//创建服务器端和客户端的地址结构socklen_t addrlen;//地址结构的长度fd_set rset,allset;//文件描述符集合,创建监听集合int opt1;setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用lfd Socket(AF_INET,SOCK_STREAM,0);bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPBind(lfd,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构Listen(lfd,MAXLISTEN);//设置监听上限maxfd lfd;maxi-1;for(i0;iFD_SETSIZE;i)client[i]-1;//对客户端文件描述符集合进行初始化FD_ZERO(allset); //将监听集合清空FD_SET(lfd,allset);//将lfd添加到读集合中。addrlen sizeof(struct sockaddr);printf(Accepting connections ...\n);while(1){rsetallset;//保存监听集合ret select(maxfd1,rset,NULL,NULL,NULL); //监听文件描述符集合对应事件if(ret0)perr_exit(select error);if(FD_ISSET(lfd,rset)){//1 在0 不在cfd Accept(lfd,(struct sockaddr*)client_addr,addrlen);//建立连接不会阻塞printf(client ip:%s at port:%d access\n,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)),ntohs(client_addr.sin_port));for(i0;iFD_SETSIZE;i)if(client[i]0){client[i]cfd;break;}if (i FD_SETSIZE) {/* 达到select能监控的文件个数上限 1024 */fputs(too many clients\n, stderr);exit(1);}FD_SET(cfd,allset);//将新产生的fd添加到监听通信描述符集合中if(maxfdcfd)maxfdcfd;//select第一个参数需要if(imaxi)maxii;//更新client[]数组中的最大文件描述符if(--ret 0) continue;//只有lfd事件后续的for不执行}for(i0;imaxi;i){//处理满足都事件的fdif((sockfd client[i])0) continue;//将client[i]赋值给sockfdif(FD_ISSET(sockfd,rset)){//找到满足读事件的fdslen Read(sockfd,buf,sizeof buf);if(slen 0){//当客户端关闭连接时服务端也关闭连接/*printf(client ip %s at port %d quit\n,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)),ntohs(client_addr.sin_port));*/Close(sockfd);FD_CLR(sockfd,allset);//解除select对此文件描述符的监控client[i]-1;}else if(slen0){/*printf(received from %s at port %d :,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)),ntohs(client_addr.sin_port));*/Write(1,buf,slen);for(int j0;jslen;j)//进行处理if(buf[j]abuf[j]z)buf[j]buf[j]-aA;slen Write(sockfd,buf,slen);}if(--ret 0)break;} }}Close(lfd);//关闭文件描述符return 0;
}
第五版服务器poll多路IO转接poll是半成品了解即可server5.c
#include stdio.h
#include stdlib.h
#include string.h
#include netinet/in.h
#include arpa/inet.h
#include poll.h
#include errno.h
#include wrap.h#define MAXLISTEN 100 //设置监听上限
#define MAXLINE 80 //缓冲区大小
#define SERVER_PORT 8888 //设置服务端的端口
#define OPEN_MAX 1024int main(int argc, char *argv[])
{int lfd,cfd,sockfd,slen,ret,i,maxi;//创建套接字,maxi为用来保存最大的文件描述符char buf[MAXLINE],str[INET_ADDRSTRLEN];//创建字符串来作为缓冲区,或用BUFSIZ4096//str用来使用inet_ntop函数,INET_ADDESTRLEN16struct sockaddr_in server_addr,client_addr;//创建服务器端和客户端的地址结构struct pollfd client[OPEN_MAX];socklen_t addrlen;//地址结构的长度int opt1;setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用lfd Socket(AF_INET,SOCK_STREAM,0);bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPBind(lfd,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构Listen(lfd,MAXLISTEN);//设置监听上限maxi0;client[0].fdlfd;client[0].eventsPOLLRDNORM;for(i1;iOPEN_MAX;i)client[i].fd-1;addrlen sizeof(struct sockaddr);printf(Accepting connections ...\n);while(1){retpoll(client,maxi1,-1);if(client[0].revents POLLRDNORM){//处理lfdcfdAccept(lfd,(struct sockaddr*)client_addr,addrlen);printf(client ip:%s at port:%d access\n,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)),ntohs(client_addr.sin_port));for(i1;iOPEN_MAX;i)if(client[i].fd0){client[i].fdcfd;//找到client中空闲的位置并将客户端的文件描述符放入break;}if(iOPEN_MAX) perr_exit(to many client);//客户端数量过多client[i].eventsPOLLRDNORM;if(imaxi)maxii;if(--ret0)continue;}for(i1;imaxi;i){//处理cfdsockfdclient[i].fd;if(sockfd0)continue;if(client[i].revents (POLLRDNORM | POLLERR)){slenRead(sockfd,buf,sizeof buf);if(slen0){if(errno ECONNRESET){//收到RST标志printf(client[%d](ip:%s) aborted connection\n,i,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)));Close(sockfd);client[i].fd-1;}else perr_exit(read error);}else if(slen 0){//说明客户端先关闭连接printf(client[%d](ip:%s) closed connection\n,i,inet_ntop(AF_INET, client_addr.sin_addr, str, sizeof(str)));Close(sockfd);client[i].fd-1;}else {for(int j0;jslen;j)if(buf[j]abuf[j]z)buf[j]buf[j]-aA;slenWrite(sockfd,buf,slen);}if(--ret0)break;}}}Close(lfd);//关闭文件描述符return 0;
}
第六版服务器epoll多路IO转接server6.c
#include stdio.h
#include stdlib.h
#include string.h
#include netinet/in.h
#include arpa/inet.h
#include sys/epoll.h
#include errno.h
#include wrap.h#define MAXLISTEN 100 //设置listen监听上限
#define MAXLINE 80 //缓冲区大小
#define SERVER_PORT 8888 //设置服务端的端口
#define OPEN_MAX 1024int main(int argc, char *argv[])
{int lfd,cfd,sockfd,slen,ret,res,i,j,maxi,efd;//创建套接字,maxi为用来保存最大的文件描述符int client[OPEN_MAX];char buf[MAXLINE],str[INET_ADDRSTRLEN];//创建字符串来作为缓冲区,或用BUFSIZ4096//str用来使用inet_ntop函数,INET_ADDESTRLEN16struct sockaddr_in server_addr,client_addr;//创建服务器端和客户端的地址结构struct epoll_event tep,ep[OPEN_MAX];//tep为临时变量socklen_t addrlen;//地址结构的长度int opt1;setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//设置端口复用lfd Socket(AF_INET,SOCK_STREAM,0);bzero(server_addr,sizeof server_addr);//清零server_addr.sin_family AF_INET;//协议族server_addr.sin_port htons(SERVER_PORT);//绑定端口server_addr.sin_addr.s_addr htonl(INADDR_ANY);//绑定IPBind(lfd,(struct sockaddr*)server_addr,sizeof server_addr);//给socket绑定地址结构Listen(lfd,MAXLISTEN);//设置监听上限maxi -1;for(i 0;i OPEN_MAX;i) client[i] -1;efd epoll_create(OPEN_MAX);if(efd 0) perr_exit(epoll_create error);tep.events EPOLLIN;//设置临时变量tep.data.fd lfd;res epoll_ctl(efd,EPOLL_CTL_ADD,lfd,tep);if(res 0) perr_exit(epoll_ctl error);addrlen sizeof(struct sockaddr);printf(Accepting connections ...\n);while(1){ret epoll_wait(efd, ep, OPEN_MAX, -1);//阻塞监听,返回监听到的文件描述符数量if(ret 0) perr_exit(epoll_wait error);for(i 0;i ret; i){if(!(ep[i].events EPOLLIN)) continue;if(ep[i].data.fd lfd){cfd Accept(lfd,(struct sockaddr *)client_addr,addrlen);printf(client ip:%s at port %d access\n,inet_ntop(AF_INET,client_addr.sin_addr,str,sizeof str),ntohs(client_addr.sin_port));for(j0;jOPEN_MAX;j)//找一个空位置存放客户端的文件描述符if(client[j] 0){client[j]cfd;break;}if(j OPEN_MAX) perr_exit(too many clients);if(j maxi) maxij;tep.events EPOLLIN;tep.data.fd cfd;res epoll_ctl(efd,EPOLL_CTL_ADD,cfd,tep);if(res 0)perr_exit(epoll_ctl error);}else {sockfd tep.data.fd;slen Read(sockfd,buf,sizeof buf);if(slen 0){for(j0;jmaxi;j)if(client[j]sockfd){client[j]-1;break;}res epoll_ctl(efd,EPOLL_CTL_DEL,sockfd,NULL);if(res 0) perr_exit(eopll_ctl error);Close(sockfd);printf(client[%d] closed connection\n,j);}else{Write(1,buf,slen);for(j0;jslen;j)if(buf[j]abuf[j]z)buf[j]buf[j]-aA;Write(sockfd,buf,slen);}}}}Close(lfd);//关闭文件描述符Close(efd);return 0;
}
结语 没啥好说的找到工作之后就是当牛马了也不知道能干几年已经在想养老了但是养老计算器说还要干40年我想我真能活到那时候吗。现在是还没转正工作也是最近才找到的因为考研失败摆烂了好长时间是一家国企965感觉还行。公司计算机不能接外网所以我发个博客用手机看个人电脑不推荐带到时候看一些函数作用啥的看自己的代码好想起。
