本文小編為大家詳細介紹“如何用redis實現(xiàn)倒計時任務”,內(nèi)容詳細,步驟清晰,細節(jié)處理妥當,希望這篇“如何用redis實現(xiàn)倒計時任務”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來學習新知識吧。
創(chuàng)新互聯(lián)公司專注于綏寧企業(yè)網(wǎng)站建設,響應式網(wǎng)站,購物商城網(wǎng)站建設。綏寧網(wǎng)站建設公司,為綏寧等地區(qū)提供建站服務。全流程按需策劃,專業(yè)設計,全程項目跟蹤,創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務
示例如下:
import redis import time def event_handler(msg): ''' 監(jiān)聽到任何key過期后,得到的消息如下 msg ={'type': 'pmessage', #返回值類型 'pattern': '__keyevent@2__:expired', #來源 'channel': '__keyevent@2__:expired', # 實際的Channel 'data': 'mykey' # key名稱 } 可以根據(jù)您要監(jiān)控的key進行業(yè)務判斷或觸發(fā)其他事件 if msg['data']=='mykey': do.... elif msg['data']=='yourkey': do ---- ''' print(msg) redis_conn = redis.Redis(host='host', port='6379', db=2, password='test.123.com', decode_responses=True) #設置過期時間2秒 redis_conn.set('mykey', 'asjdhkjashdkjahdskjahsd', ex=2) # 訂閱消息 pubsub =redis_conn.pubsub() # 訂閱key過期事件 # __keyevent@2__:expired : __keyevent@{db}__:事件 pubsub.psubscribe(**{'__keyevent@2__:expired': event_handler}) while True: message = pubsub.get_message() if message: # redis_conn.set('mykey', 'asjdhkjashdkjahdskjahsd', ex=10) print('wqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwqwq') else: time.sleep(0.01)
讀到這里,這篇“如何用redis實現(xiàn)倒計時任務”文章已經(jīng)介紹完畢,想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會,如果想了解更多相關內(nèi)容的文章,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。