本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

Amazon MQ for ActiveMQ 最佳实践

以此作为参考快速找到在 Amazon MQ 上使用 ActiveMQ 代理时最大程度提高性能和降低吞吐量成本的建议。

永远不要修改或删除 Amazon MQ 弹性网络接口

当您首次创建 Amazon MQ 代理时，Amazon MQ 会在您的账户下的虚拟私有云 VPC () 中配置一个弹性网络接口，因此需要一些权限。EC2该网络接口允许您的客户端（创建者或使用者）与 Amazon MQ 代理通信。尽管网络接口属于您的账户，但仍被视为在 Amazon MQ 的服务范围内。VPC

始终使用连接池

在使用单个创建者和单个使用者的方案（例如 入门：创建并连接 ActiveMQ 代理 教程），您可以将单个 ActiveMQConnectionFactory 类用于每个创建者和使用者。例如：

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Establish a connection for the consumer.
final Connection consumerConnection = connectionFactory.createConnection();
consumerConnection.start();

但是，在具有多个创建者和使用者的更真实的方案中，为多个创建者创建大量连接可能成本高昂，并且效率低下。在这些方案中，您应使用 PooledConnectionFactory 类将多个创建者请求分组。例如：

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Create a pooled connection factory.
final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(connectionFactory);
pooledConnectionFactory.setMaxConnections(10);

// Establish a connection for the producer.
final Connection producerConnection = pooledConnectionFactory.createConnection();
producerConnection.start();

始终使用故障转移传输连接到多个代理终端节点

如果应用程序需要连接到多个代理终端节点，例如，当您使用主/备用部署模式或者从本地消息代理迁移到 Amazon MQ 时，使用故障转移传输以允许您的使用者随机连接到一个。例如：

failover:(ssl://b-1234a5b6-78cd-901e-2fgh-3i45j6k178l9-1.mq.us-east-2.amazonaws.com:61617,ssl://b-9876l5k4-32ji-109h-8gfe-7d65c4b132a1-2.mq.us-east-2.amazonaws.com:61617)?randomize=true

避免使用消息选择器

可以使用JMS选择器将过滤器附加到主题订阅（根据消费者的内容将消息路由给消费者）。但是，使用JMS选择器会填满 Amazon MQ 经纪商的筛选缓冲区，使其无法筛选消息。

一般来说，应避免让使用者路由消息，这样做的原因是，为了实现使用者和创建者的最佳解耦，使用者和创建者均应是短暂存在的。

首选虚拟目标而非持久订阅

持久订阅可帮助确保使用者收到发布到主题的所有消息，例如，在恢复丢失的连接后。但是，使用持久订阅还阻止竞争性使用者使用并可能具有大规模性能问题。考虑改用虚拟目标。

如果使用 Amazon VPC 对等互连，请避开IPs位于范围内的CIDR客户端 10.0.0.0/16

如果您要在本地基础设施和 Ama VPC zon MQ 代理之间设置 Amazon 对等互连，则不得在范围内配置客户端连接IPs。CIDR 10.0.0.0/16

对具有慢速使用者的队列禁用并发存储和分派

默认情况下，Amazon MQ 针对具有快速使用者的队列进行优化：

要指示 Amazon MQ 针对具有慢速使用者的队列进行优化，请将 concurrentStoreAndDispatchQueues 属性设置为 false。有关示例配置，请参阅 concurrentStoreAndDispatchQueues。

选择正确的代理实例类型以实现最佳吞吐量

代理实例类型的消息吞吐量取决于应用程序的使用案例和以下因素：

了解消息大小、延迟和吞吐量之间的关系

根据您的使用案例，较大的代理实例类型不一定能提高系统吞吐量。当 ActiveMQ 将消息写入持久存储中，消息的大小决定了系统的限制因素：

当您在持久模式下使用 ActiveMQ 时，通常会在使用者较少或使用者较慢的情况下发生写入存储。在非持久模式下，如果代理实例的堆内存已满，则也会在使用者较慢的情况下发生写入存储。

要为您的应用程序确定最佳代理实例类型，我们建议您测试不同的代理实例类型。有关更多信息，请参阅Broker instance types并使用基准测试衡量 Amazon MQ 的吞吐量。JMS

较大代理实例类型的使用案例

当较大代理实例类型提高吞吐量时，存在以下三个常见使用案例：

选择正确的代理存储类型以实现最佳吞吐量

要利用高耐久性和跨多个可用区复制的优势，请使用 Amazon EFS。要充分利用低延迟和高吞吐量的优势，请使用 Amazon EBS。有关更多信息，请参阅 Storage。

正确配置您的代理网络

当您创建代理网络时，请为您的应用程序正确配置它：

通过恢复已准备 XA 事务避免缓慢重

ActiveMQ 支持分布式 (XA) 事务。了解 ActiveMQ 如何处理 XA 事务有助于避免 Amazon MQ 中代理重启和故障转移的缓慢恢复时间

每次重启时都会重放未解析的已准备 XA 事务。如果这些问题仍未被解析，其数量将随着时间的推移而增长，从而显著增加启动代理所需的时间。这会影响重启和故障转移时间。您必须使用 commit() 或 rollback() 解析这些事务，以便性能不会随着时间的推移而降低。

要监控未处理的准备的 XA 交易，您可以使用 Amazon CloudWatch Logs 中的JournalFilesForFastRecovery指标。如果该数字不断增加，或者始终高于 1，则应使用类似于以下示例的代码恢复未解析的事务。有关更多信息，请参阅 Quotas in Amazon MQ。

以下示例代码遍历已准备 XA 事务，并使用 rollback() 关闭它们。

import org.apache.activemq.ActiveMQXAConnectionFactory;

import javax.jms.XAConnection;
import javax.jms.XASession;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;

public class RecoverXaTransactions {
    private static final ActiveMQXAConnectionFactory ACTIVE_MQ_CONNECTION_FACTORY;
    final static String WIRE_LEVEL_ENDPOINT =
            "tcp://localhost:61616";;
    static {
        final String activeMqUsername = "MyUsername123";
        final String activeMqPassword = "MyPassword456";
        ACTIVE_MQ_CONNECTION_FACTORY = new ActiveMQXAConnectionFactory(activeMqUsername, activeMqPassword, WIRE_LEVEL_ENDPOINT);
        ACTIVE_MQ_CONNECTION_FACTORY.setUserName(activeMqUsername);
        ACTIVE_MQ_CONNECTION_FACTORY.setPassword(activeMqPassword);
    }

    public static void main(String[] args) {
        try {
            final XAConnection connection = ACTIVE_MQ_CONNECTION_FACTORY.createXAConnection();
            XASession xaSession = connection.createXASession();
            XAResource xaRes = xaSession.getXAResource();

            for (Xid id : xaRes.recover(XAResource.TMENDRSCAN)) {
                xaRes.rollback(id);
            }
            connection.close();

        } catch (Exception e) {          
        }
    }
}

在实际场景中，您可以针对 XA 事务管理器检查已准备 XA 事务。然后，您可以使用 rollback() 或 commit() 来决定是否处理每个已准备事务。