利用Redis keyspace notification(鍵空間通知)實現過時提醒

時間  2020-05-10
標籤 利用 redis keyspace notification 空間 通知 實現 過時 提醒 欄目 Redis 简体版
原文   原文鏈接

1、序言：

本文所說的定時任務或者說計劃任務並非不少人想象中的那樣，好比說天天凌晨三點自動運行起來跑一個腳本。這種都已經爛大街了，隨便一個 Crontab 就能搞定了。php

這裏所說的定時任務能夠說是計時器任務，好比說用戶觸發了某個動做，那麼從這個點開始過二十四小時咱們要對這個動做作點什麼。那麼若是有 1000 個用戶觸發了這個動做，就會有 1000 個定時任務。因而這就不是 Cron 範疇裏面的內容了。html

舉個最簡單的例子，一個用戶推薦了另外一個用戶，咱們定一個二十四小時以後的任務，看看被推薦的用戶有沒有來註冊，若是沒註冊就給他搞一條短信過去mysql

2、需求分析：

  1. 設置了生存時間的Key，在過時時能不能有所提示？web

  2. 若是能對過時Key有個監聽，如何對過時Key進行一個回調處理？redis

  3. 如何使用 Redis 來實現定時任務？sql

  4. 更具體需求：數據庫

    如今須要作一個拍賣活動，如何在拍賣結束那一刻，就執行任務進行相關邏輯；數組

    如何在訂單交易有效期時間結束的那一刻，進行相關邏輯服務器

3、Redis介紹

在 Redis 的 2.8.0 版本以後，其推出了一個新的特性——鍵空間消息（Redis Keyspace Notifications），它配合 2.0.0 版本以後的 SUBSCRIBE 就能完成這個定時任務websocket

的操做了，不過定時的單位是秒。

（1）Publish / Subscribe

Redis 在 2.0.0 以後推出了 Pub / Sub 的指令，大體就是說一邊給 Redis 的特定頻道發送消息，另外一邊從 Redis 的特定頻道取值——造成了一個簡易的消息隊列。

（2）Redis Keyspace Notifications

在 Redis 裏面有一些事件，好比鍵到期、鍵被刪除等。而後咱們能夠經過配置一些東西來讓 Redis 一旦觸發這些事件的時候就往特定的 Channel 推一條消息。

大體的流程就是咱們給 Redis 的某一個 db 設置過時事件，使其鍵一旦過時就會往特定頻道推消息，我在本身的客戶端這邊就一直消費這個頻道就行了。

之後一來一條定時任務，咱們就把這個任務狀態壓縮成一個鍵，而且過時時間爲距這個任務執行的時間差。那麼當鍵一旦到期，就到了任務該執行的時間，Redis 天然會把過時消息推去，咱們的客戶端就能接收到了。這樣一來就起到了定時任務的做用。

配置

由於開啓鍵空間通知功能須要消耗一些 CPU ， 因此在默認配置下， 該功能處於關閉狀態。

能夠經過修改 redis.conf 文件， 或者直接使用 CONFIG SET 命令來開啓或關閉鍵空間通知功能：

  • 當 notify-keyspace-events 選項的參數爲空字符串時，功能關閉。

  • 另外一方面，當參數不是空字符串時，功能開啓。

notify-keyspace-events 的參數能夠是如下字符的任意組合， 它指定了服務器該發送哪些類型的通知：

字符 發送的通知
  K 鍵空間通知，全部通知以 __keyspace@<db>__ 爲前綴
  E 鍵事件通知，全部通知以 __keyevent@<db>__ 爲前綴
  g DEL 、 EXPIRE 、 RENAME 等類型無關的通用命令的通知
  $ 字符串命令的通知
  l 列表命令的通知
  s 集合命令的通知
  h 哈希命令的通知
  z 有序集合命令的通知
  x 過時事件：每當有過時鍵被刪除時發送
  e 驅逐(evict)事件：每當有鍵由於 maxmemory 政策而被刪除時發送
  A 參數 g$lshzxe 的別名

輸入的參數中至少要有一個 K 或者 E ， 不然的話， 無論其他的參數是什麼， 都不會有任何通知被分發。

舉個例子， 若是隻想訂閱鍵空間中和列表相關的通知， 那麼參數就應該設爲 Kl ， 諸如此類。

