美文网首页程序员
Swoole单例模式及依赖注入进行Redis底层类库封装

Swoole单例模式及依赖注入进行Redis底层类库封装

作者: Bing的天涯路 | 来源:发表于2019-12-31 14:07 被阅读0次
  1. redis安装及php-redis扩展安装
  2. 初步使用
  3. 封装基类 – 单例模式
  4. 优化封装 – 依赖注入
  5. 从配置加载
  6. 从自定义配置加载
    本文将一步一步的从redis的安装一直到easySwoole使用高度封装的底层类库，并进行优化提高代码的维护性，可以直接看最后的优化结果

第一部分 redis安装及php-redis扩展安装

redis的安装很简单，直接到redis官网下载，这里使用的是redis4.0.12，下载后直接make && make install即可，
进入到redis的文件夹的src目录，运行一个redis服务，其默认端口是6379：

./redis-server

运行一个redis客户端

./redis-cli

安装php-redis也很简单，从github把扩展下载下来解压，然后

phpize
./configure
make && make install

即可，如果想要configure到指定的php版本就指定phpize的目录并在config的时候prefix到指定的php配置文件，安好之后再php.ini加上redis.so即可。

第二部分 初步使用

直接在源码中进行redis的连接：

<?php
/**
 * Created by bingxiong.
 * Date: 12/19/18
 * Time: 6:38 PM
 * Description:
 */
 
namespace App\HttpController\Api;
 
use \EasySwoole\Core\Component\Di;
// 使用封装的redis基类
use App\Lib\Redis\Redis;
 
class Index extends Base
{
    public function getRedis(){
        $redis = new \Redis();
        $redis->connect("127.0.0.1",6379, 5);
        $redis->set("bing",19249);
        return $this->writeJson(200,'OK',$redis->get("bing"));
    }
 
}

显然我们不可能这样使用，需要对其进行二次封装

第三部分 创建Redis的基类

基类创建在App->Lib->Redis->redis.php

<?php
/**
 * Created by bingxiong.
 * Date: 12/21/18
 * Time: 12:44 AM
 * Description:
 */
 
namespace App\Lib\Redis;
 
// 使用单例模式
use EasySwoole\Config;
use EasySwoole\Core\AbstractInterface\Singleton;
 
class Redis
{
    use Singleton;
 
    public $redis = "";
 
    private function __construct()
    {
        //判断扩展有没有安装
        if(!extension_loaded('redis')){
            throw new \Exception("redis.so文件不存在");
        }
        try{
            $this->redis = new \Redis();
            $result = $this->redis->connect("127.0.0.1",6379,3);
        } catch (\Exception $e){
            throw new \Exception("redis服务异常");
        }
 
        if($result === false){
            throw new \Exception("redis连接失败");
        }
    }
 
    /**
     * 重写get友好的返回key不存在的情况
     * @param $key
     * @return bool|string
     */
    public function get($key){
        if(empty($key)){
            return '';
        }
        return $this->redis->get($key);
    }
 
}

说明：
使用了单例模式：用于为一个类生成一个唯一的对象。最常用的地方是数据库连接。 使用单例模式生成一个对象后，该对象可以被其它众多对象所使用。作为对象的创建模式，单例模式确保某一个类只有一个实例，而且自行实例化并向整个系统提供这个实例，这个类称为单例类。1、一个类只能有一个实例 2、它必须自行创建这个实例 3、它必须自行向整个系统提供这个实例
有了基类之后，配置和连接的任务就从基类的构造函数加载了，之前的代码就变成了

<?php
/**
 * Created by bingxiong.
 * Date: 12/19/18
 * Time: 6:38 PM
 * Description:
 */
 
namespace App\HttpController\Api;
 
 
use \EasySwoole\Core\Component\Di;
// 使用封装的redis基类
use App\Lib\Redis\Redis;
 
class Index extends Base
{ 
    public function getRedis(){
        $result = Redis::getInstance()->get('bing');
        return $this->writeJson(200,'OK',$result);
    }
 
}

第四部分 依赖注入

依赖注入：一个对象提供另一个对象的依赖关系，是一种设计模式，好处就是有效的分离了对象和它所需要的外部资源，使得它们松散耦合，有利于功能复用，更重要的是使得程序的整个体系结构变得非常灵活。
easyswool使用依赖注入非常的简单，在easyswoolevent的文件中

