当前位置: 首页 > news >正文

30-使用RocketMQ做削峰处理

1、增加排队功能的思路

        在出票模块里,一个消费者拿到了某个车次锁,则该车次下所有的票都由他来出,一张一张的出,知道所有的订单都出完。

2、实现排队出票功能

2.1、  修改发送到MQ消息的内容

        修改MQ消息内容,只需要通知出哪天和哪个车次的票(即:组成锁的内容),不需要具体到哪个人。

2.1.1、创建内部传递的dto类ConfirmOrderMQDto

@Data
public class ConfirmOrderMQDto {//    火车车次private String trainCode;//    日期private Date date;/***  日志流程号,用于同转异时,用同一个流水号*/private String logId;}

2.1.2、BeforeConfirmOrderServiceImpl类中 修改发送到MQ消息的内容

@Service
public class BeforeConfirmOrderServiceImpl implements BeforeConfirmOrderService {private static final Logger LOG = LoggerFactory.getLo
http://www.lryc.cn/news/102765.html

相关文章:

  • 如何用非root账号安装k8s集群
  • windows环境安装elasticsearch+kibana并完成JAVA客户端查询
  • 高精度算法
  • DragGAN:用崭新的方式进行图像处理
  • 语音播放 linux
  • 各大互联网公司面经分享:Java 全栈知识 +1500 道大厂面试真题
  • 【LeetCode】剑指offer礼物的最大价值
  • 应用层协议——https
  • Emacs之实现鼠标/键盘选中即拷贝外界内容(一百二十)
  • 智慧城市环境污染数据采集远程监控方案4G工业路由器应用
  • 大数据技术之Clickhouse---入门篇---安装
  • vue3搭建Arco design UI框架
  • 提升数据质量的四大有效方式
  • ALLEGRO之FlowPlan
  • Python - OpenCV实现摄像头人脸识别(亲测版)
  • date日期相关操作汇总
  • 生产者-消费者模式
  • Jetson Nano之ROS入门 -- YOLO目标检测与定位
  • 【移动机器人运动规划】01 —— 常见地图基础 |图搜索基础
  • mongotop跟踪Mongodb集合读取和写入数据
  • Linux中使用du命令来查看目录的大小
  • 【Linux】进程篇Ⅰ:进程信息、进程状态、环境变量、进程地址空间
  • 保护 TDengine 查询性能——3.0 如何大幅降低乱序数据干扰?
  • 状态机实现N位按键消抖
  • uniapp自定义消息语音
  • k8s安装Jenkins
  • 共筑开源新长城 龙蜥社区走进开放原子校源行-清华大学站
  • Jgit 工具类 (代码检出、删除分支(本地、远程)、新建分支、切换分支、代码提交)
  • 什么是redux?如何在react 项目中使用redux?
  • mysql的json处理