我是用 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() })
慕仙森
相关分类