逍遥阁

swoole之mysql连接池的实现

关键词: swoole mysql

swoole之mysql连接池的实现

`mysql_pool_server.php`

```
<?php
class mysqlPoolServer
{
    private $server;

private $pdo;

public function __construct($host, $port)
    {
        $this->server = new swoole_server($host, $port);
        $this->server->set(array(
            'worker_num' => 8,
            'daemonize' => false,
            'max_request' => 10000,
            'dispatch_mode' => 3,
            'debug_mode'=> 1,
            'task_worker_num' => 8
        ));
        $this->server->on('workerstart', array($this, 'onWorkerStart'));
        $this->server->on('connect', array($this, 'onConnect'));
        $this->server->on('receive', array($this, 'onReceive'));
        $this->server->on('close', array($this, 'onClose'));
        $this->server->on('task', array($this, 'onTask'));
        $this->server->on('finish', array($this, 'onFinish'));
        $this->server->start();
    }

private function getPdo()
    {
        return new PDO(
            'mysql:host=192.168.1.20;port=3306;dbname=test',
            'mysql_pool',
            '1234',
            array(
                PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8';",
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_PERSISTENT => true
            )
        );
    }

public function onWorkerStart($server, $worker_id)
    {
        echo "[onWorkerStart][{$worker_id}]".PHP_EOL;
        /*判定是否为taskWorker进程*/
        if($worker_id >= $server->setting['worker_num']){
            $this->pdo = $this->getPdo();
        }
    }

public function onConnect($server, $fd, $from_id)
    {
        echo "[onConnect][{$fd}][{$from_id}]".PHP_EOL;
    }

public function onReceive(swoole_server $server, $fd, $from_id, $data)
    {
        echo "[onReceive][{$fd}][{$from_id}]".PHP_EOL;
        $server->task(array('fd' => $fd, 'data' => $data));
    }

public function onClose($server, $fd, $from_id)
    {
        echo "[onClose][{$fd}][{$from_id}]".PHP_EOL;
    }

public function onTask($server, $task_id, $from_id, $data)
    {
        echo "[onTask][{$task_id}][{$from_id}]".PHP_EOL;
        try
        {
            $statement = $this->pdo->prepare('select * from region order by rand() limit 1');
            $statement->execute();
            $list = $statement->fetchAll();
            $server->send($data['fd'], json_encode($list));
            $server->finish('ok');
            return true;
        }
        catch(PDOException $e)
        {
            var_dump($e);
            return false;
        }
    }

public function onFinish($server, $task_id, $data)
    {
        echo "[onFinish][{$task_id}]".PHP_EOL;
    }

}

new mysqlPoolServer('0.0.0.0', 9500);
```

可以用

https://www.zhouchun.net/blog/show/475

里面的`client.php`测试

mysql可以用`show full processlist`查看连接数，最好专门开一个账号用来测试，这样可以通过观察`Id`和`User`判断程序的正确性

admin
2017-10-10 11:31:52
swoole

文章分类

文章标签

文章归档

友情链接

swoole之mysql连接池的实现