|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 |
<?php require __DIR__ . '/db.php'; $dbPool = array(); $poolSize = 20; for ($i=0; $i < $poolSize; $i++) { $dbPool[$i]= new Db(); } $serv = new swoole_server("127.0.0.1", 9501); // $serv->set(array( // 'worker_num' => 8, //工作进程数量 // 'daemonize' => true, //是否作为守护进程 // )); $serv->on('connect', function ($serv, $fd){ echo "Client:Connect.\n"; }); $serv->on('receive', function ($serv, $fd, $from_id, $sql) { global $dbPool; $rs = false; if (!empty($dbPool)) { $db = array_pop($dbPool); $rs = $db->execute($sql); array_push($dbPool, $db); } if ($rs) { $serv->send($fd, 'ok'); } else { $serv->send($fd, 'not ok'); } $serv->close($fd); }); $serv->on('close', function ($serv, $fd) { echo "Client: Close.\n"; }); $serv->start(); |
db类下载地址：
http://www.fengfengphp.com/yaf/db.zip
