文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot怎么整合ActiveMQ实现秒杀队列

2024-04-02 19:55

关注

本文小编为大家详细介绍“SpringBoot怎么整合ActiveMQ实现秒杀队列”,内容详细,步骤清晰,细节处理妥当,希望这篇“SpringBoot怎么整合ActiveMQ实现秒杀队列”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。

前言

在实际生产环境中中,通常生产者和消费者会是两个独立的应用,这样才能通过消息队列实现了服务解耦和广播。因为此项目仅是一个案例,为了方便期间,生产和消费定义在了同一个项目中。

基础配置

pom.xml 添加依赖:

<!-- activemq -->

<dependency>

 <groupId>org.springframework.boot</groupId>

 <artifactId>spring-boot-starter-activemq</artifactId>

</dependency>

application.properties 基础配置:

# activemq 基础配置

#spring.activemq.broker-url=tcp://47.94.232.109:61616

# 生产环境设置密码

#spring.activemq.user=admin

#spring.activemq.password=123456

#spring.activemq.in-memory=true

#spring.activemq.pool.enabled=false

项目集成

定义生产者:

import javax.jms.Destination;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsMessagingTemplate;

import org.springframework.stereotype.Component;

@Component

public class ActiveMQSender {

 @Autowired

 private JmsMessagingTemplate jmsTemplate; 

 

 public void sendChannelMess(Destination destination, final String message){

 jmsTemplate.convertAndSend(destination, message);

 }

}

定义消费者:

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.annotation.JmsListener;

import org.springframework.stereotype.Service;

import com.itstyle.seckill.common.entity.Result;

import com.itstyle.seckill.common.enums.SeckillStatEnum;

import com.itstyle.seckill.common.redis.RedisUtil;

import com.itstyle.seckill.common.webSocket.WebSocketServer;

import com.itstyle.seckill.service.ISeckillService;

@Service

public class ActiveMQConsumer {

  @Autowired

 private ISeckillService seckillService;

 @Autowired

 private RedisUtil redisUtil; 

 // 使用JmsListener配置消费者监听的队列,其中text是接收到的消息

 @JmsListener(destination = "seckill.queue")

 public void receiveQueue(String message) {

 //收到通道的消息之后执行秒杀操作(超卖)

 String[] array = message.split(";"); 

 Result result = seckillService.startSeckilDBPCC_TWO(Long.parseLong(array[0]), Long.parseLong(array[1]));

 if(result.equals(Result.ok(SeckillStatEnum.SUCCESS))){

 WebSocketServer.sendInfo(array[0].toString(), "秒杀成功");//推送给前台

 }else{

 WebSocketServer.sendInfo(array[0].toString(), "秒杀失败");//推送给前台

 redisUtil.cacheValue(array[0], "ok");//秒杀结束

 }

 }

}

测试案例:

@ApiOperation(value="秒杀五(ActiveMQ分布式队列)",nickname="科帮网")

@PostMapping("/startActiveMQQueue")

public Result startActiveMQQueue(long seckillId){

 seckillService.deleteSeckill(seckillId);

 final long killId = seckillId;

 LOGGER.info("开始秒杀五");

 for(int i=0;i<1000;i++){

 final long userId = i;

 Runnable task = new Runnable() {

 @Override

 public void run() {

 if(redisUtil.getValue(killId+"")==null){

 Destination destination = new ActiveMQQueue("seckill.queue");

 //思考如何返回给用户信息ws

 activeMQSender.sendChannelMess(destination,killId+";"+userId);

 }else{

 //秒杀结束

 }

 }

 };

 executor.execute(task);

 }

 try {

 Thread.sleep(10000);

 redisUtil.cacheValue(killId+"", null);

 Long seckillCount = seckillService.getSeckillCount(seckillId);

 LOGGER.info("一共秒杀出{}件商品",seckillCount);

 } catch (InterruptedException e) {

 e.printStackTrace();

 }

 return Result.ok();

}

注意事项

spring-boot-starter-activemq 依赖即可默认采用内嵌的 ActiveMQ,这个跟 elasticsearch 是一样的,测试的小伙伴可以不用安装,注释掉相关参数,使用默认即可。

如果自行安装 ActiveMQ 记得配置防火墙/安全组,配置web访问密码以及连接密码。

在生产环境下尽量还是采用外部 activemq 服务,提高扩展性、稳定性、可维护性。

读到这里,这篇“SpringBoot怎么整合ActiveMQ实现秒杀队列”文章已经介绍完毕,想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会,如果想了解更多相关内容的文章,欢迎关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