订单到期关闭

news/2024/7/18 4:17:35 标签: 开发语言, java, spring boot

文章目录

  • 前言
  • 一、场景?
  • 二、使用步骤
    • 1.项目配置好rocketmq
    • 2.读入数据
  • 其他方式处理订单到期关闭
    • 定时任务


前言

实习期间在做订单模块。遇到过订单到时关闭的场景。
因为我们在通过回调接收第三方订单状态的时候,使用了rocketmq,在遇到订单超时关闭的场景的时候,为了不引入额外的依赖,我们就继续使用rocketmq的延迟队列来做实现。

同时记录几种刚了解到的订单到期关闭实现方式。


一、场景?

酒店模块中,比如用户下单酒店了。
我们要设置超过多少分钟,就将订单自动取消了。

二、使用步骤

1.项目配置好rocketmq

2.读入数据

创建一个生产者

java">public class DelayProduce {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    /**
     * @param topic 主题
     * @param message 消息内容
     * @param delayLevel 分为18个等级,分别对应:1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
     */
    public void sendDelayMessage(String topic, String message, int delayLevel) {
        SendResult sendResult = rocketMQTemplate.syncSend(topic, MessageBuilder.withPayload(message).build(), 10000L, delayLevel);
        log.info("sendtime is {}", DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss").format(LocalDateTime.now()));
        log.info("sendResult is{}", sendResult);
    }

    public void sendCommonMessage(String topic, String message) {
        SendResult sendResult = rocketMQTemplate.syncSend(topic, MessageBuilder.withPayload(message).build(), 10000L);
        log.info("sendtime is {}", DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss").format(LocalDateTime.now()));
        log.info("sendResult is{}", sendResult);
    }
}

创建好订单之后,将订单发送到延迟队列

java">public class orderCreator {

    public void create( ... ) {
        
        ...

        delayProduce.sendDelayMessage(
                CERTAIN_TOPIC,
                JSON.toJSONString(order),
                15 // 15代表rocketmq中第15级的延时时长,20分钟
        );

        ...

    }
}

延时队列的消费者,来处理到时间的订单消息

java">@RocketMQMessageListener(
        topic = TOPIC,
        consumerGroup = CONSUMERGROUP
)
public class OrderDelayConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        检测订单是否已经支付成功,如果支付过了,就不管了
        如果仍然没有支付,就取消订单,对订单进行关闭
        if (取消成功) {
            创建message,发送给状态机,转换订单状态为已取消
        }
    }
}

其他方式处理订单到期关闭

定时任务

通过定时任务,去定期扫描到期的订单,做关单操作。比如使用xxl-job。
这样的处理方式的优点是:

  1. 简单 实现容易

缺点也显而易见:

  1. 关单时机不精确,

http://www.niftyadmin.cn/n/5548474.html

相关文章

网络服务器配置与管理

网络服务器配置与管理是一个涉及多个方面的领域&#xff0c;它涵盖了从物理硬件的设置到操作系统、网络服务和应用的配置&#xff0c;再到日常维护和安全策略的实施。以下是网络服务器配置与管理的一些核心概念和步骤&#xff1a; 硬件配置&#xff1a; 选择合适的服务器硬件&a…

短视频矩阵系统多账号搭建技术源码(saas开发者技术独立搭建)

在构建云服务环境以部署虚拟机方面&#xff0c;以Amazon Web Services&#xff08;AWS&#xff09;为示例&#xff0c;需采购并配置适当数量的EC2实例以及相关网络设施。 接下来&#xff0c;根据业务需求&#xff0c;应创建多个社交媒体平台如抖音和快手的官方账户&#xff0c;…

vue中v-if与v-show的区别

在 Vue.js 中&#xff0c;v-if 和 v-show 都是用来控制元素显示与隐藏的指令&#xff0c;但它们之间有几个关键的区别&#xff1a; 直接上图 一. 条件渲染方式不同 v-if&#xff1a; 真正的条件渲染&#xff1a;v-if 指令会根据表达式的真假来销毁或重新创建 DOM 元素及其…

昇思25天学习打卡营第22天 | Shufflenet图像分类

ShuffleNet图像分类 当前案例不支持在GPU设备上静态图模式运行&#xff0c;其他模式运行皆支持。 ShuffleNet网络介绍 ShuffleNetV1是旷视科技提出的一种计算高效的CNN模型&#xff0c;和MobileNet, SqueezeNet等一样主要应用在移动端&#xff0c;所以模型的设计目标就是利用有…

C++发票识别接口轻松管理财务、发票识别sdk、增值税发票识别

“营”“增”两种税是主流的流转税种&#xff0c;是两个独立而不能交叉的税种。也就是说交增值税的话就不交营业税&#xff0c;而交了营业税就不需要交增值税。而且&#xff0c;两者在征收的对象、征税范围、计税的依据、税目、税率以及征收管理等都有所不同&#xff0c;增值税…

从天空到地面:无人机航拍推流直播技术在洞庭湖决口封堵中的全方位支援

据新闻报道&#xff0c;受持续强降雨影响&#xff0c;湖南省华容县团洲垸洞庭湖一线堤防发生管涌险情&#xff0c;随后出现决口。截至7月8日20时左右&#xff0c;226米长的洞庭湖一线堤防决口已累计进占208米&#xff0c;目前剩余18米&#xff0c;有望在今晚或9日凌晨实现合龙。…

问题解决:“Cannot search on field [show_num] since it is not indexed.

找的解决方案&#xff0c;因为索引字段已经有数据 1. 新建索引&#xff0c;将mappings的show_num字段&#xff0c;index设置为true 2. 将旧索引的数据&#xff0c;复制到新索引 3. 删除旧索引 没采用新建索引&#xff0c;使用新增字段解决 1. 查询mapping&#xff0c;检测里…

Day06-角色管理-员工管理

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 1.编辑角色-进入行内编辑2.角色管理-行内编辑-数据缓存3.角色管理-编辑角色-确定取消4.角色管理-删除角色员工管理-页面结构6.员工管理-左侧树7.员工管理-选中首个节…