当 ActiveMQ 在类路径上可用时，Spring Boot 可以配置 ConnectionFactory。如果代理存在，则会自动启动和配置嵌入式代理（如果没有通过配置指定代理 URL）。

ActiveMQ 配置由 Spring 中的外部配置属性 spring.activemq.* 控制。例如，你可以在 application.properties 声明以下部分:

spring.activemq.broker-url=tcp://192.168.1.210:9876
spring.activemq.user=admin
spring.activemq.password=secret

默认情况下，CachingConnectionFactory 将本地 ConnectionFactory 封装为可以通过 Spring 中的外部配置属性 spring.jms.* 控制的合理设置。

spring.jms.cache.session-cache-size=5

如果你愿意使用本地池，可以通过向 org.apache.activemq:activemq-jms-pool 添加依赖项并相应地配置 PooledConnectionFactory 来实现这一点，如下面的示例所示：

spring.activemq.pool.enabled=true
spring.activemq.pool.max-connections=50

默认情况下，ActiveMQ 创建一个目的地，如果它还不存在，那么目的地是根据其提供的名称来解决的。

当 Spring Boot 检测到 Artemis 在类路径上可用时，它会自动配置 ConnectionFactory。如果代理存在，则会自动启动和配置嵌入代理（除非已显式设置了模式属性）。所支持的模式是 embedded（明确表示需要嵌入代理，并且代理在类路径上不可用时，应该发生错误）和 native（使用 netty 传输协议连接到代理）。当后者被配置时，Spring Boot 配置连接到本地机器上运行的代理的 ConnectionFactory，并具有默认设置。

Artemis 配置由 spring.artemis.* 中的外部配置属性控制。例如，你可以在 application.properties 中添加以下部分：

spring.artemis.mode=native
spring.artemis.host=192.168.1.210
spring.artemis.port=9876
spring.artemis.user=admin
spring.artemis.password=secret

在嵌入代理时，可以选择是否启用持久性，并列出应该使用的目的地。这些可以被指定为逗号分隔的列表，用默认选项创建它们，或者可以定义 org.apache.activemq.artemis.jms.server.config.JMSQueueConfiguration 或 org.apache.activemq.artemis.jms.server.config.TopicConfiguration 类型的 bean，分别用于高级队列和主题配置。

默认情况下，CachingConnectionFactory 将本地 ConnectionFactory 封装为可以通过 spring.jms.* 的外部配置属性控制的敏感设置。

spring.jms.cache.session-cache-size=5

如果你愿意使用本地池，可以通过向 org.apache.activemq:activemq-jms-pool 添加依赖项并相应地配置 PooledConnectionFactory 来实现这一点，如下面的示例所示：

spring.artemis.pool.enabled=true
spring.artemis.pool.max-connections=50

更多支持的选项请参阅 ArtemisProperties。

不涉及 JNDI 查找，并且使用 Artemis 配置中的 name 属性或通过配置提供的名称来解决目的地对它们的名称。

如果在应用服务器中运行应用程序，Spring Boot 将尝试使用 JNDI 定位 JMS ConnectionFactory。默认情况下，检查 java:/JmsXA 和 java:/XAConnectionFactory 位置。如果需要指定另一个位置，可以使用 spring.jms.jndi-name 属性，如下面的示例所示：

spring.jms.jndi-name=java:/MyConnectionFactory