將參數設爲字符串 "AKE" 表示發送全部類型的通知。

監聽過時事件須要設置Redis 配置文件

notify-keyspace-events "Ex"

命令產生的通知

如下列表記錄了不一樣命令所產生的不一樣通知：

Note

全部命令都只在鍵真的被改動了以後，纔會產生通知。

好比說，當 [SREM key member member …] 試圖刪除不存在於集合的元素時，刪除操做會執行失敗，由於沒有真正的改動鍵，因此這一操做不會發送通知。

若是對命令所產生的通知有疑問， 最好仍是使用如下命令， 本身來驗證一下：

$ redis-cli config set notify-keyspace-events KEA $ redis-cli --csv psubscribe '__key*__:*' Reading messages... (press Ctrl-C to quit) "psubscribe","__key*__:*",1

而後， 只要在其餘終端裏用 Redis 客戶端發送命令， 就能夠看到產生的通知了：

"pmessage","__key*__:*","__keyspace@0__:foo","set"
"pmessage","__key*__:*","__keyevent@0__:set","foo" ...

過時通知的發送時間

Redis 使用如下兩種方式刪除過時的鍵：

  • 當一個鍵被訪問時，程序會對這個鍵進行檢查，若是鍵已通過期，那麼該鍵將被刪除。

  • 底層系統會在後臺漸進地查找並刪除那些過時的鍵，從而處理那些已通過期、可是不會被訪問到的鍵。

當過時鍵被以上兩個程序的任意一個發現、 而且將鍵從數據庫中刪除時， Redis 會產生一個 expired 通知。

Redis 並不保證生存時間（TTL）變爲 0 的鍵會當即被刪除： 若是程序沒有訪問這個過時鍵， 或者帶有生存時間的鍵很是多的話， 那麼在鍵的生存時間變爲 0 ， 直到鍵真正被刪除這中間， 可能會有一段比較顯著的時間間隔。

所以， Redis 產生 expired 通知的時間爲過時鍵被刪除的時候， 而不是鍵的生存時間變爲 0 的時候。

4、高可用性

由於 Redis 目前的訂閱與發佈功能採起的是發送即忘（fire and forget）策略， 因此若是你的程序須要可靠事件通知（reliable notification of events）， 那麼目前的鍵空間通知可能並不適合你：當訂閱事件的客戶端斷線時， 它會丟失全部在斷線期間分發給它的事件。並不能確保消息送達。將來有計劃容許更可靠的事件傳遞，但可能這將在更通常的層面上解決，或者爲Pub / Sub自己帶來可靠性，或者容許Lua腳本攔截Pub / Sub消息來執行諸如推送將事件列入清單。

事件類型

對於每一個修改數據庫的操做，鍵空間通知都會發送兩種不一樣類型的事件消息：keyspace 和 keyevent。以 keyspace 爲前綴的頻道被稱爲鍵空間通知（key-space notification）， 而以 keyevent 爲前綴的頻道則被稱爲鍵事件通知（key-event notification）。

事件是用  __keyspace@DB__:KeyPattern 或者  __keyevent@DB__:OpsType 的格式來發布消息的。
DB表示在第幾個庫；KeyPattern則是表示須要監控的鍵模式（能夠用通配符，如：__key*__:*）；OpsType則表示操做類型。所以，若是想要訂閱特殊的Key上的事件，應該是訂閱keyspace。
好比說，對 0 號數據庫的鍵 mykey 執行 DEL 命令時， 系統將分發兩條消息， 至關於執行如下兩個 PUBLISH 命令：
PUBLISH __keyspace@0__:sampleKey del
PUBLISH __keyevent@0__:del sampleKey
訂閱第一個頻道 __keyspace@0__:mykey 能夠接收 0 號數據庫中全部修改鍵 mykey 的事件， 而訂閱第二個頻道 __keyevent@0__:del 則能夠接收 0 號數據庫中全部執行 del 命令的鍵。

5、實現步驟

爲了高可用性，爲了確保解決過時事件的執行，將 定時事件存入MySQL數據庫。觸發鍵過時事件後，再查詢一次數據庫，檢查一下過時事件是否所有執行了。

數據表結構

