当前位置：首页 > 文档资料 > Egg.js 开发 Restful API 最佳实践 >

消息应答和持久化

优质

小牛编辑

133浏览

2023-12-01

消息应答 ack

>[danger] noAck: false 手动接收消息模式

async consume() {
    const ch = await this.app.amqplib.createChannel();
    await ch.assertQueue(queueName, { durable: false });
    const msg = await new Promise(resolve =&gt; ch.consume(queueName, msg =&gt; resolve(msg) , { noAck: false } )); 

    if (msg !== null) {
      // 告诉MQ 我已经收到消息并处理完成了，MQ会删除队列中的消息，并从内存中删除
      ch.ack(msg);
      await ch.close();

      this.ctx.status = 200;
      this.ctx.body = { msg: msg.content.toString() };
    } else {
      this.ctx.status = 500;
    }
}

消息持久化

免责声明：以上内容版权归原作者所有，如有侵犯您的原创版权请告知，我们将尽快删除相关内容。感谢每一位辛勤著写的作者，感谢每一位的分享。