小编Pra*_*rak的帖子

我最近 3 天尝试了以下问题。请帮我解决问题，

>Error: Unexpected close
at succeed (/usr/local/lib/node_modules/amqplib/lib/connection.js:259:13)
at onOpenOk (/usr/local/lib/node_modules/amqplib/lib/connection.js:241:5)
at /usr/local/lib/node_modules/amqplib/lib/connection.js:160:32
at /usr/local/lib/node_modules/amqplib/lib/connection.js:154:12
at Socket.recv (/usr/local/lib/node_modules/amqplib/lib/connection.js:480:12)
at Socket.g (events.js:180:16)
at Socket.EventEmitter.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:407:10)
at emitReadable (_stream_readable.js:403:5)
at readableAddChunk (_stream_readable.js:165:9)

我正在使用 amqplib + 节点 js。每当我启动服务器时，我都会在一段时间内收到上述错误。最多每隔 5 分钟就会发生一次。

amqplib = amqplib.connect('amqp://'+rabit_host).then(function(conn)
{
    amqpconnection = conn;
});

io.sockets.on('connection', function(client)
{   
    client.on('receivemsg', function(arg)
    {
        amqpconnection.createConfirmChannel().then(function(channelObjSuccess)
        {
            channelObjSuccess.assertQueue(queue_name,{durable:false,autoDelete:true});
            client.assignObj = channelObjSuccess;
            channelObjSuccess.consume(queue_name, function(msg)
            {
                var encodemsg = msg.content.toString();
                var json_msg = JSON.parse(encodemsg);                           
                client.emit('chatrecive',json_msg);
            }).then(function(){
                console.log("Receive Consiuume Close");
            }); 
        });
    }); …