【网络编程实例】C++实现基于I/O复用epoll函数的服务器和客户端通信
admin
2024-02-17 01:12:54
0

参考《TCP/IP网络编程第17章》

epoll函数

  • epoll函数的优点:
    • 无需编写以监视状态变化为目的的针对所有文件描述符的循环语句;
    • 调用对应于 select 函数的 epoll_wait 函数时无需每次传递监视对象信息。
  • epoll 函数的功能:
    • epoll_create:创建保存 epoll 文件描述符的空间;
    • epoll_ctl:向空间注册并注销文件描述符;
    • epoll_wait:与 select 函数类似,等待文件描述符发生变化;
  • epoll_event 结构体:
    • 用于保存事件的文件描述符结合;
    • epoll_event 的成员 events 中可以保存的常量及所指的事件类型:
      • EPOLLIN:需要读取数据的情况
      • EPOLLOUT:输出缓冲为空,可以立即发送数据的情况
      • EPOLLPRI:收到 OOB 数据的情况
      • EPOLLRDHUP:断开连接或半关闭的情况,这在边缘触发方式下非常有用
      • EPOLLERR:发生错误的情况

实现基于epoll函数的服务器和客户端通信

  • 服务器端代码
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include #include 
#include using std::cout;
using std::cin;
using std::string;
using std::endl;#define BUF_SIZE 1024
#define EPOLL_SIZE 50
#define SERVER_IP "127.0.0.1"    // 指定服务端的IP
#define SERVER_PORT 9190            // 指定服务端的portint main()
{int serv_sock, clnt_sock;struct sockaddr_in serv_adr, clnt_adr;socklen_t adr_sz;int str_len, i;char buf[BUF_SIZE];struct epoll_event *ep_events;struct epoll_event event;int epfd, event_cnt;serv_sock = socket(PF_INET, SOCK_STREAM, 0);bzero(&serv_adr, sizeof(serv_adr));serv_adr.sin_family = AF_INET;serv_adr.sin_addr.s_addr = htonl(INADDR_ANY);serv_adr.sin_port = htons(SERVER_PORT);if(bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr)) == -1) cout << "Bind error" << errno << ": " << strerror(errno) << endl;if(listen(serv_sock, 5) == -1) cout << "Listen error" <<  errno << ": " << strerror(errno) << endl;epfd = epoll_create(EPOLL_SIZE);//可以忽略这个参数,填入的参数为操作系统参考ep_events = (struct epoll_event*)malloc(sizeof(struct epoll_event) * EPOLL_SIZE);event.events = EPOLLIN;//需要读取数据的情况event.data.fd = serv_sock;//例程epfd 中添加文件描述符 serv_sock,目的是监听 enevt 中的事件epoll_ctl(epfd, EPOLL_CTL_ADD,serv_sock, &event);while(1){event_cnt = epoll_wait(epfd, ep_events, EPOLL_SIZE, - 1);//获取改变了的文件描述符,返回数量if(event_cnt == -1) {cout << "epoll_wait() error" << endl;break;}for(i = 0; i < event_cnt; ++i) {if(ep_events[i].data.fd == serv_sock)//客户端请求连接时{adr_sz = sizeof(clnt_adr);clnt_sock = accept(serv_sock, (struct sockaddr*)&clnt_adr, &adr_sz);event.events = EPOLLIN;event.data.fd = clnt_sock;//把客户端套接字添加进去epoll_ctl(epfd, EPOLL_CTL_ADD, clnt_sock, &event);cout << "connected client:" << clnt_sock << endl;}else //是客户端套接字时{str_len = read(ep_events[i].data.fd,buf, BUF_SIZE);if(str_len == 0){epoll_ctl(epfd, EPOLL_CTL_DEL, ep_events[i].data.fd, &event);close(ep_events[i].data.fd);cout << "closed client:" << ep_events[i].data.fd << endl;}else{write(ep_events[i].data.fd,buf, str_len);}}}}close(serv_sock);close(epfd);return 0;
}
  • 客户端代码
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include #include 
#include using std::cout;
using std::cin;
using std::string;
using std::endl;#define BUFFSIZE 1024
#define SERVER_IP "127.0.0.1"    // 指定服务端的IP
#define SERVER_PORT 9190            // 指定服务端的portint main()
{int sock;char message[BUFFSIZE];int str_len;struct sockaddr_in serv_adr;sock = socket(PF_INET, SOCK_STREAM, 0);if(sock == -1) cout << "socket() error" << endl;bzero(&serv_adr, sizeof(serv_adr));serv_adr.sin_family = AF_INET;serv_adr.sin_addr.s_addr = inet_addr(SERVER_IP);serv_adr.sin_port = htons(SERVER_PORT);if(connect(sock, (struct sockaddr *)&serv_adr, sizeof(serv_adr)) == -1)cout << "connect() error: " << errno << " " << strerror(errno) << endl;elsecout << "connected............" << endl;while(1){cout << "Input message(Q to quit): " << endl;cin >> message;if(!strcmp(message, "q") || !strcmp(message, "Q"))break;write(sock, message, strlen(message));str_len = read(sock, message, BUFFSIZE - 1);message[str_len] = 0;cout << "Message from server:" << message << endl;}close(sock);return 0;
}

