[[427158]]

1 HTTP 解析器

No.js 使用 Node.js 的 HTTP 解析器 llhttp 實(shí)現(xiàn) HTTP 協(xié)議的解析，llhttp 負(fù)責(zé)解析 HTTP 報(bào)文，No.js 需要做的事情是保存解析的結(jié)果并封裝具體的能力?？纯?No.js 是如何封裝 llhttp 的。

class HTTP_Parser { 
    public: 
        HTTP_Parser(llhttp_type type, parser_callback callbacks = {}) { 
            llhttp_init(&parser, type, &HTTP_Parser::settings); 
            // set data after llhttp_init, because llhttp_init will call memset to fill zero to memory  
            parser.data = this; 
            memset((void *)&callback, 0, sizeof(callback)); 
            callback = callbacks; 
        } 
 
        int on_message_begin(llhttp_t* parser); 
        int on_status(llhttp_t* parser, const char* at, size_t length); 
        int on_url(llhttp_t* parser, const char* at, size_t length); 
        int on_header_field(llhttp_t* parser, const char* at, size_t length); 
        int on_header_value(llhttp_t* parser, const char* at, size_t length); 
        int on_headers_complete(llhttp_t* parser); 
        int on_body(llhttp_t* parser, const char* at, size_t length); 
        int on_message_complete(llhttp_t* parser); 
        int parse(const char* data, int len); 
        void print(); 
    private:  
        unsigned char major_version; 
        unsigned char minor_version; 
        unsigned char upgrade; 
        unsigned char keepalive; 
        time_t parse_start_time; 
        time_t header_end_time; 
        time_t message_end_time; 
        string url; 
        string status; 
        vector<string> keys; 
        vector<string> values; 
        string body; 
        llhttp_t parser; 
        parser_callback callback; 
        static llhttp_settings_t settings; 
}; 

HTTP_Parser 是對(duì) llhttp 的封裝，主要是注冊(cè) llhttp 的鉤子，llhttp 在解析 HTTP 報(bào)文的時(shí)候會(huì)回調(diào) HTTP_Parser 的鉤子。比較麻煩的是需要在 HTTP_Parser 對(duì)象里保存 llhttp 的解析結(jié)果，把 HTTP_Parser 類的成員函數(shù)轉(zhuǎn)成 c 函數(shù)作為 llhttp 的回調(diào)非常麻煩，問(wèn)題在于如何在 llhttp 執(zhí)行回調(diào)的時(shí)候找到對(duì)應(yīng)的 HTTP_Parser 對(duì)象。比如 llhttp 的 on_message_begin 回調(diào)格式是

typedef int (*llhttp_cb)(llhttp_t*); 

我們看到回調(diào)里只有 llhttp 相關(guān)的數(shù)據(jù)結(jié)構(gòu)，拿不到 HTTP_Parser 對(duì)象，最終發(fā)現(xiàn) llhttp 提供了 data 字段關(guān)聯(lián)上下文。所以在 HTTP_Parser 初始化時(shí)關(guān)聯(lián) llhttp 和 HTTP_Parser 的上下文。

HTTP_Parser(llhttp_type type, parser_callback callbacks = {}) { 
    llhttp_init(&parser, type, &HTTP_Parser::settings); 
    parser.data = this; 
} 

我們?cè)?llhttp 回調(diào)時(shí)通過(guò) data 字段就可以取得 HTTP_Parser 對(duì)象。下面是所有鉤子的實(shí)現(xiàn)。

llhttp_settings_t No::HTTP::HTTP_Parser::settings = { 
    [](llhttp_t * parser) { 
        return ((HTTP_Parser *)parser->data)->on_message_begin(parser); 
    }, 
    [](llhttp_t * parser, const char * data, size_t len) { 
        return ((HTTP_Parser *)parser->data)->on_url(parser, data, len); 
    }, 
    [](llhttp_t * parser, const char * data, size_t len) { 
        return ((HTTP_Parser *)parser->data)->on_status(parser, data, len); 
    }, 
    [](llhttp_t * parser, const char * data, size_t len) { 
        return ((HTTP_Parser *)parser->data)->on_header_field(parser, data, len); 
    }, 
    [](llhttp_t * parser, const char * data, size_t len) { 
        return ((HTTP_Parser *)parser->data)->on_header_value(parser, data, len); 
    }, 
    [](llhttp_t * parser) { 
        return ((HTTP_Parser *)parser->data)->on_headers_complete(parser); 
    }, 
    [](llhttp_t * parser, const char * data, size_t len) { 
        return ((HTTP_Parser *)parser->data)->on_body(parser, data, len); 
    }, 
    [](llhttp_t * parser) { 
        return ((HTTP_Parser *)parser->data)->on_message_complete(parser); 
    } 
}; 

這樣就完成了 llhttp 和 No.js 的關(guān)聯(lián)。解析完 HTTP 協(xié)議后，最終還需要回調(diào) No.js 的 JS 層。HTTP_Parser 目前支持三種回調(diào)。

