This project hosts a sample for Spring AMQP
使用 IDEA 创建 Spring Boot 项目，勾选 Web 的 Spring Web 和 Messaging 的 Spring for RabbitMQ。
因为需要创建生产者和消费者两个模块，所以在创建好后，要删除包括 src 在内的其他文件，只保留 pom.xml 文件夹即可。
然后分别创建 Spring Boot 子模块 amqp-producer 和 amqp-consumer，并修改 amqp-producer 的 pom.xml 和 amqp-consumer 的 pom.xml （具体的修改需要点开相应的 pom.xml 文件查看，上面标有注解）
amqp-producer 模块的配置文件 和 amqp-consumer 模块的配置文件 配置了：
- RabbitMQ 相关信息：
- 用户名和密码
- 单实例的 RabbitMQ 和 RabbitMQ 集群，分别的地址配置方式
- 每个 Spring Boot 应用模块的端口号：
- amqp-producer 模块的端口号为 8091
- amqp-consumer 模块的端口号为 8090。
- fanout 和 direct 模式使用的是配置类的方式
- topic 模式使用的注解方式
因为这个项目的 Configuration 类只在 amqp-consumer 模块中有（比如 DirectConfig.java 和 FanoutConfig.java 等配置类都在 amqp-consumer 模块中），所以要先启动该模块才会加载配置类去创建交换机和队列。
同理，如果只在 amqp-producer 模块中有配置类的话，就先启动该模块。
也可以在全部模块内，使用内容相同的 Configuration 类，这样就不用考虑启动顺序了。
TTL 和 Dead Letter Exchange：
-
设置队列内的消息的过期时间的方法：
- 参考 FanoutConfig.java 中的
public Queue queueOneFanout() - 例子中有 Dead Letter 相关的设置，如果该队列内的消息过期后，会放入 Dead Letter 的队列中
- 参考 FanoutConfig.java 中的
-
设置具体某条消息的过期时间的方法：
- 参考 RabbitProducerService.java 中的
public void direct(String msg, Integer id)的 if 判断语句 里面的内容 - 这个例子中没有 Dead Letter 相关的设置，所以过期后会直接被抛弃
- 参考 RabbitProducerService.java 中的
-
Dead Letter Exchange 相关配置，可以查看 DeadLetterConfig.java
测试 TTL 的时候，需要复制相应的配置类到生产者的模块（因为生产者模块没有配置类），然后启动生产者模块，发送消息，观察消息是否到期后会失效
RabbitMQ 相关链接：