Node.js http2stream.respond() 方法

http2stream.respond()是 http2 模块中 Http2Stream 类的内置应用程序编程接口，用于将特定流的响应头发送到其客户端。

句法：

const http2stream.respond([headers[, options]])

参数：此方法将响应头作为其参数。

返回值：此方法不返回任何值。

如何生成私钥和公共证书

私钥

步骤 - 1：打开记事本并复制粘贴以下密钥

第 2 步：另存为private-key.pem

公共证书

步骤 - 1：打开记事本并复制粘贴以下密钥

第 2 步：另存为public-cert.pem

示例 1：文件名：index.js

Javascript

// Node.js program to demonstrate the
// Http2Stream.respond() method
const http2 = require('http2');
const fs = require('fs');
 
// Private key and public certificate for access
const options = {
    key: fs.readFileSync('private-key.pem'),
    cert: fs.readFileSync('public-cert.pem'),
};
 
// Creating and initializing server
// by using http2.createServer() method
const server = http2.createServer(options);
 
 
server.on('stream', (stream, requestHeaders) => {
 
    // Setting response header to client
    // by using respond() method
    stream.respond({
        ':status': 200,
        'content-type': 'text/plain'
    });
     
    stream.write('hello ');
 
    // Checking if header is sent or not
    // by using pushAllowed method
    const status = stream.pushAllowed;
 
    if (status)
        stream.end("push stream is accepted");
    else
        stream.end("push stream is not accepted");
 
    // Stopping the server by using the
    // close() method
    server.close(() => {
        console.log("server destroyed");
    })
});
server.listen(8000);
 
 
// Creating and initializing client
// by using tls.connect() method
const client = http2.connect(
        'http://localhost:8000');
 
const req = client.request({
    ':method': 'GET',
    ':path': '/'
});
 
req.on('response', (responseHeaders) => {
    console.log("status : "
        + responseHeaders[":status"]);
});
 
req.on('data', (data) => {
 
    console.log('Received: %s ',
        data.toString().replace(/(\n)/gm, ""));
});
 
req.on('end', () => {
    client.close(() => {
        console.log("client destroyed");
    })
 
});

Javascript

// Node.js program to demonstrate the
// Http2Stream.respond() method
const http2 = require('http2');
const fs = require('fs');
 
// Private key and public certificate
// for access
const options = {
    key: fs.readFileSync('private-key.pem'),
    cert: fs.readFileSync('public-cert.pem'),
};
 
// Creating and initializing server by
// using http2.createServer() method
const server = http2.createServer(options);
 
 
server.on('stream', (stream, requestHeaders) => {
 
    // Setting response header to client
    // by using respond() method
    stream.respond({
        ':status': 200,
        'content-type': 'text/plain'
    });
 
    // Stopping the server by
    // using the close() method
    server.close(() => {
        console.log("server destroyed");
    })
});
server.listen(8000);
 
 
// Creating and initializing client
// by using tls.connect() method
const client = http2.connect(
        'http://localhost:8000');
 
const req = client.request({
    ':method': 'GET',
    ':path': '/'
});
 
req.on('response', (responseHeaders) => {
 
    console.log("status : "
        + responseHeaders[":status"]);
});

输出：

status : 200
Received: hello
Received: header is sent
client destroyed
server destroyed

使用以下命令运行 index.js 文件：

node index.js

示例 2：文件名：index.js

Javascript

// Node.js program to demonstrate the
// Http2Stream.respond() method
const http2 = require('http2');
const fs = require('fs');
 
// Private key and public certificate
// for access
const options = {
    key: fs.readFileSync('private-key.pem'),
    cert: fs.readFileSync('public-cert.pem'),
};
 
// Creating and initializing server by
// using http2.createServer() method
const server = http2.createServer(options);
 
 
server.on('stream', (stream, requestHeaders) => {
 
    // Setting response header to client
    // by using respond() method
    stream.respond({
        ':status': 200,
        'content-type': 'text/plain'
    });
 
    // Stopping the server by
    // using the close() method
    server.close(() => {
        console.log("server destroyed");
    })
});
server.listen(8000);
 
 
// Creating and initializing client
// by using tls.connect() method
const client = http2.connect(
        'http://localhost:8000');
 
const req = client.request({
    ':method': 'GET',
    ':path': '/'
});
 
req.on('response', (responseHeaders) => {
 
    console.log("status : "
        + responseHeaders[":status"]);
});

输出：

status : 200

使用以下命令运行 index.js 文件：

node index.js

参考： https://nodejs.org/dist/latest-v12.x/docs/api/http2.html#http2_http2stream_respond_headers_options