执行 promise 时不会触发 console.log

Question

我有一个 js 文件，我在其中导出了一个承诺，然后在另一个文件中调用它。 我不明白为什么当我调用承诺时控制台日志没有被触发， 也许我没有完全理解承诺是如何运作的，或者我称之为承诺的方式有问题

pub.js

var config = require('../config');
var q = 'tasks';
var open = require('amqplib').connect('amqp://'+ config.rabbitmq.url);

module.exports =  open.then(function(conn) {
  return conn.createChannel();
}).then(function(ch) {
  return ch.assertQueue(q).then(function(ok) {
   console.log('inside publisher')
   const r = ch.sendToQueue(q, Buffer.from('something to do'));
   console.log('r',r)
     return r
  });
}).catch(console.warn);

index.js（我称之为 promise）

var express = require('express');
var router = express.Router();
var publisher = require('../connectors/pub');

var rabbitPromise = () => (
    new Promise((resolve,reject)=>{
        publisher
                .then(res=>{
                        console.log('-----------------------')
                        console.log('publishing now',res)
                        resolve(res)

                })
    })  

);
/* GET home page. */
router.get('/', async(req, res, next) => {
    const result_pub = await rabbitPromise()  
    res.send('ok')
});

我希望看到 console.log('inside publisher') 但我没有看到它我只得到 console.log('----------------- -----') 和 console.log('publishing now',res),

Answer 1

pub.js 中的链接不正确。为了调用承诺，它会更像这样：

module.exports =  open
   .then(function(conn) {
     return conn.createChannel();
   })
   .then(function(ch) {
     return ch.assertQueue(q);
   })
   .then(function(ok) {
      console.log('inside publisher')
      const r = ch.sendToQueue(q, Buffer.from('something to do'));
      console.log('r',r)
      return r
   })
   .catch(console.warn);