谷粒商城——RabbitMQ

0. 消息中间件

1.RabbitMQ的核心概念

2. 工作流程

整体架构：

2.1Exchange(交换机)类型

交换机的原理就是：每一个消息都有其路由键(routing key)，每一个消息队列有自己的binding key。交换机就是通过这两个的匹配关系将消息绑定到对应的队列中

2.1.1direct类型

如果routing key=binding key，交换机就会把这个消息绑定到对应的队列中。

2.1.2fanout类型

fanout类型类似于广播，他不查看routing key与binding key的匹配关系，而是将消息绑定到所有队列。

2.1.3topic类型

将routing key与binding key按照模式匹配的方式进行匹配。

2.1.4headers模式（不用，性能差）

Headers 类型的交换器不依赖于路由键的匹配规则来路由消息，而是根据发送的消息内容中的 headers 属性进行匹配。在绑定队列和交换器时制定一组键值对，headers是键，交换机是值。

3.Springboot整合RabbitMQ(订单微服务)

首先，需要引入spring-boot-starter-amqp:

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

配置相关的配置：

# RabbitMQ配置
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
# 虚拟主机配置
spring.rabbitmq.virtual-host=/
# 开启发送端消息抵达Broker确认
spring.rabbitmq.publisher-confirms=true
# 开启发送端消息抵达Queue确认
spring.rabbitmq.publisher-returns=true
# 只要消息抵达Queue，就会异步发送优先回调returnfirm
spring.rabbitmq.template.mandatory=true
# 手动ack消息，不使用默认的消费端确认
spring.rabbitmq.listener.simple.acknowledge-mode=manual

4.Springboot使用RabbitMQ

创建交换机：

    @Autowiredprivate AmqpAdmin amqpAdmin;/*** 1、如何创建Exchange、Queue、Binding*      1）、使用AmqpAdmin进行创建* 2、如何收发消息*/@Testpublic void createExchange() {Exchange directExchange = new DirectExchange("hello-java-exchange",true,false);amqpAdmin.declareExchange(directExchange);log.info("Exchange[{}]创建成功：","hello-java-exchange");}

AmqpAdmin用于对RabbitMQ中的交换机、队列和交换机与队列的绑定关系进行实例化的管理类。