struct parser_callback { 
    void * data; 
    p_on_headers_complete on_headers_complete; 
    p_on_body on_body; 
    p_on_body_complete on_body_complete; 
}; 

2 HTTP C++ 模塊

完成了 llhttp 的封裝后，接著需要把這個(gè)能力暴露到 JS 層?？匆幌?C++ 模塊到定義。

class Parser : public BaseObject { 
  public: 
      Parser(Environment* env, Local<Object> object): BaseObject(env, object) { 
          // 注冊(cè)到 HTTP_Parser 的回調(diào) 
          parser_callback callback = { 
              this, 
              ..., 
              ..., 
              [](on_body_complete_info info, parser_callback callback) { 
                  Parser * parser = (Parser *)callback.data; 
                  Local<Value> cb; 
                  Local<Context> context = parser->env()->GetContext(); 
                  Isolate * isolate = parser->env()->GetIsolate(); 
                  Local <String> key = newStringToLcal(isolate, "onBodyComplete"); 
                  parser->object()->Get(context, key).ToLocal(&cb); 
                  // 回調(diào) JS 層 
                  if (!cb.IsEmpty() && cb->IsFunction()) { 
                      Local<Value> argv[] = { 
                          newStringToLcal(isolate, info.body.c_str()) 
                      }; 
                      cb.As<v8::Function>()->Call(context, parser->object(), 1, argv);   
                  } 
              }, 
          }; 
          httpparser = new HTTP_Parser(HTTP_REQUEST, callback); 
      } 
      void Parse(const char * data, size_t len);  
      static void Parse(const FunctionCallbackInfo<Value>& args);  
      static void New(const FunctionCallbackInfo<Value>& args);  
  private: 
      HTTP_Parser * httpparser; 
}; 

C++ 模塊到定義非常簡(jiǎn)單，只是對(duì) HTTP_Parser 的封裝，然后通過(guò) V8 導(dǎo)出能力到 JS 層。

void No::HTTP::Init(Isolate* isolate, Local<Object> target) { 
    Local<FunctionTemplate> parser = FunctionTemplate::New(isolate, No::HTTP::Parser::New); 
    parser->InstanceTemplate()->SetInternalFieldCount(1); 
    parser->SetClassName(newStringToLcal(isolate, "HTTPParser")); 
    parser->PrototypeTemplate()->Set(newStringToLcal(isolate, "parse"), FunctionTemplate::New(isolate, No::HTTP::Parser::Parse)); 
    setObjectValue(isolate, target, "HTTPParser", parser->GetFunction(isolate->GetCurrentContext()).ToLocalChecked()); 
} 

我們看到 C++ 模塊導(dǎo)出了 HTTPParser 到 JS 層，并提供一個(gè) parse方法。JS 層拿到 TCP 層的數(shù)據(jù)后，通過(guò)執(zhí)行 parse 進(jìn)行 HTTP 協(xié)議的解析，我們看看 parse 對(duì)應(yīng)函數(shù) No::HTTP::Parser::Parse 的實(shí)現(xiàn)。

void No::HTTP::Parser::Parse(const FunctionCallbackInfo<Value>& args) { 
    Parser * parser = (Parser *)unwrap(args.This()); 
    Local<ArrayBuffer> arrayBuffer = args[0].As<ArrayBuffer>(); 
    std::shared_ptr<BackingStore> backing = arrayBuffer->GetBackingStore(); 
    const char * data = (const char * )backing->Data(); 
    parser->Parse(data, strlen(data)); 
} 

Parse首先通過(guò) args 拿到 C++ 的對(duì)象 Parser(熟悉 Node.js 的同學(xué)應(yīng)該很容易明白這個(gè)處理方式)。接著調(diào)用 HTTP_Parser 的 parse 方法，在解析的過(guò)程中，llhttp 就會(huì)執(zhí)行 HTTP_Parser 的回調(diào)， HTTP_Parser 就會(huì)執(zhí)行 Parser 對(duì)象的回調(diào)，Parser 就會(huì)執(zhí)行 JS 回調(diào)。比如解析完 body 后執(zhí)行 JS 層回調(diào)。

[](on_body_complete_info info, parser_callback callback) { 
    Parser * parser = (Parser *)callback.data; 
    Local<Value> cb; 
    Local<Context> context = parser->env()->GetContext(); 
    Isolate * isolate = parser->env()->GetIsolate(); 
    Local <String> key = newStringToLcal(isolate, "onBodyComplete"); 
    parser->object()->Get(context, key).ToLocal(&cb); 
    if (!cb.IsEmpty() && cb->IsFunction()) { 
        Local<Value> argv[] = { 
            newStringToLcal(isolate, info.body.c_str()) 
        }; 
        cb.As<v8::Function>()->Call(context, parser->object(), 1, argv);   
    } 
}, 

就是找到 JS 設(shè)置的 onBodyComplete 函數(shù)并執(zhí)行。結(jié)構(gòu)如下。

3 JS 層

完成了底層的封裝和能力導(dǎo)出，接下來(lái)就是 JS 層的實(shí)現(xiàn)，首先看看 一個(gè)使用例子。

const { 
    console,} = No;const { http } = No.libs; 
 
