Comprendre brièvement le module Buffer dans Node.js

Cet article vous amènera à comprendre le Buffer dans Node.js, à jeter un œil à la structure du Buffer, à l'allocation de mémoire du Buffer, à l'épissage du Buffer, etc. J'espère qu'il vous sera utile !

Comprendre Buffer

JavaScript est très convivial pour les opérations sur les chaînesJavaScript对于字符串的操作十分友好

Buffer是一个像Array的对象，主要用于操作字节。

Buffer结构

Buffer是一个典型的JavaScript和C++结合的模块，将性能相关部分用C++实现，将非性能相关部分用JavaScript实现。

Buffer所占用的内存不是通过V8分配，属于堆外内存。 由于V8垃圾回收性能影响，将常用的操作对象用更高效和专有的内存分配回收政策来管理是个不错的思路。

Buffer在Node进程启动时就已经价值，并且放在全局对象（global）上。所以使用buffer无需require引入

Buffer对象

Buffer对象的元素未16进制的两位数，即0-255的数值

let buf01 = Buffer.alloc(8);
console.log(buf01);  // <Buffer 00 00 00 00 00 00 00 00>

可以使用fill填充buf的值(默认为utf-8编码)，如果填充的值超过buffer，将不会被写入。

如果buffer长度大于内容，则会反复填充

如果想要清空之前填充的内容，可以直接fill()

buf01.fill('12345678910')

console.log(buf01);   // <Buffer 31 32 33 34 35 36 37 38>
console.log(buf01.toString()); // 12345678

如果填入的内容是中文，在utf-8的影响下，中文字会占用3个元素，字母和半角标点符号占用1个元素。

let buf02 = Buffer.alloc(18, '开始我们的新路程', 'utf-8');
console.log(buf02.toString());  // 开始我们的新

Buffer受Array类型影响很大，可以访问length属性得到长度，也可以通过下标访问元素，也可以通过indexOf查看元素位置。

