项目说明： 本项目是一个springboot集成rabbitmq的一个简单使用示例，演示不同类型的消息的从生产到消费过程。

项目结构：

rabbitmq-common： 一个rabbitmq通用配置module 主要是exchage 、queue 的定义和绑定。 三种转发模式的演示示例，DirectExchange：路由键方式转发消息。FanoutExchange：广播方式转发消息。TopicExchange：主题匹配方式转发消息。

此外，本项目包括消息的延迟消费处理。

rabbitmq-provider： 消息生产者 使用一个简单业务演示生产业务消息通过RabbitTemplate 发送到rabbitmq 队列。

rabbitmq-consumer 消息消费者 演示监听不同队列的消息，然后进行消费。

备注说明: 问题1：

消费者使用 @RabbitListener(queues = "testmq.msg.direct.queue.rpc")方式监听队列，则会遇见以下问题： 生产者启动之后 ，在没有产生任何消息之前，此时rabbitmq中并没有生产者中定义生成的exchange 和queue。 此时启动消费者，将提示找不到队列，启动失败。

修改方案：

消费者使用 @RabbitListener(bindings = {@QueueBinding(value = @Queue(value = "testmq.msg.direct.queue.rpc", durable = "true"), exchange = @Exchange(value = "testmq.msg.direct.exchange"), key = "testmq.msg.direct.rpc")}) 方式监听， 该监听方式，如果rabbitmq中不存在相应的queue和exchange，将会自动创建。不指定Exchange 类型将会默认创建direct类型的exchange。 同时如果已经存在相应的bing类型的exchange和queue，如果exchange类型有出入，消费者启动则会报错。

问题2：

在@Configuration 配置中，配置binding关系 ，有如下两种方式： 方式一： @Bean public Binding bindingTopicQueue1() { Binding binding = BindingBuilder.bind(createTopicQueue1()).to(topicExchange()).with(TopicQueueEnum.TOPIC_QUEUE_QUEUE_1.getRoutingKey()); log.info("绑定 TopicQueue1 到topic 交换成功"); return binding; } 和方式二： @Bean public Binding bindingTopicQueue2(TopicExchange topicExchange, Queue createTopicQueue2) { Binding binding = BindingBuilder.bind(createTopicQueue2).to(topicExchange).with(TopicQueueEnum.TOPIC_QUEUE_QUEUE_2.getRoutingKey()); log.info("绑定 TopicQueue2 到topic 交换成功"); return binding; }

修改意见：

推荐使用后者方式二。 原因： 1、方式1 会除了bean自动生成的对象之外，调用函数还会额外生成一个bean对象。 2、方式2 会自动类型配置，通过前面@Bean注解生成的对象，自动注入， 默认是按照类型配置 3、可以通过 @Qualifier("directExchange") 按名称装配， 不写也可以默认按类型装配