部分业务通过 MQ 异步处理，但接口返回后就立刻查询，这种情况怎么处理？

3 years ago

source link: https://www.v2ex.com/t/786254
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

V2EX › 程序员

部分业务通过 MQ 异步处理，但接口返回后就立刻查询，这种情况怎么处理？

WillingXyz · 17 小时 16 分钟前 · 967 次点击

比如，下单后，前端重新调用请求获取购物车数量，但购物车数量是通过 mq 减少的，这个时候获取的数据不对，这种要怎么处理呢

改成同步：但如果有很多相关业务，不能都改成同步吧
前端轮询查询：还是有一段时间显示的数据不对

10 条回复 • 2021-06-29 07:54:32 +08:00

atalia 17 小时 13 分钟前

加入一个 version，前端轮询判断 version

funbox 16 小时 50 分钟前

实时性要求那么高为啥用异步。。。要取舍

WillingXyz 16 小时 48 分钟前

@atalia 具体怎么加呢

thet 16 小时 28 分钟前 via iPhone

看 mq 平均消费时间是多少，可以通过一些障眼法等差不多时间再返回购物车页面，或者就不返回到购物车页面

zhaorunze 15 小时 19 分钟前

mq 本来就是异步，想要同步的效果就改成同步。
如果不想换 api，可以看看 mq 是否可以查询消息的消费状态，查询到被消费后，第一个接口才返回。等于强行把异步该改为同步。

lasuar 15 小时 8 分钟前

购物车商品数量更新本身应该是同步，其他操作改异步

hejw19970413 12 小时 16 分钟前

双十一淘宝也不可能做到实时同步啊。所以还得看你们业务接受的延迟和业务场景。不推荐改成同步方式。你可以进行一个粗略的数字这个数字可以做成热点缓存的方式，等到用户在下单动作时进行业务事务的处理。

akira 12 小时 9 分钟前

接口返回后等一会再查询

sujin190 9 小时 46 分钟前

对于这种异步任务接口偶尔调用需要返回的，我们都是通过分布式 Event，异步任务加一个 event_id 的参数，传了这个参数，mq 异步任务处理完了如果传了 event_id 的话激活这个分布式 Event 就行，接口这边简单的等待这个分布式 Event 激活就行，这样一个 mq 的异步任务就可以既单纯一个异步任务，也可以支持接口调用了，解耦了

不过估计很多都用过分布式锁，但是估计都没用过分布式 Event 吧，或者用 redis 的 pubsub 回传结果其实也行的吧

potatowish 53 分钟前 via iPhone

流程要进行拆分，购物车数量减少明显是应该做成同步的，消息异步处理更适合状态类或者前台感知不到的业务

Recommend

147

www.v2ex.com 7 years ago
Cache

PHP 接口返回 JSON 数据保证正确的类型难（或者麻烦）在哪？ - V2EX

PHP - @cielpy - 一直以来有一个疑问，和后端同事合作时定好了接口文档，如：```{ type: 0}```定义好 type 是 number 类型，返回数据一会儿是 string，

微信 mp.weixin.qq.com 6 years ago
Cache

接口返回的 JSON，再离谱也有办法，谈谈 JSON 容错！

www.v2ex.com 5 years ago
Cache

接口 api，后端结构返回问题？

API - @Zach369 - 最近跟 ios 接口联调，ios 说我的 api 接口返回格式不合理。想问问大家工作中是怎么处理的？我的接口返回样子： ``` { 'data': [

blog.csdn.net 4 years ago
Cache

编程小知识之 Random接口返回值

lindexi.gitee.io 4 years ago
Cache

asp dotnet core 3.0 接口返回 json 使用 PascalCase 格式

asp dotnet core 3.0 接口返回 json 使用 PascalCase 格式在 asp dotnet core 3.0 默认的 webapi 返回接口都是返回 json 格式，同时这个 json 格式使用的是 CamelCase 属性名风格。如果想要兼容之前的格式，让 webapi 返回的 json 的属性名使用 PascalCase...