Nuxt CNode：Node.js专业中文社区

关于node Koa2 异步回调的问题

发布于 7 年前作者 enternull 3903 次预览最后一次回复是 7 年前来自问答

function demo(context, next) {
    console.log(1)
        setTimeout(() => {
            let string_num = Date.now()
            console.log(string_num)
            context.body = string_num
            context.res.end()
        }, 1000)
    })
}

写了个DEMO 流程是发起请求然后 console.log(1) 程序中有个定时器延迟一秒后返回数据前端接收不到数据但是加入promise

function demo(context, next) {
    console.log(1)
    return new Promise((resolve,reject) => {
        setTimeout(() => {
            let string_num = Date.now()
            console.log(string_num)
            context.body = string_num
            context.res.end()
            resolve()
        }, 1000)
    })
}

它就变成同步的了每次输出时间戳后才会处理下一个请求请问nodejs有什么方式可以接收多个请求然后异步返回数据的嘛？框架用的koa2

5 回复

chenzeZzz

1楼•7 年前

你要处理多个请求了，为什么要promise

enternull

2楼•7 年前

@chenzeZzz 不用promise 我收不到异步返回的结果啊

chenzeZzz

3楼•7 年前

@enternull 服务路由没问题，你有请求就会有返回，promise可以控制返回的时间，但是高并发应当让请求尽快返回

lizhenwu

4楼•7 年前

注释掉context.res.end()就可以了

const Koa = require('koa')
const app = new Koa()
const http = require('http')

app.use(function demo(context, next) {
    console.log(Date.now())
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            let string_num = Date.now()
            // console.log(string_num)
            context.body = string_num
            // context.res.end()
            resolve(string_num)
        }, 1000)
    })
})

app.listen(3000, () => {
    console.log('server runnning on 3000')
})

function testPort() {
    http.get('http://localhost:3000', res => {
        let error
        if(res.statusCode !== 200) {
            error = new Error(`请求失败：${res.statusCode}`)
        }
        if(error) {
            res.resume()
            console.log(error.message)
            return
        }
        let data = ''
        res.on('data', chunk => {
            data += chunk
        }).on('error', (e) => {
            console.log(`错误: ${e.message}`)
        }).on('end', () => {
            console.log(data.toString())
        })
    })
}
testPort()
testPort()

输出

// 1524705937439
// 1524705937439
// 1524705938461
// 1524705938461

不知道是不是你想要的结果😂

Sunkaystar

5楼•7 年前

我觉得可以使用ES6的async/await，当然promise在有些情况也是必须的。