public static function mainServerCreate(ServerManager $server,EventRegister $register): void
    {
        Di::getInstance()->set('MYSQL',\MysqliDb::class,Array (
                'host' => '127.0.0.1',
                'username' => 'root',
                'password' => 'root',
                'db'=> 'imooc_video',
                'port' => 8889,
                'charset' => 'utf8')
        );
        Di::getInstance()->set('REDIS',Redis::getInstance());
 
    }

上面的是我数据库的配置，下面getInstance中实例化了刚才封装的基类

实例化di再getInstance就可以了

<?php
/**
 * Created by bingxiong.
 * Date: 12/19/18
 * Time: 6:38 PM
 * Description:
 */
 
namespace App\HttpController\Api;
 
 
use \EasySwoole\Core\Component\Di;
// 使用封装的redis基类
use App\Lib\Redis\Redis;
 
class Index extends Base
{
 
    public function getRedis(){
        // 3使用依赖注入
        $result = Di::getInstance()->get('REDIS')->get('bing');
        return $this->writeJson(200,'OK',$result);
    }
 
}

第5部分 从配置加载

在配置文件中添加,或者用你喜欢的方式配置

'REDIS' => [
     'host' => '127.0.0.1',
     'port' => 6379,
     'time_out' => 3
 ]

然后基类改写成

<?php
/**
 * Created by bingxiong.
 * Date: 12/21/18
 * Time: 12:44 AM
 * Description:
 */
 
namespace App\Lib\Redis;
 
// 使用单例模式
use EasySwoole\Config;
use EasySwoole\Core\AbstractInterface\Singleton;
 
class Redis
{
    use Singleton;
 
    public $redis = "";
 
    private function __construct()
    {
        //判断扩展有没有安装
        if(!extension_loaded('redis')){
            throw new \Exception("redis.so文件不存在");
        }
        try{
            //从配置加载REDIS - 提高维护性
            $redisConfig = Config::getInstance()->getConf("REDIS");
            $this->redis = new \Redis();
            $result = $this->redis->connect($redisConfig['host'],$redisConfig['port'],$redisConfig['time_out']);
        } catch (\Exception $e){
            throw new \Exception("redis服务异常");
        }
 
        if($result === false){
            throw new \Exception("redis连接失败");
        }
    }
 
    /**
     * 重写get友好的返回key不存在的情况
     * @param $key
     * @return bool|string
     */
    public function get($key){
        if(empty($key)){
            return '';
        }
        return $this->redis->get($key);
    }
 
}

第6部分 从自定义配置加载

由于可能有很多配置，把配置都放在这个文件的话会显得很臃肿，因此我们将每个配置文件比如redis mysql elasticsearch的配置单独抽离出来单独管理，这样有更好的维护性

所以在根目录创建config->redis.php,在这里直接返回redis的配置

<?php
/**
 * Created by bingxiong.
 * Date: 12/21/18
 * Time: 2:10 AM
 * Description: redis相关配置
 */
 
return ['host' => '127.0.0.1', 'port' => 6379, 'time_out' => 3];

然后自定义载入配置文件,创建了一个loadConf方法，这个方法在easyswoole的文档中有，所以最终的

EasySwooleEvent.php

<?php
/**
 * Created by PhpStorm.
 * User: yf
 * Date: 2018/1/9
 * Time: 下午1:04
 */
 
namespace EasySwoole;
 
use App\Lib\Redis\Redis;
use \EasySwoole\Core\AbstractInterface\EventInterface;
use EasySwoole\Core\Component\Di;
use \EasySwoole\Core\Swoole\ServerManager;
use \EasySwoole\Core\Swoole\EventRegister;
use \EasySwoole\Core\Http\Request;
use \EasySwoole\Core\Http\Response;
use \EasySwoole\Core\Utility\File;
 
Class EasySwooleEvent implements EventInterface {
 
    public static function frameInitialize(): void
    {
        // TODO: Implement frameInitialize() method.
        date_default_timezone_set('Asia/Shanghai');
        self::loadConf(EASYSWOOLE_ROOT.'/Config');
    }
 
    public static function loadConf($ConfPath)
    {
        $Conf  = Config::getInstance();
        $files = File::scanDir($ConfPath);
        foreach ($files as $file) {
            $data = require_once $file;
            $Conf->setConf(strtolower(basename($file, '.php')), (array)$data);
        }
    }
 
    /**
     * 使用依赖注入加载
     * @param ServerManager $server
     * @param EventRegister $register
     */
    public static function mainServerCreate(ServerManager $server,EventRegister $register): void
    {
        Di::getInstance()->set('MYSQL',\MysqliDb::class,Array (
                'host' => '127.0.0.1',
                'username' => 'root',
                'password' => 'root',
                'db'=> 'imooc_video',
                'port' => 8889,
                'charset' => 'utf8')
        );
        Di::getInstance()->set('REDIS',Redis::getInstance());
 
    }
 
    public static function onRequest(Request $request,Response $response): void
    {
        // TODO: Implement onRequest() method.
    }
 
    public static function afterAction(Request $request,Response $response): void
    {
        // TODO: Implement afterAction() method.
    }
}

