Node.js
Node.js Leistung

Ereignisschleife

Beispiel für das Blockieren

let loop = (i, max) => {
  while (i < max) i++
  return i
}

// This operation will block Node.js
// Because, it's CPU-bound
// You should be careful about this kind of code
loop(0, 1e+12)

Beispiel für nicht blockierende E / A-Operationen

let i = 0

const step = max => {
  while (i < max) i++
  console.log('i = %d', i)
}

const tick = max => process.nextTick(step, max)

// this will postpone tick run step's while-loop to event loop cycles
// any other IO-bound operation (like filesystem reading) can take place
// in parallel
tick(1e+6)
tick(1e+7)
console.log('this will output before all of tick operations. i = %d', i)
console.log('because tick operations will be postponed')
tick(1e+8)

Vereinfacht ausgedrückt handelt es sich bei Event Loop um einen Single-Threaded-Warteschlangenmechanismus, der Ihren CPU-gebundenen Code bis zum Ende seiner Ausführung und E / A-gebundenen Code auf nicht blockierende Weise ausführt.

In Node.js unter dem Teppich wird jedoch für einige Operationen der libuv Library Multithreading verwendet .

Überlegungen zur Leistung

• Nicht blockierende Vorgänge blockieren die Warteschlange nicht und wirken sich nicht auf die Leistung der Schleife aus.
• CPU-gebundene Vorgänge blockieren jedoch die Warteschlange. Sie sollten daher darauf achten, dass Sie keine CPU-gebundenen Vorgänge in Ihrem Node.js-Code ausführen.

Node.js blockiert die E / A nicht, da sie die Arbeit in den Betriebssystemkern verlagert. Wenn die E / A-Operation Daten ( als Ereignis ) bereitstellt, benachrichtigt sie Ihren Code mit Ihren bereitgestellten Rückrufen.

Erhöhen Sie maxSockets

Grundlagen

require('http').globalAgent.maxSockets = 25

// You can change 25 to Infinity or to a different value by experimenting

Node.js verwendet standardmäßig maxSockets = Infinity gleichzeitig (seit v0.12.0 ). Bis zum Knoten v0.12.0 war der Standardwert maxSockets = 5 (siehe v0.11.0 ). Nach mehr als 5 Anforderungen werden sie in die Warteschlange gestellt. Wenn Sie Parallelität wünschen, erhöhen Sie diese Anzahl.

Stellen Sie Ihren eigenen Agenten ein

http API verwendet einen " Global Agent " . Sie können Ihren eigenen Agenten zur Verfügung stellen. So was:

const http = require('http')
const myGloriousAgent = new http.Agent({ keepAlive: true })
myGloriousAgent.maxSockets = Infinity

http.request({ ..., agent: myGloriousAgent }, ...)

Socket Pooling vollständig ausschalten

const http = require('http')
const options = {.....}

options.agent = false

const request = http.request(options)

Fallstricke

• Sie sollten dasselbe für die https API tun, wenn Sie dieselben Effekte erzielen möchten

• Beachten Sie, dass AWS beispielsweise 50 anstelle von Infinity .

Gzip aktivieren

const http = require('http')
const fs   = require('fs')
const zlib = require('zlib')

http.createServer((request, response) => {
  const stream          = fs.createReadStream('index.html')
  const acceptsEncoding = request.headers['accept-encoding']

  let encoder = {
    hasEncoder     : false,
    contentEncoding: {},
    createEncoder  : () => throw 'There is no encoder'
  }

  if (!acceptsEncoding) {
    acceptsEncoding = ''
  }

  if (acceptsEncoding.match(/\bdeflate\b/)) {
    encoder = {
      hasEncoder     : true,
      contentEncoding: { 'content-encoding': 'deflate' },
      createEncoder  : zlib.createDeflate
    }
  } else if (acceptsEncoding.match(/\bgzip\b/)) {
    encoder = {
      hasEncoder     : true,
      contentEncoding: { 'content-encoding': 'gzip' },
      createEncoder  : zlib.createGzip
    }
  }

  response.writeHead(200, encoder.contentEncoding)

  if (encoder.hasEncoder) {
    stream = stream.pipe(encoder.createEncoder())
  }

  stream.pipe(response)

}).listen(1337)