Node.Js中怎么實(shí)現(xiàn)更快的數(shù)據(jù)傳輸

這篇文章主要介紹“Node.Js中怎么實(shí)現(xiàn)更快的數(shù)據(jù)傳輸”的相關(guān)知識(shí)，小編通過(guò)實(shí)際案例向大家展示操作過(guò)程，操作方法簡(jiǎn)單快捷，實(shí)用性強(qiáng)，希望這篇“Node.Js中怎么實(shí)現(xiàn)更快的數(shù)據(jù)傳輸”文章能幫助大家解決問(wèn)題。

在Node.js中，當(dāng)我們給前端返回一個(gè)靜態(tài)文件的時(shí)候，我們通常會(huì)把文件先讀進(jìn)內(nèi)容，然后通過(guò)socket接口寫(xiě)到底層，從而返回給前端。無(wú)論是一次性讀取到內(nèi)存還是使用流式的方式，都不可避免地要把數(shù)據(jù)從內(nèi)核復(fù)制到用戶層，再把數(shù)據(jù)復(fù)制到內(nèi)核，這是一種低效的方式，因?yàn)槎嗔藷o(wú)效的復(fù)制。在nginx中，可以通過(guò)sendfile指令提供效率。Node.js的copyFile底層使用了sendfile系統(tǒng)調(diào)用，但是網(wǎng)絡(luò)IO的時(shí)候，沒(méi)有使用該API。因?yàn)镹ode.js通過(guò)隊(duì)列的方式，控制數(shù)據(jù)的寫(xiě)入。那么是否可以實(shí)現(xiàn)sendfile的方式來(lái)提供這網(wǎng)絡(luò)IO的效率。首先我們看一下sendfile的好處是什么。

• sendfile() copies data between one file descriptor and another. Because this  copying is done within the kernel, sendfile() is more efficient than the  combination of read(2) and write(2), which would require transferring data to  and from user space.

我們看到sendfile通過(guò)把內(nèi)核完成數(shù)據(jù)的傳輸，減少了內(nèi)核和用戶層的數(shù)據(jù)復(fù)制，從而提高了效率。下面我們通過(guò)napi寫(xiě)一個(gè)addon來(lái)實(shí)現(xiàn)這個(gè)功能。

#include <sys/sendfile.h>  #include <stdio.h>  #include <unistd.h> #include <fcntl.h> #include <node_api.h> static napi_value copyFile(napi_env env, napi_callback_info info) {   size_t argc = 3;   napi_value args[3];   // 拿到j(luò)s層的入?yún)?，這里是三個(gè)   napi_get_cb_info(env, info, &argc, args, NULL, NULL);   int fd1;   int fd2;   int len;   // js傳入的是一個(gè)數(shù)字，v8轉(zhuǎn)成了對(duì)象，這里再次把入?yún)⑥D(zhuǎn)成int型   napi_get_value_int32(env, args[0], &fd1);   napi_get_value_int32(env, args[1], &fd2);   napi_get_value_int32(env, args[2], &len);   int writed = sendfile(fd2, fd1, 0,len);   napi_value ret;   napi_create_int32(env, writed, &ret);   return ret; }  napi_value Init(napi_env env, napi_value exports) {   napi_value func;   // 創(chuàng)建一個(gè)函數(shù)并且設(shè)置為exports對(duì)象的getArray屬性的值   napi_create_function(env,                       NULL,                       NAPI_AUTO_LENGTH,                       copyFile,                       NULL,                       &func);   napi_set_named_property(env, exports, "copyFile", func);   return exports; } NAPI_MODULE(NODE_GYP_MODULE_NAME, Init)

下面我們看看怎么使用。首先用這個(gè)addon來(lái)復(fù)制文件，類似Node.js的copyyFile

const fs= require('fs'); const { copyFile } = require('./build/Release/sendfile.node'); const {   O_WRONLY,   O_CREAT, } = fs.constants; async function test() {   const [fd1, fd2] = await Promise.all([openFile('1.txt', 'r'), openFile('2.txt', O_WRONLY | O_CREAT)]);   const { size } = await getFileInfo(fd1);   console.log(copyFile(fd1, fd2, size));   fs.close(fd1, () => {});   fs.close(fd2, () => {}); } function openFile(filename, mode) {   return new Promise((resolve, reject) => {     fs.open(filename, mode, (err, fd) => {       if (err) {         reject(err);       } else {         resolve(fd);       }     });   })}  function getFileInfo(fd) {   return new Promise((resolve, reject) => {     fs.fstat(fd, (err, stat) => {       if (err) {         reject(err)       }else {         resolve(stat);       }     });   }) } test();

執(zhí)行上面代碼，我們可以看到文件會(huì)成功復(fù)制2.txt。接著我們?cè)賮?lái)試一下網(wǎng)絡(luò)IO的場(chǎng)景。

const fs= require('fs'); const http = require('http'); const { copyFile } = require('./build/Release/sendfile.node'); const server = http.createServer(async (req, res) => {   const fd = await openFile('1.txt', 'r');   const { size } = await getFileInfo(fd);   const ret = copyFile(fd, res.socket._handle.fd, size);   res.socket.end(); }).listen(8002);  const {   O_WRONLY,   O_CREAT, } = fs.constants;  function openFile(filename, mode) {   return new Promise((resolve, reject) => {     fs.open(filename, mode, (err, fd) => {       if (err) {         reject(err);       } else {         resolve(fd);       }     });   })}  function getFileInfo(fd) {   return new Promise((resolve, reject) => {     fs.fstat(fd, (err, stat) => {       if (err) {         reject(err)       }else {         resolve(stat);       }     });   })}

以上代碼首先啟動(dòng)一個(gè)http服務(wù)器，然后收到請(qǐng)求的時(shí)候，通過(guò)addon調(diào)用sendfile給前端返回對(duì)應(yīng)的內(nèi)容，最后關(guān)閉連接。結(jié)果如下。

關(guān)于“Node.Js中怎么實(shí)現(xiàn)更快的數(shù)據(jù)傳輸”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)，可以關(guān)注億速云行業(yè)資訊頻道，小編每天都會(huì)為大家更新不同的知識(shí)點(diǎn)。