一. 初始MQ1. 同步调用2. 异步调用3. 技术选型二. RabbitMQ1. 安装部署先下载镜像docker pull rabbitmq:3.8-management再安装docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USERadmin -e RABBITMQ_DEFAULT_PASSadmin -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 rabbitmq:3.8-management2. 基本介绍3. 快速入门步骤一声明组件交换机user.exchange队列email.queue负责发送邮件points.queue负责发送积分绑定email.queue用 Binding Keyuser.register.email绑定到交换机points.queue用 Binding Keyuser.register.points绑定到交换机步骤二发送消息生产者发送消息到user.exchange指定 Routing Key 为user.register.email。步骤三路由匹配交换机检查绑定关系消息的 Routing Keyuser.register.email与email.queue的 Binding Key完全匹配→ 路由到email.queue与points.queue的 Binding Keyuser.register.points不匹配→ 不路由步骤四消费处理email.queue中的消息被邮件消费者取走并发送邮件points.queue无新消息。4. 数据隔离创建用户和虚拟主机(Virtual Host)三. Java客户端1. 快速入门1. 引入依赖!--rabbitMQ-- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-amqp/artifactId /dependency2. 配置信息spring: rabbitmq: host: localhost password: admin username: admin virtual-host: / port: 56723. 发送消息4. 接受消息2. WorkQueue3. 交换机Fanout交换机Direct交换机Topic交换机4. 声明队列和交换机1. 基于Bean2. 基于注解5. 消息转换器