说明

体验

安装

composer require naka1205/phpkoa

使用

<?phprequire __DIR__ . "/vendor/autoload.php";use Naka507KoaApplication;use Naka507KoaContext;$app = new Application();$app->υse(function(Context $ctx) { $ctx->status = 200; $ctx->body = "<h1>Hello World</h1>";});$app->listen(3000);

<?phprequire __DIR__ . "/vendor/autoload.php";use Naka507KoaApplication;use Naka507KoaContext;use Naka507KoaError;use Naka507KoaTimeout;use Naka507KoaRouter;use Naka507KoaNotFound;$app = new Application();$app->υse(new Error());$app->υse(new NotFound());$app->υse(new Timeout(3)); //设置3秒超时$router = new Router();//正常访问$router->get("/hello", function(Context $ctx, $next) { $ctx->status = 200; $ctx->body = "<h1>Hello World</h1>";});//访问超时$router->get("/timeout", function(Context $ctx, $next) { yield async_sleep(5);});//访问出错$router->get("/error", function(Context $ctx, $next) { $ctx->thrοw(500, "Internal Error"); yield;});$app->υse($router->routes());$app->listen(3000);

<?phprequire __DIR__ . "/vendor/autoload.php";define("DS", DIRECTORY_SEPARATOR);use Naka507KoaApplication;use Naka507KoaContext;use Naka507KoaError;use Naka507KoaTimeout;use Naka507KoaRouter;$app = new Application();$app->υse(new Error());$app->υse(new Timeout(5));$router = new Router();$router->get("/demo1", function(Context $ctx, $next) { $ctx->body = "demo1";});$router->get("/demo2", function(Context $ctx, $next) { $ctx->body = "demo2";});$router->get("/demo3/(d+)", function(Context $ctx, $next, $vars) { $ctx->status = 200; $ctx->body = "demo3={$vars[0]}";});$router->get("/demo4", function(Context $ctx, $next) { $ctx->redirect("/demo2");});//RESTful API$router->post("/demo3/(d+)", function(Context $ctx, $next, $vars) { //设置 session $ctx->setSession("demo3",$vars[0]); //设置 cookie $ctx->setCookie("demo3",$vars[0]); $ctx->status = 200; $ctx->body = "post:demo3={$vars[0]}";});$router->put("/demo3/(d+)", function(Context $ctx, $next, $vars) { //获取单个 cookie $cookie_demo3 = $ctx->getCookie("demo3"); //或者 $cookies = $ctx->cookies["demo3"]; //获取单个 session $session_demo3 = $ctx->getSession("demo3"); //或者 $session = $ctx->session["demo3"]; $ctx->status = 200; $ctx->body = "put:demo3={$vars[0]}";});$router->delete("/demo3/(d+)", function(Context $ctx, $next, $vars) { //清除所有 cookie $ctx->clearCookie(); //清除所有 session $ctx->clearSession(); $ctx->status = 200; $ctx->body = "delete:demo3={$vars[0]}";});//文件上传$router->post("/files/(d+)", function(Context $ctx, $next, $vars) { $upload_path = __DIR__ . DS . "uploads" . DS; if ( !is_dir($upload_path) ) { mkdir ($upload_path , 0777, true); } $files = []; foreach ( $ctx->request->files as $key => $value) { if ( !$value["file_name"] || !$value["file_data"] ) { continue; } $file_path = $upload_path . $value["file_name"]; file_put_contents($file_path, $value["file_data"]); $value["file_path"] = $file_path; $files[] = $value; } $ctx->status = 200; $ctx->body = json_encode($files);});$app->υse($router->routes());$app->listen(3000);<?php//此处已省略 ... //使用第三方 HTTP 客户端类库，方便测试use GuzzleHttpClient;$router = new Router();//路由分组 //http://127.0.0.1:5000/curl/get//http://127.0.0.1:5000/curl/post//http://127.0.0.1:5000/curl/put//http://127.0.0.1:5000/curl/delete$router->mount("/curl", function() use ($router) { $client = new Client(); $router->get("/get", function( Context $ctx, $next ) use ($client) { $r = (yield $client->request("GET", "http://127.0.0.1:3000/demo3/1")); $ctx->status = $r->getStatusCode(); $ctx->body = $r->getBody(); }); $router->get("/post", function(Context $ctx, $next ) use ($client){ $r = (yield $client->request("POST", "http://127.0.0.1:3000/demo3/2")); $ctx->status = $r->getStatusCode(); $ctx->body = $r->getBody(); }); $router->get("/put", function( Context $ctx, $next ) use ($client){ $r = (yield $client->request("PUT", "http://127.0.0.1:3000/demo3/3")); $ctx->status = $r->getStatusCode(); $ctx->body = $r->getBody(); }); $router->get("/delete", function( Context $ctx, $next ) use ($client){ $r = (yield $client->request("DELETE", "http://127.0.0.1:3000/demo3/4")); $ctx->status = $r->getStatusCode(); $ctx->body = $r->getBody(); });});//http://127.0.0.1:5000/files$router->get("/files", function(Context $ctx, $next ) { $client = new Client(); $r = ( yield $client->request("POST", "http://127.0.0.1:3000/files/2", [ "multipart" => [ [ "name" => "file_name", "contents" => fopen( __DIR__ . "/file.txt", "r") ], [ "name" => "other_file", "contents" => "hello", "filename" => "filename.txt", "headers" => [ "X-Foo" => "this is an extra header to include" ] ] ] ])); $ctx->status = $r->getStatusCode(); $ctx->body = $r->getBody();});// $router->get("/curl/(w+)", function(Context $ctx, $next, $vars) {// $method = strtoupper($vars[0]);// $client = new Client();// $r = (yield $client->request($method, "http://127.0.0.1:3000/demo3/123"));// $ctx->status = $r->getStatusCode();// $ctx->body = $r->getBody();// });$app->υse($router->routes());$app->listen(5000);

