http.Agent
http.ClientRequest
'abort''close''connect''continue''finish''information''response''socket''timeout''upgrade'request.abort()request.abortedrequest.connectionrequest.cork()request.end([data[, encoding]][, callback])request.destroy([error])
request.finishedrequest.flushHeaders()request.getHeader(name)request.getHeaderNames()request.getHeaders()request.getRawHeaderNames()request.hasHeader(name)request.maxHeadersCountrequest.pathrequest.methodrequest.hostrequest.protocolrequest.removeHeader(name)request.reusedSocketrequest.setHeader(name, value)request.setNoDelay([noDelay])request.setSocketKeepAlive([enable][, initialDelay])request.setTimeout(timeout[, callback])request.socketrequest.uncork()request.writableEndedrequest.writableFinishedrequest.write(chunk[, encoding][, callback])http.Server
'checkContinue''checkExpectation''clientError''close''connect''connection''dropRequest''request''upgrade'server.close([callback])server.closeAllConnections()server.closeIdleConnections()server.headersTimeoutserver.listen()server.listeningserver.maxHeadersCountserver.requestTimeoutserver.setTimeout([msecs][, callback])server.maxRequestsPerSocketserver.timeoutserver.keepAliveTimeoutserver.keepAliveTimeoutBufferserver[Symbol.asyncDispose]()http.ServerResponse
'close''finish'response.addTrailers(headers)response.connectionresponse.cork()response.end([data[, encoding]][, callback])response.finishedresponse.flushHeaders()response.getHeader(name)response.getHeaderNames()response.getHeaders()response.hasHeader(name)response.headersSentresponse.removeHeader(name)response.reqresponse.sendDateresponse.setHeader(name, value)response.setTimeout(msecs[, callback])response.socketresponse.statusCoderesponse.statusMessageresponse.strictContentLengthresponse.uncork()response.writableEndedresponse.writableFinishedresponse.write(chunk[, encoding][, callback])response.writeContinue()response.writeEarlyHints(hints[, callback])response.writeHead(statusCode[, statusMessage][, headers])response.writeInformation(statusCode[, headers][, callback])response.writeProcessing()http.IncomingMessage
'aborted''close'message.abortedmessage.completemessage.connectionmessage.destroy([error])message.headersmessage.headersDistinctmessage.httpVersionmessage.methodmessage.rawHeadersmessage.rawTrailersmessage.setTimeout(msecs[, callback])message.signalmessage.socketmessage.statusCodemessage.statusMessagemessage.trailersmessage.trailersDistinctmessage.urlhttp.OutgoingMessage
'drain''finish''prefinish'outgoingMessage.addTrailers(headers)outgoingMessage.appendHeader(name, value)outgoingMessage.connectionoutgoingMessage.cork()outgoingMessage.destroy([error])outgoingMessage.end(chunk[, encoding][, callback])outgoingMessage.flushHeaders()outgoingMessage.getHeader(name)outgoingMessage.getHeaderNames()outgoingMessage.getHeaders()outgoingMessage.hasHeader(name)outgoingMessage.headersSentoutgoingMessage.pipe()outgoingMessage.removeHeader(name)outgoingMessage.setHeader(name, value)outgoingMessage.setHeaders(headers)outgoingMessage.setTimeout(msecs[, callback])outgoingMessage.socketoutgoingMessage.uncork()outgoingMessage.writableCorkedoutgoingMessage.writableEndedoutgoingMessage.writableFinishedoutgoingMessage.writableHighWaterMarkoutgoingMessage.writableLengthoutgoingMessage.writableObjectModeoutgoingMessage.write(chunk[, encoding][, callback])http.METHODShttp.STATUS_CODEShttp.createServer([options][, requestListener])http.get(options[, callback])http.get(url[, options][, callback])http.globalAgenthttp.maxHeaderSizehttp.request(options[, callback])http.request(url[, options][, callback])http.validateHeaderName(name[, label])http.validateHeaderValue(name, value)http.setMaxIdleHTTPParsers(max)http.setGlobalProxyFromEnv([proxyEnv])WebSocketnode:module APIStability: 2 - Stable
This module, containing both a client and server, can be imported via
require('node:http') (CommonJS) or import * as http from 'node:http' (ES module).
The HTTP interfaces in Node.js are designed to support many features of the protocol which have been traditionally difficult to use. In particular, large, possibly chunk-encoded, messages. The interface is careful to never buffer entire requests or responses, so the user is able to stream data.
HTTP message headers are represented by an object like this:
{ "content-length": "123",
"content-type": "text/plain",
"connection": "keep-alive",
"host": "example.com",
"accept": "*/*" }
Keys are lowercased. Values are not modified.
In order to support the full spectrum of possible HTTP applications, the Node.js HTTP API is very low-level. It deals with stream handling and message parsing only. It parses a message into headers and body but it does not parse the actual headers or the body.
See message.headers for details on how duplicate headers are handled.
rawHeaders
property, which is an array of [key, value, key2, value2, ...]. For
example, the previous message header object might have a rawHeaders
list like the following:[ "ConTent-Length", "123456",
"content-LENGTH", "123",
"content-type", "text/plain",
"CONNECTION", "keep-alive",
"Host", "example.com",
"accepT", "*/*" ]
http.Agent#An Agent is responsible for managing connection persistence
and reuse for HTTP clients. It maintains a queue of pending requests
for a given host and port, reusing a single socket connection for each
until the queue is empty, at which time the socket is either destroyed
or put into a pool where it is kept to be used again for requests to the
same host and port. Whether it is destroyed or pooled depends on the
keepAlive option.
Pooled connections have TCP Keep-Alive enabled for them, but servers may
still close idle connections, in which case they will be removed from the
pool and a new connection will be made when a new HTTP request is made for
that host and port. Servers may also refuse to allow multiple requests
over the same connection, in which case the connection will have to be
remade for every request and cannot be pooled. The Agent will still make
the requests to that server, but each one will occur over a new connection.
When a connection is closed by the client or the server, it is removed
from the pool. Any unused sockets in the pool will be unrefed so as not
to keep the Node.js process running when there are no outstanding requests.
(see socket.unref()).
It is good practice, to destroy() an Agent instance when it is no
longer in use, because unused sockets consume OS resources.
Sockets are removed from an agent when the socket emits either
a 'close' event or an 'agentRemove' event. When intending to keep one
HTTP request open for a long time without keeping it in the agent, something
like the following may be done:
http.get(options, (res) => {
// Do stuff
}).on('socket', (socket) => {
socket.emit('agentRemove');
});
An agent may also be used for an individual request. By providing
{agent: false} as an option to the http.get() or http.request()
functions, a one-time use Agent with default options will be used
for the client connection.
agent:false:http.get({
hostname: 'localhost',
port: 80,
path: '/',
agent: false, // Create a new agent just for this one request
}, (res) => {
// Do stuff with response
});
new Agent([options])#agentKeepAliveTimeoutBuffer.proxyEnv.defaultPort and protocol.maxTotalSockets option to agent constructor.Add scheduling option to specify the free socket scheduling strategy.
options <Object> Set of configurable options to set on the agent.
Can have the following fields:
keepAlive <boolean> Keep sockets around even when there are no
outstanding requests, so they can be used for future requests without
having to reestablish a TCP connection. Not to be confused with the keep-alive value of the Connection header. The Connection: keep-alive
header is always sent when using an agent except when the Connection
header is explicitly specified or when the keepAlive and maxSockets
options are respectively set to false and Infinity, in which case
Connection: close will be used. Default: false.keepAliveMsecs <number> When using the keepAlive option, specifies
the initial delay
for TCP Keep-Alive packets. Ignored when the
keepAlive option is false or undefined. Default: 1000.agentKeepAliveTimeoutBuffer <number> Milliseconds to subtract from
the server-provided keep-alive: timeout=... hint when determining socket
expiration time. This buffer helps ensure the agent closes the socket
slightly before the server does, reducing the chance of sending a request
on a socket that’s about to be closed by the server.
Default: 1000.maxSockets <number> Maximum number of sockets to allow per host.
If the same host opens multiple concurrent connections, each request
will use new socket until the maxSockets value is reached.
If the host attempts to open more connections than maxSockets,
the additional requests will enter into a pending request queue, and
will enter active connection state when an existing connection terminates.
This makes sure there are at most maxSockets active connections at
any point in time, from a given host.
Default: Infinity.maxTotalSockets <number> Maximum number of sockets allowed for
all hosts in total. Each request will use a new socket
until the maximum is reached. Default: Infinity.maxFreeSockets <number> Maximum number of sockets per host to leave open
in a free state. Only relevant if keepAlive is set to true.
Default: 256.scheduling <string> Scheduling strategy to apply when picking
the next free socket to use. It can be 'fifo' or 'lifo'.
The main difference between the two scheduling strategies is that 'lifo'
selects the most recently used socket, while 'fifo' selects
the least recently used socket.
In case of a low rate of request per second, the 'lifo' scheduling
will lower the risk of picking a socket that might have been closed
by the server due to inactivity.
In case of a high rate of request per second,
the 'fifo' scheduling will maximize the number of open sockets,
while the 'lifo' scheduling will keep it as low as possible.
Default: 'lifo'.timeout <number> Socket timeout in milliseconds.
This will set the timeout when the socket is created.proxyEnv <Object> | <undefined> Environment variables for proxy configuration.
See Built-in Proxy Support for details. Default: undefined
HTTP_PROXY <string> | <undefined> URL for the proxy server that HTTP requests should use.
If undefined, no proxy is used for HTTP requests.HTTPS_PROXY <string> | <undefined> URL for the proxy server that HTTPS requests should use.
If undefined, no proxy is used for HTTPS requests.NO_PROXY <string> | <undefined> Patterns specifying the endpoints
that should not be routed through a proxy.http_proxy <string> | <undefined> Same as HTTP_PROXY. If both are set, http_proxy takes precedence.https_proxy <string> | <undefined> Same as HTTPS_PROXY. If both are set, https_proxy takes precedence.no_proxy <string> | <undefined> Same as NO_PROXY. If both are set, no_proxy takes precedence.defaultPort <number> Default port to use when the port is not specified
in requests. Default: 80.protocol <string> The protocol to use for the agent. Default: 'http:'.options in socket.connect() are also supported.
http.Agent instance must be created.import { Agent, request } from 'node:http'; const keepAliveAgent = new Agent({ keepAlive: true }); options.agent = keepAliveAgent; request(options, onResponseCallback);const http = require('node:http'); const keepAliveAgent = new http.Agent({ keepAlive: true }); options.agent = keepAliveAgent; http.request(options, onResponseCallback);
agent.createConnection(options[, callback])#options <Object> Options containing connection details. Check net.createConnection() for the format of the options. For custom agents,
this object is passed to the custom createConnection function.callback <Function> (Optional, primarily for custom agents) A function to be
called by a custom createConnection implementation when the socket is
created, especially for asynchronous operations.
err <Error> | <null> An error object if socket creation failed.socket <stream.Duplex> The created socket.<stream.Duplex> The created socket. This is returned by the default
implementation or by a custom synchronous createConnection implementation.
If a custom createConnection uses the callback for asynchronous
operation, this return value might not be the primary way to obtain the socket.Produces a socket/stream to be used for HTTP requests.
By default, this function behaves identically to net.createConnection(),
synchronously returning the created socket. The optional callback parameter in the
signature is not used by this default implementation.
However, custom agents may override this method to provide greater flexibility,
for example, to create sockets asynchronously. When overriding createConnection:
callback
and pass the created socket/stream to it (e.g., callback(null, newSocket)).
If an error occurs during socket creation, it should be passed as the first
argument to the callback (e.g., callback(err)).createConnection function with options and
this internal callback. The callback provided by the agent has a signature
of (err, stream).
agent.keepSocketAlive(socket)#socket <stream.Duplex>Called when socket is detached from a request and could be persisted by the
Agent. Default behavior is to:
socket.setKeepAlive(true, this.keepAliveMsecs);
socket.unref();
return true;
This method can be overridden by a particular Agent subclass. If this
method returns a falsy value, the socket will be destroyed instead of persisting
it for use with the next request.
socket argument can be an instance of <net.Socket>, a subclass of
<stream.Duplex>.
agent.reuseSocket(socket, request)#socket <stream.Duplex>request <http.ClientRequest>Called when socket is attached to request after being persisted because of
the keep-alive options. Default behavior is to:
socket.ref();
This method can be overridden by a particular Agent subclass.
socket argument can be an instance of <net.Socket>, a subclass of
<stream.Duplex>.
agent.destroy()#Destroy any sockets that are currently in use by the agent.
It is usually not necessary to do this. However, if using an agent withkeepAlive enabled, then it is best to explicitly shut down
the agent when it is no longer needed. Otherwise,
sockets might stay open for quite a long time before the server
terminates them.
agent.freeSockets#The property now has a null prototype.
<Object>An object which contains arrays of sockets currently awaiting use by
the agent when keepAlive is enabled. Do not modify.
freeSockets list will be automatically destroyed and
removed from the array on 'timeout'.
agent.getName([options])#The options parameter is now optional.
host:port:localAddress or host:port:localAddress:family. For an HTTPS agent,
the name includes the CA, cert, ciphers, and other HTTPS/TLS-specific options
that determine socket reusability.
agent.maxFreeSockets#<number>keepAlive enabled, this
sets the maximum number of sockets that will be left open in the free
state.
agent.maxSockets#<number>Infinity. Determines how many concurrent sockets the agent
can have open per origin. Origin is the returned value of agent.getName().
agent.maxTotalSockets#<number>Infinity. Determines how many concurrent sockets the agent
can have open. Unlike maxSockets, this parameter applies across all origins.
agent.requests#The property now has a null prototype.
<Object>agent.sockets#The property now has a null prototype.
<Object>http.ClientRequest#<http.OutgoingMessage>This object is created internally and returned from http.request(). It
represents an in-progress request whose header has already been queued. The
header is still mutable using the setHeader(name, value),
getHeader(name), removeHeader(name) API. The actual header will
be sent along with the first data chunk or when calling request.end().
To get the response, add a listener for 'response' to the request object.
'response' will be emitted from the request object when the response
headers have been received. The 'response' event is executed with one
argument which is an instance of http.IncomingMessage.
During the 'response' event, one can add listeners to the
response object; particularly to listen for the 'data' event.
If no 'response' handler is added, then the response will be
entirely discarded. However, if a 'response' event handler is added,
then the data from the response object must be consumed, either by
calling response.read() whenever there is a 'readable' event, or
by adding a 'data' handler, or by calling the .resume() method.
Until the data is consumed, the 'end' event will not fire. Also, until
the data is read it will consume memory that can eventually lead to a
'process out of memory' error.
For backward compatibility, res will only emit 'error' if there is an
'error' listener registered.
Set Content-Length header to limit the response body size.
If response.strictContentLength is set to true, mismatching the
Content-Length header value will result in an Error being thrown,
identified by code: 'ERR_HTTP_CONTENT_LENGTH_MISMATCH'.
Content-Length value should be in bytes, not characters. Use
Buffer.byteLength() to determine the length of the body in bytes.
'abort'#Stability: 0 - Deprecated. Listen for the 'close' event instead.
abort().
'close'#'connect'#response <http.IncomingMessage>socket <stream.Duplex>head <Buffer>Emitted each time a server responds to a request with a CONNECT method. If
this event is not being listened for, clients receiving a CONNECT method will
have their connections closed.
This event is guaranteed to be passed an instance of the <net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
'connect' event:import { createServer, request } from 'node:http'; import { connect } from 'node:net'; import { URL } from 'node:url'; // Create an HTTP tunneling proxy const proxy = createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('okay'); }); proxy.on('connect', (req, clientSocket, head) => { // Connect to an origin server const { port, hostname } = new URL(`http://${req.url}`); const serverSocket = connect(port || 80, hostname, () => { clientSocket.write('HTTP/1.1 200 Connection Established\r\n' + 'Proxy-agent: Node.js-Proxy\r\n' + '\r\n'); serverSocket.write(head); serverSocket.pipe(clientSocket); clientSocket.pipe(serverSocket); }); }); // Now that proxy is running proxy.listen(1337, '127.0.0.1', () => { // Make a request to a tunneling proxy const options = { port: 1337, host: '127.0.0.1', method: 'CONNECT', path: 'www.google.com:80', }; const req = request(options); req.end(); req.on('connect', (res, socket, head) => { console.log('got connected!'); // Make a request over an HTTP tunnel socket.write('GET / HTTP/1.1\r\n' + 'Host: www.google.com:80\r\n' + 'Connection: close\r\n' + '\r\n'); socket.on('data', (chunk) => { console.log(chunk.toString()); }); socket.on('end', () => { proxy.close(); }); }); });const http = require('node:http'); const net = require('node:net'); const { URL } = require('node:url'); // Create an HTTP tunneling proxy const proxy = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('okay'); }); proxy.on('connect', (req, clientSocket, head) => { // Connect to an origin server const { port, hostname } = new URL(`http://${req.url}`); const serverSocket = net.connect(port || 80, hostname, () => { clientSocket.write('HTTP/1.1 200 Connection Established\r\n' + 'Proxy-agent: Node.js-Proxy\r\n' + '\r\n'); serverSocket.write(head); serverSocket.pipe(clientSocket); clientSocket.pipe(serverSocket); }); }); // Now that proxy is running proxy.listen(1337, '127.0.0.1', () => { // Make a request to a tunneling proxy const options = { port: 1337, host: '127.0.0.1', method: 'CONNECT', path: 'www.google.com:80', }; const req = http.request(options); req.end(); req.on('connect', (res, socket, head) => { console.log('got connected!'); // Make a request over an HTTP tunnel socket.write('GET / HTTP/1.1\r\n' + 'Host: www.google.com:80\r\n' + 'Connection: close\r\n' + '\r\n'); socket.on('data', (chunk) => { console.log(chunk.toString()); }); socket.on('end', () => { proxy.close(); }); }); });
'continue'#'finish'#'information'#info <Object>
Emitted when the server sends a 1xx intermediate response (excluding 101 Upgrade). The listeners of this event will receive an object containing the HTTP version, status code, status message, key-value headers object, and array with the raw header names followed by their respective values.
101 Upgrade statuses do not fire this event due to their break from the traditional HTTP request/response chain, such as web sockets, in-place TLS upgrades, or HTTP 2.0. To be notified of 101 Upgrade notices, listen for theimport { request } from 'node:http'; const options = { host: '127.0.0.1', port: 8080, path: '/length_request', }; // Make a request const req = request(options); req.end(); req.on('information', (info) => { console.log(`Got information prior to main response: ${info.statusCode}`); });const http = require('node:http'); const options = { host: '127.0.0.1', port: 8080, path: '/length_request', }; // Make a request const req = http.request(options); req.end(); req.on('information', (info) => { console.log(`Got information prior to main response: ${info.statusCode}`); });
'upgrade' event instead.
'response'#response <http.IncomingMessage>'socket'#socket <stream.Duplex><net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
'timeout'#Emitted when the underlying socket times out from inactivity. This only notifies that the socket has been idle. The request must be destroyed manually.
See also:request.setTimeout().
'upgrade'#response <http.IncomingMessage>stream <stream.Duplex>head <Buffer>Emitted each time a server responds to a request with an upgrade. If this event is not being listened for and the response status code is 101 Switching Protocols, clients receiving an upgrade header will have their connections closed.
This event is guaranteed to be passed an instance of the <net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
'upgrade' event.import http from 'node:http'; import process from 'node:process'; // Create an HTTP server const server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('okay'); }); server.on('upgrade', (req, stream, head) => { stream.write('HTTP/1.1 101 Web Socket Protocol Handshake\r\n' + 'Upgrade: WebSocket\r\n' + 'Connection: Upgrade\r\n' + '\r\n'); stream.pipe(stream); // echo back }); // Now that server is running server.listen(1337, '127.0.0.1', () => { // make a request const options = { port: 1337, host: '127.0.0.1', headers: { 'Connection': 'Upgrade', 'Upgrade': 'websocket', }, }; const req = http.request(options); req.end(); req.on('upgrade', (res, stream, upgradeHead) => { console.log('got upgraded!'); stream.end(); process.exit(0); }); });const http = require('node:http'); // Create an HTTP server const server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('okay'); }); server.on('upgrade', (req, stream, head) => { stream.write('HTTP/1.1 101 Web Socket Protocol Handshake\r\n' + 'Upgrade: WebSocket\r\n' + 'Connection: Upgrade\r\n' + '\r\n'); stream.pipe(stream); // echo back }); // Now that server is running server.listen(1337, '127.0.0.1', () => { // make a request const options = { port: 1337, host: '127.0.0.1', headers: { 'Connection': 'Upgrade', 'Upgrade': 'websocket', }, }; const req = http.request(options); req.end(); req.on('upgrade', (res, stream, upgradeHead) => { console.log('got upgraded!'); stream.end(); process.exit(0); }); });
request.abort()#Stability: 0 - Deprecated: Use request.destroy() instead.
request.aborted#The aborted property is no longer a timestamp number.
Stability: 0 - Deprecated. Check request.destroyed instead.
<boolean>request.aborted property will be true if the request has
been aborted.
request.connection#Stability: 0 - Deprecated. Use request.socket.
<stream.Duplex>request.socket.
request.cork()#writable.cork().
request.end([data[, encoding]][, callback])#data parameter can now be a Uint8Array.This method now returns a reference to ClientRequest.
data <string> | <Buffer> | <Uint8Array>encoding <string>callback <Function><this>Finishes sending the request. If any parts of the body are
unsent, it will flush them to the stream. If the request is
chunked, this will send the terminating '0\r\n\r\n'.
If data is specified, it is equivalent to calling
request.write(data, encoding) followed by request.end(callback).
callback is specified, it will be called when the request stream
is finished.
request.destroy([error])#The function returns this for consistency with other Readable streams.
Destroy the request. Optionally emit an 'error' event,
and emit a 'close' event. Calling this will cause remaining data
in the response to be dropped, and the socket to be destroyed if used,
or returned to the corresponding Agent pool otherwise if possible.
writable.destroy() for further details.
request.destroyed#<boolean>Is true after request.destroy() has been called.
writable.destroyed for further details.
request.finished#Stability: 0 - Deprecated. Use request.writableEnded.
<boolean>request.finished property will be true if request.end()
has been called. request.end() will automatically be called if the
request was initiated via http.get().
request.flushHeaders()#Flushes the request headers.
For efficiency reasons, Node.js normally buffers the request headers until
request.end() is called or the first chunk of request data is written. It
then tries to pack the request headers and data into a single TCP packet.
request.flushHeaders() bypasses
the optimization and kickstarts the request.
request.getHeader(name)#request.setHeader().request.setHeader('content-type', 'text/html');
request.setHeader('Content-Length', Buffer.byteLength(body));
request.setHeader('Cookie', ['type=ninja', 'language=javascript']);
const contentType = request.getHeader('Content-Type');
// 'contentType' is 'text/html'
const contentLength = request.getHeader('Content-Length');
// 'contentLength' is of type number
const cookie = request.getHeader('Cookie');
// 'cookie' is of type string[]
request.getHeaderNames()#<string[]>request.setHeader('Foo', 'bar');
request.setHeader('Cookie', ['foo=bar', 'bar=baz']);
const headerNames = request.getHeaderNames();
// headerNames === ['foo', 'cookie']
request.getHeaders()#<Object>Returns a shallow copy of the current outgoing headers. Since a shallow copy is used, array values may be mutated without additional calls to various header-related http module methods. The keys of the returned object are the header names and the values are the respective header values. All header names are lowercase.
The object returned by therequest.getHeaders() method does not
prototypically inherit from the JavaScript Object. This means that typical
Object methods such as obj.toString(), obj.hasOwnProperty(), and others
are not defined and will not work.request.setHeader('Foo', 'bar');
request.setHeader('Cookie', ['foo=bar', 'bar=baz']);
const headers = request.getHeaders();
// headers === { foo: 'bar', 'cookie': ['foo=bar', 'bar=baz'] }
request.getRawHeaderNames()#<string[]>request.setHeader('Foo', 'bar');
request.setHeader('Set-Cookie', ['foo=bar', 'bar=baz']);
const headerNames = request.getRawHeaderNames();
// headerNames === ['Foo', 'Set-Cookie']
request.hasHeader(name)#true if the header identified by name is currently set in the
outgoing headers. The header name matching is case-insensitive.const hasContentType = request.hasHeader('content-type');
request.maxHeadersCount#<number> Default: 2000request.path#<string> The request path.request.method#<string> The request method.request.host#<string> The request host.request.protocol#<string> The request protocol.request.removeHeader(name)#name <string>request.removeHeader('Content-Type');
request.reusedSocket#<boolean> Whether the request is send through a reused socket.When sending request through a keep-alive enabled agent, the underlying socket might be reused. But if server closes connection at unfortunate time, client may run into a 'ECONNRESET' error.
By marking a request whether it reused socket or not, we can do automatic error retry base on it.import http from 'node:http'; const agent = new http.Agent({ keepAlive: true }); // Server has a 5 seconds keep-alive timeout by default http .createServer((req, res) => { res.write('hello\n'); res.end(); }) .listen(3000); setInterval(() => { // Adapting a keep-alive agent http.get('http://localhost:3000', { agent }, (res) => { res.on('data', (data) => { // Do nothing }); }); }, 5000); // Sending request on 5s interval so it's easy to hit idle timeoutconst http = require('node:http'); const agent = new http.Agent({ keepAlive: true }); // Server has a 5 seconds keep-alive timeout by default http .createServer((req, res) => { res.write('hello\n'); res.end(); }) .listen(3000); setInterval(() => { // Adapting a keep-alive agent http.get('http://localhost:3000', { agent }, (res) => { res.on('data', (data) => { // Do nothing }); }); }, 5000); // Sending request on 5s interval so it's easy to hit idle timeout
import http from 'node:http'; const agent = new http.Agent({ keepAlive: true }); function retriableRequest() { const req = http .get('http://localhost:3000', { agent }, (res) => { // ... }) .on('error', (err) => { // Check if retry is needed if (req.reusedSocket && err.code === 'ECONNRESET') { retriableRequest(); } }); } retriableRequest();const http = require('node:http'); const agent = new http.Agent({ keepAlive: true }); function retriableRequest() { const req = http .get('http://localhost:3000', { agent }, (res) => { // ... }) .on('error', (err) => { // Check if retry is needed if (req.reusedSocket && err.code === 'ECONNRESET') { retriableRequest(); } }); } retriableRequest();
request.setHeader(name, value)#Sets a single header value for headers object. If this header already exists in
the to-be-sent headers, its value will be replaced. Use an array of strings
here to send multiple headers with the same name. Non-string values will be
stored without modification. Therefore, request.getHeader() may return
non-string values. However, the non-string values will be converted to strings
for network transmission.
request.setHeader('Content-Type', 'application/json');
or
request.setHeader('Cookie', ['type=ninja', 'language=javascript']);
When the value is a string an exception will be thrown if it contains
characters outside the latin1 encoding.
const filename = 'Rock 🎵.txt';
request.setHeader('Content-Disposition', `attachment; filename*=utf-8''${encodeURIComponent(filename)}`);
request.setNoDelay([noDelay])#noDelay <boolean>socket.setNoDelay() will be called.
request.setSocketKeepAlive([enable][, initialDelay])#socket.setKeepAlive() will be called.
request.setTimeout(timeout[, callback])#Consistently set socket timeout only when the socket connects.
timeout <number> Milliseconds before a request times out.callback <Function> Optional function to be called when a timeout occurs.
Same as binding to the 'timeout' event.<http.ClientRequest>socket.setTimeout() will be called.
request.socket#<stream.Duplex>Reference to the underlying socket. Usually users will not want to access
this property. In particular, the socket will not emit 'readable' events
because of how the protocol parser attaches to the socket.
This property is guaranteed to be an instance of theimport http from 'node:http'; const options = { host: 'www.google.com', }; const req = http.get(options); req.end(); req.once('response', (res) => { const ip = req.socket.localAddress; const port = req.socket.localPort; console.log(`Your IP address is ${ip} and your source port is ${port}.`); // Consume response object });const http = require('node:http'); const options = { host: 'www.google.com', }; const req = http.get(options); req.end(); req.once('response', (res) => { const ip = req.socket.localAddress; const port = req.socket.localPort; console.log(`Your IP address is ${ip} and your source port is ${port}.`); // Consume response object });
<net.Socket> class,
a subclass of <stream.Duplex>, unless the user specified a socket
type other than <net.Socket>.
request.uncork()#writable.uncork().
request.writableEnded#<boolean>true after request.end() has been called. This property
does not indicate whether the data has been flushed, for this use
request.writableFinished instead.
request.writableFinished#<boolean>true if all data has been flushed to the underlying system, immediately
before the 'finish' event is emitted.
request.write(chunk[, encoding][, callback])#The chunk parameter can now be a Uint8Array.
chunk <string> | <Buffer> | <Uint8Array>encoding <string>callback <Function><boolean>Sends a chunk of the body. This method can be called multiple times. If no
Content-Length is set, data will automatically be encoded in HTTP Chunked
transfer encoding, so that server knows when the data ends. The
Transfer-Encoding: chunked header is added. Calling request.end()
is necessary to finish sending the request.
The encoding argument is optional and only applies when chunk is a string.
Defaults to 'utf8'.
The callback argument is optional and will be called when this chunk of data
is flushed, but only if the chunk is non-empty.
Returns true if the entire data was flushed successfully to the kernel
buffer. Returns false if all or part of the data was queued in user memory.
'drain' will be emitted when the buffer is free again.
write function is called with empty string or buffer, it does
nothing and waits for more input.
http.Server#<net.Server>'checkContinue'#request <http.IncomingMessage>response <http.ServerResponse>Emitted each time a request with an HTTP Expect: 100-continue is received.
If this event is not listened for, the server will automatically respond
with a 100 Continue as appropriate.
Handling this event involves calling response.writeContinue() if the
client should continue to send the request body, or generating an appropriate
HTTP response (e.g. 400 Bad Request) if the client should not continue to send
the request body.
'request' event will
not be emitted.
'checkExpectation'#request <http.IncomingMessage>response <http.ServerResponse>Emitted each time a request with an HTTP Expect header is received, where the
value is not 100-continue. If this event is not listened for, the server will
automatically respond with a 417 Expectation Failed as appropriate.
'request' event will
not be emitted.
'clientError'#rawPacket is the current buffer that just parsed. Adding this buffer to the error object of 'clientError' event is to make it possible that developers can log the broken packet.The default action of calling .destroy() on the socket will no longer take place if there are listeners attached for 'clientError'.
exception <Error>socket <stream.Duplex>If a client connection emits an 'error' event, it will be forwarded here.
Listener of this event is responsible for closing/destroying the underlying
socket. For example, one may wish to more gracefully close the socket with a
custom HTTP response instead of abruptly severing the connection. The socket
must be closed or destroyed before the listener ends.
This event is guaranteed to be passed an instance of the <net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
Default behavior is to try close the socket with an HTTP '400 Bad Request',
or an HTTP '431 Request Header Fields Too Large' in the case of an
HPE_HEADER_OVERFLOW error. If the socket is not writable or headers
of the current attached http.ServerResponse has been sent, it is
immediately destroyed.
socket is the net.Socket object that the error originated from.
import http from 'node:http'; const server = http.createServer((req, res) => { res.end(); }); server.on('clientError', (err, socket) => { socket.end('HTTP/1.1 400 Bad Request\r\n\r\n'); }); server.listen(8000);const http = require('node:http'); const server = http.createServer((req, res) => { res.end(); }); server.on('clientError', (err, socket) => { socket.end('HTTP/1.1 400 Bad Request\r\n\r\n'); }); server.listen(8000);
When the 'clientError' event occurs, there is no request or response
object, so any HTTP response sent, including response headers and payload,
must be written directly to the socket object. Care must be taken to
ensure the response is a properly formatted HTTP response message.
err is an instance of Error with two extra columns:
bytesParsed: the bytes count of request packet that Node.js may have parsed
correctly;rawPacket: the raw packet of current request.ECONNRESET errors. Before
trying to send data to the socket, it is better to check that it is still
writable.server.on('clientError', (err, socket) => {
if (err.code === 'ECONNRESET' || !socket.writable) {
return;
}
socket.end('HTTP/1.1 400 Bad Request\r\n\r\n');
});
'close'#'connect'#request <http.IncomingMessage> Arguments for the HTTP request, as it is in
the 'request' eventsocket <stream.Duplex> Network socket between the server and clienthead <Buffer> The first packet of the tunneling stream (may be empty)Emitted each time a client requests an HTTP CONNECT method. If this event is
not listened for, then clients requesting a CONNECT method will have their
connections closed.
This event is guaranteed to be passed an instance of the <net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
'data'
event listener, meaning it will need to be bound in order to handle data
sent to the server on that socket.
'connection'#socket <stream.Duplex>This event is emitted when a new TCP stream is established. socket is
typically an object of type net.Socket. Usually users will not want to
access this event. In particular, the socket will not emit 'readable' events
because of how the protocol parser attaches to the socket. The socket can
also be accessed at request.socket.
This event can also be explicitly emitted by users to inject connections
into the HTTP server. In that case, any Duplex stream can be passed.
If socket.setTimeout() is called here, the timeout will be replaced with
server.keepAliveTimeout when the socket has served a request (if
server.keepAliveTimeout is non-zero).
<net.Socket> class,
a subclass of <stream.Duplex>, unless the user specifies a socket
type other than <net.Socket>.
'dropRequest'#request <http.IncomingMessage> Arguments for the HTTP request, as it is in
the 'request' eventsocket <stream.Duplex> Network socket between the server and clientserver.maxRequestsPerSocket, the server will drop new requests
and emit 'dropRequest' event instead, then send 503 to client.
'request'#request <http.IncomingMessage>response <http.ServerResponse>'upgrade'#'request' events.shouldUpgradeCallback and sockets will be destroyed if upgraded while no event handler is listening.Not listening to this event no longer causes the socket to be destroyed if a client sends an Upgrade header.
request <http.IncomingMessage> Arguments for the HTTP request, as it is in
the 'request' eventstream <stream.Duplex> The upgraded stream between the server and clienthead <Buffer> The first packet of the upgraded stream (may be empty)Emitted each time a client's HTTP upgrade request is accepted. By default
all HTTP upgrade requests are ignored (i.e. only regular 'request' events
are emitted, sticking with the normal HTTP request/response flow) unless you
listen to this event, in which case they are all accepted (i.e. the 'upgrade'
event is emitted instead, and future communication must handled directly
through the raw stream). You can control this more precisely by using the
server shouldUpgradeCallback option.
Listening to this event is optional and clients cannot insist on a protocol change.
If an upgrade is accepted by shouldUpgradeCallback but no event handler
is registered then the socket will be destroyed, resulting in an immediate
connection closure for the client.
In the uncommon case that the incoming request has a body, this body will be
parsed as normal, separate to the upgrade stream, and the raw stream data will
only begin after it has completed. To ensure that reading from the stream isn't
blocked by waiting for the request body to be read, any reads on the stream
will start the request body flowing automatically. If you want to read the
request body, ensure that you do so (i.e. you attach 'data' listeners)
before starting to read from the upgraded stream.
<net.Socket> instance used by the
request, but in some cases (such as with a request body) it may be a duplex
stream. If required, you can access the raw connection underlying the request
via request.socket, which is guaranteed to be an instance of <net.Socket>
unless the user specified another socket type.
server.close([callback])#The method closes idle connections before returning.
callback <Function>net.Server.close().const http = require('node:http');
const server = http.createServer({ keepAliveTimeout: 60000 }, (req, res) => {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({
data: 'Hello World!',
}));
});
server.listen(8000);
// Close the server after 10 seconds
setTimeout(() => {
server.close(() => {
console.log('server on port 8000 closed successfully');
});
}, 10000);
server.closeAllConnections()#This is a forceful way of closing all connections and should be used with caution. Whenever using this in conjunction with
server.close, calling this afterserver.closeis recommended as to avoid race conditions where new connections are created between a call to this and a call toserver.close.
const http = require('node:http');
const server = http.createServer({ keepAliveTimeout: 60000 }, (req, res) => {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({
data: 'Hello World!',
}));
});
server.listen(8000);
// Close the server after 10 seconds
setTimeout(() => {
server.close(() => {
console.log('server on port 8000 closed successfully');
});
// Closes all connections, ensuring the server closes successfully
server.closeAllConnections();
}, 10000);
server.closeIdleConnections()#Starting with Node.js 19.0.0, there's no need for calling this method in conjunction with
server.closeto reapkeep-aliveconnections. Using it won't cause any harm though, and it can be useful to ensure backwards compatibility for libraries and applications that need to support versions older than 19.0.0. Whenever using this in conjunction withserver.close, calling this afterserver.closeis recommended as to avoid race conditions where new connections are created between a call to this and a call toserver.close.
const http = require('node:http');
const server = http.createServer({ keepAliveTimeout: 60000 }, (req, res) => {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({
data: 'Hello World!',
}));
});
server.listen(8000);
// Close the server after 10 seconds
setTimeout(() => {
server.close(() => {
console.log('server on port 8000 closed successfully');
});
// Closes idle connections, such as keep-alive connections. Server will close
// once remaining active connections are terminated
server.closeIdleConnections();
}, 10000);
server.headersTimeout#The default is now set to the minimum between 60000 (60 seconds) or requestTimeout.
<number> Default: The minimum between server.requestTimeout or 60000.Limit the amount of time the parser will wait to receive the complete HTTP headers.
If the timeout expires, the server responds with status 408 without forwarding the request to the request listener and then closes the connection.
It must be set to a non-zero value (e.g. 120 seconds) to protect against potential Denial-of-Service attacks in case the server is deployed without a reverse proxy in front.server.listen()#server.listen() from net.Server.
server.listening#<boolean> Indicates whether or not the server is listening for connections.server.maxHeadersCount#<number> Default: 2000server.requestTimeout#The default request timeout changed from no timeout to 300s (5 minutes).
<number> Default: 300000Sets the timeout value in milliseconds for receiving the entire request from the client.
If the timeout expires, the server responds with status 408 without forwarding the request to the request listener and then closes the connection.
It must be set to a non-zero value (e.g. 120 seconds) to protect against potential Denial-of-Service attacks in case the server is deployed without a reverse proxy in front.server.setTimeout([msecs][, callback])#The default timeout changed from 120s to 0 (no timeout).
msecs <number> Default: 0 (no timeout)callback <Function><http.Server>Sets the timeout value for sockets, and emits a 'timeout' event on
the Server object, passing the socket as an argument, if a timeout
occurs.
If there is a 'timeout' event listener on the Server object, then it
will be called with the timed-out socket as an argument.
'timeout' event, timeouts must be handled
explicitly.
server.maxRequestsPerSocket#<number> Requests per socket. Default: 0 (no limit)The maximum number of requests socket can handle before closing keep alive connection.
A value of 0 will disable the limit.
Connection header value to close,
but will not actually close the connection, subsequent requests sent
after the limit is reached will get 503 Service Unavailable as a response.
server.timeout#The default timeout changed from 120s to 0 (no timeout).
<number> Timeout in milliseconds. Default: 0 (no timeout)The number of milliseconds of inactivity before a socket is presumed to have timed out.
A value of 0 will disable the timeout behavior on incoming connections.
server.keepAliveTimeout#<number> Timeout in milliseconds. Default: 5000 (5 seconds).The number of milliseconds of inactivity a server needs to wait for additional incoming data, after it has finished writing the last response, before a socket will be destroyed.
This timeout value is combined with the
server.keepAliveTimeoutBuffer option to determine the actual socket
timeout, calculated as:
socketTimeout = keepAliveTimeout + keepAliveTimeoutBuffer
If the server receives new data before the keep-alive timeout has fired, it
will reset the regular inactivity timeout, i.e., server.timeout.
A value of 0 will disable the keep-alive timeout behavior on incoming
connections.
A value of 0 makes the HTTP server behave similarly to Node.js versions prior
to 8.0.0, which did not have a keep-alive timeout.
server.keepAliveTimeoutBuffer#<number> Timeout in milliseconds. Default: 1000 (1 second).An additional buffer time added to the
server.keepAliveTimeout to extend the internal socket timeout.
This buffer helps reduce connection reset (ECONNRESET) errors by increasing
the socket timeout slightly beyond the advertised keep-alive timeout.
server[Symbol.asyncDispose]()#No longer experimental.
Callsserver.close() and returns a promise that fulfills when the
server has closed.
http.ServerResponse#<http.OutgoingMessage>'request' event.
'close'#'finish'#response.addTrailers(headers)#headers <Object>This method adds HTTP trailing headers (a header but at the end of the message) to the response.
Trailers will only be emitted if chunked encoding is used for the response; if it is not (e.g. if the request was HTTP/1.0), they will be silently discarded.
HTTP requires the Trailer header to be sent in order to
emit trailers, with a list of the header fields in its value. E.g.,
response.writeHead(200, { 'Content-Type': 'text/plain',
'Trailer': 'Content-MD5' });
response.write(fileData);
response.addTrailers({ 'Content-MD5': '7895bf4b8828b55ceaf47747b4bca667' });
response.end();
Attempting to set a header field name or value that contains invalid characters
will result in a TypeError being thrown.
response.connection#Stability: 0 - Deprecated. Use response.socket.
<stream.Duplex>response.socket.
response.cork()#writable.cork().
response.end([data[, encoding]][, callback])#data parameter can now be a Uint8Array.This method now returns a reference to ServerResponse.
data <string> | <Buffer> | <Uint8Array>encoding <string>callback <Function><this>This method signals to the server that all of the response headers and body
have been sent; that server should consider this message complete.
The method, response.end(), MUST be called on each response.
If data is specified, it is similar in effect to calling
response.write(data, encoding) followed by response.end(callback).
callback is specified, it will be called when the response stream
is finished.
response.finished#Stability: 0 - Deprecated. Use response.writableEnded.
<boolean>response.finished property will be true if response.end()
has been called.
response.flushHeaders()#request.flushHeaders().
response.getHeader(name)#name <string><number> | <string> | <string[]> | <undefined>response.setHeader().response.setHeader('Content-Type', 'text/html');
response.setHeader('Content-Length', Buffer.byteLength(body));
response.setHeader('Set-Cookie', ['type=ninja', 'language=javascript']);
const contentType = response.getHeader('content-type');
// contentType is 'text/html'
const contentLength = response.getHeader('Content-Length');
// contentLength is of type number
const setCookie = response.getHeader('set-cookie');
// setCookie is of type string[]
response.getHeaderNames()#<string[]>response.setHeader('Foo', 'bar');
response.setHeader('Set-Cookie', ['foo=bar', 'bar=baz']);
const headerNames = response.getHeaderNames();
// headerNames === ['foo', 'set-cookie']
response.getHeaders()#<Object>Returns a shallow copy of the current outgoing headers. Since a shallow copy is used, array values may be mutated without additional calls to various header-related http module methods. The keys of the returned object are the header names and the values are the respective header values. All header names are lowercase.
The object returned by theresponse.getHeaders() method does not
prototypically inherit from the JavaScript Object. This means that typical
Object methods such as obj.toString(), obj.hasOwnProperty(), and others
are not defined and will not work.response.setHeader('Foo', 'bar');
response.setHeader('Set-Cookie', ['foo=bar', 'bar=baz']);
const headers = response.getHeaders();
// headers === { foo: 'bar', 'set-cookie': ['foo=bar', 'bar=baz'] }
response.hasHeader(name)#true if the header identified by name is currently set in the
outgoing headers. The header name matching is case-insensitive.const hasContentType = response.hasHeader('content-type');
response.headersSent#<boolean>response.removeHeader(name)#name <string>response.removeHeader('Content-Encoding');
response.req#<http.IncomingMessage>request object.
response.sendDate#<boolean>When true, the Date header will be automatically generated and sent in the response if it is not already present in the headers. Defaults to true.
This should only be disabled for testing; the Date header is required in most HTTP responses (see RFC 9110 Section 6.6.1 for details).response.setHeader(name, value)#name <string>value <number> | <string> | <string[]><http.ServerResponse>Returns the response object.
Sets a single header value for implicit headers. If this header already exists
in the to-be-sent headers, its value will be replaced. Use an array of strings
here to send multiple headers with the same name. Non-string values will be
stored without modification. Therefore, response.getHeader() may return
non-string values. However, the non-string values will be converted to strings
for network transmission. The same response object is returned to the caller,
to enable call chaining.
response.setHeader('Content-Type', 'text/html');
or
response.setHeader('Set-Cookie', ['type=ninja', 'language=javascript']);
Attempting to set a header field name or value that contains invalid characters
will result in a TypeError being thrown.
When headers have been set with response.setHeader(), they will be merged
with any headers passed to response.writeHead(), with the headers passed
to response.writeHead() given precedence.
// Returns content-type = text/plain
const server = http.createServer((req, res) => {
res.setHeader('Content-Type', 'text/html');
res.setHeader('X-Foo', 'bar');
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end('ok');
});
If response.writeHead() method is called and this method has not been
called, it will directly write the supplied header values onto the network
channel without caching internally, and the response.getHeader() on the
header will not yield the expected result. If progressive population of headers
is desired with potential future retrieval and modification, use
response.setHeader() instead of response.writeHead().
response.setTimeout(msecs[, callback])#msecs <number>callback <Function><http.ServerResponse>Sets the Socket's timeout value to msecs. If a callback is
provided, then it is added as a listener on the 'timeout' event on
the response object.
'timeout' listener is added to the request, the response, or
the server, then sockets are destroyed when they time out. If a handler is
assigned to the request, the response, or the server's 'timeout' events,
timed out sockets must be handled explicitly.
response.socket#<stream.Duplex>Reference to the underlying socket. Usually users will not want to access
this property. In particular, the socket will not emit 'readable' events
because of how the protocol parser attaches to the socket. After
response.end(), the property is nulled.
This property is guaranteed to be an instance of theimport http from 'node:http'; const server = http.createServer((req, res) => { const ip = res.socket.remoteAddress; const port = res.socket.remotePort; res.end(`Your IP address is ${ip} and your source port is ${port}.`); }).listen(3000);const http = require('node:http'); const server = http.createServer((req, res) => { const ip = res.socket.remoteAddress; const port = res.socket.remotePort; res.end(`Your IP address is ${ip} and your source port is ${port}.`); }).listen(3000);
<net.Socket> class,
a subclass of <stream.Duplex>, unless the user specified a socket
type other than <net.Socket>.
response.statusCode#<number> Default: 200When using implicit headers (not calling response.writeHead() explicitly),
this property controls the status code that will be sent to the client when
the headers get flushed.
response.statusCode = 404;
After response header was sent to the client, this property indicates the
status code which was sent out.
response.statusMessage#<string>When using implicit headers (not calling response.writeHead() explicitly),
this property controls the status message that will be sent to the client when
the headers get flushed. If this is left as undefined then the standard
message for the status code will be used.
response.statusMessage = 'Not found';
After response header was sent to the client, this property indicates the
status message which was sent out.
response.strictContentLength#<boolean> Default: falsetrue, Node.js will check whether the Content-Length
header value and the size of the body, in bytes, are equal.
Mismatching the Content-Length header value will result
in an Error being thrown, identified by code: 'ERR_HTTP_CONTENT_LENGTH_MISMATCH'.
response.uncork()#writable.uncork().
response.writableEnded#<boolean>true after response.end() has been called. This property
does not indicate whether the data has been flushed, for this use
response.writableFinished instead.
response.writableFinished#<boolean>true if all data has been flushed to the underlying system, immediately
before the 'finish' event is emitted.
response.write(chunk[, encoding][, callback])#The chunk parameter can now be a Uint8Array.
chunk <string> | <Buffer> | <Uint8Array>encoding <string> Default: 'utf8'callback <Function><boolean>If this method is called and response.writeHead() has not been called,
it will switch to implicit header mode and flush the implicit headers.
This sends a chunk of the response body. This method may be called multiple times to provide successive parts of the body.
If rejectNonStandardBodyWrites is set to true in createServer
then writing to the body is not allowed when the request method or response
status do not support content. If an attempt is made to write to the body for a
HEAD request or as part of a 204 or 304response, a synchronous Error
with the code ERR_HTTP_BODY_NOT_ALLOWED is thrown.
chunk can be a string or a buffer. If chunk is a string,
the second parameter specifies how to encode it into a byte stream.
callback will be called when this chunk of data is flushed.
This is the raw HTTP body and has nothing to do with higher-level multi-part body encodings that may be used.
The first time response.write() is called, it will send the buffered
header information and the first chunk of the body to the client. The second
time response.write() is called, Node.js assumes data will be streamed,
and sends the new data separately. That is, the response is buffered up to the
first chunk of the body.
true if the entire data was flushed successfully to the kernel
buffer. Returns false if all or part of the data was queued in user memory.
'drain' will be emitted when the buffer is free again.
response.writeContinue()#'checkContinue' event on
Server.
response.writeEarlyHints(hints[, callback])#Allow passing hints as an object.
hints <Object>callback <Function>Sends an HTTP/1.1 103 Early Hints message to the client with a Link header,
indicating that the user agent can preload/preconnect the linked resources.
The hints is an object containing the values of headers to be sent with
early hints message. The optional callback argument will be called when
the response message has been written.
const earlyHintsLink = '</styles.css>; rel=preload; as=style';
response.writeEarlyHints({
'link': earlyHintsLink,
});
const earlyHintsLinks = [
'</styles.css>; rel=preload; as=style',
'</scripts.js>; rel=preload; as=script',
];
response.writeEarlyHints({
'link': earlyHintsLinks,
'x-trace-id': 'id for diagnostics',
});
const earlyHintsCallback = () => console.log('early hints message sent');
response.writeEarlyHints({
'link': earlyHintsLinks,
}, earlyHintsCallback);
response.writeHead(statusCode[, statusMessage][, headers])#this from writeHead() to allow chaining with end().A RangeError is thrown if statusCode is not a number in the range [100, 999].
statusCode <number>statusMessage <string>headers <Object> | <Array><http.ServerResponse>Sends a response header to the request. The status code is a 3-digit HTTP
status code, like 404. The last argument, headers, are the response headers.
Optionally one can give a human-readable statusMessage as the second
argument.
headers may be an Array where the keys and values are in the same list.
It is not a list of tuples. So, the even-numbered offsets are key values,
and the odd-numbered offsets are the associated values. The array is in the same
format as request.rawHeaders.
Returns a reference to the ServerResponse, so that calls can be chained.
const body = 'hello world';
response
.writeHead(200, {
'Content-Length': Buffer.byteLength(body),
'Content-Type': 'text/plain',
})
.end(body);
This method must only be called once on a message and it must
be called before response.end() is called.
If response.write() or response.end() are called before calling
this, the implicit/mutable headers will be calculated and call this function.
When headers have been set with response.setHeader(), they will be merged
with any headers passed to response.writeHead(), with the headers passed
to response.writeHead() given precedence.
If this method is called and response.setHeader() has not been called,
it will directly write the supplied header values onto the network channel
without caching internally, and the response.getHeader() on the header
will not yield the expected result. If progressive population of headers is
desired with potential future retrieval and modification, use
response.setHeader() instead.
// Returns content-type = text/plain
const server = http.createServer((req, res) => {
res.setHeader('Content-Type', 'text/html');
res.setHeader('X-Foo', 'bar');
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end('ok');
});
Content-Length is read in bytes, not characters. Use
Buffer.byteLength() to determine the length of the body in bytes. Node.js
will check whether Content-Length and the length of the body which has
been transmitted are equal or not.
TypeError being thrown.
response.writeInformation(statusCode[, headers][, callback])#statusCode <number> An HTTP 1xx informational status code, between 100
and 199 inclusive, excluding 101 (Switching Protocols) which is only
available through the 'upgrade' event.headers <Object> | <Array> An optional set of headers to send with the
informational response. Accepts the same shapes as response.writeHead().callback <Function> Optional, called once the message has been written
to the socket.Sends an arbitrary HTTP/1.1 1xx informational response to the client. This
is a generic equivalent of response.writeContinue(),
response.writeProcessing() and response.writeEarlyHints(), and
can be called multiple times before the final response. After the final
response headers have been sent (via response.writeHead() or an
implicit header), calling this method throws ERR_HTTP_HEADERS_SENT.
'information'
event on http.ClientRequest.response.writeInformation(110, { 'X-Progress': '50%' });
response.writeProcessing()#http.IncomingMessage#destroyed value returns true after the incoming data is consumed.The readableHighWaterMark value mirrors that of the socket.
<stream.Readable>An IncomingMessage object is created by http.Server or
http.ClientRequest and passed as the first argument to the 'request'
and 'response' event respectively. It may be used to access response
status, headers, and data.
socket value which is a subclass of <stream.Duplex>, the IncomingMessage itself extends <stream.Readable> and is created separately to
parse and emit the incoming HTTP headers and payload, as the underlying socket
may be reused multiple times in case of keep-alive.
'aborted'#Stability: 0 - Deprecated. Listen for 'close' event instead.
'close'#The close event is now emitted when the request has been completed and not when the underlying socket is closed.
Emitted when the request has been completed.message.aborted#Stability: 0 - Deprecated. Check message.destroyed from <stream.Readable>.
<boolean>message.aborted property will be true if the request has
been aborted.
message.complete#<boolean>The message.complete property will be true if a complete HTTP message has
been received and successfully parsed.
const req = http.request({
host: '127.0.0.1',
port: 8080,
method: 'POST',
}, (res) => {
res.resume();
res.on('end', () => {
if (!res.complete)
console.error(
'The connection was terminated while the message was still being sent');
});
});
message.connection#Stability: 0 - Deprecated. Use message.socket.
message.socket.
message.destroy([error])#The function returns this for consistency with other Readable streams.
destroy() on the socket that received the IncomingMessage. If error
is provided, an 'error' event is emitted on the socket and error is passed
as an argument to any listeners on the event.
message.headers#joinDuplicateHeaders option in the http.request() and http.createServer() functions ensures that duplicate headers are not discarded, but rather combined using a comma separator, in accordance with RFC 9110 Section 5.3.message.headers is now lazily computed using an accessor property on the prototype and is no longer enumerable.
<Object>The request/response headers object.
Key-value pairs of header names and values. Header names are lower-cased.
// Prints something like:
//
// { 'user-agent': 'curl/7.22.0',
// host: '127.0.0.1:8000',
// accept: '*/*' }
console.log(request.headers);
Duplicates in raw headers are handled in the following ways, depending on the
header name:age, authorization, content-length, content-type,
etag, expires, from, host, if-modified-since, if-unmodified-since,
last-modified, location, max-forwards, proxy-authorization, referer,
retry-after, server, or user-agent are discarded.
To allow duplicate values of the headers listed above to be joined,
use the option joinDuplicateHeaders in http.request()
and http.createServer(). See RFC 9110 Section 5.3 for more
information.set-cookie is always an array. Duplicates are added to the array.cookie headers, the values are joined together with ; ., .message.headersDistinct#<Object>message.headers, but there is no join logic and the values are
always arrays of strings, even for headers received just once.// Prints something like:
//
// { 'user-agent': ['curl/7.22.0'],
// host: ['127.0.0.1:8000'],
// accept: ['*/*'] }
console.log(request.headersDistinct);
message.httpVersion#<string>In case of server request, the HTTP version sent by the client. In the case of
client response, the HTTP version of the connected-to server.
Probably either '1.1' or '1.0'.
message.httpVersionMajor is the first integer and
message.httpVersionMinor is the second.
message.method#<string>Only valid for request obtained from http.Server.
'GET', 'DELETE'.
message.rawHeaders#<string[]>The raw request/response headers list exactly as they were received.
The keys and values are in the same list. It is not a list of tuples. So, the even-numbered offsets are key values, and the odd-numbered offsets are the associated values.
Header names are not lowercased, and duplicates are not merged.// Prints something like:
//
// [ 'user-agent',
// 'this is invalid because there can be only one',
// 'User-Agent',
// 'curl/7.22.0',
// 'Host',
// '127.0.0.1:8000',
// 'ACCEPT',
// '*/*' ]
console.log(request.rawHeaders);
message.rawTrailers#<string[]>'end' event.
message.setTimeout(msecs[, callback])#msecs <number>callback <Function><http.IncomingMessage>message.socket.setTimeout(msecs, callback).
message.signal#<AbortSignal>An <AbortSignal> that is aborted when the underlying socket closes or the
request is destroyed. The signal is created lazily on first access — no
<AbortController> is allocated for requests that never use this property.
fetch calls when a client disconnects mid-request.import http from 'node:http'; http.createServer(async (req, res) => { try { const data = await fetch('https://example.com/api', { signal: req.signal }); res.end(JSON.stringify(await data.json())); } catch (err) { if (err.name === 'AbortError') return; res.statusCode = 500; res.end('Internal Server Error'); } }).listen(3000);const http = require('node:http'); http.createServer(async (req, res) => { try { const data = await fetch('https://example.com/api', { signal: req.signal }); res.end(JSON.stringify(await data.json())); } catch (err) { if (err.name === 'AbortError') return; res.statusCode = 500; res.end('Internal Server Error'); } }).listen(3000);
message.socket#<stream.Duplex>The net.Socket object associated with the connection.
With HTTPS support, use request.socket.getPeerCertificate() to obtain the
client's authentication details.
<net.Socket> class,
a subclass of <stream.Duplex>, unless the user specified a socket
type other than <net.Socket> or internally nulled.
message.statusCode#<number>Only valid for response obtained from http.ClientRequest.
404.
message.statusMessage#<string>Only valid for response obtained from http.ClientRequest.
OK or Internal Server Error.
message.trailers#<Object>'end' event.
message.trailersDistinct#<Object>message.trailers, but there is no join logic and the values are
always arrays of strings, even for headers received just once.
Only populated at the 'end' event.
message.url#<string>Only valid for request obtained from http.Server.
Request URL string. This contains only the URL that is present in the actual HTTP request. Take the following request:
GET /status?name=ryan HTTP/1.1
Accept: text/plain
To parse the URL into its parts:
new URL(`http://${process.env.HOST ?? 'localhost'}${request.url}`);
When request.url is '/status?name=ryan' and process.env.HOST is undefined:
$ node
> new URL(`http://${process.env.HOST ?? 'localhost'}${request.url}`);
URL {
href: 'http://localhost/status?name=ryan',
origin: 'http://localhost',
protocol: 'http:',
username: '',
password: '',
host: 'localhost',
hostname: 'localhost',
port: '',
pathname: '/status',
search: '?name=ryan',
searchParams: URLSearchParams { 'name' => 'ryan' },
hash: ''
}
Ensure that you set process.env.HOST to the server's host name, or consider
replacing this part entirely. If using req.headers.host, ensure proper
validation is used, as clients may specify a custom Host header.
http.OutgoingMessage#<Stream>http.ClientRequest
and http.ServerResponse. It is an abstract outgoing message from
the perspective of the participants of an HTTP transaction.
'drain'#'finish'#'prefinish'#outgoingMessage.end() is called.
When the event is emitted, all data has been processed but not necessarily
completely flushed.
outgoingMessage.addTrailers(headers)#headers <Object>Adds HTTP trailers (headers but at the end of the message) to the message.
Trailers will only be emitted if the message is chunked encoded. If not, the trailers will be silently discarded.
HTTP requires the Trailer header to be sent to emit trailers,
with a list of header field names in its value, e.g.
message.writeHead(200, { 'Content-Type': 'text/plain',
'Trailer': 'Content-MD5' });
message.write(fileData);
message.addTrailers({ 'Content-MD5': '7895bf4b8828b55ceaf47747b4bca667' });
message.end();
Attempting to set a header field name or value that contains invalid characters
will result in a TypeError being thrown.
outgoingMessage.appendHeader(name, value)#name <string> Header namevalue <string> | <string[]> Header value<this>Append a single header value to the header object.
If the value is an array, this is equivalent to calling this method multiple times.
If there were no previous values for the header, this is equivalent to calling
outgoingMessage.setHeader(name, value).
options.uniqueHeaders when the client request or the
server were created, this will end up in the header being sent multiple times or
a single time with values joined using ; .
outgoingMessage.connection#Stability: 0 - Deprecated: Use outgoingMessage.socket instead.
outgoingMessage.socket.
outgoingMessage.cork()#writable.cork().
outgoingMessage.destroy([error])#outgoingMessage.end(chunk[, encoding][, callback])#chunk parameter can now be a Uint8Array.add callback argument.
chunk <string> | <Buffer> | <Uint8Array>encoding <string> Optional, Default: utf8callback <Function> Optional<this>Finishes the outgoing message. If any parts of the body are unsent, it will
flush them to the underlying system. If the message is chunked, it will
send the terminating chunk 0\r\n\r\n, and send the trailers (if any).
If chunk is specified, it is equivalent to calling
outgoingMessage.write(chunk, encoding), followed by
outgoingMessage.end(callback).
callback is provided, it will be called when the message is finished
(equivalent to a listener of the 'finish' event).
outgoingMessage.flushHeaders()#Flushes the message headers.
For efficiency reason, Node.js normally buffers the message headers
until outgoingMessage.end() is called or the first chunk of message data
is written. It then tries to pack the headers and data into a single TCP
packet.
outgoingMessage.flushHeaders()
bypasses the optimization and kickstarts the message.
outgoingMessage.getHeader(name)#name <string> Name of header<number> | <string> | <string[]> | <undefined>undefined.
outgoingMessage.getHeaderNames()#<string[]>outgoingMessage.getHeaders()#<Object>Returns a shallow copy of the current outgoing headers. Since a shallow copy is used, array values may be mutated without additional calls to various header-related HTTP module methods. The keys of the returned object are the header names and the values are the respective header values. All header names are lowercase.
The object returned by theoutgoingMessage.getHeaders() method does
not prototypically inherit from the JavaScript Object. This means that
typical Object methods such as obj.toString(), obj.hasOwnProperty(),
and others are not defined and will not work.outgoingMessage.setHeader('Foo', 'bar');
outgoingMessage.setHeader('Set-Cookie', ['foo=bar', 'bar=baz']);
const headers = outgoingMessage.getHeaders();
// headers === { foo: 'bar', 'set-cookie': ['foo=bar', 'bar=baz'] }
outgoingMessage.hasHeader(name)#true if the header identified by name is currently set in the
outgoing headers. The header name is case-insensitive.const hasContentType = outgoingMessage.hasHeader('content-type');
outgoingMessage.headersSent#<boolean>true if the headers were sent, otherwise false.
outgoingMessage.pipe()#Overrides the stream.pipe() method inherited from the legacy Stream class
which is the parent class of http.OutgoingMessage.
Error because outgoingMessage is a
write-only stream.
outgoingMessage.removeHeader(name)#name <string> Header nameoutgoingMessage.removeHeader('Content-Encoding');
outgoingMessage.setHeader(name, value)#name <string> Header namevalue <number> | <string> | <string[]> Header value<this>outgoingMessage.setHeaders(headers)#Sets multiple header values for implicit headers.
headers must be an instance of Headers or Map,
if a header already exists in the to-be-sent headers,
its value will be replaced.
const headers = new Headers({ foo: 'bar' });
outgoingMessage.setHeaders(headers);
or
const headers = new Map([['foo', 'bar']]);
outgoingMessage.setHeaders(headers);
When headers have been set with outgoingMessage.setHeaders(),
they will be merged with any headers passed to response.writeHead(),
with the headers passed to response.writeHead() given precedence.// Returns content-type = text/plain
const server = http.createServer((req, res) => {
const headers = new Headers({ 'Content-Type': 'text/html' });
res.setHeaders(headers);
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end('ok');
});
outgoingMessage.setTimeout(msecs[, callback])#msecs <number>callback <Function> Optional function to be called when a timeout
occurs. Same as binding to the timeout event.<this>socket.setTimeout() will be called with msecs as the first parameter.
outgoingMessage.socket#<stream.Duplex>Reference to the underlying socket. Usually, users will not want to access this property.
After callingoutgoingMessage.end(), this property will be nulled.
outgoingMessage.uncork()#writable.uncork()
outgoingMessage.writableCorked#<number>outgoingMessage.cork() has been called.
outgoingMessage.writableEnded#<boolean>true if outgoingMessage.end() has been called. This property does
not indicate whether the data has been flushed. For that purpose, use
message.writableFinished instead.
outgoingMessage.writableFinished#<boolean>true if all data has been flushed to the underlying system.
outgoingMessage.writableHighWaterMark#<number>highWaterMark of the underlying socket if assigned. Otherwise, the default
buffer level when writable.write() starts returning false (16384).
outgoingMessage.writableLength#<number>outgoingMessage.writableObjectMode#<boolean>false.
outgoingMessage.write(chunk[, encoding][, callback])#chunk parameter can now be a Uint8Array.The callback argument was added.
chunk <string> | <Buffer> | <Uint8Array>encoding <string> Default: utf8callback <Function><boolean>Sends a chunk of the body. This method can be called multiple times.
The encoding argument is only relevant when chunk is a string. Defaults to
'utf8'.
The callback argument is optional and will be called when this chunk of data
is flushed.
true if the entire data was flushed successfully to the kernel
buffer. Returns false if all or part of the data was queued in the user
memory. The 'drain' event will be emitted when the buffer is free again.
http.METHODS#<string[]>http.STATUS_CODES#<Object>http.STATUS_CODES[404] === 'Not Found'.
http.createServer([options][, requestListener])#httpValidation option is supported now.shouldUpgradeCallback option is now supported.highWaterMark option is supported now.requestTimeout, headersTimeout, keepAliveTimeout, and connectionsCheckingInterval options are supported now.noDelay option now defaults to true.noDelay, keepAlive and keepAliveInitialDelay options are supported now.insecureHTTPParser option is supported now.maxHeaderSize option is supported now.The options argument is supported now.
options <Object>
connectionsCheckingInterval: Sets the interval value in milliseconds to
check for request and headers timeout in incomplete requests.
Default: 30000.headersTimeout: Sets the timeout value in milliseconds for receiving
the complete HTTP headers from the client.
See server.headersTimeout for more information.
Default: 60000.highWaterMark <number> Optionally overrides all sockets'
readableHighWaterMark and writableHighWaterMark. This affects
highWaterMark property of both IncomingMessage and ServerResponse.
Default: See stream.getDefaultHighWaterMark().httpValidation <string> Controls HTTP header value validation strictness
for incoming requests. Accepted values are:
'strict': Strictest validation; rejects any non-ASCII or control
characters in header values.'relaxed': Allows a limited set of non-ASCII characters in header
values, aligning with the
Fetch specification.'insecure': Disables all header value validation (equivalent to
insecureHTTPParser: true).
Cannot be used together with insecureHTTPParser. Default: 'strict'.insecureHTTPParser <boolean> If set to true, it will use an HTTP parser
with leniency flags enabled. Using the insecure parser should be avoided.
See --insecure-http-parser for more information.
Default: false.IncomingMessage <http.IncomingMessage> Specifies the IncomingMessage
class to be used. Useful for extending the original IncomingMessage.
Default: IncomingMessage.joinDuplicateHeaders <boolean> If set to true, this option allows
joining the field line values of multiple headers in a request with
a comma (, ) instead of discarding the duplicates.
For more information, refer to message.headers.
Default: false.keepAlive <boolean> If set to true, it enables keep-alive functionality
on the socket immediately after a new incoming connection is received,
similarly on what is done in [socket.setKeepAlive([enable][, initialDelay])][socket.setKeepAlive(enable, initialDelay)].
Default: false.keepAliveInitialDelay <number> If set to a positive number, it sets the
initial delay before the first keepalive probe is sent on an idle socket. Default: 0.keepAliveTimeout: The number of milliseconds of inactivity a server
needs to wait for additional incoming data, after it has finished writing
the last response, before a socket will be destroyed.
See server.keepAliveTimeout for more information.
Default: 5000.maxHeaderSize <number> Optionally overrides the value of --max-http-header-size for requests received by this server, i.e.
the maximum length of request headers in bytes.
Default: 16384 (16 KiB).noDelay <boolean> If set to true, it disables the use of Nagle's
algorithm immediately after a new incoming connection is received.
Default: true.requestTimeout: Sets the timeout value in milliseconds for receiving
the entire request from the client.
See server.requestTimeout for more information.
Default: 300000.requireHostHeader <boolean> If set to true, it forces the server to
respond with a 400 (Bad Request) status code to any HTTP/1.1
request message that lacks a Host header
(as mandated by the specification).
Default: true.ServerResponse <http.ServerResponse> Specifies the ServerResponse class
to be used. Useful for extending the original ServerResponse. Default:
ServerResponse.shouldUpgradeCallback(request) <Function> A callback which receives an
incoming request and returns a boolean, to control which upgrade attempts
should be accepted. Accepted upgrades will fire an 'upgrade' event (or
their sockets will be destroyed, if no listener is registered) while
rejected upgrades will fire a 'request' event like any non-upgrade
request. This options defaults to
() => server.listenerCount('upgrade') > 0.uniqueHeaders <Array> A list of response headers that should be sent only
once. If the header's value is an array, the items will be joined
using ; .rejectNonStandardBodyWrites <boolean> If set to true, an error is thrown
when writing to an HTTP response which does not have a body.
Default: false.optimizeEmptyRequests <boolean> If set to true, requests without Content-Length
or Transfer-Encoding headers (indicating no body) will be initialized with an
already-ended body stream, so they will never emit any stream events
(like 'data' or 'end'). You can use req.readableEnded to detect this case.
Default: false.requestListener <Function>
Returns: <http.Server>
Returns a new instance of http.Server.
requestListener is a function which is automatically
added to the 'request' event.import http from 'node:http'; // Create a local server to receive data from const server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'application/json' }); res.end(JSON.stringify({ data: 'Hello World!', })); }); server.listen(8000);const http = require('node:http'); // Create a local server to receive data from const server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'application/json' }); res.end(JSON.stringify({ data: 'Hello World!', })); }); server.listen(8000);
import http from 'node:http'; // Create a local server to receive data from const server = http.createServer(); // Listen to the request event server.on('request', (request, res) => { res.writeHead(200, { 'Content-Type': 'application/json' }); res.end(JSON.stringify({ data: 'Hello World!', })); }); server.listen(8000);const http = require('node:http'); // Create a local server to receive data from const server = http.createServer(); // Listen to the request event server.on('request', (request, res) => { res.writeHead(200, { 'Content-Type': 'application/json' }); res.end(JSON.stringify({ data: 'Hello World!', })); }); server.listen(8000);
http.get(options[, callback])#http.get(url[, options][, callback])#url parameter can now be passed along with a separate options object.The options parameter can be a WHATWG URL object.
url <string> | <URL>options <Object> Accepts the same options as
http.request(), with the method set to GET by default.callback <Function><http.ClientRequest>Since most requests are GET requests without bodies, Node.js provides this
convenience method. The only difference between this method and
http.request() is that it sets the method to GET by default and calls req.end()
automatically. The callback must take care to consume the response
data for reasons stated in http.ClientRequest section.
The callback is invoked with a single argument that is an instance of
http.IncomingMessage.
http.get('http://localhost:8000/', (res) => {
const { statusCode } = res;
const contentType = res.headers['content-type'];
let error;
// Any 2xx status code signals a successful response but
// here we're only checking for 200.
if (statusCode !== 200) {
error = new Error('Request Failed.\n' +
`Status Code: ${statusCode}`);
} else if (!/^application\/json/.test(contentType)) {
error = new Error('Invalid content-type.\n' +
`Expected application/json but received ${contentType}`);
}
if (error) {
console.error(error.message);
// Consume response data to free up memory
res.resume();
return;
}
res.setEncoding('utf8');
let rawData = '';
res.on('data', (chunk) => { rawData += chunk; });
res.on('end', () => {
try {
const parsedData = JSON.parse(rawData);
console.log(parsedData);
} catch (e) {
console.error(e.message);
}
});
}).on('error', (e) => {
console.error(`Got error: ${e.message}`);
});
// Create a local server to receive data from
const server = http.createServer((req, res) => {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({
data: 'Hello World!',
}));
});
server.listen(8000);
http.globalAgent#The agent now uses HTTP Keep-Alive and a 5 second timeout by default.
<http.Agent>Agent which is used as the default for all HTTP client
requests. Diverges from a default Agent configuration by having keepAlive
enabled and a timeout of 5 seconds.
http.maxHeaderSize#<number>Read-only property specifying the maximum allowed size of HTTP headers in bytes.
Defaults to 16 KiB. Configurable using the --max-http-header-size CLI
option.
maxHeaderSize option.
http.request(options[, callback])#http.request(url[, options][, callback])#httpValidation option is supported now.URL object parsed username and password will now be properly URI decoded.insecureHTTPParser option is supported now.maxHeaderSize option is supported now.url parameter can now be passed along with a separate options object.The options parameter can be a WHATWG URL object.
url <string> | <URL>options <Object>
agent <http.Agent> | <boolean> Controls Agent behavior. Possible
values:
undefined (default): use http.globalAgent for this host and port.Agent object: explicitly use the passed in Agent.false: causes a new Agent with default values to be used.auth <string> Basic authentication ('user:password') to compute an
Authorization header.createConnection <Function> A function that produces a socket/stream to
use for the request when the agent option is not used. This can be used to
avoid creating a custom Agent class just to override the default
createConnection function. See agent.createConnection() for more
details. Any Duplex stream is a valid return value.defaultPort <number> Default port for the protocol. Default:
agent.defaultPort if an Agent is used, else undefined.family <number> IP address family to use when resolving host or
hostname. Valid values are 4 or 6. When unspecified, both IP v4 and
v6 will be used.headers <Object> | <Array> An object or an array of strings containing request
headers. The array is in the same format as message.rawHeaders.hints <number> Optional dns.lookup() hints.host <string> A domain name or IP address of the server to issue the
request to. Default: 'localhost'.hostname <string> Alias for host. To support url.parse(),
hostname will be used if both host and hostname are specified.httpValidation <string> Controls HTTP header value validation strictness
for outgoing requests. Accepted values are:
'strict': Strictest validation; rejects any non-ASCII or control
characters in header values.'relaxed': Allows a limited set of non-ASCII characters in header
values, aligning with the
Fetch specification.'insecure': Disables all header value validation (equivalent to
insecureHTTPParser: true).
Cannot be used together with insecureHTTPParser. Default: 'strict'.insecureHTTPParser <boolean> If set to true, it will use an HTTP parser
with leniency flags enabled. Using the insecure parser should be avoided.
See --insecure-http-parser for more information.
Default: falsejoinDuplicateHeaders <boolean> It joins the field line values of
multiple headers in a request with , instead of discarding
the duplicates. See message.headers for more information.
Default: false.localAddress <string> Local interface to bind for network connections.localPort <number> Local port to connect from.lookup <Function> Custom lookup function. Default: dns.lookup().maxHeaderSize <number> Optionally overrides the value of --max-http-header-size (the maximum length of response headers in
bytes) for responses received from the server.
Default: 16384 (16 KiB).method <string> A string specifying the HTTP request method. Default:
'GET'.path <string> Request path. Should include query string if any.
E.G. '/index.html?page=12'. An exception is thrown when the request path
contains illegal characters. Currently, only spaces are rejected but that
may change in the future. Default: '/'.port <number> Port of remote server. Default: defaultPort if set,
else 80.protocol <string> Protocol to use. Default: 'http:'.setDefaultHeaders <boolean>: Specifies whether or not to automatically add
default headers such as Connection, Content-Length, Transfer-Encoding,
and Host. If set to false then all necessary headers must be added
manually. Defaults to true.setHost <boolean>: Specifies whether or not to automatically add the Host header. If provided, this overrides setDefaultHeaders. Defaults to
true.signal <AbortSignal>: An AbortSignal that may be used to abort an ongoing
request.socketPath <string> Unix domain socket. Cannot be used if one of host
or port is specified, as those specify a TCP Socket.timeout <number>: A number specifying the socket timeout in milliseconds.
This will set the timeout before the socket is connected.uniqueHeaders <Array> A list of request headers that should be sent
only once. If the header's value is an array, the items will be joined
using ; .callback <Function><http.ClientRequest>options in socket.connect() are also supported.
Node.js maintains several connections per server to make HTTP requests. This function allows one to transparently issue requests.
url can be a string or a URL object. If url is a
string, it is automatically parsed with new URL(). If it is a URL
object, it will be automatically converted to an ordinary options object.
If both url and options are specified, the objects are merged, with the
options properties taking precedence.
The optional callback parameter will be added as a one-time listener for
the 'response' event.
http.request() returns an instance of the http.ClientRequest
class. The ClientRequest instance is a writable stream. If one needs to
upload a file with a POST request, then write to the ClientRequest object.
import http from 'node:http'; import { Buffer } from 'node:buffer'; const postData = JSON.stringify({ 'msg': 'Hello World!', }); const options = { hostname: 'www.google.com', port: 80, path: '/upload', method: 'POST', headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData), }, }; const req = http.request(options, (res) => { console.log(`STATUS: ${res.statusCode}`); console.log(`HEADERS: ${JSON.stringify(res.headers)}`); res.setEncoding('utf8'); res.on('data', (chunk) => { console.log(`BODY: ${chunk}`); }); res.on('end', () => { console.log('No more data in response.'); }); }); req.on('error', (e) => { console.error(`problem with request: ${e.message}`); }); // Write data to request body req.write(postData); req.end();const http = require('node:http'); const postData = JSON.stringify({ 'msg': 'Hello World!', }); const options = { hostname: 'www.google.com', port: 80, path: '/upload', method: 'POST', headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData), }, }; const req = http.request(options, (res) => { console.log(`STATUS: ${res.statusCode}`); console.log(`HEADERS: ${JSON.stringify(res.headers)}`); res.setEncoding('utf8'); res.on('data', (chunk) => { console.log(`BODY: ${chunk}`); }); res.on('end', () => { console.log('No more data in response.'); }); }); req.on('error', (e) => { console.error(`problem with request: ${e.message}`); }); // Write data to request body req.write(postData); req.end();
In the example req.end() was called. With http.request() one
must always call req.end() to signify the end of the request -
even if there is no data being written to the request body.
If any error is encountered during the request (be that with DNS resolution,
TCP level errors, or actual HTTP parse errors) an 'error' event is emitted
on the returned request object. As with all 'error' events, if no listeners
are registered the error will be thrown.
There are a few special headers that should be noted.
Sending a 'Connection: keep-alive' will notify Node.js that the connection to the server should be persisted until the next request.
Sending a 'Content-Length' header will disable the default chunked encoding.
Sending an 'Expect' header will immediately send the request headers.
Usually, when sending 'Expect: 100-continue', both a timeout and a listener
for the 'continue' event should be set. See RFC 2616 Section 8.2.3 for more
information.
Sending an Authorization header will override using the auth option
to compute basic authentication.
Example using a URL as options:
const options = new URL('http://abc:xyz@example.com');
const req = http.request(options, (res) => {
// ...
});
In a successful request, the following events will be emitted in the following order:
'socket''response'
'data' any number of times, on the res object
('data' will not be emitted at all if the response body is empty, for
instance, in most redirects)'end' on the res object'close'In the case of a connection error, the following events will be emitted:
'socket''error''close'In the case of a premature connection close before the response is received, the following events will be emitted in the following order:
'socket''error' with an error with message 'Error: socket hang up' and code
'ECONNRESET''close'In the case of a premature connection close after the response is received, the following events will be emitted in the following order:
'socket''response'
'data' any number of times, on the res object'aborted' on the res object'close''error' on the res object with an error with message
'Error: aborted' and code 'ECONNRESET''close' on the res objectIf req.destroy() is called before a socket is assigned, the following
events will be emitted in the following order:
req.destroy() called here)'error' with an error with message 'Error: socket hang up' and code
'ECONNRESET', or the error with which req.destroy() was called'close'If req.destroy() is called before the connection succeeds, the following
events will be emitted in the following order:
'socket'req.destroy() called here)'error' with an error with message 'Error: socket hang up' and code
'ECONNRESET', or the error with which req.destroy() was called'close'If req.destroy() is called after the response is received, the following
events will be emitted in the following order:
'socket''response'
'data' any number of times, on the res objectreq.destroy() called here)'aborted' on the res object'close''error' on the res object with an error with message 'Error: aborted'
and code 'ECONNRESET', or the error with which req.destroy() was called'close' on the res objectIf req.abort() is called before a socket is assigned, the following
events will be emitted in the following order:
req.abort() called here)'abort''close'If req.abort() is called before the connection succeeds, the following
events will be emitted in the following order:
'socket'req.abort() called here)'abort''error' with an error with message 'Error: socket hang up' and code
'ECONNRESET''close'If req.abort() is called after the response is received, the following
events will be emitted in the following order:
'socket''response'
'data' any number of times, on the res objectreq.abort() called here)'abort''aborted' on the res object'error' on the res object with an error with message
'Error: aborted' and code 'ECONNRESET'.'close''close' on the res objectSetting the timeout option or using the setTimeout() function will
not abort the request or do anything besides add a 'timeout' event.
AbortSignal and then calling abort() on the corresponding
AbortController will behave the same way as calling .destroy() on the
request. Specifically, the 'error' event will be emitted with an error with
the message 'AbortError: The operation was aborted', the code 'ABORT_ERR'
and the cause, if one was provided.
http.validateHeaderName(name[, label])#The label parameter is added.
Performs the low-level validations on the provided name that are done when
res.setHeader(name, value) is called.
Passing illegal value as name will result in a TypeError being thrown,
identified by code: 'ERR_INVALID_HTTP_TOKEN'.
It is not necessary to use this method before passing headers to an HTTP request or response. The HTTP module will automatically validate such headers.
Example:import { validateHeaderName } from 'node:http'; try { validateHeaderName(''); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code); // --> 'ERR_INVALID_HTTP_TOKEN' console.error(err.message); // --> 'Header name must be a valid HTTP token [""]' }const { validateHeaderName } = require('node:http'); try { validateHeaderName(''); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code); // --> 'ERR_INVALID_HTTP_TOKEN' console.error(err.message); // --> 'Header name must be a valid HTTP token [""]' }
http.validateHeaderValue(name, value)#Performs the low-level validations on the provided value that are done when
res.setHeader(name, value) is called.
Passing illegal value as value will result in a TypeError being thrown.
code: 'ERR_HTTP_INVALID_HEADER_VALUE'.code: 'ERR_INVALID_CHAR'.It is not necessary to use this method before passing headers to an HTTP request or response. The HTTP module will automatically validate such headers.
Examples:import { validateHeaderValue } from 'node:http'; try { validateHeaderValue('x-my-header', undefined); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code === 'ERR_HTTP_INVALID_HEADER_VALUE'); // --> true console.error(err.message); // --> 'Invalid value "undefined" for header "x-my-header"' } try { validateHeaderValue('x-my-header', 'oʊmɪɡə'); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code === 'ERR_INVALID_CHAR'); // --> true console.error(err.message); // --> 'Invalid character in header content ["x-my-header"]' }const { validateHeaderValue } = require('node:http'); try { validateHeaderValue('x-my-header', undefined); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code === 'ERR_HTTP_INVALID_HEADER_VALUE'); // --> true console.error(err.message); // --> 'Invalid value "undefined" for header "x-my-header"' } try { validateHeaderValue('x-my-header', 'oʊmɪɡə'); } catch (err) { console.error(err instanceof TypeError); // --> true console.error(err.code === 'ERR_INVALID_CHAR'); // --> true console.error(err.message); // --> 'Invalid character in header content ["x-my-header"]' }
http.setMaxIdleHTTPParsers(max)#max <number> Default: 1000.http.setGlobalProxyFromEnv([proxyEnv])#proxyEnv <Object> An object containing proxy configuration. This accepts the
same options as the proxyEnv option accepted by Agent. Default:
process.env.<Function> A function that restores the original agent and dispatcher
settings to the state before this http.setGlobalProxyFromEnv() is invoked.Dynamically resets the global configurations to enable built-in proxy support for
fetch() and http.request()/https.request() at runtime, as an alternative
to using the --use-env-proxy flag or NODE_USE_ENV_PROXY environment variable.
It can also be used to override settings configured from the environment variables.
As this function resets the global configurations, any previously configured
http.globalAgent, https.globalAgent or undici global dispatcher would be
overridden after this function is invoked. It's recommended to invoke it before any
requests are made and avoid invoking it in the middle of any requests.
NO_PROXY
syntax.
WebSocket#<WebSocket>.
Stability: 1.1 - Active development
When Node.js creates the global agent, if the NODE_USE_ENV_PROXY environment variable is
set to 1 or --use-env-proxy is enabled, the global agent will be constructed
with proxyEnv: process.env, enabling proxy support based on the environment variables.
To enable proxy support dynamically and globally, use http.setGlobalProxyFromEnv().
Custom agents can also be created with proxy support by passing a
proxyEnv option when constructing the agent. The value can be process.env
if they just want to inherit the configuration from the environment variables,
or an object with specific setting overriding the environment.
The following properties of the proxyEnv are checked to configure proxy
support.
HTTP_PROXY or http_proxy: Proxy server URL for HTTP requests. If both are set,
http_proxy takes precedence.HTTPS_PROXY or https_proxy: Proxy server URL for HTTPS requests. If both are set,
https_proxy takes precedence.NO_PROXY or no_proxy: Comma-separated list of hosts to bypass the proxy. If both are set,
no_proxy takes precedence.http://proxy.example.com:8080https://proxy.example.com:8080http://username:password@proxy.example.com:8080NO_PROXY Format#The NO_PROXY environment variable supports several formats:
* - Bypass proxy for all hostsexample.com - Exact host name match.example.com - Domain suffix match (matches sub.example.com)*.example.com - Wildcard domain match192.168.1.100 - Exact IP address match192.168.1.1-192.168.1.100 - IP address rangeexample.com:8080 - Hostname with specific portTo start a Node.js process with proxy support enabled for all requests sent
through the default global agent, either use the NODE_USE_ENV_PROXY environment
variable:
NODE_USE_ENV_PROXY=1 HTTP_PROXY=http://proxy.example.com:8080 NO_PROXY=localhost,127.0.0.1 node client.js
Or the --use-env-proxy flag.
HTTP_PROXY=http://proxy.example.com:8080 NO_PROXY=localhost,127.0.0.1 node --use-env-proxy client.js
To enable proxy support dynamically and globally with process.env (the default option of http.setGlobalProxyFromEnv()):
const http = require('node:http'); // Reads proxy-related environment variables from process.env const restore = http.setGlobalProxyFromEnv(); // Subsequent requests will use the configured proxies from environment variables http.get('http://www.example.com', (res) => { // This request will be proxied if HTTP_PROXY or http_proxy is set }); fetch('https://www.example.com', (res) => { // This request will be proxied if HTTPS_PROXY or https_proxy is set }); // To restore the original global agent and dispatcher settings, call the returned function. // restore();import http from 'node:http'; // Reads proxy-related environment variables from process.env http.setGlobalProxyFromEnv(); // Subsequent requests will use the configured proxies from environment variables http.get('http://www.example.com', (res) => { // This request will be proxied if HTTP_PROXY or http_proxy is set }); fetch('https://www.example.com', (res) => { // This request will be proxied if HTTPS_PROXY or https_proxy is set }); // To restore the original global agent and dispatcher settings, call the returned function. // restore();
To enable proxy support dynamically and globally with custom settings:
const http = require('node:http'); const restore = http.setGlobalProxyFromEnv({ http_proxy: 'http://proxy.example.com:8080', https_proxy: 'https://proxy.example.com:8443', no_proxy: 'localhost,127.0.0.1,.internal.example.com', }); // Subsequent requests will use the configured proxies http.get('http://www.example.com', (res) => { // This request will be proxied through proxy.example.com:8080 }); fetch('https://www.example.com', (res) => { // This request will be proxied through proxy.example.com:8443 });import http from 'node:http'; http.setGlobalProxyFromEnv({ http_proxy: 'http://proxy.example.com:8080', https_proxy: 'https://proxy.example.com:8443', no_proxy: 'localhost,127.0.0.1,.internal.example.com', }); // Subsequent requests will use the configured proxies http.get('http://www.example.com', (res) => { // This request will be proxied through proxy.example.com:8080 }); fetch('https://www.example.com', (res) => { // This request will be proxied through proxy.example.com:8443 });
To create a custom agent with built-in proxy support:
const http = require('node:http');
// Creating a custom agent with custom proxy support.
const agent = new http.Agent({ proxyEnv: { HTTP_PROXY: 'http://proxy.example.com:8080' } });
http.request({
hostname: 'www.example.com',
port: 80,
path: '/',
agent,
}, (res) => {
// This request will be proxied through proxy.example.com:8080 using the HTTP protocol.
console.log(`STATUS: ${res.statusCode}`);
});
Alternatively, the following also works:
const http = require('node:http');
// Use lower-cased option name.
const agent1 = new http.Agent({ proxyEnv: { http_proxy: 'http://proxy.example.com:8080' } });
// Use values inherited from the environment variables, if the process is started with
// HTTP_PROXY=http://proxy.example.com:8080 this will use the proxy server specified
// in process.env.HTTP_PROXY.
const agent2 = new http.Agent({ proxyEnv: process.env });