activemq 重新连接的机制

最近一个项目要用到ActiveMq，并且需要最大程度的保证消息不丢失。以前对activeMq不是很熟悉，完全是摸着石头过河，目前基本配置都搞定了。只是对于它的自动重连一直找不到好的解决办法，我希望的效果是当一个broker（假设只有这一个，没有备用的）如果异常down掉的话，那么监听程序能够等待broker重启后再自动重新连接。看了它的文档似乎 设置一下failover:(tcp://localhost:61616） 就可以了

 

Failover Transport
    Failover Transport是一种重新连接的机制，它工作于其它transport的上层，用于建立可靠的传输。它的配置语法允许制定任意多个复合的URI。 Failover transport会自动选择其中的一个URI来尝试建立连接。如果没有成功，那么会选择一个其它的URI来建立一个新的连接。以下是配置语法：
    failover:(uri1,...,uriN)?transportOptions
    failover:uri1,...,uriN
    Transport Options的可选值如下：
Option Name Default Value Description
initialReconnectDelay 10 How long to wait before the first reconnect attempt (in ms)
maxReconnectDelay 30000 The maximum amount of time we ever wait between reconnect attempts (in ms)
useExponentialBackOff true Should an exponential backoff be used between reconnect attempts
backOffMultiplier 2 The exponent used in the exponential backoff attempts
maxReconnectAttempts 0 If not 0, then this is the maximum number of reconnect attempts before an error is sent back to the client
randomize true use a random algorithm to choose the URI to use for reconnect from the list provided
backup false initialize and hold a second transport connection - to enable fast failover
   例如：failover:(tcp://localhost:61616,tcp://remotehost:61616)?initialReconnectDelay=100

2．2．4 Discovery transport
    Discovery transport是可靠的tranport。它使用Discovery transport来定位用来连接的URI列表。以下是配置语法：
    discovery:(discoveryAgentURI)?transportOptions
    discovery:discoveryAgentURI
    Transport Options的可选值如下：
Option Name Default Value Description
initialReconnectDelay 10 How long to wait before the first reconnect attempt
maxReconnectDelay 30000 The maximum amount of time we ever wait between reconnect attempts
useExponentialBackOff true Should an exponential backoff be used btween reconnect attempts
backOffMultiplier 2 The exponent used in the exponential backoff attempts
maxReconnectAttempts 0 If not 0, then this is the maximum number of reconnect attempts before an error is sent back to the client
   例如：discovery:(multicast://default)?initialReconnectDelay=100  
    为了使用Discovery来发现broker，需要为broker启用discovery agent。 以下是XML配置文件中的一个例子：
Xml代码 
1. <broker name="foo"> 
2.    <transportConnectors> 
3.       <transportConnector uri="tcp://localhost:0" discoveryUri="multicast://default"/> 
4.     </transportConnectors> 
5.     ... 
6. </broker> 
   在使用Failover Transport或Discovery transport等能够自动重连的transport的时候，需要注意的是：设想有两个broker，它们都启用AMQ Message Store作为持久化存储，有一个producer和一个consumer连接到某个queue。当因其中一个broker失效时而切换到另一个 broker的时候，如果失效的broker的queue中还有未被consumer消费的消息，那么这个queue里的消息仍然滞留在失效broker 的中，直到失效的broker被修复并重新切换回这个被修复的broker后，之前被保留的消息才会被consumer消费掉。如果被处理的消息有时序限 制，那么应用程序就需要处理这个问题。另外也可以通过ActiveMQ集群来解决这个问题。
   在transport重连的时候，可以在connection上注册TransportListener来获得回调，例如：
Java代码 
1. (ActiveMQConnection)connection).addTransportListener(new TransportListener() { 
2.     public void onCommand(Object cmd) { 
3.     } 
4.  
5.     public void onException(IOException exp) { 
6.     } 
7.  
8.     public void transportInterupted() { 
9.         // The transport has suffered an interruption from which it hopes to recover. 
10.     } 
11.  
12.     public void transportResumed() { 
13.         // The transport has resumed after an interruption. 
14.     } 
15. }); 

---------------------

我的做法是 不要在服务器端设置,而在本地设置:failover:(tcp://192.168.0.245:61616?wireFormat.maxInactivityDuration=0)

评论

4 楼 bluseli 2012-12-31  

这位大神，请教下MQ，关于数据库存储，默认配置是200个线程，但是目前只看到2个线程在跑。不知道什么原因，请赐教

失败重连机制。failover我是配置在具体的客户端的。但是生产者貌似在MQ断掉之后不会去尝试重连。消费者（我这里是订阅主题监听方式）是可以尝试重练的。（还有，这个跟配置的MQ服务的个数有关系吗？）请指教。非常感谢。

3 楼 smile_wangchun 2012-11-02  

(ActiveMQConnection)connection).
您不觉得代码错了吗

2 楼 wwm4851186 2008-10-17  

failover(tcp://192.168.0.245:61616wireFormat.maxInactivityDuration=0)
该怎么用，能给个例子吗？

1 楼 log_cd 2008-09-25  

failover:(tcp://192.168.0.245:61616?wireFormat.maxInactivityDuration=0)这样配置后，如果ActiveMQ没有启动，它们一直重连，应用服务好像不能启动(我用的resin)，如果一开始ActiveMQ启动的，然后停掉，此时停resin服务时也会报1053错误。
请问有什么解决办法 ?