将HTTP2中的多个JSON数据从客户端发送到Node.js中的服务器

Question

我有一个正常工作的http2服务器和客户端，在其中使用POST方法从客户端向服务器发送JSON数据。由于Node.js中的http2具有双工流，因此我使用事件“数据”和“结束”从服务器流中读取了数据。现在，我想多次发送相同的数据。但是如何区分新数据和旧数据？

我想使用sleep进行此操作，因为（如果我错了，请纠正我），当我们从客户端向服务器发送许多数据包时，它将最终耗尽我所有的CPU资源。现在，当服务器中的流事件不接收数据（我的意思是“数据”和“结束”）时，它们将如何表现？如何再次使用它们来获取数据？假设服务器接收数据时将其存储在文件中。

服务器：

const h2=require('http2');
const fs=require('fs');
const options={
    key: fs.readFileSync('key.pem'),
    cert: fs.readFileSync('cert.pem')
};
//server begin
const server=h2.createSecureServer(options);
server.on('error', (err)=>{throw err});

server.on('stream', (stream, headers)=>{        
    stream.respond({':status': 200})        //giving out response headers
    if(headers[':method']==='POST'){
        let data=''     
        let i=0;   
        stream.on('data',(chunk)=>{
            console.log(`iteration: ${++i}`)
            data+=chunk
        });
        stream.on('end', ()=>{
            // stream.close()      
            console.log('\n')
            console.log(JSON.parse(data))
        })
    }else if(headers[':method']==='GET'){
        stream.end('Hello from SMF')
    }else{
        //else condition
    }
})
server.listen(3000, 'localhost');
//server end

客户：

const h2=require('http2');
const fs=require('fs');
const packet=require('./packet.json');

//client start
const client=h2.connect('https://localhost:3000',{      //establishing connection
    ca: fs.readFileSync('cert.pem')
});
client.on('error', (err)=>{throw err})

const req=client.request({              //giving out a post request
    ':method': 'POST',
    'content-type': 'application/json'
})
req.setEncoding('utf8');
req.on('error', (err)=>{throw err})

// req.write(JSON.stringify(packet))


req.end(JSON.stringify(packet), ()=>{   //writing the data to SMF
    req.on('response', (headers)=>{     //getting the response headers
        if(headers[':status']===200) console.log('success')
        req.close()                     //closing client stream
        client.close()                  //closing client session
    })
})
//client end

JSON数据：

{
  "supi": "imsi-<IMSI>",
  "pduSessionId": 235,
  "dnn": "<DNN>",
  "sNssai": {
    "sst": 0
  },
  "servingNfId": "<AMF Identifier>",
  "n1SmMsg": {
    "contentId": "n1msg"
  },
  "anType": "3GPP_ACCESS",
  "smContextStatusUri": "<URI>"
}

（（我知道我已经使用过安全服务器，您只需从代码中删除证书，而使用createServer（）即可。

Answer 1

实际上，如果使用drain事件，则应该能够避免内存不足和崩溃。这是该文档：https://nodejs.org/api/stream.html#stream_event_drain