基于swoole框架redis连接池的实现

本文就给大家说说swoole怎么实现一个redis连接池

首先什么连接池？

连接池说白了是用来处理连接外部应用程序的线程池子，池子的大小是有限的，防止过多的连接导致系统奔溃，每次请求来的时候随机从池子中取一条连接返回给程序，而不需要重新生成连接。

连接池有很多种，比如数据库连接池，Redis连接池等，但是本质上都是一样，我们知道数据库连接成功后会生成数据库连接的对象，当把多个数据库连接对象放入数组或者集合中时，这个集合就称为连接池。主要用来做负载均衡。

PHP中的连接池
在早期的PHP中是没有连接池的概念的，因为php脚本在解释执行完毕后会释放所有内存资源，其中的连接其他应用的资源也会释放，比如连接数据库的资源。但是随着互联网的快速发展，系统的最大瓶颈是连接外部资源，急需PHP提高性能，于是连接池也加入到PHP的大军。

然后再来说说具体实现方法

Demo 中大概包含这些点：

• 实现 MySQL 连接池
• 实现 MySQL CURD 方法的定义
• 实现 Redis 连接池
• 实现 Redis 方法的定义
• 满足 HTTP、TCP、WebSocket 调用
• 提供 Demo 供测试
• 调整 目录结构

HTTP 调用：

实现 读取 MySQL 中数据的 Demo

实现 读取 Redis 中数据的 Demo

TCP 调用：

• 实现 读取 MySQL 中数据的 Demo
• 实现 读取 Redis 中数据的 Demo

目录结构

代码如下：

<?
php



if
 
(!
defined
(
'SERVER_PATH'
))
 
exit
(
"No Access"
);



class
 
RedisPool

{

    
private
 
static
 $instance
;

    
private
 $pool
;

    
private
 $config
;



    
public
 
static
 
function
 getInstance
(
$config 
=
 
null
)

    
{

        
if
 
(
empty
(
self
::
$instance
))
 
{

            
if
 
(
empty
(
$config
))
 
{

                
throw
 
new
 
RuntimeException
(
"Redis config empty"
);

            
}

            
self
::
$instance 
=
 
new
 
static
(
$config
);

        
}

        
return
 
self
::
$instance
;

    
}



    
public
 
function
 __construct
(
$config
)

    
{

        
if
 
(
empty
(
$this
->
pool
))
 
{

            $this
->
config 
=
 $config
;

            $this
->
pool 
=
 
new
 chan
(
$config
[
'master'
][
'pool_size'
]);

            
for
 
(
$i 
=
 
0
;
 $i 
<
 $config
[
'master'
][
'pool_size'
];
 $i
++)
 
{

                go
(
function
()
 
use
 
(
$config
)
 
{

                    $redis 
=
 
new
 
RedisDB
();

                    $res 
=
 $redis
->
connect
(
$config
);

                    
if
 
(
$res 
===
 
false
)
 
{

                        
throw
 
new
 
RuntimeException
(
"Failed to connect redis server"
);

                    
}
 
else
 
{

                        $this
->
pool
->
push
(
$redis
);

                    
}

                
});

            
}

        
}

    
}



    
public
 
function
 
get
()

    
{

        
if
 
(
$this
->
pool
->
length
()
 
>
 
0
)
 
{

            $redis 
=
 $this
->
pool
->
pop
(
$this
->
config
[
'master'
][
'pool_get_timeout'
]);

            
if
 
(
false
 
===
 $redis
)
 
{

                
throw
 
new
 
RuntimeException
(
"Pop redis timeout"
);

            
}

            defer
(
function
 
()
 
use
 
(
$redis
)
 
{
 
//释放

                $this
->
pool
->
push
(
$redis
);

            
});

            
return
 $redis
;

        
}
 
else
 
{

            
throw
 
new
 
RuntimeException
(
"Pool length <= 0"
);

        
}

    
}

}

以上就是“基于swoole框架redis连接池的实现”的详细内容，想要了解更多swoole教程欢迎关注编程学习网