2024-06-22

RabbitMQ-黑马商城为例

title: RabbitMQ-黑马商城为例
date: 2024-06-22 20:37:17
tags: RabbitMQ

1.启动RabbitMQ

基于Docker来安装RabbitMQ，命令如下：

docker run 
-e RABBITMQ_DEFAULT_USER=itheima   #设置默认用户名
-e RABBITMQ_DEFAULT_PASS=123456   #设置默认密码
-v mq-plugins:/plugins   #将本地主机上的mq-plugins目录挂载到容器内部的/plugins目录，可以存放插件
--name mq    #指定容器名
--hostname mq  #指定容器的主机名
-p 15672:15672 #RabbitMQ管理页面登录的端口号 [浏览器输入http://localhost:15672/即可进入]
-p 5672:5672  #RabbitMQ用于AMQP协议通信 [SpringAMQP配置时候用]
--network heima #将容器连接到名字为heima的网络中  [如果没有就使用命令创建hmall网络 docker network create heima]
-d  #在后台运行容器
rabbitmq:3.8-management  #使用RabbitMQ 3.8版本带有管理界面的镜像来创建容器


精简版 --直接在虚拟机上启动docker然后docker run
docker run \
 -e RABBITMQ_DEFAULT_USER=itheima \
 -e RABBITMQ_DEFAULT_PASS=123456 \
 -v mq-plugins:/plugins \
 --name mq \
 --hostname mq \
 -p 15672:15672 \
 -p 5672:5672 \
 --network heima\
 -d \
 rabbitmq:3.8-management

可以看到在安装命令中有两个映射的端口：

15672：RabbitMQ提供的管理控制台的端口
5672：RabbitMQ的消息发送处理接口

通过访问 http://localhost:15672或者http://192.168.92.129:15672即可看到本地/服务器上的管理控制台。首次访问登录，需要配置文件中设定的用户名和密码

创建hmall用户，并且配置一个hmall2虚拟空间

2.操作步骤

1.pom.xml中引入AMQP依赖：消费者和生产者项目
2.yml文件中配置RabbitMQ信息：
- 2.1消费者项目【基础配置，消费者重试机制，消费者确认机制】
- 2.2生产者项目【基础配置，生产者重试机制，生产者确认机制】
3.发送消息：生产者利用RabbitTemplate.convertAndSend(exchange交换机, routingKey路由key，message消息【传递的字段】(.setDelay设置延迟时间)，confirm消息确认机制信息);
- 3.1 message默认是JDK序列化有一堆问题 –>引入Jackson序列化【①引入依赖，②生产者和消费者的启动类添加@Bean注入】
4.接收消息：消费者在方法上添加@RabbitListener注解

具体就是@RabbitListener(bindings=@QueueBinding(

value=@Queue(name=队列名，durable=true持久化，惰性队列arguments = @Argument(name=”x-queue-mode”,value = “lazy”)),

exchange=@Exchange(name=交换机名,type = ExchangeTypes.TOPIC，delayed=”true”延迟属性),

key={“绑定条件1”,”绑定条件2”}

))

方法(原来传递的字段){

//里面写的就是之前直接调用的那个方法(serviceimpl层代码)

}

3.更改余额支付需求

改造余额支付功能，将支付成功后基于OpenFeign的交易服务的更新订单状态接口的同步调用—–>基于RabbitMQ的异步通知

说明：目前没有通知服务和积分服务，因此我们只关注交易服务，步骤如下：

定义direct类型交换机，命名为pay.direct
定义消息队列，命名为trade.pay.success.queue
将trade.pay.success.queue与pay.direct绑定，BindingKey为pay.success
支付成功时不再调用交易服务更新订单状态的接口，而是发送一条消息到pay.direct，发送消息的RoutingKey 为pay.success，消息内容是订单id
交易服务监听trade.pay.success.queue队列，接收到消息后更新订单状态为已支付

分析：

生产者：支付服务pay-service
消费者：交易服务trade-service

3.1 pom.xml导入依赖

在生产者和消费者的pom.xml文件中配置：

<!--消息发送-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

3.2 yml配置RabbitMQ信息

3.2.1 简单配置

在生产者和消费者的application.yml文件中配置：

spring:
  rabbitmq:
    host: 192.168.92.129 # 你的虚拟机IP
    port: 5672 # 端口
    virtual-host: /hmall2 # 虚拟主机
    username: hmall # 用户名
    password: 123456 # 密码
    
//消费者和生产者会在对应位置添加配置 【例如：生产者消费者的确认机制，重试机制等】