set(array( 'worker_num' => NUMCORES )); $server->on('request', function ($req, $res) { switch ($req->server['request_uri']) { case "/json": $res->header('Content-Type', 'application/json'); $res->end(json_encode(array('message' => 'Hello, World!'))); break; case "/plaintext": $res->header('Content-Type', 'text/plain; charset=utf-8'); $res->end('Hello, World!'); break; case "/db": $db = new Swoole\Coroutine\Mysql; $server = [ 'host' => co::gethostbyname('tfb-database'), 'user' => 'benchmarkdbuser', 'password' => 'benchmarkdbpass', 'database' => 'hello_world' ]; $db->connect($server); // Read number of queries to run from URL parameter $query_count = 1; if (isset($req->get['queries']) && $req->get['queries'] > 0) $query_count = $req->get['queries'] > 500 ? 500 : $req->get['queries']; // Create an array with the response string. $arr = array(); // Define query $stmt = $db->prepare('SELECT randomNumber FROM World WHERE id = ?'); // For each query, store the result set values in the response array while (0 < $query_count--) { $id = mt_rand(1, 10000); $ret = $stmt->execute(array($id)); // Store result in array. $arr[] = array('id' => $id, 'randomNumber' => $ret[0]['randomNumber']); } // Use the PHP standard JSON encoder. // http://www.php.net/manual/en/function.json-encode.php if (count($arr) === 1) $arr = $arr[0]; $res->header('Content-Type', 'application/json'); $res->end(json_encode($arr)); break; case "/fortunes": $db = new Swoole\Coroutine\Mysql; $server = [ 'host' => co::gethostbyname('tfb-database'), 'user' => 'benchmarkdbuser', 'password' => 'benchmarkdbpass', 'database' => 'hello_world' //;charset=utf8 ]; $db->connect($server); $fortune = []; // Define query $arr = $db->query('SELECT id, message FROM Fortune'); foreach ($arr as $row) $fortune[$row['id']] = $row['message']; $fortune[0] = 'Additional fortune added at request time.'; asort($fortune); $html = ""; foreach ($fortune as $id => $message) $html .= ""; $html .= "

id	message
" . $id . "	" . htmlspecialchars($message, ENT_QUOTES, 'UTF-8') . "

"; $res->header('Content-Type', 'text/html; charset=utf-8'); $res->end($html); break; case "/updates": $db = new Swoole\Coroutine\Mysql; $server = [ 'host' => co::gethostbyname('tfb-database'), 'user' => 'benchmarkdbuser', 'password' => 'benchmarkdbpass', 'database' => 'hello_world' ]; $db->connect($server); $query_count = 1; if (isset($req->get['queries']) && $req->get['queries'] > 0) $query_count = $req->get['queries'] > 500 ? 500 : $req->get['queries']; $arr = array(); $statement = $db->prepare('SELECT randomNumber FROM World WHERE id = ?'); $updateStatement = $db->prepare('UPDATE World SET randomNumber = ? WHERE id = ?'); while (0 < $query_count--) { $id = mt_rand(1, 10000); $randomNumber = mt_rand(1, 10000); $ret = $statement->execute(array($id)); // Store result in array. $world = array('id' => $id, 'randomNumber' => $ret[0]['randomNumber']); $world['randomNumber'] = $randomNumber; $updateStatement->execute(array($randomNumber, $id)); $arr[] = $world; } $res->header('Content-Type', 'application/json'); $res->end(json_encode($arr)); break; } }); $server->start();