【黑马点评】 使用RabbitMQ实现消息队列——2.使用RabbitMQ监听秒杀下单

server/2024/10/20 5:28:02/

2 使用RabbitMQ实现消息队列

2.1 修改\hm-dianping\pom.xmlpom.xml文件

添加RabbitMQ的环境

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

2.2 修改Resource下的application.yaml文件

添加RabbitMQ的配置信息

spring:rabbitmq:host: 127.0.0.1 # IP地址port: 5672 # 端口号username: hmdianping # 用户名password: 123456 # 密码listener:simple:concurrency: 1max-concurrency: 1acknowledge-mode: manualprefetch: 1

主启动类标注@EnableRabbit开启消息队列的监听功能

在这里插入图片描述

2.3 配置RabbitMQ,创建交换机和消息队列，将二者绑定

创建direct类型的交换机以及一个名为seckill.order.queue的消息队列，然后将二者绑定.之后发往该交换机且路由键为seckill.order的消息都会转发seckill.order.queue

具体而言，在hm-dianping.src.main.java.com.hmdp.config下新建RabbitMQConfig文件

文件内容如下

package com.hmdp.config;import com.hmdp.entity.VoucherOrder;
import com.hmdp.service.IVoucherOrderService;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.core.Message;
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.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.annotation.Resource;
import java.io.IOException;@Configuration
public class RabbitMQConfig {@ResourceIVoucherOrderService voucherOrderService;@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.seckill.queue"),key = "direct.seckill",exchange = @Exchange(name = "hmdianping.direct", type = ExchangeTypes.DIRECT)))public void recieveMessage(Object message){System.out.println("监听到了"+message);}@Beanpublic MessageConverter messageConverter() {return new Jackson2JsonMessageConverter();}
}

2.3.1 测试监听消息

在Test中添加发送消息的方法，指定交换机hmdianping.direct 为和路由键 direct.seckill。

    @ResourceRabbitTemplate rabbitTemplate;@Testpublic void testSendMessage(){rabbitTemplate.convertAndSend("hmdianping.direct","direct.seckill","测试发送消息");}

先运行Test方法

在这里插入图片描述

之后运行启动类HmDianPingApplication

发现监听到了，说明连接成功。

在这里插入图片描述

