|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring AMQP 3.2.6！ |
为不耐烦的人提供快速游览
介绍
这是开始使用 Spring AMQP 的五分钟游览。
前提条件：安装并运行 RabbitMQ 代理 （https://www.rabbitmq.com/download.html）。 然后获取 spring-rabbit JAR 及其所有依赖项 - 最简单的方法是在构建工具中声明依赖项。 例如，对于 Maven，您可以执行类似于以下作：
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>4.0.0-M4</version>
</dependency>对于 Gradle，您可以执行类似于以下作的作：
compile 'org.springframework.amqp:spring-rabbit:4.0.0-M4'兼容性
最低 Spring Framework 版本依赖项为 6.1.0。
最低限度amqp-clientJava 客户端库版本为 5.18.0。
最低限度stream-client流队列的 Java 客户端库是 0.12.0。
非常非常快
本节提供最快的介绍。
首先，添加以下内容import使本节后面的示例起作用的语句：
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;以下示例使用纯命令式 Java 发送和接收消息：
ConnectionFactory connectionFactory = new CachingConnectionFactory();
AmqpAdmin admin = new RabbitAdmin(connectionFactory);
admin.declareQueue(new Queue("myqueue"));
AmqpTemplate template = new RabbitTemplate(connectionFactory);
template.convertAndSend("myqueue", "foo");
String foo = (String) template.receiveAndConvert("myqueue");请注意，还有一个ConnectionFactory在本机 Java Rabbit 客户端中。
我们在前面的代码中使用了 Spring 抽象。
它缓存通道（以及可选的连接）以供重用。
我们依赖于代理中的默认交换（因为在发送中没有指定任何交换），以及所有队列按其名称默认绑定到默认交换（因此，我们可以使用队列名称作为发送中的路由键）。
这些行为在 AMQP 规范中定义。
使用 XML 配置
以下示例与前面的示例相同，但将资源配置外部化为 XML：
ApplicationContext context =
new GenericXmlApplicationContext("classpath:/rabbit-context.xml");
AmqpTemplate template = context.getBean(AmqpTemplate.class);
template.convertAndSend("myqueue", "foo");
String foo = (String) template.receiveAndConvert("myqueue");<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/rabbit
https://www.springframework.org/schema/rabbit/spring-rabbit.xsd
http://www.springframework.org/schema/beans
https://www.springframework.org/schema/beans/spring-beans.xsd">
<rabbit:connection-factory id="connectionFactory"/>
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"/>
<rabbit:admin connection-factory="connectionFactory"/>
<rabbit:queue name="myqueue"/>
</beans>默认情况下，<rabbit:admin/>声明自动查找类型Queue,Exchange和Binding并代表用户向代理声明它们。
因此，您无需在简单的 Java 驱动程序中显式使用该 bean。
有很多选项可以配置 XML 架构中组件的属性。
您可以使用 XML 编辑器的自动完成功能来浏览它们并查看它们的文档。
使用 Java 配置
以下示例重复与前面示例相同的示例，但使用Java中定义的外部配置：
ApplicationContext context =
new AnnotationConfigApplicationContext(RabbitConfiguration.class);
AmqpTemplate template = context.getBean(AmqpTemplate.class);
template.convertAndSend("myqueue", "foo");
String foo = (String) template.receiveAndConvert("myqueue");
........
@Configuration
public class RabbitConfiguration {
@Bean
public CachingConnectionFactory connectionFactory() {
return new CachingConnectionFactory("localhost");
}
@Bean
public RabbitAdmin amqpAdmin() {
return new RabbitAdmin(connectionFactory());
}
@Bean
public RabbitTemplate rabbitTemplate() {
return new RabbitTemplate(connectionFactory());
}
@Bean
public Queue myQueue() {
return new Queue("myqueue");
}
}使用 Spring Boot 自动配置和异步 POJO 监听器
Spring Boot 自动配置基础架构 bean，如以下示例所示：
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Bean
public ApplicationRunner runner(AmqpTemplate template) {
return args -> template.convertAndSend("myqueue", "foo");
}
@Bean
public Queue myQueue() {
return new Queue("myqueue");
}
@RabbitListener(queues = "myqueue")
public void listen(String in) {
System.out.println(in);
}
}