SimpleMessageListenerContainer - 使用者引发的异常，如果连接工厂支持，处理可以重新启动
我一直得到以下警告在我的SpringRabbitmq消费者方面。它一直在寻找重新启动。
[SimpleAsyncTaskExecutor-3317] WARN org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: connection error
at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:715)
at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:705)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:567)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:189)
at java.net.SocketInputStream.read(SocketInputStream.java:121)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532)
... 1 more
和
[SimpleAsyncTaskExecutor-3316] INFO org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Restarting Consumer: tags=[[amq.ctag-0o_AANjD6-IsH8H3MGWNnQ]], channel=Cached Rabbit Channel: AMQChannel, acknowledgeMode=AUTO local queue size=0
2016-02-28 06:06:58,634 334085996 [SimpleAsyncTaskExecutor-3317] INFO org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Restarting Consumer: tags=[[amq.ctag-RXsch0v9cjuRlEB-ck1Lvg]], channel=Cached Rabbit Channel: AMQChannel, acknowledgeMode=AUTO local queue size=0
2016-02-28 06:06:58,651 334086013 [SimpleAsyncTaskExecutor-3318] WARN org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: connection error
共有2个答案
查看服务器日志-服务器出于某种原因强制关闭（重置）连接。
如果您看到下面的异常
java.net.SocketException: Connection reset at java.net.SocketInputStream.read(SocketInputStream.java:189) at java.net.SocketInputStream.read(SocketInputStream.java:121) at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) at java.io.BufferedInputStream.read(BufferedInputStream.java:265) at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288) at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532)
这意味着您正在关闭消费者，而不停止它。
-
System.ObjectDisposedException：无法访问已释放的对象。对象名称：“System.net.Sockets.NetworkStream”。在system.net.sockets.networkstream.read(Byte[]缓冲区，Int32偏移量，Int32大小） 我的问题是我做错了什么？以及重新连接到服务器的最佳解决方案是什么？我的代码如下所示：
-
我有一个循环缓冲区（数组/先进先出），一个消费者和一个生产者。生产者将随机数放入数组中，消费者获取第一个数字并检查它是否是相对素数。 我的代码工作正常，我认为它工作正常，但我想改进它。我不太确定我的“空运行”方法。我应该在其他地方做异常处理吗？改变“无限循环”？不应更改方法签名（它们是预定义的）。 我会很高兴每一个改进代码的建议。(不在乎知名度(公开，...)，还有静态的东西，我刚刚把它们放在一个
-
问题内容： （下面的示例代码是独立且可运行的，您可以尝试一下，它不会使系统崩溃：） Tom Hawtin在这里评论了这个问题：为什么人们在事件队列上运行JavaGUI 那： EDT不太可能崩溃。 EDT调度中抛出的未经检查的异常将被捕获，转储并且线程继续运行。 有人可以解释一下这是怎么回事（每次您单击 “引发未经检查的异常” 按钮时，都会有意除以零）： 我收到以下消息（这是我期望的）： 对我来说，
-
问题内容： 考虑以下示例： 这将输出从1到5的数字，然后打印异常。 我要实现的是使观察者保持订阅状态，并在引发异常后继续运行，即打印从1到10的所有数字。 我曾尝试使用和其他各种错误处理运算符，但是，正如文档中所述，它们的目的是处理可观察对象自身发出的错误。 最直接的解决方案是将整个过程包装到try- catch块中，但这对我来说似乎不是一个好的解决方案。在类似的Rx.NET问题中，提出的解决方案
-
所以，场景是我正在做一些数据库操作，最后提交/回滚，然后连接关闭。但是连接关闭也会抛出SQLException。 在这种情况下，最好的方法是什么？ 捕获并记录它。 捕获并抛出异常，以便调用函数可以处理它 在#1的情况下，调用函数永远不会知道出了问题。
-
我们正在将Redis堆栈迁移到Redis集群。 在我们应用程序的某些部分，这意味着我们必须用JedisCluster对象替换Jedis对象。 在我们的Spring客户端中，我们使用JedisConnectionFactory将会话持久化到redis。但是，此类似乎不支持JedisCluster。 有没有想过如何将Spring应用程序连接到Redis集群？ 我注意到这个工厂实现了RedisConne