console.log(buf02);  // <Buffer e5 bc 80 e5 a7 8b e6 88 91 e4 bb ac e7 9a 84 e6 96 b0>
console.log(buf02.length)  // 18字节
console.log(buf02[6])  // 230： e6 转换后就是 230
console.log(buf02.indexOf(&#39;我&#39;))  // 6：在第7个字节位置
console.log(buf02.slice(6, 9).toString())  // 我: 取得<Buffer e6 88 91>，转换后就是&#39;我&#39;

如果给字节赋值不是0255之间的整数，或者赋值时小数时，赋值小于0，将该值逐次加256.直到得到0255之间的整数。如果大于255，就逐次减去255。 如果是小数，舍去小数部分(不做四舍五入)

Buffer内存分配

Buffer对象的内存分配不是在V8的堆内存中，而是在Node的C++层面实现内存的申请。 因为处理大量的字节数据不能采用需要一点内存就向操作系统申请一点内存的方式。为此Node在内存上使用的是在C++层面申请内存，在JavaScript中分配内存的方式

Node采用了slab分配机制，slab是以中动态内存管理机制，目前在一些*nix操作系统用中有广泛的应用，比如Linux

slab就是一块申请好的固定大小的内存区域，slab具有以下三种状态：

• full：完全分配状态
• partial：部分分配状态
• empty：没有被分配状态

Node以8KB为界限来区分Buffer是大对象还是小对象

console.log(Buffer.poolSize);  // 8192

这个8KB的值就额是每个slab的大小值，在JavaScript层面，以它作为单位单元进行内存的分配

分配小buffer对象

如果指定Buffer大小小于8KB，Node会按照小对象方式进行分配

1. 构造一个新的slab单元，目前slab处于empty空状态

2. 构造小buffer对象1024KB，当前的slab会被占用1024KB，并且记录下是从这个slab的哪个位置开始使用的

3. 这时再创建一个buffer对象，大小为3072KB。 构造过程会判断当前slab剩余空间是否足够，如果足够，使用剩余空间，并更新slab的分配状态。 3072KB空间被使用后，目前此slab剩余空间4096KB。

4. 如果此时创建一个6144KB大小的buffer，当前slab空间不足，会构造新的slab
Buffer est un objet comme Array, principalement utilisé pour manipuler les octets.

Buffer structure

Buffer est un module typique qui combine JavaScript et C++. Les parties liées aux performances sont implémentées en C++. Les parties non liées aux performances sont implémentées en JavaScript.

🎜🎜Tampon La mémoire occupée n'est pas allouée via V8 et appartient à la mémoire hors tas. En raison de l'impact sur les performances du garbage collection V8, il est judicieux de gérer les objets d'opération couramment utilisés avec des politiques d'allocation de mémoire et de recyclage plus efficaces et propriétaires. 🎜

🎜Buffer est déjà valorisé au démarrage du processus Node et est placé sur l'objet global (global). Par conséquent, lors de l'utilisation de buffer, il n'est pas nécessaire d'introduire 🎜

🎜Objet Buffer🎜

🎜Les éléments de l'objet Buffer ne sont pas hexadécimaux à deux chiffres les nombres, c'est-à-dire 0-255 Les valeurs numériques 🎜

Buffer.alloc(1)
Buffer.alloc(8192)

🎜 peuvent utiliser fill pour remplir la valeur de buf (la valeur par défaut est l'encodage utf-8 si le). La valeur remplie dépasse le tampon, elle ne sera pas écrite. 🎜

🎜Si la longueur du tampon est supérieure au contenu, il sera rempli à plusieurs reprises🎜

🎜Si vous souhaitez effacer le contenu précédemment rempli, vous pouvez directement fill()🎜

const fs = require('fs');

let rs = fs.createReadStream('./静夜思.txt', { flags:'r'});
let str = ''
rs.on('data', (chunk)=>{
    str += chunk;
})

rs.on('end', ()=>{
    console.log(str);
})

🎜Si le contenu rempli est chinois. Sous l'influence de utf-8, les caractères chinois occuperont 3 éléments, et les lettres et signes de ponctuation demi-chasse occuperont 1 élément. 🎜

fs.createReadStream('./静夜思.txt', { flags:'r', highWaterMark: 11});

🎜Buffer est grandement affecté par le Type de tableau Vous pouvez accéder à l'attribut length pour obtenir la longueur, vous pouvez également accéder à l'élément via l'indice, et vous pouvez. affichez également la position de l'élément via indexOf. 🎜

fs.createReadStream('./静夜思.txt', { flags:'r', highWaterMark: 11, encoding:'utf-8'});

🎜Si la valeur attribuée à l'octet n'est pas un entier compris entre 0255, ou si la valeur attribuée est une décimale, la valeur attribuée est inférieure à 0, ajoutez 256 à la valeur un par un jusqu'à obtenir un entier compris entre 0 et 255. S'il est supérieur à 255, soustrayez 255 un par un. S'il s'agit d'un nombre décimal, supprimez la partie décimale (pas d'arrondi)🎜

🎜Allocation de mémoire tampon🎜

🎜L'allocation de mémoire du Buffer L'objet n'est pas dans la mémoire tas de la V8, l'application mémoire est implémentée au niveau C++ de Node. Parce que lors du traitement d'une grande quantité de données d'octets, vous ne pouvez pas demander de la mémoire au système d'exploitation lorsque vous en avez besoin. Pour cette raison, Node utilise la méthode de demande de mémoire au niveau C++ et l'allocation de mémoire en JavaScript🎜🎜Node adopte le mécanisme d'allocation de dalle</code > , <code>slab est un mécanisme de gestion dynamique de la mémoire, actuellement largement utilisé dans certains systèmes d'exploitation *nix, tels que Linux🎜🎜 slab< /code> est une zone mémoire de taille fixe qui a été demandée. La dalle a les trois états suivants : 🎜<ul><li>complet : état entièrement alloué 🎜<li>partiel : état partiellement alloué 🎜<li >Vide. : Statut non attribué🎜</ul>🎜Le nœud utilise 🎜8 Ko🎜 comme limite pour distinguer si le tampon est un gros objet ou un petit objet🎜<div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:js;toolbar:false;">const { StringDecoder } = require(&amp;#39;string_decoder&amp;#39;); let s1 = Buffer.from([0xe7, 0xaa, 0x97, 0xe5, 0x89, 0x8d, 0xe6, 0x98, 0x8e, 0xe6, 0x9c]) let s2 = Buffer.from([0x88, 0xe5, 0x85, 0x89, 0xef, 0xbc, 0x8c, 0x0d, 0x0a, 0xe7, 0x96]) console.log(s1.toString()); console.log(s2.toString()); console.log(&amp;#39;------------------&amp;#39;); const decoder = new StringDecoder(&amp;#39;utf8&amp;#39;); console.log(decoder.write(s1)); console.log(decoder.write(s2));</pre><div class="contentsignin">Copier après la connexion</div></div><div class="contentsignin">Copier après la connexion</div></div><blockquote>🎜La valeur de 8 Ko est la taille de chaque dalle au niveau du JavaScript. niveau, utilisez-le comme unité pour allouer de la mémoire🎜</blockquote><h3 data-id="heading-4">🎜Allouer de petits objets tampon🎜</h3>🎜Si vous spécifiez <code>Buffer Si la taille est inférieure à 8 Ko, Node l'attribuera selon la méthode des petits objets🎜

1. Construire une nouvelle unité de dalle Actuellement, la dalle est à l'état vide🎜🎜🎜🎜
   2. Construisez un petit objet buffer</ code> de 1024 Ko, la <code>dalle actuelle occupera 1024 Ko et enregistrez l'emplacement à partir duquel cette dalle est utilisée🎜🎜🎜🎜
      3. À ce stade, créez un autre objet buffer d'une taille de 3 072 Ko. Le processus de construction déterminera si l'espace restant de la dalle actuelle est suffisant. Si c'est suffisant, utilisez l'espace restant et mettez à jour l'état d'allocation de la dalle. Une fois l’espace de 3 072 Ko utilisé, l’espace restant de cette dalle est actuellement de 4 096 Ko. 🎜🎜🎜🎜< ol start="4">
      4. Si un tampon de 6 144 Ko est créé à ce moment, l'espace actuel de la dalle est insuffisant et une nouvelle dalle sera construite (ceci la dalle d'origine sera perdue. L'espace restant est gaspillé) 🎜🎜🎜🎜🎜🎜Par exemple, dans l'exemple suivant : 🎜

         Buffer.alloc(1)
         Buffer.alloc(8192)

         第一个slab中只会存在1字节的buffer对象，而后一个buffer对象会构建一个新的slab存放

         由于一个slab可能分配给多个Buffer对象使用，只有这些小buffer对象在作用域释放并都可以回收时，slab的空间才会被回收。 尽管只创建1字节的buffer对象，但是如果不释放，实际是8KB的内存都没有释放

         小结：

         真正的内存是在Node的C++层面提供，JavaScript层面只是使用。当进行小而频繁的Buffer操作时，采用slab的机制进行预先申请和时候分配，使得JavaScript到操作系统之间不必有过多的内存申请方面的系统调用。 对于大块的buffer，直接使用C++层面提供的内存即可，无需细腻的分配操作。

         Buffer的拼接

         buffer在使用场景中，通常是以一段段的方式进行传输。

         const fs = require('fs');
         
         let rs = fs.createReadStream('./静夜思.txt', { flags:'r'});
         let str = ''
         rs.on('data', (chunk)=>{
             str += chunk;
         })
         
         rs.on('end', ()=>{
             console.log(str);
         })

         以上是读取流的范例，data时间中获取到的chunk对象就是buffer对象。

         但是当输入流中有宽字节编码（一个字占多个字节）时，问题就会暴露。在str += chunk中隐藏了toString()操作。等价于str = str.toString() + chunk.toString()。

         下面将可读流的每次读取buffer长度限制为11.

         fs.createReadStream('./静夜思.txt', { flags:'r', highWaterMark: 11});

         输出得到：

         

         上面出现了乱码，上面限制了buffer长度为11，对于任意长度的buffer而言，宽字节字符串都有可能存在被截断的情况，只不过buffer越长出现概率越低。

         encoding

         但是如果设置了encoding为utf-8，就不会出现此问题了。

         fs.createReadStream('./静夜思.txt', { flags:'r', highWaterMark: 11, encoding:'utf-8'});

         

         原因： 虽然无论怎么设置编码，流的触发次数都是一样，但是在调用setEncoding时，可读流对象在内部设置了一个decoder对象。每次data事件都会通过decoder对象进行buffer到字符串的解码，然后传递给调用者。

         string_decoder 模块提供了用于将 Buffer 对象解码为字符串（以保留编码的多字节 UTF-8 和 UTF-16 字符的方式）的 API

         const { StringDecoder } = require('string_decoder');
         let s1 = Buffer.from([0xe7, 0xaa, 0x97, 0xe5, 0x89, 0x8d, 0xe6, 0x98, 0x8e, 0xe6, 0x9c])
         let s2 = Buffer.from([0x88, 0xe5, 0x85, 0x89, 0xef, 0xbc, 0x8c, 0x0d, 0x0a, 0xe7, 0x96])
         console.log(s1.toString());
         console.log(s2.toString());
         console.log('------------------');
         
         const decoder = new StringDecoder('utf8');
         console.log(decoder.write(s1));
         console.log(decoder.write(s2));

         

         StringDecoder在得到编码之后，知道了宽字节字符串在utf-8编码下是以3个字节的方式存储的，所以第一次decoder.write只会输出前9个字节转码的字符，后两个字节会被保留在StringDecoder内部。

         Buffer与性能

         buffer在文件I/O和网络I/O中运用广泛，尤其在网络传输中，性能举足轻重。在应用中，通常会操作字符串，但是一旦在网络中传输，都需要转换成buffer，以进行二进制数据传输。 在web应用中，字符串转换到buffer是时时刻刻发生的，提高字符串到buffer的转换效率，可以很大程度地提高网络吞吐率。

         如果通过纯字符串的方式向客户端发送，性能会比发送buffer对象更差，因为buffer对象无须在每次响应时进行转换。通过预先转换静态内容为buffer对象，可以有效地减少CPU重复使用，节省服务器资源。

         可以选择将页面中动态和静态内容分离，静态内容部分预先转换为buffer的方式，使得性能得到提升。

         在文件的读取时，highWaterMark设置对性能影响至关重要。在理想状态下，每次读取的长度就是用户指定的highWaterMark。

         highWaterMark大小对性能有两个影响的点：

         • 对buffer内存的分配和使用有一定影响
         • 设置过小，可能导致系统调用次数过多

         更多node相关知识，请访问：nodejs 教程！！

         Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!