AMQP 示例

要试用 AMQP 适配器,请查看位于 https://github.com/SpringSource/spring-integration-samples 的 Spring Integration 示例 git 仓库中的示例。

目前,有一个示例通过使用出站通道适配器和入站通道适配器来演示 Spring Integration AMQP 适配器的基本功能。该示例使用 RabbitMQ 作为 AMQP 代理实现。

为了运行该示例,你需要一个运行中的 RabbitMQ 实例。仅使用基本默认设置的本地安装即可。有关详细的 RabbitMQ 安装步骤,请参阅 https://rabbitmq.cn/install.html

启动示例应用程序后,在命令行提示符下输入一些文本,包含该文本的消息将被发送到 AMQP 队列。随后,该消息会被 Spring Integration 检索并打印到控制台。

下图展示了此示例中使用的基本 Spring Integration 组件集

spring integration amqp sample graph
图 1. AMQP 示例的 Spring Integration 图