http.createServer({host: '127.0.0.1', port: 8888}, (req, res) => { 
    console.log(JSON.stringify(req.headers)); 
    req.on('data', (buffer) => { 
        console.log(buffer); 
    }); 
}); 

和 Node.js 很相似，接下來(lái)看看具體實(shí)現(xiàn)。先看 TCP 層的封裝。

class Server extends events { 
    fd = -1; 
    connections = 0; 
    constructor(options = {}) { 
        super(); 
        const fd = tcp.socket(constant.domain.AF_INET, constant.type.SOCK_STREAM); 
        this.fd = fd; 
        tcp.bind(fd, options.host, options.port); 
        tcp.listen(fd, 512, (clientFd) => { 
            this.connections++; 
            const serverSocket = new ServerSocket({fd: clientFd}); 
            this.emit('connection', serverSocket); 
        }); 
    } 
} 

createServer 的時(shí)候會(huì)監(jiān)聽(tīng)傳入的地址，從而啟動(dòng)一個(gè)服務(wù)器，listen 回調(diào)執(zhí)行說(shuō)明有連接到來(lái)，我們新建一個(gè) ServerSocket 對(duì)象表示和客戶端通信的 Socket。并觸發(fā) connection 事件到上層。接著看 ServerSocket 的實(shí)現(xiàn)

class ServerSocket extends Socket { 
    constructor(options = {}) { 
        super(options); 
        this.fd = options.fd; 
        this.read(); 
    } 
    read() { 
        const buffer = new ArrayBuffer(1024); 
        tcp.read(this.fd, buffer, 0, (status) => { 
            this.emit('data', buffer); 
            this.read(); 
        }) 
    } 
} 

ServerSocket 的實(shí)現(xiàn)目前很簡(jiǎn)單，主要是讀取數(shù)據(jù)并觸發(fā) data 事件，因?yàn)?TCP 只是負(fù)責(zé)數(shù)據(jù)傳輸，不負(fù)責(zé)數(shù)據(jù)解析。有了這個(gè)能力后，我們看看 http 層的實(shí)現(xiàn)。

function createServer(...arg) { 
    return new Server(...arg);} 
 
class Server extends No.libs.tcp.Server { 
    constructor(options = {}, cb) { 
        super(options); 
        this.options = options; 
        if (typeof cb === 'function') { 
            this.on('request', cb); 
        } 
        this.on('connection', (socket) => { 
            new HTTPRequest({socket, server: this}); 
        }); 
    } 
} 

http 模塊繼承于 tcp 模塊，所以我們調(diào)用 http.createServer 的時(shí)候，會(huì)先執(zhí)行 tcp 模塊啟動(dòng)一個(gè)服務(wù)器，http 層監(jiān)聽(tīng) connection 事件等待連接到來(lái)，有連接到來(lái)時(shí)，http 創(chuàng)建一個(gè) HTTPRequest 對(duì)象表示 http 請(qǐng)求。

class HTTPRequest extends No.libs.events { 
    socket = null; 
    httpparser = null; 
    constructor({socket, server}) { 
        super(); 
        this.server = server; 
        this.socket = socket; 
        this.httpparser = new HTTPParser(); 
        this.httpparser.onHeaderComplete = (data) => { 
            this.major = data.major; 
            this.minor = data.minor; 
            this.keepalive = data.keepalive; 
            this.upgrade = data.upgrade; 
            this.headers = data.headers; 
            this.server.emit('request', this); 
        } 
        this.httpparser.onBody = (data) => { 
            this.emit('data', data); 
        } 
        this.httpparser.onBodyComplete = (data) => { 
            // console.log(data); 
        } 
 
        socket.on('data', (buffer) => { 
            this.httpparser.parse(buffer); 
        }); 
    } 
} 

HTTPRequest 的邏輯如下 1. 保存底層的 socket 2. 新建一個(gè) HTTPParser 解析 HTTP 協(xié)議。3. 監(jiān)聽(tīng) data 事件，收到 TCP 層數(shù)據(jù)后調(diào)用 HTTP 解析器解析。4. 注冊(cè) HTTP 解析的回調(diào)鉤子，就是前面講到的。等到解析完 HTTP header 后，也就是執(zhí)行 onHeaderComplete 回調(diào)后，No.js 就會(huì)通過(guò)觸發(fā) request事件 回調(diào)業(yè)務(wù)層，也就是 createServer 傳入的回調(diào)。業(yè)務(wù)層可以監(jiān)聽(tīng) HTTPRequest 的 data 事件，當(dāng) HTTP 請(qǐng)求有 body 數(shù)據(jù)時(shí)，就會(huì)注冊(cè) HTTPRequest 的 data 事件回調(diào)業(yè)務(wù)層。

4 總結(jié)

雖然目前只是粗糙地實(shí)現(xiàn)了 HTTP 模塊，但實(shí)現(xiàn)的過(guò)程中，涉及到的內(nèi)容還是挺多的，后面有時(shí)間再慢慢完善。有興趣的同學(xué)可以到 https://github.com/theanarkh/No.js 了解。