node rabbit mq

node在使用rabbitmq时，需要使用amqplib，
生产者的示例代码如下：
const amqp =require('amqplib');

async function product(params) {

const conn={
    protocol:'amqp',
    hostname:'localhost',
    port:5672,
    username:'admin',
    password:'admin',
    vhost:'/'
}
 // 1. 创建链接对象
 const connection = await amqp.connect(conn);
 // 2. 获取通道
 const channel = await connection.createChannel();
 // 3. 声明参数
 const routingKey = 'helloKoalaQueue';
 const msg = 'hello koala';
 for (let i=0; i<10; i++) {
     // 4. 发送消息
     await channel.publish('', routingKey, Buffer.from(`${msg} 第${i}条消息`));
 }
 // 5. 关闭通道
 await channel.close();
 // 6. 关闭连接
 await connection.close();

}
product();