问一个并发上座的问题?

问题描述

我是用 hash 表来表示座位上的人的( key 表示座位位置,value 就是具体的 uid ),然后用 hsetnx 处理并发上座,
但是有个问题是,在上座成功后,我要把这条信息投递到消息队列里去(为了通知客户端),但是这里可能有网络原因(或者其他原因),
导致投递失败,但是 redis 又没有事务,没办法回滚,这样就会出问题,不知道大家有什么好思路,冒昧请教下。
伪代码类似于:

res =  cache.setnx(pos, uid)if (!res) {
    throw new Exception('上座失败!')
}
mq.send({
    pos: pos,
    uid: uid,    time: new Date()
})


MYYA
浏览 388回答 1
1回答

慕仙森

消息队列本身就是解耦的,如果投递失败就回滚那就相当于强依赖了?
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java