update

Author: yuesong-feng

code/day06/server.cpp

@@ -1,9 +1,61 @@
-#include "EventLoop.h"
 #include "Server.h"
+#include "Socket.h"
+#include "InetAddress.h"
+#include "Channel.h"
+#include <functional>
+#include <string.h>
+#include <unistd.h>
 
-int main() {
-    EventLoop *loop = new EventLoop();
-    Server *server = new Server(loop);
-    loop->loop();
-    return 0;
+#define READ_BUFFER 1024
+
+Server::Server(EventLoop *_loop) : loop(_loop){    
+    Socket *serv_sock = new Socket();
+    InetAddress *serv_addr = new InetAddress("127.0.0.1", 8888);
+    serv_sock->bind(serv_addr);
+    serv_sock->listen(); 
+    serv_sock->setnonblocking();
+       
+    Channel *servChannel = new Channel(loop, serv_sock->getFd());
+    std::function<void()> cb = std::bind(&Server::newConnection, this, serv_sock);
+    servChannel->setCallback(cb);
+    servChannel->enableReading();
+
+}
+
+Server::~Server()
+{
+    
 }
+
+void Server::handleReadEvent(int sockfd){
+    char buf[READ_BUFFER];
+    while(true){    //由于使用非阻塞IO，读取客户端buffer，一次读取buf大小数据，直到全部读取完毕
+        bzero(&buf, sizeof(buf));
+        ssize_t bytes_read = read(sockfd, buf, sizeof(buf));
+        if(bytes_read > 0){
+            printf("message from client fd %d: %s\n", sockfd, buf);
+            write(sockfd, buf, sizeof(buf));
+        } else if(bytes_read == -1 && errno == EINTR){  //客户端正常中断、继续读取
+            printf("continue reading");
+            continue;
+        } else if(bytes_read == -1 && ((errno == EAGAIN) || (errno == EWOULDBLOCK))){//非阻塞IO，这个条件表示数据全部读取完毕
+            printf("finish reading once, errno: %d\n", errno);
+            break;
+        } else if(bytes_read == 0){  //EOF，客户端断开连接
+            printf("EOF, client fd %d disconnected\n", sockfd);
+            close(sockfd);   //关闭socket会自动将文件描述符从epoll树上移除
+            break;
+        }
+    }
+}
+
+void Server::newConnection(Socket *serv_sock){
+    InetAddress *clnt_addr = new InetAddress();      //会发生内存泄露！没有delete
+    Socket *clnt_sock = new Socket(serv_sock->accept(clnt_addr));       //会发生内存泄露！没有delete
+    printf("new client fd %d! IP: %s Port: %d\n", clnt_sock->getFd(), inet_ntoa(clnt_addr->addr.sin_addr), ntohs(clnt_addr->addr.sin_port));
+    clnt_sock->setnonblocking();
+    Channel *clntChannel = new Channel(loop, clnt_sock->getFd());
+    std::function<void()> cb = std::bind(&Server::handleReadEvent, this, clnt_sock->getFd());
+    clntChannel->setCallback(cb);
+    clntChannel->enableReading();
+}

day06-服务器与事件驱动核心类登场.md

@@ -6,14 +6,14 @@
 
 需要注意的是，事件驱动不是服务器开发的专利。事件驱动是一种设计应用的思想、开发模式，而服务器是根据客户端的不同请求提供不同的服务的一个实体应用，服务器开发可以采用事件驱动模型、也可以不采用。事件驱动模型也可以在服务器之外的其他类型应用中出现，如进程通信、k8s调度、V8引擎、Node.js等。
 
-理解了以上的概念，就能容易理解服务器开发的两种经典模式——Reactor和Proactor模式。详细请参考$游双《Linux高性能服务器编程》$第八章第四节、$陈硕《Linux多线程服务器编程》$第六章第六节。
+理解了以上的概念，就能容易理解服务器开发的两种经典模式——Reactor和Proactor模式。详细请参考游双《Linux高性能服务器编程》第八章第四节、陈硕《Linux多线程服务器编程》第六章第六节。
 
 > 如何深刻理解Reactor和Proactor？ - 小林coding的回答 - 知乎
 https://www.zhihu.com/question/26943938/answer/1856426252
 
 由于Linux内核系统调用的设计更加符合Reactor模式，所以绝大部分高性能服务器都采用Reactor模式进行开发，我们的服务器也使用这种模式。
 
-接下来我们要将服务器改造成Reactor模式。首先我们将整个服务器抽象成一个`Server`类，这个类中有一个main Reactor（在这个版本没有sub Reactor），里面的核心是一个`EventLoop`（libevent中叫做EventBase），这是一个事件循环，我们添加需要监听的事务到这个事件循环内，每次有事件发生时就会通知（在程序中返回给我们`Channel`），然后根据不同的描述符、事件类型进行处理（以回调函数的方式）。
+接下来我们要将服务器改造成Reactor模式。首先我们将整个服务器抽象成一个`Server`类，这个类中有一个main-Reactor（在这个版本没有sub-Reactor），里面的核心是一个`EventLoop`（libevent中叫做EventBase），这是一个事件循环，我们添加需要监听的事务到这个事件循环内，每次有事件发生时就会通知（在程序中返回给我们`Channel`），然后根据不同的描述符、事件类型进行处理（以回调函数的方式）。
 > 如果你不太清楚这个自然段在讲什么，请先看一看前面提到的两本书的具体章节。
 
 EventLoop类的定义如下：