前言
第一部分: 半协程调度器
- 统一生成器接口
- 生成器迭代
- 生成器返回值
- 生成器委托
- 改写 return
- 抽象异步模型
- 引入异常处理
- 异常: 嵌套任务透传
- 异常: 传递流程
- 异常: 重新进行 CPS 变换
- 异常: 重新加入 Async
- Syscall 与 Context
- 调度器: 里程碑
- spawn
- callcc
- race 与 timeout
- all 与 parallel
- channel 与协程间通信
- 无缓存 channel
- 缓存 channel
- channel 演示
- FutureTask 与 fork
第二部分: Koa
- 穿越地心之旅
- 洋葱圈模型
- rightReduce与中间件compose
- Koa::Application
- Koa::Context
- Koa::Request
- Koa::Response
- Koa - HelloWorld
- Middleware Interface
- Middleware: 全局异常处理
- Middleware: Router
- Middleware: 请求超时
- 一个综合示例
附录
参考
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
一个综合示例
一个综合示例
<?php
$app = new Application();
$app->υse(new Logger());
$app->υse(new Favicon(__DIR__ . "/favicon.iRco"));
$app->υse(new BodyDetecter()); // 输出特定格式body
$app->υse(new ExceptionHandler()); // 处理异常
$app->υse(new NotFound()); // 处理404
$app->υse(new RequestTimeout(200)); // 处理请求超时, 会抛出HttpException
$router = new Router();
$router->get('/index', function(Context $ctx) {
$ctx->status = 200;
$ctx->state["title"] = "HELLO WORLD";
$ctx->state["time"] = date("Y-m-d H:i:s", time());;
$ctx->state["table"] = $_SERVER;
yield $ctx->render(__DIR__ . "/index.html");
});
$router->get('/404', function(Context $ctx) {
$ctx->status = 404;
});
$router->get('/bt', function(Context $ctx) {
$ctx->body = "<pre>" . print_r(debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS), true);
});
$router->get('/timeout', function(Context $ctx) {
// 超时
yield async_sleep(500);
});
$router->get('/error/http_exception', function(Context $ctx) {
// 抛出带status的错误
$ctx->thrοw(500, "Internal Error");
// 等价于 throw new HttpException(500, "Internal Error");
yield;
});
$router->get('/error/exception', function(Context $ctx) {
// 直接抛出错误, 500 错误
throw new \Exception("some internal error", 10000);
yield;
});
$router->get('/user/{id:\d+}', function(Context $ctx, $next, $vars) {
$ctx->body = "user={$vars['id']}";
yield;
});
// http://127.0.0.1:3000/request/www.baidu.com
$router->get('/request/{url}', function(Context $ctx, $next, $vars) {
$r = (yield async_curl_get($vars['url']));
$ctx->body = $r->body;
$ctx->status = $r->statusCode;
});
$app->υse($router->routes());
$app->υse(function(Context $ctx) {
$ctx->status = 200;
$ctx->body = "<h1>Hello World</h1>";
yield;
});
$app->listen(3000);
以上我们完成了一个基于swoole的版本的php-koa。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论