关于断开 Rabbit MQ 连接的问题
while (falg) { debuglogger.info("find msg of: " + acid); QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String text = new String(delivery.getBody()); // 解析消息 String from = ""; String to = ""; 。。。。。。。。 }com.rabbitmq.client.ShutdownSignalException: clean channel shutdown; reason: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)at com.rabbitmq.client.QueueingConsumer.handle(QueueingConsumer.java:198)at com.rabbitmq.client.QueueingConsumer.nextDelivery(QueueingConsumer.java:214)at com.handbb.dating.mq.MQMsgMrg.recmsg(MQMsgMrg.java:251)at com.handbb.dating.action.UserAction$1.run(UserAction.java:156)Caused by: com.rabbitmq.client.ShutdownSignalException: clean channel shutdown; reason: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:521)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:480)at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:473)at com.handbb.dating.mq.MQMsgMrg.closeMq(MQMsgMrg.java:519)at com.handbb.dating.action.UserAction.userlogout(UserAction.java:194)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)at java.lang.reflect.Method.invoke(Method.java:585)at com.opensymphony.xwork2.DefaultActionInvocation.invokeAction(DefaultActionInvocation.java:452)at com.opensymphony.xwork2.DefaultActionInvocation.invokeActionOnly(DefaultActionInvocation.java:291)at com.opensymphony.xwork2.DefaultActionInvocation.invoke(DefaultActionInvocation.java:254)