activemq自动重连

在使用 ActiveMQ 进行消息传递时，可能会遇到连接断开的情况，此时可以采用自动重连机制来保证消息传输的可靠性。在 ActiveMQ 中，可以通过配置 ConnectionFactory 对象来实现自动重连。

具体操作步骤如下：

1. 创建 ConnectionFactory 对象时，设置其属性，例如：

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
connectionFactory.setUserName(username);
connectionFactory.setPassword(password);
connectionFactory.setRedeliveryPolicy(redeliveryPolicy);

其中，`url` 是连接 ActiveMQ 的 URL，`username` 和 `password` 是登录 ActiveMQ 的用户名和密码，`redeliveryPolicy` 是重发策略对象。

2. 设置重连策略，例如：

RedeliveryPolicy redeliveryPolicy = connectionFactory.getRedeliveryPolicy();
redeliveryPolicy.setInitialRedeliveryDelay(1000);
redeliveryPolicy.setBackOffMultiplier(2);
redeliveryPolicy.setMaximumRedeliveryDelay(30000);
redeliveryPolicy.setUseExponentialBackOff(true);
connectionFactory.setRedeliveryPolicy(redeliveryPolicy);

其中，`InitialRedeliveryDelay` 是初始重发延迟时间，`BackOffMultiplier` 是指数退避系数，`MaximumRedeliveryDelay` 是最大重发延迟时间，`UseExponentialBackOff` 表示是否使用指数退避算法。

3. 创建 Connection 对象时，设置其异常监听器，例如：

connection.setExceptionListener(new ExceptionListener() {
    @Override
    public void onException(JMSException exception) {
        // 处理连接异常，例如重新连接
    }
});

其中，`onException()` 方法会在连接异常时被调用，可以在该方法中处理连接异常，例如重新连接。

通过以上步骤，即可实现 ActiveMQ 的自动重连功能。