(转)Spring AMQP-快速入门

• Spring AMQP项目介绍

Spring AMQP项目将Spring的核心思想应用于基于AMQP的消息解决方案的开发上。它提供了“template”这个高度抽象来发送和接收信息。它同样提供了消息驱动的实体，这些实体存在于“listener container”容器中。这些库不但使得AMQP资源的管理变得容易，与此同时促进了依赖注入和声明式配置的使用。在所有的情况下，你将看到许多Spring框架提供的类似于JMS的便利。

这个项目包含两部分：

1、spring-amqp的基础抽象；

2、spring-rabbit这个RabbitMQ的实现

特点：

1、异步处理没有绑定消息的监听容器；

2、RabbitTemplate发送和接收消息；

3、RabbitAdmin自动声明队列，交换和绑定。

 

• Spring AMQP快速入门

推荐开始在你的项目中使用spring-amqp的快捷方式是使用依赖管理系统，例如Maven和Gradle，配置片段如下：

1. <dependencies>
2. <dependency>
3. <groupId>org.springframework.amqp</groupId>
4. <artifactId>spring-rabbit</artifactId>
5. <version>1.4.0.RELEASE</version>
6. </dependency>
7. </dependencies>

使用Java编码的方式：

1. publicstaticvoid main(finalString... args)throwsException{
3. ConnectionFactory cf =newCachingConnectionFactory();
5. // set up the queue, exchange, binding on the broker
6. RabbitAdmin admin =newRabbitAdmin(cf);
7. Queue queue =newQueue("myQueue");
8. admin.declareQueue(queue);
9. TopicExchange exchange =newTopicExchange("myExchange");
10. admin.declareExchange(exchange);
11. admin.declareBinding(
12. BindingBuilder.bind(queue).to(exchange).with("foo.*"));
14. // set up the listener and container
15. SimpleMessageListenerContainer container =
16. newSimpleMessageListenerContainer(cf);
17. Object listener =newObject(){
18. publicvoid handleMessage(String foo){
19. System.out.println(foo);
20. }
21. };
22. MessageListenerAdapter adapter =newMessageListenerAdapter(listener);
23. container.setMessageListener(adapter);
24. container.setQueueNames("myQueue");
25. container.start();
27. // send something
28. RabbitTemplate template =newRabbitTemplate(cf);
29. template.convertAndSend("myExchange","foo.bar","Hello, world!");
30. Thread.sleep(1000);
31. container.stop();
32. }

 

使用Spring的方式：

 

1. publicstaticvoid main(finalString... args)throwsException{
3. AbstractApplicationContext ctx =
4. newClassPathXmlApplicationContext("context.xml");
5. RabbitTemplate template = ctx.getBean(RabbitTemplate.class);
6. template.convertAndSend("Hello, world!");
7. Thread.sleep(1000);
8. ctx.destroy();
9. }

 

1. publicclassFoo{
3. publicvoid listen(String foo){
4. System.out.println(foo);
5. }
6. }

 

 

1. <!--context.xml -->
2. <rabbit:connection-factoryid="connectionFactory"/>
4. <rabbit:templateid="amqpTemplate"connection-factory="connectionFactory"
5. exchange="myExchange"routing-key="foo.bar"/>
7. <rabbit:adminconnection-factory="connectionFactory"/>
9. <rabbit:queuename="myQueue"/>
11. <rabbit:topic-exchangename="myExchange">
12. <rabbit:bindings>
13. <rabbit:bindingqueue="myQueue"pattern="foo.*"/>
14. </rabbit:bindings>
15. </rabbit:topic-exchange>
18. <rabbit:listener-containerconnection-factory="connectionFactory">
19. <rabbit:listenerref="foo"method="listen"queue-names="myQueue"/>
20. </rabbit:listener-container>
22. <beanid="foo"class="foo.Foo"/>