如何在Koa中使用异步并等待？

2024-05-20 • 问答

我创建了一个简单的登录api，但出现404错误。我该如何解决这个问题？我的ctx主体无法正常工作。当我碰到邮递员时，找不到它。

router.post('/login',async (ctx,next) => {

    var phone= ctx.request.body.phone;
    var password = ctx.request.body.password;


        await ctx.app.pool.query("SELECT * FROM users WHERE phone= $1",[`${phone}`],async (err,result) => {
               if (result) {
                   await bcrypt.compare(password,result.rows[0].password).then(function (res) {

                        if (res === true) {
                            ctx.body = {
                                status: 200,message: "login successfully",data: result.rows[0],};
                        }else{
                            ctx.body = {
                                status: 400,message: "Incorrect password! Try again.",}
                        }
                    });
                }else{
                    ctx.body = {
                        status: 400,message: "Invalid phone",}
                }
            });
});

首先不要将异步与回调和then

混合使用

使用const res = await somepromise()

您对查询使用了回调，对bcrypt.compare使用了then而不是等待它

router.post('/login',async (ctx,next) => {
  const phone= ctx.request.body.phone;
  const password = ctx.request.body.password;
  const result =  await ctx.app.pool.query("SELECT * FROM users WHERE phone= $1",[`${phone}`])

  if (result) {
     const pwCorrect = await bcrypt.compare(password,result.rows[0].password)
     if (pwCorrect === true) {
        ctx.body = {
           status: 200,message: "login successfully",data: result.rows[0],};
     }else{
         ctx.body = {
           status: 400,message: "Incorrect password! Try again.",}
     }
  } else{
      ctx.body = {
        status: 400,message: "Invalid phone",}

});

如何在Koa中使用异步并等待？

bjwmkj 回答：如何在Koa中使用异步并等待？

大家都在问