python 關於redis的基本操作網上已經很多了，這裡主要介紹點個人覺得有意思的內容1.redis的事務操作以及watch 樂觀鎖；後面描述2.tornado下非同步使用redis的方式 redis是單進程單線程模型，本身應對外部請求的是單任務的，也是多線程安全的，這個大家都應該知道的， 所以才會 ...
python 關於redis的基本操作網上已經很多了，這裡主要介紹點個人覺得有意思的內容1.redis的事務操作以及watch 樂觀鎖；後面描述2.tornado下非同步使用redis的方式 redis是單進程單線程模型，本身應對外部請求的是單任務的，也是多線程安全的，這個大家都應該知道的， 所以才會經常有人用redis做計數服務。 首先redis 的事務處理只能使用pipeline：In redis-py MULTI and EXEC can only be used through a Pipeline object. http://stackoverflow.com/questions/31769163/what-are-equivalent-functions-of-multi-and-exec-commands-in-redis-py 很多人喜歡在處理電商庫存，例如秒殺活動的時候用redis做計數器，不過下麵這段代碼採用了事務來控制庫存，是不是有點問題呢？
if __name__ == "__main__": with sms_redis.pipeline() as pipe: while 1: try: # 事務開始 pipe.multi() count = int(sms_redis.get('stock_count')) if count > 0: # 有庫存 pipe.set('stock_count', count - 1) # 事務結束 pipe.execute() # 把命令推送過去 break except Exception: traceback.print_exc() continue問題在於誤以為pipe.multi() 事務處理執行後，就可以鎖住該庫存，這裡強調下： redis 本身沒有悲觀鎖的概念，也就是說對於客戶的是無法鎖住redis中的值的，當然你可以通過其它曲徑實現，比如SETNX， 這裡先不談； redis 的事務可以認為是一段命令的批量執行和執行結果一次性返還，事務操作本身沒有問題，執行過程不會中斷，但是在pipe.execute() 的時候事務才真正向redis_server 提交，但是很遺憾在redis_server 執行之前庫存都有機會被其它客戶端修改，完全起不到鎖庫存概念； 那麼如何才能實現鎖庫存呢？watch是一個很好的解決方案： watch 字面就是監視的意思，這裡可以看做為資料庫中樂觀鎖的概念，誰都可以讀，誰都可以修改，但是修改的人必須保證自己watch的數據沒有被別人修改過，否則就修改失敗了；
if __name__ == "__main__": with sms_redis.pipeline() as pipe: while 1: try: #關註一個key pipe.watch('stock_count’) count = int(pipe.get('stock_count')) if count > 0: # 有庫存 # 事務開始 pipe.multi() pipe.set('stock_count', count - 1) # 事務結束 pipe.execute() # 把命令推送過去 break except Exception: traceback.print_exc() continue如果在watch後值被修改，在執行pipe.execute()的時候會報異常WatchError: Watched variable changed. 這裡可以簡單的實現基於redis中的鎖庫存的邏輯。
