IT俱乐部 Redis easyswoole3.5 redis使用详细解析

easyswoole3.5 redis使用详细解析

安装redis指定版本

composer require easyswoole/redis:^1.3

redis配置,dev.php

 "EasySwoole",
    'MAIN_SERVER' => [
        'LISTEN_ADDRESS' => '0.0.0.0',
        'PORT' => 9503,
        'SERVER_TYPE' => EASYSWOOLE_WEB_SERVER, //可选为 EASYSWOOLE_SERVER  EASYSWOOLE_WEB_SERVER EASYSWOOLE_WEB_SOCKET_SERVER
        'SOCK_TYPE' => SWOOLE_TCP,
        'RUN_MODEL' => SWOOLE_PROCESS,
        'SETTING' => [
            'worker_num' => 8,
            'reload_async' => true,
            'max_wait_time' => 3
        ],
        'TASK' => [
            'workerNum' => 4,
            'maxRunningNum' => 128,
            'timeout' => 15
        ]
    ],
    "LOG" => [
        'dir' => null,
        'level' => LoggerInterface::LOG_LEVEL_DEBUG,
        'handler' => null,
        'logConsole' => true,
        'displayConsole' => true,
        'ignoreCategory' => []
    ],
    'TEMP_DIR' => null,
    // 添加 Redis 及对应的连接池配置
    /*################ REDIS CONFIG ##################*/
    'REDIS' => [
        'host' => '127.0.0.1', // Redis 地址
        'port' => '6379', // Redis 端口
        'auth' => '', // Redis 密码
        'timeout' => 3.0, // Redis 操作超时时间
        'reconnectTimes' => 3, // Redis 自动重连次数
        'db' => 0, // Redis 库
    ],
];

EasySwooleEvent.php,加入预加载

   public static function initialize()
    {
        date_default_timezone_set('Asia/Shanghai');
        $rdConfig = new RedisConfig(Config::getInstance()->getConf('REDIS'));
        RedisPool::getInstance()->register($rdConfig);
    }

控制器使用

public function getOne()
	{
		$param = ContextManager::getInstance()->get('param');
        $redis =  RedisPool::defer();
        //redis 操作
        $redisData = $redis->get($this->key.$param['id']);
        if ($redisData) {
            $this->writeJson(Status::CODE_OK, json_decode($redisData, true), "获取数据成功.");
            return false;
        }
		$model = new StudentModel();
        try {
            $info = $model->where('id', $param['id'])->get();
        } catch (Exception|EasySwooleORMExceptionException|Throwable $e) {
            $this->writeJson(Status::CODE_BAD_REQUEST, [], $e->getMessage());
            return false;
        }
        if (!$info) {
            $this->writeJson(400, [], '该数据不存在');
            return false;
        }
        $redis->set($this->key.$param['id'], json_encode($info, JSON_UNESCAPED_UNICODE), $this->time);
		$this->writeJson(Status::CODE_OK, $info, "获取数据成功.");
	}

到此这篇关于easyswoole3.5 redis使用的文章就介绍到这了,更多相关easyswoole3.5 redis使用内容请搜索IT俱乐部以前的文章或继续浏览下面的相关文章希望大家以后多多支持IT俱乐部!

本文收集自网络,不代表IT俱乐部立场,转载请注明出处。https://www.2it.club/database/redis/12076.html
上一篇
下一篇
联系我们

联系我们

在线咨询: QQ交谈

邮箱: 1120393934@qq.com

工作时间:周一至周五,9:00-17:30,节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

返回顶部