<body> <h1>{title}</h1> <p>{time}</p></body><?phprequire __DIR__ . "/vendor/autoload.php";use Naka507KoaApplication;use Naka507KoaContext;use Naka507KoaError;use Naka507KoaTimeout;use Naka507KoaRouter;$app = new Application();$app->υse(new Error());$app->υse(new Timeout(5));$router = new Router();$router->get("/hello", function(Context $ctx) { $ctx->status = 200; $ctx->state["title"] = "HELLO WORLD"; $ctx->state["time"] = date("Y-m-d H:i:s", time());; yield $ctx->render(__DIR__ . "/hello.html");});$app->υse($router->routes());$app->listen(3000);<body> <p>{title}</p> <table border=1> <tr><td>Name</td><td>Age</td></tr> <!-- BEGIN INFO --> <tr> <td> {name} </td> <td> {age} </td> </tr> <!-- END INFO --> </table></body><?php//此处已省略 ... //一维数组$router->get("/info", function(Context $ctx) { $info = array("name" => "小明", "age" => 15); $ctx->status = 200; $ctx->state["title"] = "这是一个学生信息"; $ctx->state["info"] = $info; yield $ctx->render(__DIR__ . "/info.html");});<body> <p>{title}</p> <table border=1> <tr><td>Name</td><td>Age</td></tr> <!-- BEGIN TABLE --> <tr> <td> {name} </td> <td> {age} </td> </tr> <!-- END TABLE --> </table></body><?php//此处已省略 ... //二维数组$router->get("/table", function(Context $ctx) { $table = array( array("name" => "小明", "age" => 15), array("name" => "小花", "age" => 13), array("name" => "小刚", "age" => 17) ); $ctx->status = 200; $ctx->state["title"] = "这是一个学生名单"; $ctx->state["table"] = $table; yield $ctx->render(__DIR__ . "/table.html");});

中间件

<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <title>PHPkoa Static</title> <link rel="stylesheet" href="/css/default.css"></head><body> <img src="/images/20264902.jpg" /></body></html><?phprequire __DIR__ . "/vendor/autoload.php";defined("DS") or define("DS", DIRECTORY_SEPARATOR);use Naka507KoaApplication;use Naka507KoaContext;use Naka507KoaError;use Naka507KoaTimeout;use Naka507KoaNotFound;use Naka507KoaRouter;//静态文件处理 中间件use Naka507KoaStaticFiles; $app = new Application();$app->υse(new Error());$app->υse(new Timeout(5));$app->υse(new NotFound()); $app->υse(new StaticFiles(__DIR__ . DS . "static" )); $router = new Router();$router->get("/index", function(Context $ctx, $next) { $ctx->status = 200; yield $ctx->render(__DIR__ . "/index.html");});$app->υse($router->routes());$app->listen(3000);