国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 系統 > Linux > 正文

Linux下Redis+crontab實現任務隊列

2020-03-22 19:05:05
字體:
來源:轉載
供稿:網友
  • 前段時間由于一個控制方法要實現的邏輯任務太多了,無論怎么優化都還是有瓶頸。網上介紹可以使用任務隊列的機制,把一些不是立即需要相應的邏輯處理放在隊列中,讓某個程序時時去執行。舉個例子:用戶上來我的網站注冊,注冊完后,我需要給用戶的郵箱帳號推送一些郵件,這個推送郵件所發的時間可能遠比注冊保存用戶資料所花的時間多些,也不是立即就需要響應到前端給客戶知道。所以,是可以把推送郵件這一動作作為一個任務添加到隊列中。

    說明下我測試調試的環境是在Ubuntu12.04下的,安裝redis和添加crontab命令是通過終端命令的,我測試的項目是基于yii框架,調用redis是通過框架提供的yiiredis插件,可能不太符合你的環境,但其中的思路或許還是可以借鑒的。

    1、安裝Redis
    進入終端命令窗口(快捷鍵Ctrl+Alt+T)切換至/usr/local/src(命令:cd /usr/local/src)下,下載并安裝redis:

    $ wget http://redis.googlecode.com/files/redis-2.6.12.tar.gz$ tar xzf redis-2.6.12.tar.gz$ cd redis-2.6.12$ make
    進入redis-2.6.12(命令:cd redis-2.6.12)目錄,修改redis.conf:
    daemonize yes 
    啟動服務端:
    $ src/redis-server redis.conf
    進入命令行驗證服務是否啟動:
    $ src/redis-cliredis> set foo barOKredis> get foo"bar"

    2、安裝Yii的Redis插件
    目前主要有兩種Yii插件:
    1> Rediscache:基于predis(Redis的純PHP實現客戶端),無需安裝Redis for PHP擴展。
    2> YiiRedis:基于phpredis客戶端,需要安裝Redis for PHP擴展。
    這里采用Rediscache插件,避免線上安裝Redis for PHP擴展。
    從以下地址下載Rediscache插件:
    http://www.yiiframework.com/extension/rediscache/files/redis.zip
    將插件解壓到helloyii/app/protected/extensions中:
    插件文件部署后的位置應為:helloyii/app/protected/extensions/redis/CredisCache.php
    配置Rediscache
    return array( 'components' => array(   …   'cache'=>array(    'html' target='_blank'>class'=>'ext.redis.CRedisCache', //對應protected/extensions/redis/CredisCache.php    'servers'=>array(     array(      'host'=>'127.0.0.1',      'port'=>6379,     ),    ),   ),  ),  … );

    3、測試redis使用

    編寫一個讀寫緩存的控制器IndexController進行測試。

    class IndexController extends CController{  public function actionSetRedisValue() {        $key = $_POST['key'];        $value = $_POST['value'];        if ( !empty( $key ) && !empty( $value ) ) {            try {                $redis = Yii::app()->cache;                $data = ( array ) $redis->get( 'test' );                $data[$key] = $value;                $redis->set( 'test', $data );                die( json_encode( array( 'status' => 1, 'msg' => 'set ok!' ) ) );            } catch ( Exception $e ) {                die( json_encode( array( 'status' => 0, 'msg' => 'set faile!' ) ) );            }        } else {            die( json_encode( array( 'status' => 0, 'msg' => 'must input!' ) ) );        }   }   public function actionGetRedisValue() {        try {            $redis = Yii::app()->cache;            $data = ( array ) $redis->get( 'test' );            $log_file = Yii::app()->runtimePath . 'edis_log.txt';            if ( file_exists( $log_file ) ) {                $handle = fopen( $log_file, "a+" );                $log = "----" . date( 'Y-m-d H:i:s' ) . "-----" . "";                foreach ( $data as $key => $value ) {                    $log .= '->' . $key . ' = ' . $value . "";                }                fwrite( $handle, $log );                fclose( $handle );            }        } catch ( Exception $e ) {            echo $e->getMessage();        }   }}

    視圖文件index內容。
    <?php Yii::app()->clientScript->registerCoreScript( 'jquery' ); ?><p>Redis</p><form id="redis_form" action="<?php echo $this->createUrl( '/cata/index/setRedisValue' ); ?>" method="post">    Key:<input id="key" type="text" value=""/>    Value:<input id="val" type="text" value=""/>    <input id="set" type="button" value="set"/>    <input id="get" type="button" value="get"/>    <span></span></form><script>    $(document).ready(function() {        $('#redis_form #set').on('click', function() {            var redisForm = $('#redis_form');            var action = redisForm.attr('action');            var key = redisForm.children('#key');            var value = redisForm.children('#val');            $.post(action, {key: key.val(), value: value.val()}, function(data) {                redisForm.find('span').html(data.msg);                setTimeout(function() {                    redisForm.find('span').html('');                }, 3000);            }, 'json');        });        $('#redis_form #get').on('click', function() {            $.post('<?php echo $this->createUrl( '/cata/index/getRedisValue' ); ?>', {}, function(data) {            }, 'json');        });    });</script>        

    鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。

  • 發表評論 共有條評論
    用戶名: 密碼:
    驗證碼: 匿名發表
    主站蜘蛛池模板: 宝山区| 怀仁县| 永济市| 洞头县| 加查县| 绥宁县| 策勒县| 佳木斯市| 大理市| 亚东县| 扶风县| 郁南县| 庆阳市| 阳泉市| 温泉县| 镶黄旗| 喜德县| 玉环县| 改则县| 葫芦岛市| 潞西市| 五台县| 东明县| 安多县| 始兴县| 新河县| 平顺县| 连山| 航空| 社会| 内丘县| 绵阳市| 丽水市| 温宿县| 鹰潭市| 开阳县| 巴中市| 石阡县| 菏泽市| 饶阳县| 保山市|