处理redis+mysql处理高并发的问题

@imhered yes!

@jiangliqin redis-lock? 是这个吗？ https://www.npmjs.com/package/node-redis-lock

@imhered 我上面描述的问题很复杂，对于出现脏读的部分，我们用redis-lock解决的啊

@jiangliqin 你的问题不是redis里的数据脏读了么？ 怎么解决脏读的？

@imhered 主要靠redis，后来再批量插进数据库，避免频繁操作数据库

问下楼主，这问题后来怎么处理的？

@coordcn ，呵呵，上面操作其实是有问题，后来改了。至于你说的parallel是不关联的并行这是对的，我上面也不存在先后关系。没讲明白，让你误解了。。。

@jiangliqin 不明白为什么要用async.parallel？

如果相关操作存在先后关系，parallel并不确定谁先执行，谁后执行，几个操作执行顺序是不确定的。

@yakczh ,这处理速度真不是自己能控制的，尤其是有上下游的情况

@jiangliqin 　看着办，适合项目就行

保持处理速度均匀,多高的并发都不怕

@chloe ,其实不一定用消息队列，只要是能控制并发就行，比如async.queue,bagpipe等

@bing6 ,你说得对，后来给成了你说的了

@jiangliqin 用消息队列的话可以用rabbitmq

不做update操作不行吗？只做insert就可以了啊,保存一份交易记录。 余额读取的可不是有redis?

@chloe ,用消息队列吧！？

@qimenxiaozi ,你说的排它锁是redis你们的watch->multi?

一律排队处理，处理完一个再去处理下一个

其实对于业务来说，钱最重要，我们的解决方案是只要牵涉钱的，都去加排他锁，保证更新金额不出现脏读.

client.getAsync('freeze' + orderObj['customer_id']).then(result => { //1.从redis中读取值 if (result) { async.parallel({ updateRedisfreeze: function(done) { //2.更新reids client.incrbyfloatAsync('freeze' + orderObj['customer_id'], '-' + orderObj['order_fee']) }, updateCustomer: function(done) { //3.更新数据库记录 customer.update({ customer_feezed_balance: freeze }, { where: { id: orderObj['customer_id'] } }) }, createOrder: function(done) { //4.数据库创建新记录 order.create(orderObj) }, deleteOrder: function(done) { client.delAsync(orderNo); /5./删除redis一条记录 } }, function(err, result) { console.log('one:', result.updateRedisfreeze); console.log('two:', result.updateCustomer); console.log('three:', result.createOrder); console.log('four:', result.deleteOrder); }) 在高并发下，怎么做到以上几步类似于数据库事务的操作，保证每次的执行具有原子性？