redis.php 这是redis的基类
<?php
/**

  • Created by bingxiong.
  • Date: 12/21/18
  • Time: 12:44 AM
  • Description:
    */

namespace App\Lib\Redis;

// 使用单例模式
use EasySwoole\Config;
use EasySwoole\Core\AbstractInterface\Singleton;

class Redis
{
use Singleton;

public $redis = "";

private function __construct()
{
    //判断扩展有没有安装
    if(!extension_loaded('redis')){
        throw new \Exception("redis.so文件不存在");
    }
    try{
        // 从自己的配置加载
        $redisConfig = Config::getInstance()->getConf("redis");
        $this->redis = new \Redis();
        $result = $this->redis->connect($redisConfig['host'],$redisConfig['port'],$redisConfig['time_out']);
    } catch (\Exception $e){
        throw new \Exception("redis服务异常");
    }

    if($result === false){
        throw new \Exception("redis连接失败");
    }
}

/**
 * 重写get友好的返回key不存在的情况
 * @param $key
 * @return bool|string
 */
public function get($key){
    if(empty($key)){
        return '';
    }
    return $this->redis->get($key);
}

}
最终实现

/**
 * Created by bingxiong.
 * Date: 12/19/18
 * Time: 6:38 PM
 * Description:
 */
 
namespace App\HttpController\Api;
 
use \EasySwoole\Core\Component\Di;
 
class Index extends Base
{
    public function getRedis(){
        // 使用依赖注入
        $result = Di::getInstance()->get('REDIS')->get('bing');
        return $this->writeJson(200,'OK',$result);
    }
 
}

本文作者熊冰，个人网站Bing的天涯路，转载请注明出处。

相关文章

  • Swoole单例模式及依赖注入进行Redis底层类库封装

    redis安装及php-redis扩展安装 初步使用 封装基类 – 单例模式 优化封装 – 依赖注入 从配置加载 ...

  • 单例模式

    单例模式是封装的一种形式，依靠单例模式调用被封装的属性和方法，因为使用单例模式的类无法生成实例（只能引用单例模式所...

  • 单例模式

    spring单例模式 spring的默认bean注入为单例，以下通过简单的例子进行测试: 创建2个类，分别为sin...

  • Django使用Redis进行缓存

    Django中使用Redis： 方式A：自定义单例模式连接redis（依赖于pip3 install redis，...

  • Java 单例模式Singleton

    单例模式特点：单例类只能有一个实例单例类自己内部创建实例单例类给其他所有对象提供这一实例 懒汉模式（使用时进行对象...

  • 几个直击灵魂的Spring拷问（六）

    单例模式可能是开发中应用最为广泛的一种的设计模式，Spring 中依赖注入 Bean 实例默认是单例的，在Nett...

  • 你真的会写单例？

    提到单例模式，相信都不会陌生，今天对其进行总结。 以下是单例模式的特点： 单例类只能有一个实例。 单例类必须自己自...

  • iOS单例模式

    单例模式 解决“应用中只有一个单例”的一类问题。 Objecttive-C实现原理 单例模式一般会封装一个静态属性...

  • koa框架（二）

    一、继承 1.实现单例 二、封装Koa操作Mongodb数据库的DB类库 1.多次实例化解决办法：单例 //解决多...

  • python09-单例设计模式

    单例设计模式 如果每个对象封装了不同的数据,则不适用单例模式 如果一个类封装的数据一样,调用方法得到的结果一样,且...

网友评论

    本文标题：Swoole单例模式及依赖注入进行Redis底层类库封装

    本文链接：https://www.haomeiwen.com/subject/srvboctx.html

    延伸阅读

    深度阅读

    • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

    栏目导航

    热点阅读

    程序员

    关于我们|服务条款|联系我们|Swoole单例模式及依赖注入进行Redis底层类库封装|投稿指南|网站地图|RSS订阅|排版工具|手机版

    提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

    Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

    备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

    本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

    所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！