首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >Thread.sleep 延时查询或延时查询前更新es缓存数据

Thread.sleep 延时查询或延时查询前更新es缓存数据

作者头像
oktokeep
发布2024-10-09 10:47:57
发布2024-10-09 10:47:57
18000
代码可运行
举报
文章被收录于专栏:第三方工具第三方工具
运行总次数:0
代码可运行

Thread.sleep 延时查询或延时查询前更新es缓存数据

MQ消息的顺序性,或发送MQ的发送端未严格事务处理,可能存在数据未落库的情况,而导致接收端处理MQ消息的时候,查询为空。

代码语言:javascript
代码运行次数:0
运行
复制
//demo1 订单
            Order Order = OrderMapper.getOrder(orderNo);
            if (Order == null) {
                //延时3秒
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    log.error("查询Order延时3秒异常:orderNo=[{}]",e,orderNo);
                }
                Order = OrderMapper.getOrder(orderNo);
                if (Order == null) {
                    throw new RuntimeException("Order is null , orderNo = " + orderNo);
                }
            }

        //demo2 查询es
        Order bo = orderSearchService.detail(orderNo);
        if(bo == null){
            //es尝试刷新一次
            List<String> orderNoList = Arrays.asList(orderNo);
            orderSearchService.refresh(orderNoList);
            Thread.sleep(3000);
            //重新查询
            bo = orderSearchService.detail(orderNo);
            if(bo == null){
                logger.info("es查询订单信息Order is null , orderNo = " + orderNo);
                return content;
            }
        }
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2023-03-15,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档