Spring AMQP 1.0 GA发布了

淩亂°似流年 2022-06-16 14:24 156阅读 0赞

本文来源于我在InfoQ中文站翻译的文章，原文地址是：[http://www.infoq.com/cn/news/2012/02/spring-amqp-1.0-ga][http_www.infoq.com_cn_news_2012_02_spring-amqp-1.0-ga]

近日，SpringSource（VMware下的一个部门）[发布][Link 1]了[Spring AMQP][] 1.0 GA（1.0.0.RELEASE）。Spring AMQP项目将Spring核心概念应用到了基于AMQP的消息解决方案的开发上，并且提供了Java与.NET两个版本。要想了解Spring AMQP与AMQP，请阅读文章“[Introduction to SpringSource's Advanced Message Queuing Protocol Support][Introduction to SpringSource_s Advanced Message Queuing Protocol Support]”。

Spring AMQP提供了org.springframework.amqp.core.AmqpTemplate来发送与接收消息。AMQP模板实现支持发送与接收POJOs而非javax.jms.Message实例。他们还提供了一种方式来自定义用于编排对象的MessageConverter。Spring与JMS用户会发现JmsTemplate与新的AmqpTemplate之间的相似性。

下面的代码片段介绍了如何联合使用Spring AMQP与RabbitMQ处理同步消息。[RabbitMQ][]是VMware的产品，并且是官方Spring AMQP示例中所用的默认AMQP实现。

上述Spring配置xml引用了ConnectionFactory，创建了一个RabbitTemplate来访问消息broker，创建了一个RabbitAdmin来管理交换、查询与绑定，最后创建了队列。下面的Java代码片段用于发送与接收消息。

Producer.java
    
    import org.springframework.amqp.core.AmqpTemplate;
    ...
    
    AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
    amqpTemplate.convertAndSend("helloworld.queue", "Hello World");

Consumer.java
    
    import org.springframework.amqp.core.AmqpTemplate;
    ...
    
    AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
    System.out.println(amqpTemplate.receiveAndConvert("helloworld.queue"));

要想上手，请下载[Spring AMQP for Java][]或是[Spring AMQP for .NET][]。Spring AMQP for Java artifacts也位于SpringSource Maven仓库与Maven Central中。其依赖是spring-amqp、spring-core与spring-context。如果消息broker使用的是RabbitMQ，那么还要引入spring-rabbit。你还可以试一下位于GitHub上的[Spring AMQP示例][Spring AMQP 1]。这些示例都是基于Maven的项目，需要用到RabbitMQ与[Erlang][]。请阅读与示例代码一同发布的readme.md文件以了解完整的构建命令。

对于Cloud Foundry用户来说，VMware还 [发布][Link 2]了RabbitMQ on Cloud Foundry免费的公开Beta版。你可以使用AMQP连接RabbitMQ on Cloud Foundry，通过这些 [示例][Link 3]可以帮助你快速上手。对于Spring Integration用户来说，版本2.1 M1提供了AMQP支持。

除了VMware的RabbitMQ外，其他基于AMQP面向消息的中间件还有[Apache Qpid][]、[Red Hat Enterprise MRG][]与[StormMQ][]（托管）。iMatrix的[OpenAMQ][]已经不再支持了，因此也没有成为一个选择。

要想了解关于Spring AMQP的更多信息，请查看[Spring AMQP Reference for Java][]与[Spring AMQP Reference for .NET][]参考页面。

**查看英文原文：**[Spring AMQP 1.0 GA][]

[http_www.infoq.com_cn_news_2012_02_spring-amqp-1.0-ga]: http://www.infoq.com/cn/news/2012/02/spring-amqp-1.0-ga
[Link 1]: http://www.springsource.org/node/3219
[Spring AMQP]: http://www.springsource.org/spring-amqp
[Introduction to SpringSource_s Advanced Message Queuing Protocol Support]: http://www.infoq.com/articles/spring_amqp
[RabbitMQ]: http://www.rabbitmq.com/server.html
[Spring AMQP for Java]: http://www.springsource.com/download/community?project=Spring%20AMQP
[Spring AMQP for .NET]: http://www.springsource.com/download/community?project=Spring%20AMQP.NET
[Spring AMQP 1]: https://github.com/SpringSource/spring-amqp-samples
[Erlang]: http://www.erlang.org/download.html
[Link 2]: http://blog.cloudfoundry.com/post/8713844574/rabbitmq-cloud-foundry-cloud-messaging-that-just-works
[Link 3]: https://github.com/rabbitmq/rabbitmq-cloudfoundry-samples/tree/master/spring
[Apache Qpid]: http://qpid.apache.org/
[Red Hat Enterprise MRG]: http://www.redhat.com/mrg/
[StormMQ]: http://stormmq.com/
[OpenAMQ]: http://www.openamq.org/
[Spring AMQP Reference for Java]: http://static.springsource.org/spring-amqp/reference/html/
[Spring AMQP Reference for .NET]: http://static.springsource.org/spring-amqp-net/docs/1.0.x/reference/html/
[Spring AMQP 1.0 GA]: http://www.infoq.com/news/2011/09/spring-amqp-1.0-ga