相关内容

热门资讯

安卓系统打游戏推荐,一触即达! 你有没有发现,现在手机游戏越来越好玩了?不管是休闲小游戏还是大型MMORPG,都能在手机上畅玩。但是...
开店宝系统和安卓,助力商家轻松... 你有没有想过,开店也能变得如此轻松?没错,就是那个神奇的“开店宝系统”,它可是安卓平台上的一大神器呢...
安卓平板装早教机系统,安卓平板... 你有没有想过,家里的安卓平板除了刷剧、玩游戏,还能变成一个超级早教机呢?没错,就是那种能让孩子从小接...
电脑装安卓系统好处,电脑装安卓... 你有没有想过,你的电脑装上安卓系统会有什么神奇的变化呢?想象一台原本只能处理文档和PPT的电脑,突然...
HTC莫扎特刷安卓系统,畅享全... 你有没有听说过HTC莫扎特这款手机?最近,它可是刷爆了安卓系统爱好者们的眼球呢!今天,就让我带你一起...
安卓系统的致命漏洞,揭秘潜在安... 你知道吗?最近安卓系统可是闹出了一个大新闻,一个致命的漏洞让无数用户都紧张兮兮的。咱们就来聊聊这个事...
安卓的系统文件在哪,安卓系统文... 你有没有想过,你的安卓手机里那些神秘的系统文件都藏在哪个角落呢?别急,今天就来带你一探究竟,让你对这...
公认最好的安卓系统,揭秘公认最... 你有没有想过,为什么安卓手机那么受欢迎?是不是因为那个公认最好的安卓系统?没错,今天咱们就来聊聊这个...
安卓系统默认音量调整,轻松设置... 你有没有发现,每次拿起手机,那个默认的音量调整按钮总是那么默默无闻地躺在那里?今天,就让我带你一探究...
照片怎样导出安卓系统,一键导出... 你有没有遇到过这种情况:手机里存了好多美美的照片,想分享给朋友或者保存到电脑上,却发现导出照片到安卓...
什么电视支持安卓系统,解锁智能... 你有没有想过,家里的电视是不是也能像手机一样,随时随地下载各种应用,畅享网络世界呢?没错,现在很多电...
鸿蒙系统投屏安卓系统电视,开启... 亲爱的读者们,你是否曾想过,家里的安卓电视也能享受到鸿蒙系统的魅力呢?没错,今天就要来聊聊这个让人眼...
安卓系统如何连手柄,安卓系统下... 你有没有想过,在安卓系统上玩游戏的时候,如果能够用上游戏手柄,那该有多爽啊!想象手指轻轻一按,游戏角...
安卓打包当前系统rom,基于安... 你有没有想过,手机里的安卓系统其实就像是一个个精心打造的城堡,而ROM就像是这座城堡的装修风格。今天...
索爱售后安卓系统,索爱售后安卓... 你有没有遇到过手机售后的问题呢?尤其是那些安卓系统的手机,有时候出了点小状况,真是让人头疼。今天,咱...
安卓7.0系统速度咋样,速度与... 你有没有发现,自从手机更新到安卓7.0系统后,感觉整个手机都焕然一新了呢?今天,就让我来给你详细聊聊...
安卓文件系统隔离,Androi... 你知道吗?在安卓的世界里,有一个神奇的小秘密,那就是安卓文件系统隔离。听起来是不是有点高大上?别急,...
电脑板安卓系统下载,轻松实现多... 你有没有想过,你的电脑板突然间变得如此强大,竟然能运行安卓系统?没错,这就是科技的魅力!今天,就让我...
安卓系统双开app排行,热门双... 安卓系统双开App排行大揭秘在数字化时代,手机已经成为我们生活中不可或缺的一部分。而安卓系统,作为全...
安卓原生系统谁在开发,谷歌主导... 你有没有想过,那个陪伴你每天刷抖音、玩游戏、办公的安卓系统,究竟是谁在背后默默开发呢?今天,就让我带...