2.3.2 修改秒杀下单业务(VoucherOrderServiceImpl中的seckillVoucher方法)

  • 注入RabbitTemplate类

  • 在认定有抢购资格后，直接向seckill.direct交换机发送消息，内容包含voucherId、userId、orderId

    @ResourceRabbitTemplate rabbitTemplate;@Overridepublic Result seckillVoucher(Long voucherId) {//1.执行lua脚本，判断当前用户的购买资格Long userId = UserHolder.getUser().getId();Long result = stringRedisTemplate.execute(SECKILL_SCRIPT,Collections.emptyList(),voucherId.toString(), userId.toString());if (result != 0) {//2.不为0说明没有购买资格return Result.fail(result==1?"库存不足":"不能重复下单");}//3.走到这一步说明有购买资格，将订单信息存到消息队列VoucherOrder voucherOrder = new VoucherOrder();long orderId = redisIdWorker.nextId("order");voucherOrder.setId(orderId);voucherOrder.setUserId(UserHolder.getUser().getId());voucherOrder.setVoucherId(voucherId);//存入消息队列等待异步消费rabbitTemplate.convertAndSend("hmdianping.direct","direct.seckill",voucherOrder);return Result.ok(orderId);}

此时VoucherOrderServiceImpl文件内容如下

package com.hmdp.service.impl;import com.hmdp.dto.Result;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.UserHolder;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.aop.framework.AopContext;
import org.springframework.core.io.ClassPathResource;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.concurrent.*;
import org.springframework.amqp.rabbit.core.RabbitTemplate;/*** <p>*  服务实现类* </p>** @author 虎哥* @since 2021-12-22*/
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {@Resourceprivate ISeckillVoucherService seckillVoucherService;@Resourceprivate IVoucherOrderService iVoucherOrderService;@Resourceprivate RedisIdWorker redisIdWorker;@Resourceprivate StringRedisTemplate stringRedisTemplate;@Resourceprivate RedissonClient redissonClient;private static final DefaultRedisScript<Long> SECKILL_SCRIPT;static {SECKILL_SCRIPT = new DefaultRedisScript<>();SECKILL_SCRIPT.setLocation(new ClassPathResource("seckill.lua"));SECKILL_SCRIPT.setResultType(Long.class);}private BlockingQueue<VoucherOrder> orderTasks = new ArrayBlockingQueue<>(1024*1024);//异步处理线程池private static final ExecutorService SECKILL_ORDER_EXECUTOR = Executors.newSingleThreadExecutor();@Transactionalpublic void handleVoucherOrder(VoucherOrder voucherOrder) {//1.所有信息从当前消息实体中拿Long voucherId = voucherOrder.getVoucherId();//2.扣减库存boolean success = seckillVoucherService.update().setSql("stock=stock-1").eq("voucher_id", voucherId)//======判断当前库存是否大于0就可以决定是否能抢池子中的券了.gt("stock", 0).update();//3.创建订单if(success) save(voucherOrder);}@ResourceRabbitTemplate rabbitTemplate;@Overridepublic Result seckillVoucher(Long voucherId) {//1.执行lua脚本，判断当前用户的购买资格Long userId = UserHolder.getUser().getId();Long result = stringRedisTemplate.execute(SECKILL_SCRIPT,Collections.emptyList(),voucherId.toString(), userId.toString());if (result != 0) {//2.不为0说明没有购买资格return Result.fail(result==1?"库存不足":"不能重复下单");}//3.走到这一步说明有购买资格，将订单信息存到消息队列VoucherOrder voucherOrder = new VoucherOrder();long orderId = redisIdWorker.nextId("order");voucherOrder.setId(orderId);voucherOrder.setUserId(UserHolder.getUser().getId());voucherOrder.setVoucherId(voucherId);//存入消息队列等待异步消费rabbitTemplate.convertAndSend("hmdianping.direct","direct.seckill",voucherOrder);return Result.ok(orderId);}@Transactionalpublic void createVoucherOrder(VoucherOrder voucherOrder){// 5.一人一单逻辑// 5.1.用户idLong userId = voucherOrder.getId();int count = query().eq("user_id", userId).eq("voucher_id", voucherOrder).count();// 5.2.判断是否存在if (count > 0) {// 用户已经购买过了log.error("用户已经购买过一次！");return ;}//6.扣减库存boolean success = seckillVoucherService.update().setSql("stock= stock -1") // set stock = stock -1.eq("voucher_id", voucherOrder).gt("stock",0)// where id = ? and stock > 0.update();if (!success) {//扣减库存log.error("库存不足！");return ;}save(voucherOrder);}
}

2.3.3 监听秒杀成功订单

  • 监听seckill.order.queue队列的信息并且创建订单到数据库，当创建完成时手动ack

RabbitMQConfig中的recieveMessage修改为

    public void recieveMessage(Message message, Channel channel, VoucherOrder voucherOrder){try {voucherOrderService.handleVoucherOrder(voucherOrder);channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);} catch (IOException e) {throw new RuntimeException(e);}System.out.println("监听到了"+message);}

此时，文件内容为。

package com.hmdp.config;import com.hmdp.entity.VoucherOrder;
import com.hmdp.service.IVoucherOrderService;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.core.Message;
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.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.annotation.Resource;
import java.io.IOException;@Configuration
public class RabbitMQConfig {@ResourceIVoucherOrderService voucherOrderService;@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.seckill.queue"),key = "direct.seckill",exchange = @Exchange(name = "hmdianping.direct", type = ExchangeTypes.DIRECT)))
/*    public void recieveMessage(Object message){System.out.println("监听到了"+message);}*/public void recieveMessage(Message message, Channel channel, VoucherOrder voucherOrder){try {voucherOrderService.handleVoucherOrder(voucherOrder);channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);} catch (IOException e) {throw new RuntimeException(e);}System.out.println("监听到了"+message);}@Beanpublic MessageConverter messageConverter() {return new Jackson2JsonMessageConverter();}
}

2.3.4 测试

使用Apifox测试

在这里插入图片描述

成功

在这里插入图片描述


http://www.ppmy.cn/server/130303.html

相关文章

Spring Cloud Bus：实现分布式系统中的消息传递与状态同步

