AMQP连接关闭与节点js的特定时间间隔

我在最近3天内尝试了以下问题。请帮我解决问题，AMQP连接关闭与节点js的特定时间间隔

>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 + node 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"); 
      }); 
     }); 
    }); 

client.on('loginentry', function(arg) 
{ 
    amqpconnection.createConfirmChannel().then(function(channelObjSuccess) { 
     channelObjSuccess.assertQueue(queue_name,{durable:false,autoDelete:true}); 
    });   
}); 

client.on('sendmsg', function(arg) 
{ 
    var payload_stringify = JSON.stringify(arg);    
    amqpconnection.createConfirmChannel().then(function(channelObjSuccess) { 
    channelObjSuccess.assertQueue(queue_name,{durable:false,autoDelete:true}); 
    channelObjSuccess.sendToQueue(queue_name, new Buffer(payload_stringify), {}, 
     function(err, ok) 
     { 
      if (err !== null) 
       console.log('Message Send Failure! '); 
      else 
      { 
       channelObjSuccess.close(); 
      } 
     }); 
    }); 
}); 

client.on('disconnect', function() 
{ 
    try { 
    console.log("AMPQ Connection Closed - Disconnect"); 
    if(typeof(client.assignObj)!=undefined) 
    { 
     client.assignObj.close(); 
    } 
    } 
    catch (alreadyClosed) { 
     console.log("RabbitMQ Connection Already Closed " + alreadyClosed.stackAtStateChange); 
    } 
    });   
}); 

server.listen(port);

来源

2014-10-07 Prakash

的错误来自您的插座，请张贴相关的代码。 'self.stream.on（'end'，self.onSocketError.bind（self，new Error（'Unexpected close'）））;' – xShirase 2014-10-07 05:25:09

感谢您的快速响应。什么时候会打电话？你想要哪部分代码？ – Prakash 2014-10-07 05:41:43

，说错误是一个套接字错误，所以告诉我们一些套接字代码 – xShirase 2014-10-07 05:43:24

我想我找到了答案，可能是连接到AMQP时心跳作为选项的问题。如：

url = "amqp://turtle.rmq.cloudamqp.com/bqftjxzn?heartbeat=45";

来源

2014-10-10 13:00:30 HDB

在localhost中也发生过同样的情况，你如何解决它？ – 2017-02-01 09:00:55

AMQP连接关闭与节点js的特定时间间隔

回答

相关问题