Spring 的 JmsTemplate 是自动配置的，你可以直接将它自动存储到你自己的 bean 中，如下面的示例所示：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class MyBean {

	private final JmsTemplate jmsTemplate;

	@Autowired
	public MyBean(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	// ...

}

当 JMS 基础结构存在时，任何 bean 都可以用 @JmsListener 注解来创建监听器端点。如果没有定义 JmsListenerContainerFactory，默认自动配置一个。如果定义了 DestinationResolver 或 MessageConverter bean，它将自动关联到默认工厂。

默认情况下，默认的工厂是事务性的。如果运行在存在 JtaTransactionManager 的基础结构中，则默认情况下它与监听器容器关联。如果没有，则启用 sessionTransacted 标志。在后一种情况下，你可以将本地数据存储事务与传入消息的处理相关联，通过在监听器方法（或其委托）中添加 @Transactional。这确保一旦本地事务完成，传入消息就被确认。这还包括发送已在同一 JMS 会话上执行的响应消息。

下面的组件在 someQueue 目的地上创建监听器端点：

@Component
public class MyBean {

	@JmsListener(destination = "someQueue")
	public void processMessage(String content) {
		// ...
	}

}

如果你需要创建更多的 JmsListenerContainerFactory 实例，或者想要重写默认值，Spring Boot 提供了一个 DefaultJmsListenerContainerFactoryConfigurer 以便你可以使用它初始化一个与自动配置的设置相同的 DefaultJmsListenerContainerFactory。

例如，下面的示例使用特定 MessageConverter 暴露另一个工厂：

@Configuration
static class JmsConfiguration {

	@Bean
	public DefaultJmsListenerContainerFactory myFactory(
			DefaultJmsListenerContainerFactoryConfigurer configurer) {
		DefaultJmsListenerContainerFactory factory =
				new DefaultJmsListenerContainerFactory();
		configurer.configure(factory, connectionFactory());
		factory.setMessageConverter(myMessageConverter());
		return factory;
	}

}

然后，你可以在任何 @JmsListener 注解方法中使用该工厂，如下：

@Component
public class MyBean {

	@JmsListener(destination = "someQueue", containerFactory="myFactory")
	public void processMessage(String content) {
		// ...
	}

}

RabbitMQ 是基于 AMQP 协议的轻量级的、可靠的、可扩展的、可移植的消息代理。Spring 使用 RabbitMQ 通过 AMQP 协议进行通信。

RabbitMQ 配置是由外部配置 spring.rabbitmq.* 属性控制的。例如，你可以在 application.properties 中声明以下部分:

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=secret

如果上下文中存在一个 ConnectionNameStrategy bean，它将被自动用于由自动配置的 ConnectionFactory 创建的名称连接。有关更多支持的选项，请参阅 RabbitProperties。

Spring 的 AmqpTemplate 和 AmqpAdmin 是自动配置的，你可以直接将他们自动存储到你自己的 bean 中，如下面的示例所示；

import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MyBean {

	private final AmqpAdmin amqpAdmin;
	private final AmqpTemplate amqpTemplate;

	@Autowired
	public MyBean(AmqpAdmin amqpAdmin, AmqpTemplate amqpTemplate) {
		this.amqpAdmin = amqpAdmin;
		this.amqpTemplate = amqpTemplate;
	}

	// ...

}

如果需要，任何定义为 bean 的 org.springframework.amqp.core.Queue，将被自动用于在 RabbitMQ 实例上声明相应的队列。

若要重试操作，你可以在 AmqpTemplate 上启用重试（例如，在代理连接丢失的情况下）。默认情况下，重试被禁用。

当 Rabbit 基础设施存在时，任何 bean 都可以使用 @RabbitListener 注解来创建监听器端点。如果没有 bean 定义 RabbitListenerContainerFactory，默认的 SimpleRabbitListenerContainerFactory 将被自动配置，并且你可以使用 spring.rabbitmq.listener.type 属性切换到直接的容器。如果定义了 MessageConverter 或 MessageRecoverer bean，它将自动与默认工厂关联。

下面的示例组件在 someQueue 队列上创建监听器端点：

@Component
public class MyBean {

	@RabbitListener(queues = "someQueue")
	public void processMessage(String content) {
		// ...
	}

}

如果你需要创建更多的 RabbitListenerContainerFactory 实例或想重写默认值，Spring Boot 提供了一个 SimpleRabbitListenerContainerFactoryConfigurer 和 DirectRabbitListenerContainerFactoryConfigurer，以便你使用与自动配置工厂相同的设置来初始化一个 SimpleRabbitListenerContainerFactory 和 DirectRabbitListenerContainerFactory。

例如，下面的配置类使用特定的 MessageConverter 暴露另一个工厂：

@Configuration
static class RabbitConfiguration {

	@Bean
	public SimpleRabbitListenerContainerFactory myFactory(
			SimpleRabbitListenerContainerFactoryConfigurer configurer) {
		SimpleRabbitListenerContainerFactory factory =
				new SimpleRabbitListenerContainerFactory();
		configurer.configure(factory, connectionFactory);
		factory.setMessageConverter(myMessageConverter());
		return factory;
	}

}

然后，你可以在任何 @RabbitListener 注解的方法中使用该工厂，如下：

@Component
public class MyBean {

	@RabbitListener(queues = "someQueue", containerFactory="myFactory")
	public void processMessage(String content) {
		// ...
	}

}

你可以启用重试来处理监听器抛出异常的情况。默认情况下，使用 RejectAndDontRequeueRecoverer，但可以定义你自己的 MessageRecoverer。如果代理被配置为这样，当重试被耗尽时则消息被拒绝，并丢弃或路由到死信交换。默认情况下，重试被禁用。

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=myGroup

Spring 的 KafkaTemplate 是自动配置的，你可以直接在自己的 bean 中自动调用它，如下面的示例所示：

@Component
public class MyBean {

	private final KafkaTemplate kafkaTemplate;

	@Autowired
	public MyBean(KafkaTemplate kafkaTemplate) {
		this.kafkaTemplate = kafkaTemplate;
	}

	// ...

}

当 Apache Kafka 基础结构存在时，任何 bean 都可以用 @KafkaListener 注解以创建监听器端点。如果没有定义 KafkaListenerContainerFactory，则自动配置一个定义为 spring.kafka.listener.* 关键字的默认工厂。此外，如果定义了一个 RecordMessageConverter bean，它将自动关联到默认工厂。

下面的组件在 someTopic 主题上创建一个监听器端点：

@Component
public class MyBean {

	@KafkaListener(topics = "someTopic")
	public void processMessage(String content) {
		// ...
	}

}

由自动配置支持的属性在附录 A, 常见的应用程序属性中展示。请注意，在大多数情况下，这些属性（连接符的或驼峰式）直接映射到 Apache Kafka 点属性。更多详细信息请参阅 Apache Kafka 文档。

这些属性中的前几个应用于生产者和消费者，但如果希望对每个用户使用不同的值，则可以在生产者或消费者级别指定。Apache Kafka 指定具有 HIGH, MEDIUM, 或 LOW 的重要性的属性。Spring Boot 自动配置支持所有 HIGH 重要性的属性，一些选定的 MEDIUM 和 LOW 的属性，以及任何没有默认值的属性。

只有 Kafka 支持的属性子集可以通过 KafkaProperties 类获得。如果你希望配置具有不直接支持的额外属性的生产者或消费者，请使用以下属性：

spring.kafka.properties.prop.one=first
spring.kafka.admin.properties.prop.two=second
spring.kafka.consumer.properties.prop.three=third
spring.kafka.producer.properties.prop.four=fourth

这就设置了，公共 prop.one Kafka 属性为 first（适用于生产者、消费者和管理员），prop.two admin 属性为 second，prop.three 消费者属性为 third，以及 prop.four 提供者属性为 fourth。

你还可以配置 Spring Kafka JsonDeserializer 如下：

spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.value.default.type=com.example.Invoice
spring.kafka.consumer.properties.spring.json.trusted.packages=com.example,org.acme

类似的，你可以在头文件中发送类型信息时禁用 JsonSerializer 的默认行为。

spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.producer.properties.spring.json.add.type.headers=false