文章目录

Spring框架的重连机制研究

Spring提供了2个MDP容器:org.springframework.jms.listener.DefaultMessageListenerContainer、org.springframework.jms.listener.SimpleMessageListenerContainer。

DefaultMessageListenerContainer重连机制

DefaultMessageListenerContainer启动内部类AsyncMessageListenerInvoker作为线程。

DefaultMessageListenerContainer重连机制

当run()出现异常,则间隔5秒做一次重连尝试,直到成功。

DefaultMessageListenerContainer重连机制

DefaultMessageListenerContainer重连机制

DefaultMessageListenerContainer重连机制

SimpleMessageListenerContainer重连机制

SimpleMessageListenerContainer 注册JMSException监听,当出现异常时,在onException中做重连。

SimpleMessageListenerContainer重连机制

问题是,如果连接不成功,则没有再次重连的机制,因此容错能力较弱

文章目录