第 6 章 网络连接

由于客户端直到第一次连接到 HA 集群后才会收到每个代理的信息，因此有一个时间窗口，客户端只能连接到连接 URI 中包含的代理。因此，如果初始连接期间发生故障，客户端无法切换到其他 master 代理，只能尝试重新建立初始连接。可以为一组重新连接尝试数配置客户端。尝试次数之后，将引发异常。

设置重新连接尝试数

以下示例演示了如何使用 AMQ 核心协议 JMS 客户端将重新连接尝试数设置为 3。默认值为 0，即，只尝试一次。

ConnectionFactory cf =  ActiveMQJMSClient.createConnectionFactory(...)
cf.setInitialConnectAttempts(3);

ConnectionFactory cf =  ActiveMQJMSClient.createConnectionFactory(...)
cf.setInitialConnectAttempts(3);

设置全局重新连接尝试数

另外，您可以为代理配置中的最大重新连接尝试数应用全局值。最大值将应用到所有客户端连接。

<configuration>
 <core>
  ...
  <initial-connect-attempts>3</initial-connect-attempts> 
  ...
 </core>
</configuration>

<configuration>
 <core>
  ...
  <initial-connect-attempts>3</initial-connect-attempts> 

  ...
 </core>
</configuration>

当发生故障转移时，客户端正在等待代理的响应继续执行，新创建的会话不知道该调用正在进行中。否则，初始调用可能会永远挂起，等待绝不会发出的响应。为防止这种情况，代理被设计为通过抛出异常来取消阻止任何在故障转移时正在进行中的调用。客户端代码可以捕获这些异常，并在需要时重试任何操作。

使用 AMQ 核心协议 JMS 客户端时，如果未阻塞的方法是调用 commit() 或 prepare()，则会自动回滚事务，代理抛出异常。

使用 AMQ 核心协议 JMS 客户端时，如果会话是事务性的，并且消息已在当前事务中发送或确认，代理无法确定这些消息或者在故障转移过程中丢失了这些消息。因此，事务被标记为回滚。任何后续尝试提交它都会抛出 javax.jms.TransactionRolledBackException。

AMQ 核心协议 JMS 客户端代码必须捕获异常并执行任何必要的客户端侧回滚。不过，不需要回滚会话，因为它已经回滚。然后，用户可以在同一会话中再次重试事务操作。

如果在执行提交调用时发生故障转移，代理会取消阻塞调用，以防止 AMQ 核心协议 JMS 客户端无限期等待响应。因此，在出现故障前，客户端无法确定事务提交是否真正在 master 代理上处理。

为补救这一点，AMQ 核心协议 JMS 客户端可以在事务中启用重复检测，并在未阻塞调用后重试事务操作。如果在故障转移前在 master 代理上成功提交事务，重复检测可确保在代理一侧忽略事务中的任何持久消息。这可防止发送多次消息。

如果会话非事务性，则在故障转移时可能会丢失消息或确认。如果您要为非转换会话 提供一次且仅一次 的保证，请启用重复检测并捕获未阻塞异常。

JMS 提供了一种标准机制，用于获得异步连接失败通知： java.jms.ExceptionListener。

当连接失败时，代理会始终调用 ExceptionListener 或 SessionFailureListener 实例，无论连接是成功通过、重新连接还是重新附加。您可以通过检查 SessionFailureListener 上在 connectionFailed 中传递的 failedOver 标记来找出是否发生了重新连接或重新附加。另外，您可以检查 javax.jms.JMSException 的错误代码，可以是以下之一：