![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418153209-68027079a9d41.png\")
<\/p>\n\u6700\u8fd1\u4e5f\u662f\u5728\u5b66\u4e60Reactor\u7684\u539f\u7406，\u4e5f\u770b\u4e86\u5f88\u591a\u76f8\u5173\u7684\u9879\u76ee\u3002\u51fa\u4e8e\u5b66\u4e60\u7684\u5fc3\u6001，\u6211\u5c31\u5c1d\u8bd5\u5b66\u4e60\u9648\u7855\u7684Tcp\u7f51\u7edc\u7f16\u7a0b\u5e93（Muduo）\u3002\u8fd9\u7bc7\u6587\u7ae0\u5c06\u5e26\u4f60\u4ece\u96f6\u5f00\u59cb\u5b9e\u73b0\u4e00\u4e2aMutli-reactor\u670d\u52a1\u5668\u3002<\/p>\n
\u5728\u9ad8\u6027\u80fd\u7f51\u7edc\u7f16\u7a0b\u4e2d，Reactor\u6a21\u5f0f\u662f\u4e00\u79cd\u5e38\u7528\u7684\u4e8b\u4ef6\u9a71\u52a8\u67b6\u6784\u6a21\u5f0f，\u5b83\u5141\u8bb8\u670d\u52a1\u5668\u9ad8\u6548\u5730\u5904\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002\u800cMulti-Reactor\u6a21\u5f0f\u662f\u5bf9\u7ecf\u5178Reactor\u6a21\u5f0f\u7684\u4e00\u79cd\u6269\u5c55\u548c\u4f18\u5316，\u901a\u8fc7\u5c06\u4e8b\u4ef6\u5206\u6d3e\u4e0e\u4e8b\u4ef6\u5904\u7406\u5206\u79bb，\u5e76\u5229\u7528\u591a\u4e2aReactor\u5b9e\u4f8b\u6765\u63d0\u9ad8\u7cfb\u7edf\u6027\u80fd\u548c\u53ef\u6269\u5c55\u6027\u3002\u5728\u8fd9\u79cd\u6a21\u5f0f\u4e0b，\u901a\u5e38\u6709\u4e00\u4e2a\u4e3b\u7ebf\u7a0b（\u6216\u5c11\u91cf\u7ebf\u7a0b）\u8d1f\u8d23\u76d1\u542c\u65b0\u8fde\u63a5\u8bf7\u6c42，\u5e76\u5c06\u8fd9\u4e9b\u8fde\u63a5\u5206\u914d\u7ed9\u5de5\u4f5c\u7ebf\u7a0b\u6c60\u4e2d\u7684\u4e0d\u540cReactor\u5b9e\u4f8b\u8fdb\u884c\u5904\u7406\u3002<\/p>\n
\u5f53\u7136，\u8fd9\u79cd\u6a21\u578b\u4e5f\u6709\u660e\u663e\u7f3a\u70b9，\u8fde\u63a5\u5efa\u7acb\u3001IO \u4e8b\u4ef6\u8bfb\u53d6\u4ee5\u53ca\u4e8b\u4ef6\u5206\u53d1\u5b8c\u5168\u6709\u5355\u7ebf\u7a0b\u5904\u7406；\u6bd4\u5982\u5f53\u67d0\u4e2a\u8fde\u63a5\u901a\u8fc7\u7cfb\u7edf\u8c03\u7528\u6b63\u5728\u8bfb\u53d6\u6570\u636e，\u6b64\u65f6\u76f8\u5bf9\u4e8e\u5176\u4ed6\u4e8b\u4ef6\u6765\u8bf4，\u5b8c\u5168\u662f\u963b\u585e\u72b6\u6001，\u65b0\u8fde\u63a5\u65e0\u6cd5\u5904\u7406\u3001\u5176\u4ed6\u8fde\u63a5\u7684 IO\u3001\u67e5\u8be2 IO \u8bfb\u5199\u4ee5\u53ca\u4e8b\u4ef6\u5206\u53d1\u90fd\u65e0\u6cd5\u5b8c\u6210\u3002\u4f46\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u5b66\u4e60Mutli-reactor\u7f16\u7a0b\u6a21\u578b\u62d3\u5c55\u81ea\u5df1\u5bf9\u4e8eReactor\u7684\u4e86\u89e3\u3002\u4e0b\u56fe\u662f\u7b80\u5355\u7684Mutli-reactor\u793a\u4f8b\u3002<\/p>\n
<\/p>\n
\u4e0b\u9762\u7684\u4ee3\u7801，\u7b80\u5355\u4ecb\u7ecd\u4e86\u5982\u4f55\u5b9e\u73b0\u4e00\u4e2a\u57fa\u672c\u7684Mutli-reactor\u670d\u52a1\u5668（\u4e10\u7248）<\/p>\n
#include <iostream>
\n#include <thread>
\n#include <vector>
\n#include <sys\/epoll.h>
\n#include <unistd.h>
\n#include <fcntl.h>
\n#include <netinet\/in.h><\/p>\n
#define MAX_EVENTS 10 \/\/ \u6700\u5927\u4e8b\u4ef6\u6570
\n#define PORT 8080 \/\/ \u76d1\u542c\u7aef\u53e3<\/p>\n
\/\/ \u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f
\nvoid set_nonblock(int fd) {
\n int flags = fcntl(fd, F_GETFL, 0); \/\/ \u83b7\u53d6\u5f53\u524d\u6587\u4ef6\u72b6\u6001\u6807\u5fd7
\n fcntl(fd, F_SETFL, flags | O_NONBLOCK); \/\/ \u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f
\n}<\/p>\n
\/\/ \u5904\u7406\u5ba2\u6237\u7aef\u8fde\u63a5
\nvoid handle_client(int client_fd) {
\n char buffer[1024]; \/\/ \u7f13\u51b2\u533a\u7528\u4e8e\u5b58\u50a8\u8bfb\u53d6\u7684\u6570\u636e
\n \/\/ \u5faa\u73af\u8bfb\u53d6\u5e76\u5904\u7406\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u6570\u636e
\n while(true) {
\n \/\/ \u4ece\u5ba2\u6237\u7aef\u8bfb\u53d6\u6570\u636e\u5230\u7f13\u51b2\u533a
\n ssize_t read_bytes = read(client_fd, buffer, sizeof(buffer));
\n if(read_bytes > 0) { \/\/ \u5982\u679c\u8bfb\u53d6\u5230\u6570\u636e
\n std::cout << "Received: " << std::string(buffer, read_bytes) << std::endl; \/\/ \u6253\u5370\u63a5\u6536\u5230\u7684\u6570\u636e
\n write(client_fd, buffer, read_bytes); \/\/ \u5c06\u6570\u636e\u56de\u4f20\u7ed9\u5ba2\u6237\u7aef（echo）
\n } else { \/\/ \u6ca1\u6709\u6570\u636e\u6216\u53d1\u751f\u9519\u8bef\u65f6\u5173\u95ed\u8fde\u63a5
\n close(client_fd);
\n break;
\n }
\n }
\n}<\/p>\n
\/\/ \u5b50Reactor\u5904\u7406\u903b\u8f91，\u8d1f\u8d23\u5904\u7406\u5177\u4f53\u7684\u5ba2\u6237\u7aef\u8fde\u63a5
\nvoid sub_reactor(int listen_fd) {
\n \/\/ \u521b\u5efaepoll\u5b9e\u4f8b
\n int epoll_fd = epoll_create1(0);
\n struct epoll_event event;
\n event.events = EPOLLIN | EPOLLET; \/\/ \u76d1\u542c\u53ef\u8bfb\u4e8b\u4ef6\u548c\u8fb9\u7f18\u89e6\u53d1\u6a21\u5f0f
\n event.data.fd = listen_fd; \/\/ \u5173\u8054\u76d1\u542csocket
\n epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listen_fd, &event); \/\/ \u5c06\u76d1\u542csocket\u52a0\u5165epoll\u76d1\u63a7\u5217\u8868<\/p>\n
struct epoll_event events[MAX_EVENTS]; \/\/ \u7528\u4e8e\u5b58\u50a8\u53d1\u751f\u7684\u4e8b\u4ef6
\n while(true) {
\n \/\/ \u7b49\u5f85\u4e8b\u4ef6\u53d1\u751f（\u963b\u585e\u76f4\u5230\u6709\u4e8b\u4ef6）
\n int n = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
\n for(int i = 0; i < n; ++i) {
\n if(events[i].data.fd == listen_fd) { \/\/ \u5982\u679c\u662f\u65b0\u7684\u8fde\u63a5\u8bf7\u6c42
\n sockaddr_in client_addr;
\n socklen_t client_len = sizeof(client_addr);
\n int client_fd = accept(listen_fd, (sockaddr*)&client_addr, &client_len); \/\/ \u63a5\u53d7\u65b0\u8fde\u63a5
\n if(client_fd == -1) continue;
\n set_nonblock(client_fd); \/\/ \u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f
\n event.events = EPOLLIN | EPOLLET; \/\/ \u8bbe\u7f6e\u76d1\u542c\u4e8b\u4ef6\u7c7b\u578b
\n event.data.fd = client_fd; \/\/ \u5173\u8054\u65b0\u7684\u5ba2\u6237\u7aefsocket
\n epoll_ctl(epoll_fd, EPOLL_CTL_ADD, client_fd, &event); \/\/ \u5c06\u65b0\u7684\u5ba2\u6237\u7aefsocket\u52a0\u5165epoll\u76d1\u63a7\u5217\u8868
\n } else { \/\/ \u5982\u679c\u662f\u5df2\u6709\u8fde\u63a5\u7684\u6570\u636e\u5230\u8fbe
\n handle_client(events[i].data.fd); \/\/ \u5904\u7406\u5ba2\u6237\u7aef\u6570\u636e
\n epoll_ctl(epoll_fd, EPOLL_CTL_DEL, events[i].data.fd, nullptr); \/\/ \u4eceepoll\u4e2d\u79fb\u9664\u8be5socket
\n close(events[i].data.fd); \/\/ \u5173\u95edsocket
\n }
\n }
\n }
\n}<\/p>\n
int main() {
\n int listen_fd = socket(AF_INET, SOCK_STREAM, 0); \/\/ \u521b\u5efa\u76d1\u542csocket
\n set_nonblock(listen_fd); \/\/ \u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f<\/p>\n
sockaddr_in server_addr;
\n server_addr.sin_family = AF_INET; \/\/ \u4f7f\u7528IPv4\u5730\u5740\u65cf
\n server_addr.sin_port = htons(PORT); \/\/ \u7ed1\u5b9a\u7aef\u53e3\u53f7
\n server_addr.sin_addr.s_addr = htonl(INADDR_ANY); \/\/ \u7ed1\u5b9a\u6240\u6709\u53ef\u7528\u7684\u7f51\u7edc\u63a5\u53e3<\/p>\n
bind(listen_fd, (sockaddr*)&server_addr, sizeof(server_addr)); \/\/ \u7ed1\u5b9asocket\u5230\u6307\u5b9a\u7684IP\u548c\u7aef\u53e3
\n listen(listen_fd, SOMAXCONN); \/\/ \u5f00\u59cb\u76d1\u542c<\/p>\n
\/\/ \u4e3bReactor\u5faa\u73af\u5728\u4e3b\u7ebf\u7a0b\u4e2d\u8fd0\u884c
\n int epoll_fd = epoll_create1(0); \/\/ \u521b\u5efaepoll\u5b9e\u4f8b
\n struct epoll_event event;
\n event.events = EPOLLIN; \/\/ \u76d1\u542c\u53ef\u8bfb\u4e8b\u4ef6
\n event.data.fd = listen_fd; \/\/ \u5173\u8054\u76d1\u542csocket
\n epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listen_fd, &event); \/\/ \u5c06\u76d1\u542csocket\u52a0\u5165epoll\u76d1\u63a7\u5217\u8868<\/p>\n
std::vector<std::thread> threads;
\n const int num_threads = std::thread::hardware_concurrency(); \/\/ \u83b7\u53d6\u786c\u4ef6\u652f\u6301\u7684\u6700\u5927\u5e76\u53d1\u7ebf\u7a0b\u6570
\n for(int i = 0; i < num_threads; ++i) {
\n threads.emplace_back(sub_reactor, listen_fd); \/\/ \u542f\u52a8\u591a\u4e2a\u5b50Reactor\u7ebf\u7a0b
\n }<\/p>\n
struct epoll_event events[MAX_EVENTS]; \/\/ \u7528\u4e8e\u5b58\u50a8\u53d1\u751f\u7684\u4e8b\u4ef6
\n while(true) {
\n int n = epoll_wait(epoll_fd, events, MAX_EVENTS, -1); \/\/ \u7b49\u5f85\u4e8b\u4ef6\u53d1\u751f
\n for(int i = 0; i < n; ++i) {
\n if(events[i].data.fd == listen_fd) { \/\/ \u5982\u679c\u662f\u65b0\u7684\u8fde\u63a5\u8bf7\u6c42
\n sockaddr_in client_addr;
\n socklen_t client_len = sizeof(client_addr);
\n int client_fd = accept(listen_fd, (sockaddr*)&client_addr, &client_len); \/\/ \u63a5\u53d7\u65b0\u8fde\u63a5
\n if(client_fd == -1) continue;
\n set_nonblock(client_fd); \/\/ \u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f<\/p>\n
\/\/ \u5728\u5b9e\u9645\u5e94\u7528\u4e2d，\u8fd9\u91cc\u5e94\u8be5\u5c06\u65b0\u8fde\u63a5\u5206\u914d\u7ed9\u4e00\u4e2a\u5b50Reactor\u8fdb\u884c\u5904\u7406
\n \/\/ \u4e3a\u4e86\u7b80\u5316\u793a\u4f8b，\u6211\u4eec\u53ea\u662f\u6253\u5370\u4e00\u6761\u6d88\u606f
\n std::cout << "New connection accepted" << std::endl;
\n }
\n }
\n }<\/p>\n
for(auto& t : threads) {
\n if(t.joinable()) t.join(); \/\/ \u7b49\u5f85\u6240\u6709\u5b50Reactor\u7ebf\u7a0b\u7ed3\u675f
\n }<\/p>\n
return 0;
\n} <\/p>\n
set_nonblock\u51fd\u6570：\u5c06\u6587\u4ef6\u63cf\u8ff0\u7b26\u8bbe\u7f6e\u4e3a\u975e\u963b\u585e\u6a21\u5f0f，\u8fd9\u6837\u5f53\u5c1d\u8bd5\u8bfb\u5199\u64cd\u4f5c\u800c\u6ca1\u6709\u6570\u636e\u53ef\u8bfb\u6216\u5199\u65f6\u4e0d\u4f1a\u963b\u585e\u3002<\/p>\n<\/li>\n
handle_client\u51fd\u6570：\u5904\u7406\u6bcf\u4e2a\u5ba2\u6237\u7aef\u7684\u5177\u4f53\u903b\u8f91，\u5305\u62ec\u63a5\u6536\u6570\u636e\u3001\u6253\u5370\u63a5\u6536\u5230\u7684\u6570\u636e\u4ee5\u53ca\u5c06\u6570\u636e\u56de\u4f20\u7ed9\u5ba2\u6237\u7aef（echo）\u3002<\/p>\n<\/li>\n
sub_reactor\u51fd\u6570：\u8fd9\u662f\u5b50Reactor\u7684\u5de5\u4f5c\u903b\u8f91，\u4e3b\u8981\u8d1f\u8d23\u5904\u7406\u5177\u4f53\u5ba2\u6237\u7aef\u7684I\/O\u4e8b\u4ef6\u3002\u9996\u5148\u521b\u5efa\u4e00\u4e2aepoll\u5b9e\u4f8b，\u5e76\u5c06\u76d1\u542c\u5957\u63a5\u5b57\u6dfb\u52a0\u5230epoll\u7684\u76d1\u63a7\u5217\u8868\u4e2d\u3002\u7136\u540e\u8fdb\u5165\u4e00\u4e2a\u65e0\u9650\u5faa\u73af，\u7b49\u5f85\u5e76\u5904\u7406\u4e8b\u4ef6\u3002\u5982\u679c\u4e8b\u4ef6\u5bf9\u5e94\u4e8e\u4e00\u4e2a\u65b0\u7684\u8fde\u63a5\u8bf7\u6c42，\u5219\u63a5\u53d7\u8be5\u8fde\u63a5，\u5e76\u5c06\u5176\u6dfb\u52a0\u5230epoll\u76d1\u63a7\u5217\u8868\u4e2d；\u5982\u679c\u662f\u5df2\u6709\u7684\u8fde\u63a5\u4e0a\u6709\u6570\u636e\u5230\u8fbe，\u5219\u8c03\u7528handle_client\u51fd\u6570\u5904\u7406\u6570\u636e\u3002<\/p>\n<\/li>\n
main\u51fd\u6570：<\/p>\n
\u4e0b\u9762\u7684\u4ee3\u7801\u5b9e\u73b0\u4e86\u591a\u4e2a\u5e76\u53d1client\u5ba2\u6237\u7aef\u5411Mutli-reactor\u670d\u52a1\u5668\u53d1\u9001\u62a5\u6587：<\/p>\n
#include <iostream>
\n#include <thread>
\n#include <vector>
\n#include <cstring>
\n#include <sys\/socket.h>
\n#include <arpa\/inet.h>
\n#include <unistd.h><\/p>\n
void client_task(int client_id, const char* ip, int port) {
\n int sock = 0;
\n struct sockaddr_in serv_addr;
\n const char* hello = "Hello from client";
\n char buffer[1024] = {0};<\/p>\n
\/\/ \u521b\u5efasocket
\n if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
\n std::cerr << "Client " << client_id << ": Socket creation error\\\\n";
\n return;
\n }<\/p>\n
serv_addr.sin_family = AF_INET;
\n serv_addr.sin_port = htons(port);<\/p>\n
\/\/ \u5c06IP\u5730\u5740\u4ece\u6587\u672c\u8f6c\u6362\u4e3a\u4e8c\u8fdb\u5236\u5f62\u5f0f
\n if (inet_pton(AF_INET, ip, &serv_addr.sin_addr) <= 0) {
\n std::cerr << "Client " << client_id << ": Invalid address\/ Address not supported\\\\n";
\n return;
\n }<\/p>\n
\/\/ \u8fde\u63a5\u5230\u670d\u52a1\u5668
\n if (connect(sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) < 0) {
\n std::cerr << "Client " << client_id << ": Connection failed\\\\n";
\n return;
\n }<\/p>\n
\/\/ \u53d1\u9001\u6d88\u606f\u7ed9\u670d\u52a1\u5668
\n send(sock, hello, strlen(hello), 0);
\n std::cout << "Client " << client_id << ": Hello message sent\\\\n";<\/p>\n
\/\/ \u63a5\u6536\u670d\u52a1\u5668\u7684\u54cd\u5e94
\n read(sock, buffer, 1024);
\n std::cout << "Client " << client_id << ": Server response: " << buffer << std::endl;<\/p>\n
close(sock); \/\/ \u5173\u95edsocket
\n}<\/p>\n
int main() {
\n const int num_clients = 100; \/\/ \u8981\u542f\u52a8\u7684\u5ba2\u6237\u7aef\u6570\u91cf
\n const char* server_ip = "127.0.0.1"; \/\/ \u670d\u52a1\u5668IP\u5730\u5740
\n int server_port = 8080; \/\/ \u670d\u52a1\u5668\u7aef\u53e3<\/p>\n
std::vector<std::thread> clients;
\n for(int i = 0; i < num_clients; ++i) {
\n clients.emplace_back(client_task, i + 1, server_ip, server_port);
\n }<\/p>\n
\/\/ \u7b49\u5f85\u6240\u6709\u5ba2\u6237\u7aef\u7ebf\u7a0b\u5b8c\u6210
\n for(auto& t : clients) {
\n if(t.joinable()) t.join();
\n }<\/p>\n
return 0;
\n} <\/p>\n
\u4e0a\u9762\u7684\u4ee3\u7801\u4e3b\u8981\u903b\u8f91\u4e3a：\u5f00\u542f\u591a\u4e2aclient\u5ba2\u6237\u7aef\u8fde\u63a5\u5230\u670d\u52a1\u5668，\u5e76\u53d1\u9001hello\u62a5\u6587\u3001\u63a5\u53d7hello\u62a5\u6587\u3002<\/p>\n
\u5b9e\u73b0\u6548\u679c\u5982\u4e0b：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418153210-6802707a14956.png\")
<\/p>\n
\u53ef\u4ee5\u770b\u5230\u6211\u4eec\u6709100\u4e2a\u5ba2\u6237\u7aef\u5411\u670d\u52a1\u5668\u53d1\u9001hello\u62a5\u6587，\u5e76\u4e14\u4e5f\u5168\u90e8\u63a5\u6536\u5230\u4e86\u3002<\/p>\n
\u91c7\u7528Multi-Reactor\u6a21\u578b\u7684\u4f18\u52bf\u5728\u4e8e：<\/p>\n
\u4e3b\u8981\u7684Reactor\u6a21\u578b\u4e3b\u8981\u6709\u5355\u7ebf\u7a0bReactor\u6a21\u578b\u3001\u00a0\u7ebf\u7a0b\u6c60Reactor\u6a21\u578b\u3001\u4e3b\u4eceReactor\u6a21\u578b\u3002\u800c\u6211\u4eec\u4e3b\u8981\u8981\u5b9e\u73b0\u7684\u662f\u7ebf\u7a0b\u6c60Reactor\u6a21\u578b（Multi-Reactor）\u3002\u4e0b\u9762\u662f\u5b83\u4eec\u4e4b\u95f4\u7684\u6bd4\u8f83\u3002<\/p>\n
\u60a8\u4e5f\u53ef\u4ee5\u901a\u8fc7\u9ad8\u6027\u80fd\u7f51\u7edc\u7f16\u7a0b\u4e4b Reactor \u7f51\u7edc\u6a21\u578b（\u5f7b\u5e95\u641e\u61c2）_reactor\u7f51\u7edc\u6a21\u578b-CSDN\u535a\u5ba2\u8fd9\u7bc7\u6587\u7ae0\u8fdb\u884c\u5b66\u4e60\u3002<\/p>\n
\u63cf\u8ff0：<\/p>\n
\u4f18\u7f3a\u70b9：<\/p>\n
\u63cf\u8ff0：<\/p>\n
\u4f18\u7f3a\u70b9：<\/p>\n
\u63cf\u8ff0：<\/p>\n
\u4f18\u7f3a\u70b9：<\/p>\n
\u00a0\u5173\u4e8eselect\u3001poll\u3001epoll\u7684\u539f\u7406\u53ef\u4ee5\u53c2\u8003\u6211\u8fd9\u7bc7\u6587\u7ae0：<\/p>\n
\u9762\u8bd5：Epoll\u3001Poll\u3001Select\u5b66\u4e60\u8bb0\u5f55<\/p>\n
\u5f53\u4f60\u6df1\u5165\u5230C++\u5f00\u53d1\u7684\u4e16\u754c\u4e2d\u5c1d\u8bd5\u5b9e\u73b0Multi-Reactor\u6a21\u578b\u65f6，\u4f60\u4f1a\u53d1\u73b0epoll\u8fd9\u4e2a\u5f3a\u5927\u7684\u5de5\u5177\u786e\u5b9e\u662f\u4e0d\u53ef\u6216\u7f3a\u7684\u3002\u4f46\u662f，\u76f4\u63a5\u4f7f\u7528epoll\u8fdb\u884c\u4e8b\u4ef6\u76d1\u542c\u548c\u5904\u7406\u6709\u65f6\u5c31\u50cf\u662f\u5728\u8d70\u94a2\u4e1d\u2014\u2014\u4e0d\u4ec5\u9700\u8981\u624b\u52a8\u8bb0\u5f55\u5404\u79cd\u4e8b\u4ef6，\u8fd8\u5f97\u81ea\u5df1\u7ba1\u7406\u8ba1\u65f6\u5668，\u5c24\u5176\u662f\u5728\u975e\u963b\u585e\u72b6\u6001\u4e0b\u64cd\u4f5c\u7684\u65f6\u5019，\u8fd9\u7b80\u76f4\u5c31\u50cf\u662f\u4e00\u573a\u5669\u68a6\u3002<\/p>\n
\u6240\u4ee5，\u4e3a\u4ec0\u4e48\u4e0d\u8ba9\u6211\u4eec\u6765\u7b80\u5316\u8fd9\u4e00\u5207\u5462？\u8bbe\u60f3\u4e00\u4e0b，\u5982\u679c\u6211\u4eec\u80fd\u591f\u521b\u5efa\u4e00\u4e2a\u53eb\u505aEPollPoller\u7684\u7c7b\u6765\u5e2e\u6211\u4eec\u641e\u5b9a\u8fd9\u4e00\u5207，\u90a3\u8be5\u6709\u591a\u68d2！\u901a\u8fc7\u8fd9\u4e2a\u7c7b\u7684\u6784\u9020\u51fd\u6570（\u5b9e\u9645\u4e0a\u5c31\u662f\u8c03\u7528epoll_create），\u6211\u4eec\u53ef\u4ee5\u8f7b\u677e\u5730\u521b\u5efa\u51faepoll\u53e5\u67c4\u3002\u66f4\u9177\u7684\u662f，\u6211\u4eec\u53ef\u4ee5\u5bf9\u5916\u63d0\u4f9b\u4e00\u4e2a\u66f4\u65b0\u63a5\u53e3（\u4e5f\u5c31\u662fupdate\u7a97\u53e3），\u8fd9\u6837\u5916\u754c\u5c31\u53ef\u4ee5\u5f88\u65b9\u4fbf\u5730\u901a\u8fc7\u7c7b\u4f3cepoll_ctl\u7684\u65b9\u5f0f\u6765\u6dfb\u52a0\u4ed6\u4eec\u60f3\u8981\u76d1\u542c\u7684\u4e8b\u4ef6\u4e86\u3002<\/p>\n
\u60f3\u8c61\u4e00\u4e0b，\u4f60\u4e0d\u518d\u9700\u8981\u62c5\u5fc3\u90a3\u4e9b\u590d\u6742\u7684\u7ec6\u8282，\u53ea\u9700\u8981\u4e13\u6ce8\u4e8e\u4f60\u7684\u4e1a\u52a1\u903b\u8f91\u3002\u5f53\u6709\u65b0\u7684\u4e8b\u4ef6\u5230\u6765\u65f6，\u6bd4\u5982\u53ef\u8bfb\u4e8b\u4ef6\u53d1\u751f，\u6211\u4eec\u7684EPollPoller\u5c31\u4f1a\u8c03\u7528\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u7136\u540e\u4f60\u5c31\u80fd\u77e5\u9053\u201c\u563f，\u8fd9\u91cc\u6709\u6d88\u606f\u7b49\u4f60\u5904\u7406\u5462！\u201d\u8fd9\u79cd\u8bbe\u8ba1\u4e0d\u4ec5\u5927\u5927\u7b80\u5316\u4e86\u4ee3\u7801\u7684\u590d\u6742\u5ea6，\u8fd8\u8ba9\u6574\u4e2a\u5f00\u53d1\u8fc7\u7a0b\u53d8\u5f97\u66f4\u52a0\u6d41\u7545\u6109\u5feb\u3002<\/p>\n
\u603b\u4e4b，\u901a\u8fc7\u5f15\u5165\u8fd9\u6837\u4e00\u4e2aEPollPoller\u7c7b，\u6211\u4eec\u4e0d\u4ec5\u53ef\u4ee5\u4f7fMulti-Reactor\u6a21\u578b\u7684\u5b9e\u73b0\u53d8\u5f97\u66f4\u52a0\u7b80\u5355\u76f4\u89c2，\u540c\u65f6\u4e5f\u4e3a\u540e\u7eed\u7684\u529f\u80fd\u6269\u5c55\u7559\u4e0b\u4e86\u5145\u8db3\u7684\u7a7a\u95f4！<\/p>\n
\u5728\u521b\u5efa EventLoop \u7684\u65f6\u5019，\u786e\u5b9e\u9700\u8981\u521d\u59cb\u5316\u4e00\u4e2a\u65b0\u7684 Poller \u5b9e\u4f8b\u6765\u7ba1\u7406\u4e0e\u76d1\u542c\u76f8\u5173\u7684 Channel\u3002\u6bcf\u4e2a Channel \u5305\u542b\u4e86\u4e00\u4e2a socket \u7aef\u53e3\u53ca\u5176\u76f8\u5173\u8054\u7684\u56de\u8c03\u51fd\u6570\u96c6\u5408，\u7528\u4e8e\u5904\u7406\u5404\u79cd\u4e8b\u4ef6（\u5982\u8fde\u63a5\u3001\u8bfb\u53d6\u3001\u5199\u5165\u7b49）\u3002\u63a5\u4e0b\u6765，\u6211\u4eec\u5bf9\u8fd9\u4e9b\u63a5\u53e3\u548c\u673a\u5236\u8fdb\u884c\u66f4\u52a0\u6e05\u6670\u7684\u63cf\u8ff0：<\/p>\n
virtual Timestamp poll(int timeout, ChannelList* channels) = 0; \u8fd9\u662f\u4e00\u4e2a\u7eaf\u865a\u51fd\u6570，\u5176\u5b9e\u73b0\u7531\u6d3e\u751f\u7c7b\u63d0\u4f9b\u3002\u8be5\u65b9\u6cd5\u6267\u884c\u4e00\u6b21\u8f6e\u8be2\u64cd\u4f5c，\u68c0\u67e5\u662f\u5426\u6709\u4efb\u4f55\u5df2\u6ce8\u518c\u7684\u901a\u9053\u53d1\u751f\u4e86\u4e8b\u4ef6，\u5e76\u8fd4\u56de\u53d1\u751f\u4e8b\u4ef6\u7684\u901a\u9053\u5217\u8868\u4ee5\u53ca\u5f53\u524d\u7684\u65f6\u95f4\u6233\u3002\u5b83\u5141\u8bb8\u6846\u67b6\u901a\u8fc7\u7edf\u4e00\u63a5\u53e3\u8bbf\u95ee\u4e0d\u540c\u7684\u5e95\u5c42I\/O\u591a\u8def\u590d\u7528\u673a\u5236（\u4f8b\u5982 epoll, poll）\u3002<\/p>\n<\/li>\n
virtual void updateChannel(Channel* channel) = 0; \u548c virtual void removeChannel(Channel* channel) = 0; \u8fd9\u4e24\u4e2a\u7eaf\u865a\u51fd\u6570\u5206\u522b\u7528\u4e8e\u66f4\u65b0（\u6dfb\u52a0\u6216\u4fee\u6539）\u548c\u79fb\u9664\u76d1\u542c\u7684\u901a\u9053\u3002\u5b83\u4eec\u786e\u4fdd\u4e86\u53ef\u4ee5\u6839\u636e\u5e94\u7528\u7a0b\u5e8f\u7684\u9700\u6c42\u52a8\u6001\u5730\u8c03\u6574\u6b63\u5728\u76d1\u542c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u96c6，\u4ece\u800c\u5b9e\u73b0\u9ad8\u6548\u4e14\u7075\u6d3b\u7684\u4e8b\u4ef6\u9a71\u52a8\u67b6\u6784\u3002<\/p>\n<\/li>\n
bool hasChannel(Channel* channel) const; \u6b64\u65b9\u6cd5\u7528\u4e8e\u68c0\u67e5\u7ed9\u5b9a\u7684\u901a\u9053\u662f\u5426\u5df2\u7ecf\u88ab\u6ce8\u518c\u5230 Poller \u4e2d\u3002\u8fd9\u5bf9\u4e8e\u907f\u514d\u91cd\u590d\u6ce8\u518c\u6216\u8005\u9519\u8bef\u5220\u9664\u975e\u5e38\u6709\u7528\u3002<\/p>\n<\/li>\n
static Poller* newDefaultPoller(EventLoop* loop); \u8fd9\u662f\u4e00\u4e2a\u9759\u6001\u5de5\u5382\u65b9\u6cd5，\u65e8\u5728\u65e0\u9700\u76f4\u63a5\u6307\u5b9a\u5177\u4f53\u7c7b\u540d\u7684\u60c5\u51b5\u4e0b\u521b\u5efa\u5e76\u8fd4\u56de\u4e00\u4e2a\u5177\u4f53\u7684 Poller \u5b9e\u4f8b（\u53ef\u80fd\u662f\u67d0\u4e2a\u6d3e\u751f\u7c7b\u5b9e\u4f8b）\u3002\u8fd9\u79cd\u65b9\u6cd5\u589e\u5f3a\u4e86\u4ee3\u7801\u7684\u7075\u6d3b\u6027\u548c\u53ef\u7ef4\u62a4\u6027，\u56e0\u4e3a\u5b83\u5141\u8bb8\u8f7b\u677e\u5207\u6362\u4e0d\u540c\u7c7b\u578b\u7684 Poller \u5b9e\u73b0\u800c\u65e0\u9700\u4fee\u6539\u5ba2\u6237\u7aef\u4ee3\u7801\u3002<\/p>\n<\/li>\n<\/ul>\n
\u5728 Poller \u7c7b\u5185\u90e8，\u4fdd\u5b58\u4e86\u4e00\u4e2a\u6307\u5411 EventLoop \u7684\u6307\u9488 ownerLoop_，\u8fd9\u8868\u660e\u4e86\u8be5 Poller \u5c5e\u4e8e\u54ea\u4e2a\u4e8b\u4ef6\u7ebf\u7a0b（\u5373 EventLoop）\u3002\u8fd9\u79cd\u8bbe\u8ba1\u5bf9\u4e8e Multi-Reactor \u6a21\u578b\u81f3\u5173\u91cd\u8981\u3002\u5728 Multi-Reactor \u67b6\u6784\u4e2d，\u901a\u5e38\u6709\u4e00\u4e2a\u4e3b Reactor \u8d1f\u8d23\u63a5\u6536\u65b0\u8fde\u63a5\u5e76\u5c06\u8fd9\u4e9b\u8fde\u63a5\u5206\u914d\u7ed9\u5b50 Reactor（Sub-Reactor）\u3002\u6bcf\u4e2a Sub-Reactor \u90fd\u9700\u8981\u77e5\u9053\u5b83\u8d1f\u8d23\u76d1\u542c\u54ea\u4e9b\u4e8b\u4ef6\u3002<\/p>\n
\u6b64\u5916\u8fd9\u4e2aPoller\u5728\u4e3bReactor\u7684\u5b9e\u73b0\u5f62\u5f0f\u662fAceptor（\u63a5\u53d7\u65b0\u8fde\u63a5\u5e76\u5206\u914d\u7ed9Sub-Reactor，\u540e\u7eed\u4ecb\u7ecd）<\/p>\n
\u56e0\u6b64，ownerLoop_ \u8ba9 Sub-Reactor \u660e\u767d\u81ea\u5df1\u5e94\u8be5\u76d1\u542c\u54ea\u4e9b\u4e8b\u4ef6\u3002\u4e00\u65e6\u901a\u8fc7 poll \u65b9\u6cd5\u5f97\u77e5\u6709\u65b0\u7684\u4e8b\u4ef6\u5230\u8fbe\u65f6，Sub-Reactor \u5c31\u4f1a\u6267\u884c\u5bf9\u5e94\u7684\u4e8b\u4ef6\u56de\u8c03\u51fd\u6570，\u4ece\u800c\u5b9e\u73b0\u9ad8\u6548\u7684\u4e8b\u4ef6\u5904\u7406\u6d41\u7a0b\u3002\u8fd9\u79cd\u673a\u5236\u786e\u4fdd\u4e86\u7cfb\u7edf\u53ef\u4ee5\u6709\u6548\u5730\u5904\u7406\u5927\u91cf\u7684\u5e76\u53d1\u8fde\u63a5，\u540c\u65f6\u4fdd\u6301\u826f\u597d\u7684\u54cd\u5e94\u901f\u5ea6\u548c\u8d44\u6e90\u5229\u7528\u7387\u3002<\/p>\n
\u8be6\u7ec6\u7684\u4ee3\u7801\u4ecb\u7ecd\u89c1\u4e0b：<\/p>\n
\/\/ Poller.h
\n#ifndef POLLER_H
\n#define POLLER_H<\/p>\n
#include "noncopyable.h"
\n#include "Channel.h"
\n#include "Timestamp.h"<\/p>\n
#include <vector>
\n#include <unordered_map>
\nclass Poller:noncopyable{
\npublic:
\n using ChannelList=std::vector<Channel*>;
\n \/\/\u6784\u9020\u51fd\u6570，\u5c06\u6b21poller\u7ed1\u5b9a\u5230\u4e00\u4e2aEventLoop（\u7ebf\u7a0b\u5faa\u73af）\u4e2d
\n Poller(EventLoop* loop);
\n \/\/ \u6790\u51fd\u6570，\u91ca\u653e\u6240\u6709channel\u3002\u5e76\u4e14\u5177\u6709\u7ee7\u627f\u7684\u6027\u8d28，\u6240\u4ee5\u8bbe\u7f6e\u4e3a\u865a\u51fd\u6570
\n virtual ~Poller()=default;
\n \/\/\u5bf9\u5916\u66b4\u9732\u7684poll\u7ed3\u6784，\u4e3b\u8981\u7528\u4e8e\u8c03\u7528epoll_wait\u6216\u8005poll_wait
\n \/\/ \u63a5\u53d7\u8d85\u65f6\u4e8b\u4ef6，\u5e76\u8fd4\u56de\u53d1\u751f\u4e8b\u4ef6\u7684ChannelList，\u8fd4\u56de\u7684\u65f6\u95f4\u4e3apoll\u51fd\u6570\u88ab\u8c03\u7528\u7684\u65f6\u95f4\u70b9
\n virtual Timestamp poll(int timeout,ChannelList* channels)=0;
\n \/\/ \u6ce8\u518c\u65b0\u7684\u4e8b\u4ef6（\u4f7f\u7528Channel\u5305\u88c5\u7684\u4e8b\u4ef6）
\n virtual void updateChannel(Channel* channel)=0;
\n \/\/ \u5220\u9664\u5df2\u6ce8\u518c\u7684\u4e8b\u4ef6（\u4f7f\u7528Channel\u5305\u88c5\u7684\u4e8b\u4ef6），\u5728Channel\u88ab\u5173\u95ed\u6216\u8005\u88ab\u9500��\u65f6\u88ab\u8c03\u7528，\u5e76\u5728Poller\u4e2d\u5220\u9664\u8be5channel\u5e76\u5173\u95edepoll\u7684\u53e5��
\n virtual void removeChannel(Channel* channel)=0;
\n \/\/ \u68c0\u6d4b\u5f53\u524d\u662f\u5426\u6709\u4e8b\u4ef6(\u4f7f\u7528Channel\u5305\u88c5\u7684\u4e8b\u4ef6)\u76d1\u542c
\n bool hasChannel(Channel* channel)const;
\n \/\/ \u521b\u5efa\u5e76\u8fd4\u56de\u4e00\u4e2a Poller \u7c7b\u578b\u7684\u5bf9\u8c61\u6307\u9488
\n \/\/ \u4e3a\u4ec0\u4e48\u8981\u8bbe\u7f6e\u4e3astatic：\u9759\u6001\u65b9\u6cd5\u53ef\u4ee5\u4e0d\u4f9d\u8d56\u4e8e\u7c7b\u7684\u4efb\u4f55\u5b9e\u4f8b\u6210\u5458\u53d8\u91cf\u6216\u5b9e\u4f8b\u65b9\u6cd5\u3002\u8fd9\u610f\u5473\u7740\u4e0d\u9700\u8981\u521b\u5efa Poller \u7c7b\u7684\u5bf9\u8c61\u5c31\u53ef\u4ee5\u8c03\u7528\u8fd9\u4e2a\u65b9\u6cd5\u3002
\n static Poller* newDefaultPoller(EventLoop* loop);<\/p>\n
protected:
\n using ChannelMap=std::unordered_map<int, Channel*>;
\n \/\/ \u76d1\u542c\u7684fd\u4e0echannel\u952e\u503c\u5bf9，\u65b9\u4fbf\u79fb\u9664\u589e\u52a0\u76d1\u542c\u4e8b\u4ef6（channel）
\n ChannelMap channels_;
\nprivate:
\n EventLoop* ownerLoop_;\/\/ \u5b9a\u4e49Poller\u6240\u5c5e\u7684\u4e8b\u4ef6\u5faa\u73afEventLoop
\n};<\/p>\n
#endif \/\/ POLLER_H<\/p>\n
\/\/ \u5b9e\u73b0Poller.cc
\n#include "Poller.h"<\/p>\n
\/\/\u6784\u9020\u51fd\u6570\u4f20\u5165\u6240\u5c5e\u7684eventloop\u5373\u53ef，\u8ba9poller\u77e5\u9053\u81ea\u5df1\u6240\u5c5e\u4e0e\u54ea\u4e2a\u7ebf\u7a0b
\n\/\/ \u4e3a\u4ec0\u4e48\u8981\u77e5\u9053\u81ea\u5df1\u5c5e\u4e8e\u90a3\u4e2a\u7ebf\u7a0b\u5462
\n\/\/ \u56e0\u4e3a\u5728\u540e\u7eed\u7684multi-reactor\u4e2d\u4f1a\u6709\u4e2a\u7ebf\u7a0b\u6c60\u7684\u6210\u5458
\n\/\/ \u5728\u7ebf\u7a0b\u6c60\u4e2d\u6240\u6709\u7684\u7ebf\u7a0b\u90fd\u88ab\u5206\u914d\u4e86\u4e00\u4e2apoller，\u7ebf\u7a0b\u4e0d\u65ad\u4fa6\u542c\u8fd9\u4e2apoller，\u7ba1\u7406\u4e8b\u4ef6
\nPoller::Poller(EventLoop* eventLoop)
\n : ownerLoop_(eventLoop){<\/p>\n
}
\n\/\/ \u67e5\u627e\u8fd9\u4e2aChannel\u662f\u5426\u6709\u76ee\u6807channel
\nbool Poller::hasChannel(Channel* channel)const{
\n auto it=channels_.find(channel->fd());
\n return it!=channels_.end()&&it->second==channel;
\n} <\/p>\n
\u4e3a\u4e86\u5229\u7528 epoll \u9ad8\u6548\u5730\u7ba1\u7406\u5927\u91cf\u6587\u4ef6\u63cf\u8ff0\u7b26，\u6211\u4eec\u5728\u521d\u59cb\u5316 EPollPoller \u65f6\u4f1a\u8c03\u7528 epoll_create \u51fd\u6570\u6765\u521b\u5efa\u4e00\u4e2a epoll \u5b9e\u4f8b\u3002\u8fd9\u91cc，kInitEventListSize \u53c2\u6570\u7528\u4e8e\u6307\u5b9a\u8be5 epoll \u5b9e\u4f8b\u521d\u59cb\u76d1\u542c\u5217\u8868\u7684\u5927\u5c0f，\u5373\u5b83\u9884\u5206\u914d\u7684\u7a7a\u95f4\u5927\u5c0f，\u4ee5\u4f18\u5316\u6027\u80fd\u5e76\u51cf\u5c11\u52a8\u6001\u6269\u5c55\u7684\u9700\u6c42\u3002<\/p>\n
poll \u65b9\u6cd5\u662f EPollPoller \u7c7b\u4e2d\u5bf9 Poller \u62bd\u8c61\u7c7b\u6240\u5b9a\u4e49\u7684\u7eaf\u865a\u51fd\u6570 poll \u7684\u5177\u4f53\u5b9e\u73b0\u3002\u5b83\u7684\u4e3b\u8981\u804c\u8d23\u662f\u901a\u8fc7\u8c03\u7528 epoll_wait \u6765\u7b49\u5f85\u6587\u4ef6\u63cf\u8ff0\u7b26\u4e0a\u7684\u4e8b\u4ef6，\u5e76\u5904\u7406\u8fd9\u4e9b\u4e8b\u4ef6\u3002\u5177\u4f53\u6765\u8bf4，\u5176\u5de5\u4f5c\u6d41\u7a0b\u5982\u4e0b：<\/p>\n
\u6267\u884c epoll_wait：\u6b64\u6b65\u9aa4\u7528\u4e8e\u76d1\u63a7\u6240\u6709\u5df2\u6ce8\u518c\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26，\u7b49\u5f85\u5176\u4e2d\u4efb\u4f55\u4e00\u4e2a\u53d8\u4e3a\u201c\u5c31\u7eea\u201d\u72b6\u6001（\u4f8b\u5982，\u53ef\u4ee5\u8fdb\u884c\u8bfb\u5199\u64cd\u4f5c）\u3002\u53c2\u6570 timeout \u6307\u5b9a\u4e86\u7b49\u5f85\u7684\u6700\u5927\u65f6\u957f，\u5982\u679c\u5728\u6b64\u671f\u95f4\u6ca1\u6709\u4e8b\u4ef6\u53d1\u751f，\u5219\u51fd\u6570\u8fd4\u56de\u3002<\/p>\n<\/li>\n
\u53d1\u73b0\u5c31\u7eea\u4e8b\u4ef6：\u4e00\u65e6 epoll_wait \u8fd4\u56de，\u5b83\u5c06\u63d0\u4f9b\u4e00\u7ec4\u5df2\u51c6\u5907\u597d\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26\u53ca\u5176\u5bf9\u5e94\u7684\u4e8b\u4ef6\u7c7b\u578b\u3002<\/p>\n<\/li>\n
\u586b\u5145\u6d3b\u8dc3\u901a\u9053：\u901a\u8fc7\u8c03\u7528\u79c1\u6709\u6210\u5458\u65b9\u6cd5 fillActiveChannels，\u6839\u636e epoll_wait \u8fd4\u56de\u7684\u7ed3\u679c，\u5c06\u6240\u6709\u5c31\u7eea\u4e8b\u4ef6\u5bf9\u5e94\u7684\u901a\u9053\u4fe1\u606f\u586b\u5145\u5230 activeChannels \u5217\u8868\u4e2d\u3002\u8fd9\u4e00\u6b65\u9aa4\u786e\u4fdd\u4e86\u5916\u90e8\u4ee3\u7801\u53ef\u4ee5\u65b9\u4fbf\u5730\u8bbf\u95ee\u5e76\u5904\u7406\u8fd9\u4e9b\u4e8b\u4ef6\u3002<\/p>\n<\/li>\n
\u4ea4\u7531\u5916\u90e8\u5904\u7406：\u6700\u7ec8，poll \u65b9\u6cd5\u8fd4\u56de\u5305\u542b\u65f6\u95f4\u6233\u548c\u6d3b\u8dc3\u901a\u9053\u5217\u8868\u7684\u4fe1\u606f，\u4f9b\u5916\u90e8\u903b\u8f91\u8fdb\u4e00\u6b65\u5904\u7406\u3002\u6bd4\u5982\u89e6\u53d1\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u6267\u884c\u5177\u4f53\u7684\u4e1a\u52a1\u903b\u8f91\u7b49\u3002<\/p>\n<\/li>\n
\u00a0\u5728\u8fd9\u4e2aEventLoop\u4ee3\u7801\u6211\u4eec\u53ef\u4ee5\u770b\u5230\u8c03\u7528poll\u7684\u65b9\u6cd5（EventLoop\u540e\u7eed\u8be6\u7ec6\u4ecb\u7ecd）：<\/p>\n
void EventLoop::loop(){
\n looping_=true;
\n quit_=false;<\/p>\n
while(!quit_){
\n activeChannels_.clear();
\n \/\/ \u8c03\u7528Poller\u7684poll\u51fd\u6570\u83b7\u53d6\u611f\u5174\u7684\u4e8b\u4ef6
\n pollReturnTime_=poller_->poll(kPollTimeMs, &activeChannels_);
\n \/\/ \u5904\u7406\u611f\u5174\u8da3\u7684\u4e8b\u4ef6
\n for(Channel* channel : activeChannels_){
\n currentActiveChannel_ = channel;
\n \/\/ \u5904\u7406channel\u4e0a\u53d1\u751f\u7684\u4e8b\u4ef6
\n channel->handleEvent(pollReturnTime_);
\n }
\n \/\/ \u6267\u884c\u5f53\u524dEventLoop\u4e8b\u4ef6\u5faa\u73af\u9700\u8981\u5904\u7406\u7684\u56de\u8c03\u64cd\u4f5c
\n \/**
\n * IO thread：mainLoop accept fd \u6253\u5305\u6210 chennel \u5206\u53d1\u7ed9 subLoop
\n * mainLoop\u5b9e\u73b0\u6ce8\u518c\u4e00\u4e2a\u56de\u8c03，\u4ea4\u7ed9subLoop\u6765\u6267\u884c，wakeup subLoop \u4e4b\u540e，\u8ba9\u5176\u6267\u884c\u6ce8\u518c\u7684\u56de\u8c03\u64cd\u4f5c
\n * \u8fd9\u4e9b\u56de\u8c03\u51fd\u6570\u5728 std::vector<Functor> pendingFunctors_; \u4e4b\u4e2d
\n *\/
\n doPendingFunctors();
\n }
\n looping_=false;
\n} <\/p>\n
\u5173\u952e\u6210\u5458\u53d8\u91cf<\/p>\n
int epollfd_;：\u8fd9\u662f\u7531 epoll_create \u521b\u5efa\u7684\u6587\u4ef6\u63cf\u8ff0\u7b26，\u7528\u4e8e\u540e\u7eed\u7684\u6240\u6709 epoll \u64cd\u4f5c\u3002<\/p>\n<\/li>\n
std::vector<epoll_event> events_;：\u8fd9\u662f\u4e00\u4e2a\u52a8\u6001\u6570\u7ec4，\u7528\u6765\u5b58\u50a8\u4ece epoll_wait \u8c03\u7528\u4e2d\u83b7\u53d6\u5230\u7684\u4e8b\u4ef6\u4fe1\u606f\u3002\u5176\u521d\u59cb\u5927\u5c0f\u7531 kInitEventListSize \u786e\u5b9a，\u4f46\u53ef\u4ee5\u6839\u636e\u9700\u8981\u81ea\u52a8\u6269\u5c55\u3002<\/p>\n<\/li>\n<\/ul>\n
\u540c\u65f6updateChannel\u3001removeChannel\u662f\u4e3a\u4e86\u65b9\u4fbf\u589e\u52a0\u3001\u5220\u9664channel\u76d1\u542c\u7684\u4e8b\u4ef6\u8282\u70b9\u3002<\/p>\n
EPollPoller\u8be6\u7ec6\u4ee3\u7801\u5982\u4e0b：<\/p>\n
\/\/ EPollPoller<\/p>\n
#ifndef EPOLLPOLLER_H
\n#define EPOLLPOLLER_H<\/p>\n
#include <vector>
\n#include <sys\/epoll.h>
\n#include <unistd.h><\/p>\n
#include "Poller.h"
\n#include "Timestamp.h"<\/p>\n
class EPollPoller:public Poller{
\npublic:
\n EPollPoller(EventLoop* loop);
\n ~EPollPoller() override;<\/p>\n
Timestamp poll(int timeout, ChannelList* activeChannels) override;
\n void updateChannel(Channel* channel) override;
\n void removeChannel(Channel* channel) override;<\/p>\n
private:
\n \/\/ \u9ed8\u8ba4\u76d1\u542c\u6570\u91cf
\n static const int kInitEventListSize = 16;
\n \/\/ \u586b\u5199\u6d3b\u8dc3\u7684\u8fde\u63a5
\n void fillActiveChannels(int numEvents,ChannelList* activeChannels)const;
\n \/\/ \u66f4\u65b0channel\u901a\u9053，\u672c\u8d28\u662f\u8c03\u7528\u4e86epoll_ctl
\n void update(int operation,Channel* channel);<\/p>\n
int epollfd_; \/\/epoll_create\u5728\u5185\u6838\u521b\u5efa\u7a7a\u95f4\u8fd4\u56de\u7684fd
\n std::vector<epoll_event> events_;
\n};<\/p>\n
#endif<\/p>\n
\/\/ EPollPoller.cc<\/p>\n
#include "EventLoop.h"
\n#include "Poller.h"
\n#include <unistd.h>
\n#include <sys\/eventfd.h>
\n#include <fcntl.h>
\n\/\/ \u9632\u6b62\u4e00\u4e2a\u7ebf\u7a0b\u521b\u5efa\u591a\u4e2aEventLoop (thread_local)
\n__thread EventLoop *t_loopInThisThread = nullptr;
\n\/\/ \u5b9a\u4e49\u9ed8\u8ba4\u7684Poller IO\u590d\u7528\u63a5\u53e3\u7684\u8d85\u65f6\u65f6\u95f4
\nconst int kPollTimeMs=10000;<\/p>\n
\/\/ eventfd\u590d\u7528
\nint createEventfd(){
\n int eventfd = ::eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK);
\n if(eventfd < 0){
\n perror("eventfd");
\n abort();
\n }
\n return eventfd;
\n}<\/p>\n
EventLoop::EventLoop():
\n looping_(false),
\n quit_(false),
\n callingPendingFunctors_(false),
\n threadId_(CurrentThread::tid()),
\n poller_(Poller::newDefaultPoller(this)),
\n timerQueue_(new TimerQueue(this)),
\n wakeupFd_(createEventfd()),
\n wakeupChannel_(new Channel(this,wakeupFd_)),
\n currentActiveChannel_(nullptr){
\n \/\/ \u8ba9mainLoop\u548cwakeupChannel\u5728\u540c\u4e00\u4e2a\u7ebf\u7a0b\u4e2d\u6267\u884c
\n if(t_loopInThisThread){
\n std::cerr<< "Another EventLoop" << t_loopInThisThread << " exists in this thread " << threadId_<<std::endl;
\n }else{
\n t_loopInThisThread = this;
\n }<\/p>\n
\/\/ \u8bbe\u7f6ewakeupfd\u7684\u4e8b\u4ef6\u7c7b\u578b\u4ee5\u53ca\u53d1\u751f\u4e8b\u4ef6\u7684\u56de\u8c03\u51fd\u6570
\n wakeupChannel_->setReadCallback(std::bind(&EventLoop::handleRead, this));
\n \/\/ \u6bcf\u4e00\u4e2aEventLoop\u90fd\u76d1\u542cwakeChannel\u7684EPOLLIN\u4e8b\u4ef6
\n wakeupChannel_->enableReading();
\n}<\/p>\n
EventLoop::~EventLoop(){
\n \/\/\u79fb\u9664\u6240\u6709\u611f\u5174\u8da3\u7684\u4e8b\u4ef6
\n wakeupChannel_->disableAll();
\n \/\/ \u5c06channel\u4eceEentLoop\u4e2d\u5220\u9664
\n wakeupChannel_->remove();
\n ::close(wakeupFd_);
\n \/\/\u6307\u5411EventLoop\u7684\u6307\u9488\u81f3\u7a7a
\n t_loopInThisThread = nullptr;
\n}<\/p>\n
void EventLoop::loop(){
\n looping_=true;
\n quit_=false;<\/p>\n
while(!quit_){
\n activeChannels_.clear();
\n \/\/ \u8c03\u7528Poller\u7684poll\u51fd\u6570\u83b7\u53d6\u611f\u5174\u7684\u4e8b\u4ef6
\n pollReturnTime_=poller_->poll(kPollTimeMs, &activeChannels_);
\n \/\/ \u5904\u7406\u611f\u5174\u8da3\u7684\u4e8b\u4ef6
\n for(Channel* channel : activeChannels_){
\n currentActiveChannel_ = channel;
\n \/\/ \u5904\u7406channel\u4e0a\u53d1\u751f\u7684\u4e8b\u4ef6
\n channel->handleEvent(pollReturnTime_);
\n }
\n \/\/ \u6267\u884c\u5f53\u524dEventLoop\u4e8b\u4ef6\u5faa\u73af\u9700\u8981\u5904\u7406\u7684\u56de\u8c03\u64cd\u4f5c
\n \/**
\n * IO thread：mainLoop accept fd \u6253\u5305\u6210 chennel \u5206\u53d1\u7ed9 subLoop
\n * mainLoop\u5b9e\u73b0\u6ce8\u518c\u4e00\u4e2a\u56de\u8c03，\u4ea4\u7ed9subLoop\u6765\u6267\u884c，wakeup subLoop \u4e4b\u540e，\u8ba9\u5176\u6267\u884c\u6ce8\u518c\u7684\u56de\u8c03\u64cd\u4f5c
\n * \u8fd9\u4e9b\u56de\u8c03\u51fd\u6570\u5728 std::vector<Functor> pendingFunctors_; \u4e4b\u4e2d
\n *\/
\n doPendingFunctors();
\n }
\n looping_=false;
\n}<\/p>\n
void EventLoop::quit(){
\n quit_=true;
\n \/**
\n * TODO:\u751f\u4ea7\u8005\u6d88\u8d39\u8005\u961f\u5217\u6d3e\u53d1\u65b9\u5f0f\u548cmuduo\u7684\u6d3e\u53d1\u65b9\u5f0f
\n * \u6709\u53ef\u80fd\u662f\u522b\u7684\u7ebf\u7a0b\u8c03\u7528quit(\u8c03\u7528\u7ebf\u7a0b\u4e0d\u662f\u751f\u6210EventLoop\u5bf9\u8c61\u7684\u90a3\u4e2a\u7ebf\u7a0b)
\n * \u6bd4\u5982\u5728\u5de5\u4f5c\u7ebf\u7a0b(subLoop)\u4e2d\u8c03\u7528\u4e86IO\u7ebf\u7a0b(mainLoop)
\n * \u8fd9\u79cd\u60c5\u51b5\u4f1a\u5524\u9192\u4e3b\u7ebf\u7a0b
\n *\/
\n if(isInLoopThread()){
\n wakeup();
\n }
\n}<\/p>\n
void EventLoop::runInLoop(Functor cb){
\n \/\/ \u6bcf\u4e2aEventLoop\u90fd\u4fdd\u5b58\u521b\u5efa\u81ea\u5df1\u7684\u7ebf\u7a0btid
\n \/\/ \u6211\u4eec\u53ef\u4ee5\u901a\u8fc7CurrentThread::tid()\u83b7\u53d6\u5f53\u524d\u6267\u884c\u7ebf\u7a0b\u7684tid\u7136\u540e\u548cEventLoop\u4fdd\u5b58\u7684\u8fdb\u884c\u6bd4\u8f83
\n if(isInLoopThread()){
\n cb();
\n }
\n \/\/ \u5728\u975e\u5f53\u524deventLoop\u7ebf\u7a0b\u4e2d\u6267\u884c\u56de\u8c03\u51fd\u6570，\u9700\u8981\u5524\u9192evevntLoop\u6240\u5728\u7ebf\u7a0b
\n else{
\n queueInLoop(cb);
\n }
\n}<\/p>\n
void EventLoop::queueInLoop(Functor cb){
\n {
\n std::unique_lock<std::mutex> lock(mutex_);
\n pendingFunctors_.emplace_back(cb);
\n }
\n \/\/ \u5524\u9192\u76f8\u5e94\u7684，\u9700\u8981\u6267\u884c\u4e0a\u9762\u56de\u8c03\u64cd\u4f5c\u7684loop\u7ebf\u7a0b
\n \/**
\n * TODO:
\n * std::atomic_bool callingPendingFunctors_; \u6807\u5fd7\u5f53\u524dloop\u662f\u5426\u6709\u9700\u8981\u6267\u884c\u7684\u56de\u8c03\u64cd\u4f5c
\n * \u8fd9\u4e2a || callingPendingFunctors_ \u6bd4\u8f83\u6709\u5fc5\u8981，\u56e0\u4e3a\u5728\u6267\u884c\u56de\u8c03\u7684\u8fc7\u7a0b\u53ef\u80fd\u4f1a\u52a0\u5165\u65b0\u7684\u56de\u8c03
\n * \u5219\u8fd9\u4e2a\u65f6\u5019\u4e5f\u9700\u8981\u5524\u9192，\u5426\u5219\u5c31\u4f1a\u53d1\u751f\u6709\u4e8b\u4ef6\u5230\u6765\u4f46\u662f\u4ecd\u88ab\u963b\u585e\u4f4f\u7684\u60c5\u51b5
\n *\/
\n if(!isInLoopThread()||callingPendingFunctors_){
\n \/\/\u5524\u9192loop\u6240\u5728\u7ebf\u7a0b
\n wakeup();
\n }
\n}<\/p>\n
void EventLoop::wakeup(){
\n uint64_t one = 1;
\n ssize_t n = ::write(wakeupFd_, &one, sizeof one);
\n if(n!=sizeof(one)){
\n perror("EventLoop::wakeup");
\n abort();
\n }
\n}<\/p>\n
void EventLoop::handleRead(){
\n uint64_t one = 1;
\n ssize_t n = ::read(wakeupFd_, &one, sizeof(one));
\n \/\/ \u5ffd\u7565\u8bfb\u53d6\u7684\u5b57\u8282\u6570
\n if(n!=sizeof(one)){
\n perror("EventLoop::wakeup");
\n abort();
\n }
\n}<\/p>\n
void EventLoop::updateChannel(Channel* channel){
\n poller_->updateChannel(channel);
\n}<\/p>\n
void EventLoop::removeChannel(Channel* channel){
\n poller_->removeChannel(channel);
\n}<\/p>\n
bool EventLoop::hasChannel(Channel* channel){
\n return poller_->hasChannel(channel);
\n}<\/p>\n
void EventLoop::doPendingFunctors(){
\n std::vector<Functor> pendingFunctors;
\n callingPendingFunctors_ = true;
\n \/**
\n * TODO:
\n * \u5982\u679c\u6ca1\u6709\u751f\u6210\u8fd9\u4e2a\u5c40\u90e8\u7684 functors
\n * \u5219\u5728\u4e92\u65a5\u9501\u52a0\u6301\u4e0b，\u6211\u4eec\u76f4\u63a5\u904d\u5386pendingFunctors
\n * \u5176\u4ed6\u7ebf\u7a0b\u8fd9\u4e2a\u65f6\u5019\u65e0\u6cd5\u8bbf\u95ee，\u65e0\u6cd5\u5411\u91cc\u9762\u6ce8\u518c\u56de\u8c03\u51fd\u6570，\u589e\u52a0\u670d\u52a1\u5668\u65f6\u5ef6
\n *\/
\n {
\n std::unique_lock<std::mutex> lock(mutex_);
\n pendingFunctors_.swap(pendingFunctors);
\n }<\/p>\n
for(const auto& cb : pendingFunctors){
\n cb();
\n }<\/p>\n
callingPendingFunctors_ = false;
\n} <\/p>\n
\u5916\u90e8\u5982\u4f55\u521b\u5efaPoller\u7ba1\u7406\u6211\u4eec\u7684poller\u5462？<\/p>\n
\u90a3\u5f53\u7136\u662f\u901a\u8fc7Poller\u4e2d\u7684newDefaultPoller\u65b9\u6cd5\u5566\u3002\u901a\u8fc7\u8bbe\u7f6e\u7cfb\u7edf\u73af\u5883\u53d8\u91cf，\u6211\u4eec\u53ef\u4ee5\u81ea\u5df1\u9009\u62e9\u751f\u6210\u90a3\u79cdio\u590d\u7528\u65b9\u6cd5\u3002\u5f53\u7136，\u76ee\u524d\u9ed8\u8ba4\u751f\u6210\u7684\u90fd\u662fEPollPoller！<\/p>\n
#include "Poller.h"
\n#include "EPollPoller.h"<\/p>\n
#include <stdlib.h><\/p>\n
\/\/ \u901a\u8fc7\u73af\u5883\u53d8\u91cf\u9009\u62e9\u90a3\u79cd\u89e6\u53d1\u65b9\u5f0f
\nPoller* Poller::newDefaultPoller(EventLoop* eventLoop){
\n if(getenv("MUDUO_USE_POLL")){
\n return nullptr; \/\/\u751f\u6210poll\u5b9e\u4f8b
\n }else{
\n return new EPollPoller(eventLoop);\/\/\u751f\u6210epoll\u5b9e\u4f8b
\n }
\n} <\/p>\n
\u6700\u540e\u8865\u5145\u65b0\u8fde\u63a5\u5230\u6765\u65f6\u5019\u7684\u8c03\u7528\u6d41\u7a0b：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250418153210-6802707a40ed5.png\")
<\/p>\n<\/p>\n
\u5728\u4e0a\u4e00\u7ae0，\u6211\u4eec\u753b\u4e86\u4e00\u4e2a\u7b80\u6613\u7684\u8c03\u7528\u6d41\u7a0b\u56fe，\u5982\u4e0b：<\/p>\n
<\/p>\n
\u90a3\u4e48，\u6211\u4eec\u540e\u7eed\u5c06\u4f1a\u4e0d\u65ad\u5730\u57fa\u4e8e\u8fd9\u5f20\u56fe，\u8865\u5145\u5b8c\u6574\u7684\u8c03\u7528\u63a5\u53e3\u3002<\/p>\n
\u518d\u4e0a\u4e00\u7ae0\u6211\u4eec\u5b9e\u73b0\u4e86EPollPoller\u3002\u6211\u4eec\u8ba8\u8bba\u5230\u4e86\u60f3\u7528\u4e00\u4e2aChannel\u6a21\u5757\u7ba1\u7406\u6211\u4eec\u7684\u65b0\u8fde\u63a5\u7684\u76d1\u542c\u4e8b\u4ef6，\u5e76\u4e14\u80fd\u591f\u5bf9\u53d1\u751f\u7684\u76d1\u542c\u4e8b\u4ef6\u901a\u8fc7Channel\u5b58\u653e\u7684\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u5b8c\u6210\u76f8\u5e94\u7684\u76d1\u542c\u4e8b\u4ef6\u64cd\u4f5c\u3002<\/p>\n
\u90a3\u4e48\u6211\u4eec\u9884\u671f\u7684\u8fd9\u4e2aChannel\u8981\u5b8c\u6210\u54ea\u4e9b\u64cd\u4f5c\u5462？<\/p>\n
\u6784\u9020\u51fd\u6570\u6709\u4e24\u4e2a\u53c2\u6570\u7684\u8f93\u5165，\u7b2c\u4e00\u4e2a\u662fEventLoop（\u5faa\u73af\u4e8b\u4ef6\u2014\u2014\u4e5f\u53ef\u6682\u65f6\u89c6\u4e3aSub-Reactor\u6216Main-Reactor），\u8868\u660e\u8be5Channel\u5c5e\u4e8e\u54ea\u4e2areactor\u8981\u76d1\u542c\u7684\u7aef\u53e3\u548c\u76f8\u5173\u4e8b\u4ef6，\u7b2c\u4e8c\u4e2a\u53c2\u6570\u5c31\u662f\u8be5Channel\u76d1\u542c\u7684socket\u3002\u4ee3\u7801\u5982\u4e0b：<\/p>\n
\/\/ Channel.cc
\nChannel::Channel(EventLoop *loop, int fd)
\n : loop_(loop),
\n fd_(fd),
\n events_(0),
\n revents_(0),
\n index_(-1),
\n tied_(false)
\n{
\n}<\/p>\n
\/\/ EventLoop
\n\/\/ \u521b\u5efa\u4e8b\u4ef6fd
\nint createEventfd()
\n{
\n int evfd = ::eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);
\n if (evfd < 0)
\n {
\n std::cerr << "eventfd error: " << std::endl;
\n }
\n return evfd;
\n}<\/p>\n
EventLoop::EventLoop() :
\n looping_(false),
\n quit_(false),
\n callingPendingFunctors_(false),
\n threadId_(CurrentThread::tid()),
\n poller_(Poller::newDefaultPoller(this)),
\n timerQueue_(new TimerQueue(this)),
\n wakeupFd_(createEventfd()), \/\/\u8fd9\u91cc\u521b\u5efafd
\n wakeupChannel_(new Channel(this, wakeupFd_)), \/\/\u5728\u8fd9\u91cc\u521b\u5efa\u65b0\u7684Channel，\u5e76\u628a\u521a\u521b\u5efa\u7684fd\u4f5c\u4e3a\u8f93\u5165
\n currentActiveChannel_(nullptr){} <\/p>\n
\u5916\u90e8\u53ef\u4ee5\u901a\u8fc7\u8c03\u7528\u8fd9\u4e9b\u63a5\u53e3，\u4ece\u800c\u8c03\u7528epoll\u7684updatechannel\u63a5\u53e3，\u6700\u7ec8\u8c03\u7528epoll_ctl\u66f4\u65b0\u76d1\u542c\u4e8b\u4ef6<\/p>\n
\/\/ Channel.h
\n \/\/ \u8bbe\u7f6efd\u76f8\u5e94\u7684\u4e8b\u4ef6\u72b6\u6001，update()\u5176\u672c\u8d28\u8c03\u7528epoll_ctl
\n void enableReading() { events_ |= kReadEvent; update(); }
\n void disableReading() { events_ &= ~kReadEvent; update(); }
\n void enableWriting() { events_ |= kWriteEvent; update(); }
\n void disableWriting() { events_ &= ~kWriteEvent; update(); }
\n void disableAll() { events_ &= kNoneEvent; update(); }
\n\/\/ Channel.cc
\n void Channel::update()
\n {
\n \/\/TODO:Channel::update()
\n \/\/ \u901a\u8fc7\u8be5channel\u6240\u5c5e\u7684EventLoop，\u8c03\u7528poller\u5bf9\u5e94\u7684\u65b9\u6cd5，\u6ce8\u518cfd\u7684events\u4e8b\u4ef6
\n loop_->updateChannel(this);
\n }<\/p>\n
\/\/ loop\u8c03\u7528 EventLoop.cc<\/p>\n
void EventLoop::updateChannel(Channel *channel)
\n{
\n poller_->updateChannel(channel);
\n}<\/p>\n
\/\/ \u968f\u540e\u8c03\u7528updateChannel，\u4f7f\u7528epollpoller\u7684update\u63a5\u53e3，\u6700\u7ec8\u8c03\u7528epoll_ctl，\u5b8c\u6210\u5bf9\u76f8\u5173\u76d1\u542c\u4e8b\u4ef6\u7684\u66f4\u65b0
\nvoid EPollPoller::updateChannel(Channel *channel)
\n{
\n \/\/ TODO:__FUNCTION__
\n \/\/ \u83b7\u53d6\u53c2\u6570channel\u5728epoll\u7684\u72b6\u6001
\n const int index = channel->index();<\/p>\n
\/\/ \u672a\u6dfb\u52a0\u72b6\u6001\u548c\u5df2\u5220\u9664\u72b6\u6001\u90fd\u6709\u53ef\u80fd\u4f1a\u88ab\u518d\u6b21\u6dfb\u52a0\u5230epoll\u4e2d
\n if (index == kNew || index == kDeleted)
\n {
\n \/\/ \u6dfb\u52a0\u5230\u952e\u503c\u5bf9
\n if (index == kNew)
\n {
\n int fd = channel->fd();
\n channels_[fd] = channel;
\n }
\n else \/\/ index == kAdd
\n {
\n }
\n \/\/ \u4fee\u6539channel\u7684\u72b6\u6001，\u6b64\u65f6\u662f\u5df2\u6dfb\u52a0\u72b6\u6001
\n channel->set_index(kAdded);
\n \/\/ \u5411epoll\u5bf9\u8c61\u52a0\u5165channel
\n update(EPOLL_CTL_ADD, channel);
\n }
\n \/\/ channel\u5df2\u7ecf\u5728poller\u4e0a\u6ce8\u518c\u8fc7
\n else
\n {
\n \/\/ \u6ca1\u6709\u611f\u5174\u8da3\u4e8b\u4ef6\u8bf4\u660e\u53ef\u4ee5\u4eceepoll\u5bf9\u8c61\u4e2d\u5220\u9664\u8be5channel\u4e86
\n if (channel->isNoneEvent())
\n {
\n update(EPOLL_CTL_DEL, channel);
\n channel->set_index(kDeleted);
\n }
\n \/\/ \u8fd8\u6709\u4e8b\u4ef6\u8bf4\u660e\u4e4b\u524d\u7684\u4e8b\u4ef6\u5220\u9664，\u4f46\u662f\u88ab\u4fee\u6539\u4e86
\n else
\n {
\n update(EPOLL_CTL_MOD, channel);
\n }
\n }
\n}
\n\/\/ \u8f93\u5165\u5bf9\u76d1\u542c\u4e8b\u4ef6\u7684\u64cd\u4f5coperation，\u548c\u5bf9\u5e94\u7684\u4e8b\u4ef6channel
\nvoid EPollPoller::update(int operation, Channel *channel)
\n{
\n epoll_event event;
\n ::memset(&event, 0, sizeof(event));<\/p>\n
int fd = channel->fd();
\n event.events = channel->events();
\n event.data.fd = fd;
\n event.data.ptr = channel;<\/p>\n
if (::epoll_ctl(epollfd_, operation, fd, &event) < 0)
\n {
\n if (operation == EPOLL_CTL_DEL)
\n {
\n LOG_ERROR << "epoll_ctl() del error:" << errno;
\n }
\n else
\n {
\n LOG_FATAL << "epoll_ctl add\/mod error:" << errno;
\n }
\n }
\n} <\/p>\n
\u5b8c\u6574\u7684Channel\u4ee3\u7801\u5982\u4e0b：<\/p>\n
\/\/ Channel.h
\n#ifndef CHANNEL_H
\n#define CHANNEL_H<\/p>\n
#include <functional>
\n#include <memory>
\n#include <sys\/epoll.h><\/p>\n
#include "noncopyable.h"
\n#include "Timestamp.h"
\n#include "Logging.h"<\/p>\n
\/\/ \u524d\u7f6e\u58f0\u660e，\u4e0d\u5f15\u7528\u5934\u6587\u4ef6\u9632\u6b62\u66b4\u9732\u592a\u591a\u4fe1\u606f
\nclass EventLoop;
\nclass Timestamp;<\/p>\n
\/**
\n* Channel \u7406\u89e3\u4e3a\u901a\u9053，\u5c01\u88c5\u4e86sockfd\u548c\u5176\u611f\u5174\u8da3\u7684event，\u5982EPOLLIN,EPOLLOUT
\n* \u8fd8\u7ed1\u5b9a\u4e86poller\u8fd4\u56de\u7684\u5177\u4f53\u4e8b\u4ef6
\n*\/
\nclass Channel : noncopyable
\n{
\npublic:
\n using EventCallback = std::function<void()>;
\n using ReadEventCallback = std::function<void(Timestamp)>;<\/p>\n
Channel(EventLoop *loop, int fd);
\n ~Channel();<\/p>\n
\/\/ fd\u5f97\u5230poller\u901a\u77e5\u4ee5\u540e，\u5904\u7406\u4e8b\u4ef6\u7684\u56de\u8c03\u51fd\u6570
\n void handleEvent(Timestamp receiveTime);<\/p>\n
\/\/ \u8bbe\u7f6e\u56de\u8c03\u51fd\u6570\u5bf9\u8c61
\n \/\/ \u4f7f\u7528\u53f3\u503c\u5f15\u7528，\u5ef6\u957f\u4e86cb\u5bf9\u8c61\u7684\u751f\u547d\u5468\u671f，\u907f\u514d\u4e86\u62f7\u8d1d\u64cd\u4f5c
\n void setReadCallback(ReadEventCallback cb) { readCallback_ = std::move(cb); }
\n void setWriteCallback(EventCallback cb) { writeCallback_ = std::move(cb); }
\n void setCloseCallback(EventCallback cb) { closeCallback_ = std::move(cb); }
\n void setErrorCallback(EventCallback cb) { errorCallback_ = std::move(cb); }<\/p>\n
\/\/ TODO:\u9632\u6b62\u5f53 channel \u6267\u884c\u56de\u8c03\u51fd\u6570\u65f6\u88ab\u88ab\u624b\u52a8 remove \u6389
\n void tie(const std::shared_ptr<void>&);<\/p>\n
int fd() const { return fd_; } \/\/ \u8fd4\u56de\u5c01\u88c5\u7684fd
\n int events() const { return events_; } \/\/ \u8fd4\u56de\u611f\u5174\u8da3\u7684\u4e8b\u4ef6
\n void set_revents(int revt) { revents_ = revt; } \/\/ \u8bbe\u7f6ePoller\u8fd4\u56de\u7684\u53d1\u751f\u4e8b\u4ef6<\/p>\n
\/\/ \u8bbe\u7f6efd\u76f8\u5e94\u7684\u4e8b\u4ef6\u72b6\u6001，update()\u5176\u672c\u8d28\u8c03\u7528epoll_ctl
\n void enableReading() { events_ |= kReadEvent; update(); }
\n void disableReading() { events_ &= ~kReadEvent; update(); }
\n void enableWriting() { events_ |= kWriteEvent; update(); }
\n void disableWriting() { events_ &= ~kWriteEvent; update(); }
\n void disableAll() { events_ &= kNoneEvent; update(); }<\/p>\n
\/\/ \u8fd4\u56defd\u5f53\u524d\u7684\u4e8b\u4ef6\u72b6\u6001
\n bool isNoneEvent() const { return events_ == kNoneEvent; }
\n bool isWriting() const { return events_ & kWriteEvent; }
\n bool isReading() const { return events_ & kReadEvent; }<\/p>\n
\/**
\n * for Poller
\n * const int kNew = -1; \/\/ fd\u8fd8\u672a\u88abpoller\u76d1\u89c6
\n * const int kAdded = 1; \/\/ fd\u6b63\u88abpoller\u76d1\u89c6\u4e2d
\n * const int kDeleted = 2; \/\/ fd\u88ab\u79fb\u9664poller
\n *\/
\n int index() { return index_; }
\n void set_index(int idx) { index_ = idx; }<\/p>\n
\/\/ one lool per thread
\n EventLoop* ownerLoop() { return loop_; }
\n void remove();<\/p>\n
private:
\n void update();
\n void handleEventWithGuard(Timestamp receiveTime);<\/p>\n
\/**
\n * const int Channel::kNoneEvent = 0;
\n * const int Channel::kReadEvent = EPOLLIN | EPOLLPRI;
\n * const int Channel::kWriteEvent = EPOLLOUT;
\n *\/
\n static const int kNoneEvent;
\n static const int kReadEvent;
\n static const int kWriteEvent;<\/p>\n
EventLoop *loop_; \/\/ \u5f53\u524dChannel\u5c5e\u4e8e\u7684EventLoop
\n const int fd_; \/\/ fd, Poller\u76d1\u542c\u5bf9\u8c61
\n int events_; \/\/ \u6ce8\u518cfd\u611f\u5174\u8da3\u7684\u4e8b\u4ef6
\n int revents_; \/\/ poller\u8fd4\u56de\u7684\u5177\u4f53\u53d1\u751f\u7684\u4e8b\u4ef6
\n int index_; \/\/ \u5728Poller\u4e0a\u6ce8\u518c\u7684\u60c5\u51b5<\/p>\n
std::weak_ptr<void> tie_; \/\/ \u5f31\u6307\u9488\u6307\u5411TcpConnection(\u5fc5\u8981\u65f6\u5347\u7ea7\u4e3ashared_ptr\u591a\u4e00\u4efd\u5f15\u7528\u8ba1\u6570，\u907f\u514d\u7528\u6237\u8bef\u5220)
\n bool tied_; \/\/ \u6807\u5fd7\u6b64 Channel \u662f\u5426\u88ab\u8c03\u7528\u8fc7 Channel::tie \u65b9\u6cd5<\/p>\n
\/\/ \u56e0\u4e3a channel \u901a\u9053\u91cc\u9762\u80fd\u591f\u83b7\u77e5fd\u6700\u7ec8\u53d1\u751f\u7684\u5177\u4f53\u7684\u4e8b\u4ef6revents
\n \/\/ \u4fdd\u5b58\u4e8b\u4ef6\u5230\u6765\u65f6\u7684\u56de\u8c03\u51fd\u6570
\n ReadEventCallback readCallback_;
\n EventCallback writeCallback_;
\n EventCallback closeCallback_;
\n EventCallback errorCallback_;
\n};<\/p>\n
#endif \/\/ CHANNEL_H
\n\/\/ Channel.cc
\n#include "Channel.h"
\n#include "EventLoop.h"<\/p>\n
const int Channel::kNoneEvent = 0;
\nconst int Channel::kReadEvent = EPOLLIN | EPOLLPRI;
\nconst int Channel::kWriteEvent = EPOLLOUT;<\/p>\n
Channel::Channel(EventLoop *loop, int fd)
\n : loop_(loop),
\n fd_(fd),
\n events_(0),
\n revents_(0),
\n index_(-1),
\n tied_(false)
\n{
\n}<\/p>\n
\/\/TODO:\u6790\u6784\u64cd\u4f5c\u548c\u65ad\u8a00，\u5224\u65ad\u662f\u5426\u662f\u5728\u5f53\u524d\u7ebf\u7a0b
\nChannel::~Channel()
\n{
\n}<\/p>\n
\/\/ \u5728TcpConnection\u5efa\u7acb\u5f97\u65f6\u5019\u4f1a\u8c03\u7528
\nvoid Channel::tie(const std::shared_ptr<void> &obj)
\n{
\n \/\/ weak_ptr \u6307\u5411 obj
\n tie_ = obj;
\n tied_ = true;
\n}<\/p>\n
\/**
\n * \u5f53\u6539\u53d8channel\u6240\u8868\u793afd\u7684events\u4e8b\u4ef6\u540e，update\u8d1f\u8d23\u5728poller\u91cc\u9762\u66f4\u6539fd\u76f8\u5e94\u7684\u4e8b\u4ef6epoll_ctl
\n *
\n *\/
\n void Channel::update()
\n {
\n \/\/TODO:Channel::update()
\n \/\/ \u901a\u8fc7\u8be5channel\u6240\u5c5e\u7684EventLoop，\u8c03\u7528poller\u5bf9\u5e94\u7684\u65b9\u6cd5，\u6ce8\u518cfd\u7684events\u4e8b\u4ef6
\n loop_->updateChannel(this);
\n }<\/p>\n
\/\/ \u5728channel\u6240\u5c5e\u7684EventLoop\u4e2d，\u628a\u5f53\u524d\u7684channel\u5220\u9664\u6389
\nvoid Channel::remove()
\n{
\n \/\/TODO:Channel::remove()
\n loop_->removeChannel(this);
\n}<\/p>\n
\/\/ fd\u5f97\u5230poller\u901a\u77e5\u4ee5\u540e，\u53bb\u5904\u7406\u4e8b\u4ef6
\nvoid Channel::handleEvent(Timestamp receiveTime)
\n{
\n \/**
\n * \u8c03\u7528\u4e86Channel::tie\u5f97\u4f1a\u8bbe\u7f6etid_=true
\n * \u800cTcpConnection::connectEstablished\u4f1a\u8c03\u7528channel_->tie(shared_from_this());
\n * \u6240\u4ee5\u5bf9\u4e8eTcpConnection::channel_ \u9700\u8981\u591a\u4e00\u4efd\u5f3a\u5f15\u7528\u7684\u4fdd\u8bc1\u4ee5\u514d\u7528\u6237\u8bef\u5220TcpConnection\u5bf9\u8c61
\n *\/
\n if (tied_)
\n {
\n \/\/ \u53d8\u6210shared_ptr\u589e\u52a0\u5f15\u7528\u8ba1\u6570，\u9632\u6b62\u8bef\u5220
\n std::shared_ptr<void> guard = tie_.lock();
\n if (guard)
\n {
\n handleEventWithGuard(receiveTime);
\n }
\n \/\/ guard\u4e3a\u7a7a\u60c5\u51b5，\u8bf4\u660eChannel\u7684TcpConnection\u5bf9\u8c61\u5df2\u7ecf\u4e0d\u5b58\u5728\u4e86
\n }
\n else
\n {
\n handleEventWithGuard(receiveTime);
\n }
\n}<\/p>\n
\/\/ \u6839\u636e\u76f8\u5e94\u4e8b\u4ef6\u6267\u884c\u56de\u8c03\u64cd\u4f5c
\nvoid Channel::handleEventWithGuard(Timestamp receiveTime)
\n{
\n \/\/ \u5bf9\u7aef\u5173\u95ed\u4e8b\u4ef6
\n \/\/ \u5f53TcpConnection\u5bf9\u5e94Channel，\u901a\u8fc7shutdown\u5173\u95ed\u5199\u7aef，epoll\u89e6\u53d1EPOLLHUP
\n if ((revents_ & EPOLLHUP) && !(revents_ & EPOLLIN))
\n {
\n \/\/ \u786e\u8ba4\u662f\u5426\u62e5\u6709\u56de\u8c03\u51fd\u6570
\n if (closeCallback_)
\n {
\n closeCallback_();
\n }
\n }<\/p>\n
\/\/ \u9519\u8bef\u4e8b\u4ef6
\n if (revents_ & (EPOLLERR))
\n {
\n LOG_ERROR << "the fd = " << this->fd();
\n if (errorCallback_)
\n {
\n errorCallback_();
\n }
\n }<\/p>\n
\/\/ \u8bfb\u4e8b\u4ef6
\n if (revents_ & (EPOLLIN | EPOLLPRI))
\n {
\n LOG_DEBUG << "channel have read events, the fd = " << this->fd();
\n if (readCallback_)
\n {
\n LOG_DEBUG << "channel call the readCallback_(), the fd = " << this->fd();
\n readCallback_(receiveTime);
\n }
\n }<\/p>\n
\/\/ \u5199\u4e8b\u4ef6
\n if (revents_ & EPOLLOUT)
\n {
\n if (writeCallback_)
\n {
\n writeCallback_();
\n }
\n }
\n} <\/p>\n
3.1.2 \u603b\u7ed3<\/p>\n<\/p>\n
\u51d1\u51d1\u5b57\u6570，\u540e\u7eed\u8865\u5145<\/p>\n
\u51d1\u51d1\u5b57\u6570，\u540e\u7eed\u8865\u5145<\/p>\n
\u51d1\u51d1\u5b57\u6570，\u540e\u7eed\u8865\u5145<\/p>\n
\u51d1\u51d1\u5b57\u6570，\u540e\u7eed\u8865\u5145<\/p>\n
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb818\u6b21\uff0c\u70b9\u8d5e29\u6b21\uff0c\u6536\u85cf26\u6b21\u3002\u5728\u9ad8\u6027\u80fd\u7f51\u7edc\u7f16\u7a0b\u4e2d\uff0cReactor\u6a21\u5f0f\u662f\u4e00\u79cd\u5e38\u7528\u7684\u4e8b\u4ef6\u9a71\u52a8\u67b6\u6784\u6a21\u5f0f\uff0c\u5b83\u5141\u8bb8\u670d\u52a1\u5668\u9ad8\u6548\u5730\u5904\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002\u800cMulti-Reactor\u6a21\u5f0f\u662f\u5bf9\u7ecf\u5178Reactor\u6a21\u5f0f\u7684\u4e00\u79cd\u6269\u5c55\u548c\u4f18\u5316\uff0c\u901a\u8fc7\u5c06\u4e8b\u4ef6\u5206\u6d3e\u4e0e\u4e8b\u4ef6\u5904\u7406\u5206\u79bb\uff0c\u5e76\u5229\u7528\u591a\u4e2aReactor\u5b9e\u4f8b\u6765\u63d0\u9ad8\u7cfb\u7edf\u6027\u80fd\u548c\u53ef\u6269\u5c55\u6027\u3002\u5728\u8fd9\u79cd\u6a21\u5f0f\u4e0b\uff0c\u901a\u5e38\u6709\u4e00\u4e2a\u4e3b\u7ebf\u7a0b\uff08\u6216\u5c11\u91cf\u7ebf\u7a0b\uff09\u8d1f\u8d23\u76d1\u542c\u65b0\u8fde\u63a5\u8bf7\u6c42\uff0c\u5e76\u5c06\u8fd9\u4e9b\u8fde\u63a5\u5206\u914d\u7ed9\u5de5\u4f5c\u7ebf\u7a0b\u6c60\u4e2d\u7684\u4e0d\u540cReactor\u5b9e\u4f8b\u8fdb\u884c\u5904\u7406\u3002\u5f53\u7136\uff0c\u8fd9\u79cd\u6a21\u578b\u4e5f\u6709\u660e\u663e\u7f3a\u70b9\uff0c\u8fde\u63a5\u5efa\u7acb\u3001IO \u4e8b\u4ef6\u8bfb\u53d6\u4ee5\u53ca\u4e8b\u4ef6\u5206\u53d1\u5b8c\u5168\u6709\u5355\u7ebf\u7a0b\u5904\u7406\uff1b<\/p>\n","protected":false},"author":2,"featured_media":17073,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[925,176],"topic":[],"class_list":["post-17076","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-925","tag-176"],"yoast_head":"\n