that

**queue**队列存储消息。

生产者投递的消息会暂存在消息队列中等待消费者处理

**exchange**交换机负责消息路由。

生产者发送的消息由交换机决定投递到哪个队列。

**virtual

host**虚拟主机起到数据隔离的作用。

每个虚拟主机相互独立有各自的exchange、queue

2.Docker安装

http://192.168.150.101:15672http://192.168.48.129:15672/http://192.168.150.101:15672即可看到管理控制台。

首次访问需要登录默认的用户名和密码在配置文件中已经指定了。

3.后端

!--AMQP依赖包含RabbitMQ--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency

3.2yml

org.springframework.amqp.core.*;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;Configuration

public

FanoutExchange(a.fanout);}//创建1个队列Beanpublic

Queue

Queue(fanout.queue1);}//绑定队列和交换机Beanpublic

Binding

BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}}

接收并处理

org.springframework.amqp.core.ExchangeTypes;

import

org.springframework.amqp.rabbit.annotation.Exchange;

import

org.springframework.amqp.rabbit.annotation.Queue;

import

org.springframework.amqp.rabbit.annotation.QueueBinding;

import

org.springframework.amqp.rabbit.annotation.RabbitListener;

import

org.springframework.stereotype.Component;Slf4j

Component

amqp!;rabbitTemplate.convertAndSend(queuename,

null,message);}

不用再在配置类里去声明了,直接业务里用注解一同声明交换机和队列了

下面代码会创建一个交换机b.direct和两个队列direct.queue1,direct.queue2

import

org.springframework.amqp.core.ExchangeTypes;

import

org.springframework.amqp.rabbit.annotation.Exchange;

import

org.springframework.amqp.rabbit.annotation.Queue;

import

org.springframework.amqp.rabbit.annotation.QueueBinding;

import

org.springframework.amqp.rabbit.annotation.RabbitListener;

import

org.springframework.stereotype.Component;import

java.util.Map;Slf4j

ExchangeTypes.DIRECT),//direct类型交换机需要传的keykey

{red,

蓝色通知;rabbitTemplate.convertAndSend(exchangeName,

blue,

红色通知;rabbitTemplate.convertAndSend(exchangeName,

red,

黄色通知;rabbitTemplate.convertAndSend(exchangeName,

yellow,