背景:
一个同事往这个队列发数据,另一个同事从这个队列取数据,进行解析。
这是昨天同事昨天消费者 消费activemq 队列,一开始有正常,运行了一段时间后,发现突然消费者变为零了。因为有监控。之后怎么也连不上。然后报了这个错。
javax.jms.JMSException: Cannot send, channel has already failed: tcp://IP:61616
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1409)
at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1496)
at org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:524)
分析:
本以为是同事写的程序有问题,就用本地写了一个最简单的取数据程序,依旧是报这个错。
为了不让队列监控一直报警,就让发送数据的同事A 停止 生产者程序。
突然之后就可以正常取程序了。
问题锁定:
这才怀疑是生产者出现的问题。是因为他每次发送消息都new 一个连接。导致超出默认最大连接数1000 。所以无法再有连接队列,导致队列无法连接
发生这个错误,去检查下自己代码,是否是每次都创建一个连接,而没有关闭连接。
一般分为两种连接
一种是长连接,适用于处于一值发送数据,
一种短连接,就是连接了,发送完数据,就关闭连接