#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <sys/epoll.h>
#include <unistd.h>
#include <sys/types.h>
#define IPADDRESS "127.0.0.1"
#define PORT 6666
#define MAXSIZE 1024
#define LISTENQ 5
#define FDSIZE 1000
#define EPOLLEVENTS 100
/*函数声明*/
/*创建套接字并进行绑定*/
int socket_bind(const char* ip,int port);
/*IO多路复用epoll*/
void do_epoll(int listenfd);
/*事件处理函数*/
void handle_events(int epollfd,struct epoll_event *events,int num,int listenfd,char *buf);
/*处理接收到的连接*/
void handle_accpet(int epollfd,int listenfd);
/*读处理*/
void do_read(int epollfd,int fd,char *buf);
/*写处理*/
void do_write(int epollfd,int fd,char *buf);
/*添加事件*/
void add_event(int epollfd,int fd,int state);
/*修改事件*/
void modify_event(int epollfd,int fd,int state);
/*删除事件*/
void delete_event(int epollfd,int fd,int state);
int main(int argc,char *argv[]){
int listenfd;
listenfd = socket_bind(IPADDRESS,PORT);
listen(listenfd,LISTENQ);
do_epoll(listenfd);
return 0;
}
int socket_bind(const char* ip,int port){
int listenfd;
struct sockaddr_in servaddr;
listenfd = socket(AF_INET,SOCK_STREAM,0);
if (listenfd == -1){
perror("socket error:");
exit(1);
}
bzero(&servaddr,sizeof(servaddr));
servaddr.sin_family = AF_INET;
inet_pton(AF_INET,ip,&servaddr.sin_addr);
servaddr.sin_port = htons(port);
if (bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr)) == -1){
perror("bind error: ");
exit(1);
}
return listenfd;
}
void do_epoll(int listenfd){
int epollfd;
struct epoll_event events[EPOLLEVENTS];
int ret;
char buf[MAXSIZE];
memset(buf,0,MAXSIZE);
/*创建一个描述符*/
epollfd = epoll_create(FDSIZE);
/*添加监听描述符事件*/
add_event(epollfd,listenfd,EPOLLIN);
while(1){
/*获取已经准备好的描述符事件*/
ret = epoll_wait(epollfd,events,EPOLLEVENTS,-1);
handle_events(epollfd,events,ret,listenfd,buf);
}
close(epollfd);
}
void handle_events(int epollfd,struct epoll_event *events,int num,int listenfd,char *buf){
int i;
int fd;
/*进行选好遍历*/
for (i = 0;i < num;i++){
fd = events[i].data.fd;
/*根据描述符的类型和事件类型进行处理*/
if ((fd == listenfd) &&(events[i].events & EPOLLIN))
handle_accpet(epollfd,listenfd);
else if (events[i].events & EPOLLIN)
do_read(epollfd,fd,buf);
else if (events[i].events & EPOLLOUT)
do_write(epollfd,fd,buf);
}
}
void handle_accpet(int epollfd,int listenfd){
int clifd;
struct sockaddr_in cliaddr;
socklen_t cliaddrlen;
clifd = accept(listenfd,(struct sockaddr*)&cliaddr,&cliaddrlen);
if (clifd == -1)
perror("accpet error:");
else{
printf("accept a new client: %s:%d\n",inet_ntoa(cliaddr.sin_addr),cliaddr.sin_port);
/*添加一个客户描述符和事件*/
add_event(epollfd,clifd,EPOLLIN);
}
}
void do_read(int epollfd,int fd,char *buf){
int nread;
nread = read(fd,buf,MAXSIZE);
if (nread == -1){
perror("read error:");
close(fd);
delete_event(epollfd,fd,EPOLLIN);
}
else if (nread == 0){
fprintf(stderr,"client close.\n");
close(fd);
delete_event(epollfd,fd,EPOLLIN);
}
else{
printf("read message is : %s",buf);
/*修改描述符对应的事件，由读改为写*/
modify_event(epollfd,fd,EPOLLOUT);
}
}
void do_write(int epollfd,int fd,char *buf){
int nwrite;
nwrite = write(fd,buf,strlen(buf));
if (nwrite == -1){
perror("write error:");
close(fd);
delete_event(epollfd,fd,EPOLLOUT);
}
else
modify_event(epollfd,fd,EPOLLIN);
memset(buf,0,MAXSIZE);
}
void add_event(int epollfd,int fd,int state){
struct epoll_event ev;
ev.events = state;
ev.data.fd = fd;
epoll_ctl(epollfd,EPOLL_CTL_ADD,fd,&ev);
}
void delete_event(int epollfd,int fd,int state){
struct epoll_event ev;
ev.events = state;
ev.data.fd = fd;
epoll_ctl(epollfd,EPOLL_CTL_DEL,fd,&ev);
}
void modify_event(int epollfd,int fd,int state){
struct epoll_event ev;
ev.events = state;
ev.data.fd = fd;
epoll_ctl(epollfd,EPOLL_CTL_MOD,fd,&ev);
}
后台开发：核心技术与应用实践 书籍源代码
需积分: 10 161 浏览量
2016-12-15
16:30:58
上传
评论
收藏 120KB ZIP 举报
后台开发：核心技术与应用实践 书籍源代码 （198个子文件） 
server.cpp 5KB server.cpp 4KB server.cpp 4KB client.cpp 4KB 0331.cpp 3KB 0317.cpp 3KB server.cpp 3KB server.cpp 2KB client.cpp 2KB client.cpp 2KB client.cpp 2KB client.cpp 2KB server.cpp 2KB 0316.cpp 2KB test.cpp 2KB 0507.cpp 2KB server.cpp 2KB test.cpp 2KB test.cpp 2KB test.cpp 2KB client.cpp 1KB server.cpp 1KB test.cpp 1KB 0305.cpp 1KB 0229.cpp 1KB reader.cpp 1KB client.cpp 1KB writer.cpp 1KB client.cpp 1KB consumer.cpp 1KB 1203.cpp 1KB msgreceive.cpp 1KB test.cpp 1KB msgsend.cpp 1KB producer.cpp 1KB 0226.cpp 1KB test.cpp 1KB test.cpp 1KB 1202.cpp 1KB 0330.cpp 1KB 0315.cpp 1021B keyboard.cpp 995B test.cpp 979B 0329.cpp 968B test.cpp 912B test.cpp 877B test.cpp 870B keyboard.cpp 866B test.cpp 864B 0213.cpp 861B 0310.cpp 856B mkfifo_r.cpp 834B 0321.cpp 813B test.cpp 811B 0311.cpp 801B 0308.cpp 799B test.cpp 794B 0302.cpp 782B 0227.cpp 775B post.cpp 774B 0307.cpp 757B test.cpp 734B test.cpp 713B test.cpp 707B test.cpp 662B 0111.cpp 655B 0209.cpp 621B 0326.cpp 608B 0233.cpp 599B 0301.cpp 591B 0103.cpp 587B 0107.cpp 574B 0210.cpp 570B test.cpp 561B test.cpp 561B test.cpp 561B 0328.cpp 551B 0225.cpp 550B test.cpp 543B 0319.cpp 526B 0224.cpp 523B 0211.cpp 508B 0231.cpp 507B 0318.cpp 492B 0313.cpp 488B 0212.cpp 484B 0110.cpp 483B 0105.cpp 475B 0113.cpp 469B 0325.cpp 468B 0309.cpp 468B 0106.cpp 460B test.cpp 458B test.cpp 454B 0327.cpp 454B 0112.cpp 448B 0220.cpp 447B 0120.cpp 446B 0323.cpp 444B 0208.cpp 444B共 198 条
- 1
- 2
资源评论
