发送HTTP / 2 POST请求NodeJS

约翰·史密斯

我试图弄清楚如何使用NodeJS发送HTTP / 2 POST请求。到目前为止，我离文档中的示例还很远：

const http2 = require('http2');
const fs = require('fs');
const client = http2.connect('https://localhost:8443', {
  ca: fs.readFileSync('localhost-cert.pem')
});
client.on('error', (err) => console.error(err));
client.on('socketError', (err) => console.error(err));

const req = client.request({ ':path': '/' });

req.on('response', (headers, flags) => {
  for (const name in headers) {
    console.log(`${name}: ${headers[name]}`);
  }
});

req.setEncoding('utf8');
let data = '';
req.on('data', (chunk) => { data += chunk; });
req.on('end', () => {
  console.log(`\n${data}`);
  client.close();
});
req.end();

但是我还不清楚如何实际设置数据以POST方式发送。

约翰·史密斯

将少量信息汇总到处之后，我终于设法解决了这个问题。这是一个模板示例。密钥在req.write（）中。老实说，我找不到任何有关如何包括身体的直接答案。几乎每个例子都没有身体！希望这对其他人有帮助。注意：这在Node-red中，因此在global.get语句中，但也可以通过将它们更改为require（'module'）来工作：

const fs = global.get('fs');
const http2 = global.get('http2');

fs.readFile('turn-off-the-desklight.raw', function(err, content){
    if(err){
        node.send(err);
    }
    var metadata = JSON.stringify(
    {  
        "context": [   
            {
                "header": {
                    "namespace": "SpeechRecognizer",
                    "name": "RecognizerState"
                },
                "payload": {

                }
            },
            {
                "header": {
                    "namespace": "Speaker",
                    "name": "VolumeState"
                },
                "payload": {
                    "volume": 10,
                    "muted": false
                }
            },
            {
                "header": {
                    "namespace": "Alerts",
                    "name": "AlertsState"
                },
                "payload": {
                    "allAlerts": [],
                    "activeAlerts": []
                }
            },
            {
                "header": {
                    "namespace": "SpeechSynthesizer",
                    "name": "SpeechState"
                },
                "payload": {
                    "token": "",
                    "offsetInMilliseconds": 0,
                    "playerActivity": "FINISHED"
                }
            },
            {
                "header": {
                    "namespace": "AudioPlayer",
                    "name": "PlaybackState"
                },
                "payload": {
                    "token": "",
                    "offsetInMilliseconds": 0,
                    "playerActivity": "IDLE"
                }
            }
        ],  
        "event": {  
            "header": {  
                "namespace": "SpeechRecognizer",  
                "name": "Recognize",  
                "messageId": "1eff3c5e-02e3-4dd3-9ca0-7c38937f005f",  
                "dialogRequestId": "a905c2bb-1bbd-45cf-9f85-6563d2546492"
            },  
            "payload": {  
                "profile": "FAR_FIELD",
                "format": "AUDIO_L16_RATE_16000_CHANNELS_1"
            }  
        }  
    });
    var data = "--this-is-my-boundary-for-alexa\r\n";
    data += 'Content-Disposition: form-data; name="metadata"\r\n';
    data +='Content-Type: application/json; charset=UTF-8\r\n\r\n';
    data += metadata;
    data += "\r\n";
    data += "--this-is-my-boundary-for-alexa\r\n";
    data += "Content-Disposition: form-data; name=\"audio\"\r\n";
    data += "Content-Type:application/octet-stream\r\n\r\n";
    var payload = Buffer.concat([
            Buffer.from(data, "utf8"),
            new Buffer(content, 'binary'),
            Buffer.from("\r\n--this-is-my-boundary-for-alexa\r\n", "utf8"),
    ]);

    const client = global.get('alexaClient');

    client.on('error', (err) => node.send({payload:err}));
    client.on('socketError', (err) => node.send({payload:err}));

    var request = {
        ':method' : 'POST',  
        ':scheme' : 'https',  
        ':path' : '/v20160207/events',
        'authorization' : 'Bearer <valid token>',
        'content-type' : 'multipart/form-data; boundary=this-is-my-boundary-for-alexa'
    };

    var req = client.request(request);

    req.on('response', (headers, flags) => {
        for (const name in headers) {
            if(name === ':status') {
                node.send({payload:`${name}: ${headers[name]}`});
            }
        }
    });

    req.on('error', function(err) {
      node.send(err);
    });

    req.setEncoding('utf8');
    let outdata = '';
    req.on('data', (chunk) => { outdata += chunk; });
    req.on('end', () => {
        node.send({payload:outdata});
    });

    req.write(payload);

    req.end();  
});

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。