CREATE TABLE `tb_time_limit_task` ( `id` int(10) unsigned NOT NULL AUTO_INCREMENT, `key` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'Redis鍵', `status` tinyint(3) unsigned NOT NULL COMMENT '狀態，0未處理，1已處理', `start_time` decimal(13,3) unsigned NOT NULL COMMENT '開始時間(小數部分爲毫秒)', `end_time` decimal(13,3) unsigned NOT NULL COMMENT '結束時間（小數部分爲毫秒）', PRIMARY KEY (`id`), KEY `we` (`key`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='這個表用於記錄須要時間控制的任務Key，配合Redis、以及回調腳本使用'; ​ key存儲規則是 類名@方法名@參數...   (參數可爲空，多個參數以@分隔) 例子： PTCountdown@countdown@218

 

實現思路：

  1. （查詢數據庫）任務狀態檢查，執行未正常執行的任務

    任務狀態檢查

    查詢 」結束時間 < 當前時間「 的未處理的任務

    若是存在，則執行任務，

    1.先解析key，類名@方法名@參數... ​ 2.而後根據類名去執行相應方法

  2. 鏈接redis

    • 鏈接成功

      • （查詢數據庫）任務狀態檢查，查看在腳本未運行期間是否有部分任務未處理，可能很長時間才連上redis，須要查看鏈接時間內的任務情況；

    • 可能會永遠連不上，則每10s，嘗試重連

  3. 生成訂閱消息丟失控制鍵

    向redis初始新增 10個有效期（900/1800/...）的鍵

    #SILCK`1 900
    #SILCK`2 1800
    #SILCK`3 2700
    ...
    #SILCK`10 9000

這一步的目的是 每900秒（15）分鐘，查詢數據庫，檢查任務執行狀況

  1. 訂閱過時事件

    • 正常鍵過時

      • 執行任務

    • 訂閱消息控制鍵過時

      • 檢查任務狀態

        • 若是超過一半的控制鍵都過時了，那麼從新生成10個

具體代碼：

監聽腳本
<?php /** * Description:時間結點任務監聽 * Created by dong.cx * DateTime: 2019-03-15 10:58 */ namespace wladmin\cmd; \think\Loader::addNamespace('wlmis', './wlmis/'); use wlmis\logic\timeLimitTask\base\TimeLimitTaskLogic; use think\Config; use think\console\Input; use think\console\Output; use think\console\Command; use think\Log; use wlmis\common\redis\Redis; use wlmis\logic\timeLimitTask\base\LogRecord; class TimeLimitTask extends Command { use LogRecord; /** * 訂閱信息丟失控制鍵最大數量 * @var int */
    protected $subscription_info_loss_control_key_max = 10; /** * 訂閱信息丟失控制鍵最後執行的索引，鍵的索引從1開始，爲0表示未執行過，這個變量用於控制訂閱信息控制鍵自動生成 * @var int */
    protected $subscription_info_loss_control_key_last = 0; public function __construct($name = null) { parent::__construct($name); // 日誌記錄初始化
        Log::init([ 'type' => 'File',
            'path' => RUNTIME_PATH . 'redis-logs/',
            // error和sql日誌單獨記錄
            'apart_level' => ['log', 'error', 'sql', 'debug', 'info', 'notice'], ]); } /** * 運行方式 php tp5cornnew.php TimeLimitTask * @author dong.cx 2019-04-02 10:59 */
    protected function configure() { $this->setName('TimeLimitTask')->setDescription('Redis keyspace notification subscription script'); } protected function execute(Input $input, Output $output) { // 配置斷線重連
        Config::set('database.break_reconnect', true); $config = Config::get('redis_db'); $reconnect_str = ''; RedisReconnect:
        try { $this->logRecord('info', "ThinkPHP Version: " . THINK_VERSION); $this->logRecord('info', $reconnect_str . "Redis host: " . $config['host'], true, true); // 進行任務狀態檢查
            $this->taskStatusCheck(); $redis = new Redis(get_class($this), true); if ($redis->ping() == '+PONG') { $this->logRecord('info', 'Connection succeeded', true, true); // 查看在腳本未運行期間是否有部分任務未處理
                $this->taskStatusCheck(); } // 生成訂閱消息丟失控制鍵
            $this->subscription_info_loss_control(true); $this->logRecord('info', 'Start listening', true, true); // 訂閱消息
            $redis->psubscribe(array( '__keyevent@' . $config['db'] . '__:expired' ), function ($redis, $pattern, $channelName, $message) { $msg_split = explode('`', $message); if (count($msg_split) == 2 && $msg_split[0] == '#SILCK' && is_numeric($msg_split[1])) { $this->subscription_info_loss_control_key_last = $msg_split[1]; $this->taskStatusCheck(); if ($this->subscription_info_loss_control_key_last > ($this->subscription_info_loss_control_key_max / 2)) { $this->subscription_info_loss_control(); $this->subscription_info_loss_control_key_last = 0; } } else { // 這裏表明是Redis回調執行
                    $this->task($message); } }); } catch (\RedisException $redisThrow) { // Redis拋出異常，通常的狀況是失去鏈接，執行從新鏈接
            $this->logRecord('notice', "Redis loses connection and is reconnecting...", true, true); try { $redis->close(); } catch (\Exception $ee) { } sleep(10); $reconnect_str = 'Reconnect '; goto RedisReconnect; } catch (\Exception $e) { // 運行錯誤，這裏拋出錯誤的緣由爲這個文件中的代碼有誤，其餘任務執行代碼拋出錯誤，不會致使運行中斷 - 執行到這裏運行中斷
            $this->logRecord('error', 'Run-time error' . PHP_EOL . 'File location: ' . $e->getFile() . PHP_EOL . 'Line: ' . $e->getLine() . PHP_EOL . 'Error Message: ' . $e->getMessage() . PHP_EOL, true, true); } } /** * 任務執行 * @param string $key 任務鍵名，記錄於Redis中的鍵名 * 鍵名規則：類名@方法名@參數...(後續的多個參數都用@分隔)，在時間限制任務基類中有生成鍵的封裝函數 * @author: dong.cx */
    private function task($key) { try { $params = explode('@', $key, 3); if (count($params) < 2) { return; } $class = new \ReflectionClass('wlmis\\logic\\timeLimitTask\\' . $params[0]); $instance = $class->newInstance(); $transfer = array(); if (count($params) == 3) { $transfer = explode('@', $params[2]); } $instance->call_func($params[1], $transfer); } catch (\Exception $e) { $this->logRecord('notice', 'Task execution class or method not found! Or call the method to throw an error.'
                . PHP_EOL . 'Pass Key Parameter: ' . $key . PHP_EOL . 'File location: ' . get_class($this) . PHP_EOL . 'Line: ' . $e->getLine() . PHP_EOL . 'Error Message: ' . $e->getMessage() . PHP_EOL . PHP_EOL); } } /** * 任務狀態檢查，執行未正常執行的任務 * @author dong.cx 2019-04-02 10:57 */
    private function taskStatusCheck() { try { $result = (new TimeLimitTaskLogic())->getNotPerformedTask(); if (!empty($result)) { $this->logRecord('info', 'Find ' . count($result) . ' unprocessed task：'); foreach ($result as $value) { $this->task($value['key']); } } } catch (\Exception $e) { $this->logRecord('notice', 'An exception occurred during task status checking.'); } } /** * 生成訂閱消息丟失控制鍵 * @param boolean $always_output_screen 無論不否在調試模式都輸出到屏幕 * * @author dong.cx 2019-04-02 10:58 */
    private function subscription_info_loss_control($always_output_screen = false) { try { $this->logRecord('info', 'Generates subscription information loss control keys.', true, $always_output_screen); $success = 0; $error = 0; $redis = new Redis(); for ($i = 1; $i <= $this->subscription_info_loss_control_key_max; $i++) { $redis->setex('#SILCK`' . $i, $i * 900, '') ? $success++ : $error++; } $this->logRecord('info', 'Generates loss control keys: ' . $this->subscription_info_loss_control_key_max . ' total, ' . $success . ' success, ' . $error . ' error', true, $always_output_screen); $redis->close(); } catch (\Exception $e) { $this->logRecord('notice', 'An exception occurs when the subscription information loss control key is created.', true, $always_output_screen); } } }

 

鍵事件回調操做
<?php /** * Description:拍賣倒計時操做 * Created by dong.cx * DateTime: 2019-03-18 10:04 */ namespace wlmis\logic\timeLimitTask; use think\Config; use think\Exception; use wlmis\common\redis\Redis; use wlmis\dao\addons\auction\AuctionGoodsDao; use wlmis\logic\oper\addons\auction\AuctionLogic; use wlmis\logic\timeLimitTask\base\TimeLimitBaseLogic; class AuctionCutDownLogic extends TimeLimitBaseLogic { private $auctionGoodsDao; public function __construct() { parent::__construct(); $this->auctionGoodsDao = new AuctionGoodsDao(); } /** * 拍賣結束, 更新拍品表/保單表 操做 * @param $params * * @author dong.cx 2019-03-18 18:39 */
    public function auctionEndCutDown($params) { $auctionId = $params[0]; $auctionLogic = new AuctionLogic(); try { if (!$auctionId || !is_numeric($auctionId)) throw new Exception('Params error'); $goodsInfo = $this->auctionGoodsDao->load($auctionId, 'final_end_time'); if (!$goodsInfo) { $this->logRecord('notice', 'tb_auction_goods主鍵:' . $auctionId . '不存在'); } else { parent::startTrans(); // 拍賣結束
                $result = $auctionLogic->auctionEnded($auctionId); if ($result['code'] == 0) { $this->logRecord('notice', $result['msg']); } // 更改mysql中鍵的狀態爲已處理
                $this->recording_process_mysql($this->key_splice(__FUNCTION__, [$auctionId])); // 刪除 redis 當前價
                $redis = new Redis(); $redis->del('auction_gid@' . $auctionId . '@current_bid'); websocket_send($auctionId . 'bid/index', true, 2, '拍賣結束'); } parent::commit(); } catch (Exception $e) { parent::rollback(); $this->throw_message(__FUNCTION__, $e); } } /** * 拍賣交易結束 * 無訂單/未付款,不釋放保證金 * @param $params * * @author dong.cx 2019-03-18 20:15 */
    public function dealCutDown($params) { $auctionId = $params[0]; $auctionLogic = new AuctionLogic(); try { parent::startTrans(); if (!$auctionId || !is_numeric($auctionId)) throw new Exception('Params error'); $goodsInfo = $this->auctionGoodsDao->load($auctionId, 'final_end_time'); if (!$goodsInfo) { $this->logRecord('notice', 'tb_auction_goods主鍵:' . $auctionId . '不存在'); } elseif (!$goodsInfo['final_end_time']) { $this->logRecord('notice', 'tb_auction_goods主鍵:' . $auctionId . '的拍品還未結束或最終結束時間爲空'); } else { $result = $auctionLogic->checkStatus($auctionId); if ($result['code'] == 0) $this->logRecord('notice', $result['msg']); // 更改mysql中鍵的狀態爲已處理
                $this->recording_process_mysql($this->key_splice(__FUNCTION__, [$auctionId])); } parent::commit(); } catch (Exception $e) { parent::rollback(); $this->throw_message(__FUNCTION__, $e); } } /** * 建立拍賣結束倒計時任務 * @param $auctionId * @param int $ttl * * @throws Exception * @author dong.cx 2019-04-01 09:49 */
    public function auction_end_countdown_create($auctionId, $ttl=0) { return $this->create('auctionEndCutDown', $ttl, [$auctionId]); } /** * 刪除拍賣結束倒計時任務 * @param int $auctionId 拍賣商品表主鍵 * * @return bool|int * @throws Exception * @author dong.cx 2019-04-01 10:08:49 */
    public function auction_end_countdown_delete($auctionId) { return $this->del_key('auctionEndCutDown', [$auctionId]); } /** * 建立交易倒計時任務 * @param int $auctionId 拍賣商品表主鍵 * @param int $ttl 生存時間 * * @throws Exception * 異常代碼： * 500 redis操做失敗 * @author dong.cx 2019-03-22 15:36 */
    public function deal_countdown_create($auctionId, $ttl=0) { $this->create('dealCutDown', $ttl + Config::get('auction_deal_limit_time'), [$auctionId]); } /** * 刪除交易倒計時任務 * @param int $auctionId 拍賣商品表主鍵 * * @return bool|int * @throws Exception * @author dong.cx 2019-03-22 15:36 */
    public function deal_countdown_delete($auctionId) { return $this->del_key('countdown', [$auctionId]); } }

 

 

任務基類
<?php /** * Created by dong.cx * Date: 2019/3/27 17:13 * Description: 時間限制任務基類 * 每個子類繼承這個基類實現時間任務調度 * 子類中開放給Redis調度的函數設置訪問權限爲protected，防止外部誤觸發 * 子類中其餘開放給內部調用的訪問權限爲public * ************************************************ * 存儲到Redis中的鍵名規則爲：類名@方法名@參數...(參數可爲空，多個參數則以@分隔) key_splice 函數可生成鍵 * 全部的參數經過一個數組傳入方法(一維索引數組，跟存儲函數 create 傳入參數時同樣) * 類名、方法名，儘可能精簡，能節約帶寬以及Redis查詢速度 * 參數設計也儘可能精簡，全部操做都在服務端內部完成，因此能用1個條件準確查詢數據庫的，不要用兩個條件查詢 * * 存儲鍵直接使用 create 方法，以秒爲單位，會自動拼接鍵鍵 * 若是以毫秒爲單位則 create_ms 方法 * ************************************************ */ namespace wlmis\logic\timeLimitTask\base; use think\Exception; use wlmis\common\redis\Redis; use wlmis\model\sys\TimeLimitTaskModel; use wlmis\logic\BaseLogic; class TimeLimitBaseLogic extends BaseLogic { use LogRecord; /** * Redis鏈接實例 * @var Redis */
    protected $redis; /** * TimeLimitBaseLogic constructor. * @author dong.cx */
    public function __construct() { parent::__construct(); $this->redis = new Redis(); } /** * 任務調度入口 * @param string $funcName 調用方法名 * @param array $params 傳遞參數 * @author: dong.cx */
    public function call_func($funcName, $params = array()) { call_user_func(array($this, $funcName), $params); } /** * 鍵拼接 * 鍵用 @ 符號做爲分隔符，因此方法名、參數中不可出現 * 鍵名規則中的類名會自動生成 * @param string $funcName 方法名 * @param array $params 參數（必須傳入一維索引數組，請勿傳入關聯數組，按照順序生成參數，關聯數組不保證順序） * @return string 返回鍵 * @author: dong.cx */
    protected function key_splice($funcName, $params = array()) { $class = explode('\\', get_class($this)); $paramsStr = ''; foreach ($params as $value) { $paramsStr .= '@' . $value; } return $class[count($class) - 1] . '@' . $funcName . $paramsStr; } /** * 向Redis存儲鍵（延時單位秒） * 會自動將參數進行拼接，而後存入Redis * @param string $funcName 調用方法名 * @param int $ttl 延時(秒) * @param array $params 參數（必須傳入一維索引數組，請勿傳入關聯數組，按照順序生成參數，關聯數組不保證順序） * @throws Exception * ********************* * 異常代碼： * 500 redis操做失敗 * ********************* * @author: dong.cx */
    public function create($funcName, $ttl = 0, $params = array()) { $key = $this->key_splice($funcName, $params); $this->recording_mysql($key, $ttl); if (!($this->redis->setex($key, $ttl, ''))) { throw new Exception('Redis存儲失敗', 500); } } /** * 向Redis存儲鍵（延時單位毫秒） * 會自動將參數進行拼接，而後存入Redis * @param string $funcName 調用方法名 * @param int $ttl 延時(毫秒) * @param array $params 參數（必須傳入一維索引數組，請勿傳入關聯數組，按照順序生成參數，關聯數組不保證順序） * @throws Exception * ********************* * 異常代碼： * 500 redis操做失敗 * ********************* * @author: dong.cx */
    public function create_ms($funcName, $ttl = 0, $params = array()) { $key = $this->key_splice($funcName, $params); $this->recording_mysql($key, $ttl, true); if (!($this->redis->psetex($key, $ttl, ''))) { throw new Exception('Redis存儲失敗', 500); } } /** * 獲取指定鍵的剩餘生存時間（秒） * @param string $funcName 任務方法名 * @param array $params 任務參數 * @return bool|int 若是爲false，說明Redis鏈接失敗 * 若是爲-1，說明改鍵不是定時鍵 * 若是爲-2，說明鍵不存在（已消失） * 其餘爲剩餘生存時間(秒) * @throws Exception * @author: dong.cx */
    protected function getTTL($funcName, $params = array()) { $key = $this->key_splice($funcName, $params); return $this->redis->ttl($key); } /** * 獲取指定鍵的剩餘生存時間（毫秒） * @param string $funcName 任務方法名 * @param array $params 任務參數 * @return bool|int 若是爲false，說明Redis鏈接失敗 * 若是爲-1，說明改鍵不是定時鍵 * 若是爲-2，說明鍵不存在（已消失） * 其餘爲剩餘生存時間(秒) * @throws Exception * @author: dong.cx */
    protected function getPTTL($funcName, $params = array()) { $key = $this->key_splice($funcName, $params); return $this->redis->pttl($key); } /** * 刪除指定鍵 * *********************************************** * 刪除不會觸發事件，用於無用記錄的刪除 * 如生成支付訂單二次提交時刪除前面一個未處理任務。 * 通常在設計任務處理流程時須要考慮到無用任務的觸發，並進行規避，必要時進行主動刪除任務能夠減輕服務器負擔 * 任務處理流程應該作到無用記錄的觸發不會影響到系統正常運行 * *********************************************** * @param $funcName * @param array $params * @return bool|int 返回false則Redis實例獲取失敗，鏈接不上，返回int則爲影響的記錄條數 * @throws Exception * @author: dong.cx */
    protected function del_key($funcName, $params = array()) { $key = $this->key_splice($funcName, $params); TimeLimitTaskModel::where('key', $key)->update([ 'sts' => 1 ]); return $this->redis->del($key); } /** * 記錄鍵到mysql中， * @param string $key 鍵 * @param int $ttl 觸發時間 * @param bool $mode 當爲false時，觸發時間爲秒，當爲true時，觸發時間爲毫秒 * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\ModelNotFoundException * @throws \think\exception\DbException * @author: dong.cx */
    private function recording_mysql($key, $ttl, $mode = false) { if ($mode) { // 這裏說明 TTL 以毫秒爲單位
            $currentTime = bcmul(microtime(true), '1', 3); $endTime = bcadd($currentTime, bcdiv($ttl, '1000', 3), 3); } else { // 這裏說明 TTL 以秒爲單位
            $currentTime = time(); $endTime = $currentTime + $ttl; } if (TimeLimitTaskModel::field('id')->where('key', $key)->find() !== null) { TimeLimitTaskModel::where('key', $key)->update([ 'status'     => 0,
                'start_time' => $currentTime,
                'end_time'   => $endTime ]); } else { TimeLimitTaskModel::create([ 'key'        => $key,
                'status'     => 0,
                'start_time' => $currentTime,
                'end_time'   => $endTime,
                'sts'        => 0 ]); } } /** * 更改鍵在mysql中的狀態爲已處理 * @param $key * @author: dong.cx */
    protected function recording_process_mysql($key) { $tlm = new TimeLimitTaskModel(); $tlm->where('key', $key)->update([ 'status' => 1 ]); } /** * 拋出錯誤信息 * @param string $funcName 出錯方法名(__FUNCTION__) * @param \Exception $e 錯誤信息 * @author: dong.cx */
    protected function throw_message($funcName, \Exception $e) { $this->logRecord('error', 'The task logic has made an error:' . PHP_EOL . 'Class：' . get_class($this) . PHP_EOL . 'Method name：' . $funcName . PHP_EOL . 'File：' . $e->getFile() . PHP_EOL . 'Line: ' . $e->getLine() . PHP_EOL . 'Error Message：' . $e->getMessage() . PHP_EOL); } /** * 析構函數 * @author dong.cx */
    public function __destruct() { $this->redis->close(); } }

 

運行

✘  ~/Documents/card253  php tp5cornnew.php TimeLimitTask 【2019-04-08 11:40:02】ThinkPHP Version: 5.0.7 【2019-04-08 11:40:02】Redis host: 127.0.0.1 【2019-04-08 11:40:02】Connection succeeded 【2019-04-08 11:40:02】Generates subscription information loss control keys. 【2019-04-08 11:40:02】Generates loss control keys: 10 total, 10 success, 0 error 【2019-04-08 11:40:02】Start listening

使用：

只須要啓動腳本，

在須要的時候，新增任務便可

參考資料：

redis鍵空間

Redis實踐操做之—— keyspace notification（鍵空間通知）

 

原文出處：https://www.cnblogs.com/martini-d/p/10675945.html

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程