总结

以上是小编为你收集整理的node --express处理get和post全部内容。

如果觉得小编网站内容还不错，欢迎将小编网站推荐给好友。

原文地址：https://www.cnblogs.com/hack-ing/p/12112517.html

Node JS Express处理多个请求

我所拥有的： 我有一个nodejs
express服务器获取端点，该端点依次调用其他耗时的API（例如大约2秒）。我已经通过回调调用了此函数，使得res.send作为回调的一部分被触发。res.send对象打包了一个对象，该对象将在执行这些耗时的API调用的结果之后创建。因此，仅当我从API调用中获得全部信息时，才能发送我的res.send。

一些代表性的代码。

someFunctionCall(params, callback){  // do some asyncronous requests.  Promise.all([requestAsync1(params),requestAsync2(params)]).then  {     // do some operations     callback(response) // callback given with some data from the promise  }}app.get(''/'',function(req, res){ someFunctionCall(params, function(err, data){    res.send(JSON.stringify(data))   }}

我要什么 我希望我的服务器能够处理其它并行输入的GET请求不会被阻挡由于其他功能的REST
API调用。但是问题在于，仅当实现了promise时才会发出回调，这些操作中的每一个都是异步的，但是我的线程将等到所有的操作都执行完毕。并且Node不执行下一个请求的res.send或res.end，就不接受下一个get请求。当我有多个请求进入，每个请求一个接一个地执行时，这成为一个问题。

注意：我不想使用cluster方法，我只是想知道如果没有它，是否有可能做到这一点。

答案1

您显然误会了node.js，异步操作和Promise的工作方式。假设长时间运行的异步操作均已使用异步I /
O正确编写，那么您的requestAsync1(params)或requestAsync2(params)调用都不会阻塞。这意味着，在等待Promise.all()调用其.then()处理程序以表明这两个异步操作均已完成时，node.js完全可以自由运行任何其他事件或传入请求。承诺本身不会阻塞，因此node.js事件系统可以自由处理其他事件。因此，您根本就没有阻塞问题，或者实际上没有阻塞问题，这不是您在此处询问的原因引起的。

要查看您的代码是否实际被阻塞，可以临时添加一个简单的计时器，将其输出到控制台，如下所示：

let startTime;setInterval(function() {    if (!startTime) {        startTime = Date.now();    }    console.log((Date.now() - startTime) / 1000);}, 100)

当事件循环未阻塞时，这将每100ms输出一个简单的相对时间戳。您显然不会在生产代码中将其保留在代码中，但是当事件循环被阻止时，向您显示可能会很有用。

我确实在您的问题中包含的代码中看到了一个奇怪的语法问题。这段代码：

someFunctionCall(params, callback){  // do some asyncronous requests.  Promise.all([requestAsync1(params),requestAsync2(params)]).then  {     // do some operations     callback(response) // callback given with some data from the promise  }}

应该这样表示：

someFunctionCall(params, callback){  // do some asyncronous requests.  Promise.all([requestAsync1(params),requestAsync2(params)]).then(function(response)  {     // do some operations     callback(response) // callback given with some data from the promise  }});

但是，更好的设计将是仅返回诺言，而不切换回简单的回调。除了允许调用者使用更灵活的Promise方案外，您还“吃”了异步操作或异步操作中可能发生的错误。建议这样做：

someFunctionCall(params) {  // do some asyncronous requests.    return Promise.all([requestAsync1(params),requestAsync2(params)]).then(function(results) {        // further processing of results        // return final resolved value of the promise        return someValue;    });}

然后，呼叫者会这样使用：

someFunctionCall(params).then(function(result) {    // process final result here}).catch(function(err) {    // handle error here});

node.js + express处理上传文件接口demo

const express = require(''express'');
const app = express();
const cors = require(''cors'');
const multer = require(''multer'');
const fs = require(''fs'');

const express = require(''express'');
const app = express();
const cors = require(''cors'');
const fs = require(''fs'');
const multer = require(''multer'');

// 引入multer
const upload = multer({
    dest: ''uploads/''
});

morgan.token(''body'', (req: { body: any; }) => {
    return JSON.stringify(req.body);
});

// 托管静态文件，并且加个前缀uploads,为了安全规范
app.use(''/uploads'', express.static(__dirname + ''/uploads''));

// 处理带cookies的跨域请求
app.use(cors({credentials: true, origin: ''http://localhost:8080''}));

// 接口填写，上传文件类型为任何文件
app.post(''/upload'', upload.any(), async (req: any, res: any) => {
    res.header(''Access-Control-Allow-Credentials'', true);
    res.header(''Access-Control-Allow-Origin'', ''http://localhost:8080'');
    res.header(''Access-Control-Allow-Methods'', ''PUT, POST, GET, DELETE, OPTIONS'');
    console.log(req.files[0]);  // 上传的文件信息

	// 保存文件，或者做一些后续文件的处理
    var des_file = "./uploads/" + req.files[0].originalname;
    fs.readFile( req.files[0].path, (err: any, data: any) => {
        fs.writeFile(des_file, data,  (err: any) => {
            if(err){
                console.log(err);
            }else{
                const response = {
                    message: ''File uploaded successfully'',
                    filename: req.files[0].originalname
                };
                res.end(JSON.stringify(response));
            }
        });
    });
})

app.use(connect.urlencoded())
app.use(connect.json())

curl -F entry[title]='Ho ho ho' -F entry[body]='santa loves you' http://abc:123@127.0.0.1:3000/api/entry

var bodyParser = require('body-parser');

...

app.use(bodyParser.json());

app.use(bodyParser.urlencoded({extended: true}));

var multipart = require('connect-multiparty');
var multipartMiddleware = multipart();
app.use('/url/that/accepts/form-data',multipartMiddleware);
app.post('/url/that/accepts/form-data',function(req,resp) {
    console.log(req.body,req.files);
});