async/await:connect([url, [socketOptions]])
    callback:connect([url, [socketOptions]], function(err, conn) {…})

    url:

    • 套接字选项:amqp://guest:guest@localhost:5672,amqp://管理员账号@管理员密码@xxx.xxx.xxx:5672适用在远端机器
    • AMQP URL:amqp://localhost,本地机器缺少参数会自动补齐

    socketOptions:

    • frameMax,连接上允许最大帧的大小,0表示没有限制,
    • channelMax,最大通道数,默认0,最大2^16-1
    • heartbeat,心跳间隔,默认未0
    • locale,语言环境,RabbitMQ只能用en_US
      1. // async/await
      2. (async () => {
      3. try {
      4. const options = {
      5. frameMax: 0,// 连接上允许最大帧的大小,0表示没有限制
      6. channelMax: 0,// 最大通道数,默认0,最大2^16-1
      7. heartbeat: 0,// 心跳间隔,默认未0
      8. locale:'en_US',// 语言环境,RabbitMQ只能用en_US
      9. };
      10. const connection = await amqp.connect('url',options)
      11. const channel = connection.createChannel();
      12. return { connection, channel }
      13. } catch (e) {
      14. console.log(e)
      15. }
      16. })()
      ```javascript // callback new Promise((resolve,reject)=>{ const options = { frameMax: 0,// 连接上允许最大帧的大小,0表示没有限制 channelMax: 0,// 最大通道数,默认0,最大2^16-1 heartbeat: 0,// 心跳间隔,默认未0 locale:’en_US’,// 语言环境,RabbitMQ只能用en_US }; amqp.connect(‘url’,(error1,options,connection){ if(error1) throw reject(error1); connection.creatcChannel(error2,channel){
      1. if(error2) throw reject(error2);
      2. return resolve({connection,channel})
      } }) })

    ```