codeigniter-phpcp
Here comes some changes of ci framework,include db seperated and the php connection pool ...
environment seperate
As the ci defines , there are three enviroments for us , including development | testing | production. So you can find out three more directories in the config directory ,with the names development ,testing, production
development : the config file here enabled while you index.php is set to development enviroment
testing : the config file here enabled while you index.php is set to testing enviroment
production : the config file here enabled while you index.php is set to production enviroment
and files under the root of config directory will enabled while the framework cannot find the file in the enviroment directories
database seperate
You can see that I put a dbmap.php file in each enviroment directory , and this is the most important config for the seperating
* @copyright CopyRight 2016
* @since Version 1.0
* @license
* @example
*
* Assuming that your config is like this :
*
* $config['bbcloud'] = array(
* 'master' => array('master01','master02'),
* 'slave' => array('slave01','slave02')
* );
*
* What you should do is to make sure that your database.php config file has the
* master01,master02,slave01,slave02 configurations
*
*
*/
$config['test1'] = array(
'master' => array('masterone'),
'slave' => array('slaveone')
);
$config['test2'] = array(
'master' => array('mastertwo'),
'slave' => array('slavetwo')
);
This will be used in the ./application/core/MY_DbConnection.php file , which is the main db connection controller of this function , and you may find the MY_Model.php in the same directory , it will be the parent of the all models instead of the CI_Model and we will mention it latter.
Now let's see an example of using the seperate db connection
* @copyright CopyRight 2016
* @since Version 1.0
* @license
*/
class Mtest extends MY_Model{
/**
* The relate table name
* @var string
*/
public $table_name = 'test';
/**
* Default constructor
*/
public function __construct(){
parent::__construct();
}
/**
* test add data
* @param array $data_arr
* @return mixed
*/
public function add_test($data_arr){
// return $this->add_data($this->masterTest1,$this->table_name,$data_arr);
$this->masterTest1->insert($this->table_name,$data_arr);
return array('affected_rows'=>$this->masterTest1->affected_rows(),'insert_id'=>$this->masterTest1->insert_id());
}
/**
* test query all data
* @return mixed
*/
public function query_all(){
return $this->slaveTest1->get($this->table_name)->result_array();
}
}
You may see the code like $this->slaveTest1 and $this->masterTest1 above , as it relates to the dbmap's test1's slave and master , to know more about this function , you should see the config file database.php
'mysql:host=localhost;dbname=test;charset=utf8',
'hostname' => 'localhost',
'username' => 'root',
'password' => 'root',
'database' => 'test',
'dbdriver' => 'pdoproxy',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);
$db['mastertwo'] = array(
'dsn' => 'mysql:host=localhost;dbname=test;charset=utf8',
'hostname' => 'localhost',
'username' => 'root',
'password' => 'root',
'database' => 'test',
'dbdriver' => 'pdoproxy',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);
$db['slaveone'] = array(
'dsn' => 'mysql:host=localhost;dbname=test;charset=utf8',
'hostname' => 'localhost',
'username' => 'root',
'password' => 'root',
'database' => 'test',
'dbdriver' => 'pdoproxy',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);
$db['slavetwo'] = array(
'dsn' => 'mysql:host=localhost;dbname=test;charset=utf8',
'hostname' => 'localhost',
'username' => 'root',
'password' => 'root',
'database' => 'test',
'dbdriver' => 'pdoproxy',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);
I think you should be very clearly about the db seperate now , if you cannot understand I would be very guilty .
php pool connection support
As the concurrent volume is more and more important , a lot of way to improve it comes out , like caching or load balancing etc.
Here I just describe the way I got these days , while my boss wanted me to make a db pool like java .
Thanks to github and the developers of php-cp (php connection pool) , I finally got the way
I clone it from the github and compile it into my php modules , as authors said , I copy the pool.ini to my /etc/ and change the config the same as my dsn in the database.php , and the most important thing is that we should start the pool_server with root
If you want to know more , please go to the github mentioned above, here show my compile process and config :
git clone https://github.com/swoole/php-cp.git
cd php-cp
phpize
./configure
make && make install
echo "extension=connect_pool.so" >> /etc/php5/apache2/php.ini && echo "extension=connect_pool.so" >> /etc/php5/cli/php.ini
cp pool.ini /etc/
cp pool_server /var/www/html/script
------------------------------------------------------------------------------------------------------
vim /etc/pool.ini
[common]
log_file = /tmp/phpcp.log
;the num of TCP connections release every idel_time cycles(连接空闲后的回收力度，值越大回收的越快，但是会造成更多的消耗)
recycle_num = 2
;In this period of time,if no process use this connection ,the TCP connection will release(空闲连接回收的发呆时间 单位秒)
idel_time = 2
;;max query package len,exceed will throw exception(最大转发的数据包,超过跑异常5M)
max_read_len = 5242880
;run as daemonize(是否开启守护进程化)
daemonize = 1
;If the num of connection to max, whether to use the queue buffer, set to 0 throw an exception(连接都被占用后,再获取连接是否使用队列缓冲,设置为0直接抛异常)
use_wait_queue = 1
;the get_disable_list() function returns the maximum number of IP(get_disable_list函数最多返回多少个失效结点,防止网络抖动踢掉所有的机器)
max_fail_num = 1
;just the pool_server process port(端口)
port = 6253
;注意数据源需要加 ''
;PDO数据源要与new PDO的第一个参数完全一致（包括顺序）
;如果不配置数据源 那么默认最大是20 最小是1 ，在第一次查询的时候自动创建
['mysql:host=localhost;dbname=test;charset=utf8'];mysql配置
pool_min = 2
pool_max = 30
------------------------------------------------------------------------------------------------------
php start /var/www/html/script/pool_server
After the server start , you can change the database.php ,modify the dbdriver to pdoproxy , and you can use the normal ci db usage to doing you work , while the proproxy driver doing the release backend .
If you just want the driver , you can get it in the directory ./system/database/drivers/pdoproxy
MY_Model.php - The parent of all Models
MY_Model.php extends the MY_DbConnection , supports the db seperate and supplies some common method for quick queries , but it's not the most important one , you can alse extends MY_DbConnection in you model directly.
RedisServer
You can find the RedisServer.php in the ./application/libraries , which will be the parent of the ./application/models/redis/RedisMain.php , make some common config of the redis , and you can see the redis config in the config directory redis.php
* @copyright CopyRight 2016
* @since Version 1.0
* @license
* @example
*
*
*/
$config['redis'] = array(
'host' => '',
'port' => 6379,
'password' => ''
);
//--------------------------------------------------------------------------------------------------
// 不同环境的前缀配置，目前有开发环境、测试环境和生产环境三种
// 此处不配置生产环境的前缀，主要是为了兼容之前的一些redis键值
//--------------------------------------------------------------------------------------------------
$config['prefix'] = array(
'development' => 'dev_',
'testing' => 'test_',
'production' => ''
);
I will describe the usage later
706 Jan 3, 2023
7 Jan 16, 2022
1 Dec 21, 2021
3 Jul 2, 2022
10.2k Dec 31, 2022
2 Sep 23, 2022
14k Dec 31, 2022
11.5k Jan 4, 2023
732 Dec 30, 2022
311 Dec 31, 2022
7 Jun 22, 2021
150 Apr 12, 2022
6 Oct 14, 2022
152 Dec 18, 2022
3 Dec 29, 2022
620 Jan 7, 2023
14 Aug 14, 2022
2 Feb 12, 2022