Spring Cloud Bus：实现分布式系统中的消息传递与状态同步

在分布式系统中&#xff0c;服务之间的消息传递和状态同步是一个关键需求。Spring Cloud Bus提供了一个轻量级的消息代理连接分布式系统的节点&#xff0c;用于广播状态更改或管理指令。本文将探讨Spring Cloud Bus的功能、使用场景及其在分布式系统中的作用。 Spring Cloud B…
阅读更多...
构建高效新闻推荐系统：Spring Boot的力量

构建高效新闻推荐系统：Spring Boot的力量

1系统概述 1.1 研究背景 如今互联网高速发展&#xff0c;网络遍布全球&#xff0c;通过互联网发布的消息能快而方便的传播到世界每个角落&#xff0c;并且互联网上能传播的信息也很广&#xff0c;比如文字、图片、声音、视频等。从而&#xff0c;这种种好处使得互联网成了信息传…
阅读更多...
2-119 基于matlab的合成孔径雷达(SAR)RDA(距离多普勒算法)、RMA(距离徙动算法)、CSA(线性调频变标算法)算法点目标成像与分析

2-119 基于matlab的合成孔径雷达(SAR)RDA(距离多普勒算法)、RMA(距离徙动算法)、CSA(线性调频变标算法)算法点目标成像与分析

基于matlab的合成孔径雷达(SAR)RDA(距离多普勒算法)、RMA(距离徙动算法)、CSA(线性调频变标算法)算法点目标成像与分析&#xff0c;RDA算法通过参考目标的多普勒历程完成对应匹配滤波器设计&#xff0c;获得同距离处不同目标相对于参考目标的方位位置。RMA是一种高分辨率的频域…
阅读更多...
独享动态IP是什么？它有什么独特优势吗？

独享动态IP是什么？它有什么独特优势吗？

在网络世界中&#xff0c;IP地址扮演着连接互联网的关键角色。随着互联网的发展&#xff0c;不同类型的IP地址也应运而生&#xff0c;其中独享动态ip作为一种新型IP地址&#xff0c;备受关注。本文将围绕它的定义及其独特优势展开探讨&#xff0c;以帮助读者更好地理解和利用这…
阅读更多...
QT学习笔记1.2（QT的应用）

QT学习笔记1.2（QT的应用）

QT原生用于c的开发&#xff0c; 主要应用于电脑、桌面手机桌面软件的开发&#xff0c;主要是widget样式模板。 Qt Widgets、Qt Quick 和 Qt for Python 是 Qt 框架中的三种不同的技术&#xff0c;分别用于不同的应用场景。以下是它们的详细介绍和对比&#xff1a; 1. Qt Widg…
阅读更多...
Linux 常用命令详细总结

Linux 常用命令详细总结

Linux 常用命令详细总结 文件和目录管理 1.1 创建文件和目录 1.2 查看文件和目录 1.3 复制、移动和删除 1.4 查看文件内容系统信息查看 2.1 系统信息 2.2 网络信息进程管理 3.1 查看和控制进程文本处理 4.1 文本搜索和替换 4.2 文件编辑权限管理 5.1 查看和修改权限其他常用命…
阅读更多...
项目解决方案：连锁店视频监控接入汇聚联网解决方案

项目解决方案：连锁店视频监控接入汇聚联网解决方案

目录 一.项目背景 二.建设目标和详细需求分析 2.1建设总目标 2.2需求分析 三.系统特色 3.1数字&#xff0c;高清&#xff0c;网络化系统 3.2安全性 3.3可拓展性 3.4资源利旧&#xff0c;节约成本 四.系统实现 4.1系统方案设计 4.2拓扑组网说明 4.3用户权限管理实现…
阅读更多...
【深度学习基础模型】神经图灵机（Neural Turing Machines, NTM）详细理解并附实现代码。

【深度学习基础模型】神经图灵机（Neural Turing Machines, NTM）详细理解并附实现代码。

【深度学习基础模型】神经图灵机&#xff08;Neural Turing Machines, NTM&#xff09;详细理解并附实现代码。 【深度学习基础模型】神经图灵机&#xff08;Neural Turing Machines, NTM&#xff09;详细理解并附实现代码。 文章目录 【深度学习基础模型】神经图灵机&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023